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
Constructors -
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- 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- 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- Define how to handle item process failures.AUTOMATIC_BISECThalves 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- The number of batches to process concurrently from each shard. The default value is 1.- Returns:
this
-
build
Builds the configured instance.- Specified by:
buildin interfacesoftware.amazon.jsii.Builder<CfnPipe.PipeSourceDynamoDBStreamParametersProperty>- Returns:
- a new instance of
CfnPipe.PipeSourceDynamoDBStreamParametersProperty - Throws:
NullPointerException- if any required attribute was not provided
-