Class CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder
java.lang.Object
software.amazon.awscdk.services.pipes.CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder
- All Implemented Interfaces:
software.amazon.jsii.Builder<CfnPipe.PipeSourceDynamoDBStreamParametersProperty>
- Enclosing interface:
CfnPipe.PipeSourceDynamoDBStreamParametersProperty
@Stability(Stable)
public static final class CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder
extends Object
implements software.amazon.jsii.Builder<CfnPipe.PipeSourceDynamoDBStreamParametersProperty>
A builder for
CfnPipe.PipeSourceDynamoDBStreamParametersProperty
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionSets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getBatchSize()
build()
Builds the configured instance.deadLetterConfig
(IResolvable deadLetterConfig) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getDeadLetterConfig()
deadLetterConfig
(CfnPipe.DeadLetterConfigProperty deadLetterConfig) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getDeadLetterConfig()
maximumBatchingWindowInSeconds
(Number maximumBatchingWindowInSeconds) maximumRecordAgeInSeconds
(Number maximumRecordAgeInSeconds) maximumRetryAttempts
(Number maximumRetryAttempts) onPartialBatchItemFailure
(String onPartialBatchItemFailure) parallelizationFactor
(Number parallelizationFactor) startingPosition
(String startingPosition) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getStartingPosition()
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
startingPosition
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder startingPosition(String startingPosition) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getStartingPosition()
- Parameters:
startingPosition
- (Streams only) The position in a stream from which to start reading. This parameter is required. Valid values :TRIM_HORIZON | LATEST
- Returns:
this
-
batchSize
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder batchSize(Number batchSize) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getBatchSize()
- Parameters:
batchSize
- The maximum number of records to include in each batch.- Returns:
this
-
deadLetterConfig
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder deadLetterConfig(IResolvable deadLetterConfig) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getDeadLetterConfig()
- Parameters:
deadLetterConfig
- Define the target queue to send dead-letter queue events to.- Returns:
this
-
deadLetterConfig
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder deadLetterConfig(CfnPipe.DeadLetterConfigProperty deadLetterConfig) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getDeadLetterConfig()
- Parameters:
deadLetterConfig
- Define the target queue to send dead-letter queue events to.- Returns:
this
-
maximumBatchingWindowInSeconds
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder maximumBatchingWindowInSeconds(Number maximumBatchingWindowInSeconds) Sets the value ofCfnPipe.PipeSourceDynamoDBStreamParametersProperty.getMaximumBatchingWindowInSeconds()
- Parameters:
maximumBatchingWindowInSeconds
- The maximum length of a time to wait for events.- Returns:
this
-
maximumRecordAgeInSeconds
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder maximumRecordAgeInSeconds(Number maximumRecordAgeInSeconds) - Parameters:
maximumRecordAgeInSeconds
- (Streams only) Discard records older than the specified age. The default value is -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge never discards old records.- Returns:
this
-
maximumRetryAttempts
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder maximumRetryAttempts(Number maximumRetryAttempts) - Parameters:
maximumRetryAttempts
- (Streams only) Discard records after the specified number of retries. The default value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts is infinite, EventBridge retries failed records until the record expires in the event source.- Returns:
this
-
onPartialBatchItemFailure
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder onPartialBatchItemFailure(String onPartialBatchItemFailure) - Parameters:
onPartialBatchItemFailure
- (Streams only) Define how to handle item process failures.AUTOMATIC_BISECT
halves each batch and retry each half until all the records are processed or there is one failed message left in the batch.- Returns:
this
-
parallelizationFactor
@Stability(Stable) public CfnPipe.PipeSourceDynamoDBStreamParametersProperty.Builder parallelizationFactor(Number parallelizationFactor) - Parameters:
parallelizationFactor
- (Streams only) The number of batches to process concurrently from each shard. The default value is 1.- Returns:
this
-
build
Builds the configured instance.- Specified by:
build
in interfacesoftware.amazon.jsii.Builder<CfnPipe.PipeSourceDynamoDBStreamParametersProperty>
- Returns:
- a new instance of
CfnPipe.PipeSourceDynamoDBStreamParametersProperty
- Throws:
NullPointerException
- if any required attribute was not provided
-