Package software.amazon.awscdk.services.pipes.sources.alpha

Class DynamoDBSource.Builder

java.lang.Object

software.amazon.awscdk.services.pipes.sources.alpha.DynamoDBSource.Builder

All Implemented Interfaces:

software.amazon.jsii.Builder<DynamoDBSource>

Enclosing class:

DynamoDBSource

@Stability(Experimental)
public static final class DynamoDBSource.Builder
extends Object
implements software.amazon.jsii.Builder<DynamoDBSource>

(experimental) A fluent builder for DynamoDBSource.

Method Summary

Modifier and Type	Method	Description
DynamoDBSource.Builder	batchSize(Number batchSize)	(experimental) The maximum number of records to include in each batch.
DynamoDBSource	build()
static DynamoDBSource.Builder	create(ITableV2 table)
DynamoDBSource.Builder	deadLetterTarget(ITopic deadLetterTarget)	(experimental) Define the target to send dead-letter queue events to.
DynamoDBSource.Builder	deadLetterTarget(IQueue deadLetterTarget)	(experimental) Define the target to send dead-letter queue events to.
DynamoDBSource.Builder	maximumBatchingWindow(Duration maximumBatchingWindow)	(experimental) The maximum length of a time to wait for events.
DynamoDBSource.Builder	maximumRecordAge(Duration maximumRecordAge)	(experimental) Discard records older than the specified age.
DynamoDBSource.Builder	maximumRetryAttempts(Number maximumRetryAttempts)	(experimental) Discard records after the specified number of retries.
DynamoDBSource.Builder	onPartialBatchItemFailure(OnPartialBatchItemFailure onPartialBatchItemFailure)	(experimental) Define how to handle item process failures.
DynamoDBSource.Builder	parallelizationFactor(Number parallelizationFactor)	(experimental) The number of batches to process concurrently from each shard.
DynamoDBSource.Builder	startingPosition(DynamoDBStartingPosition startingPosition)	(experimental) The position in a stream from which to start reading.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

@Stability(Experimental)
public static DynamoDBSource.Builder create(ITableV2 table)

Parameters:

table - This parameter is required.

Returns:

a new instance of DynamoDBSource.Builder.

batchSize

@Stability(Experimental)
public DynamoDBSource.Builder batchSize(Number batchSize)

(experimental) The maximum number of records to include in each batch.

Default: 1

Parameters:

batchSize - The maximum number of records to include in each batch. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-batchsize

deadLetterTarget

@Stability(Experimental)
public DynamoDBSource.Builder deadLetterTarget(IQueue deadLetterTarget)

(experimental) Define the target to send dead-letter queue events to.

The dead-letter queue stores any events that are not successfully delivered to a Pipes target after all retry attempts are exhausted. You can then resolve the issue that caused the failed invocations and replay the events at a later time. In some cases, such as when access is denied to a resource, events are sent directly to the dead-letter queue and are not retried.

Default: - no dead-letter queue or topic

Parameters:

deadLetterTarget - Define the target to send dead-letter queue events to. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-deadletterconfig

deadLetterTarget

@Stability(Experimental)
public DynamoDBSource.Builder deadLetterTarget(ITopic deadLetterTarget)

(experimental) Define the target to send dead-letter queue events to.

The dead-letter queue stores any events that are not successfully delivered to a Pipes target after all retry attempts are exhausted. You can then resolve the issue that caused the failed invocations and replay the events at a later time. In some cases, such as when access is denied to a resource, events are sent directly to the dead-letter queue and are not retried.

Default: - no dead-letter queue or topic

Parameters:

deadLetterTarget - Define the target to send dead-letter queue events to. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-deadletterconfig

maximumBatchingWindow

@Stability(Experimental)
public DynamoDBSource.Builder maximumBatchingWindow(Duration maximumBatchingWindow)

(experimental) The maximum length of a time to wait for events.

Default: - the events will be handled immediately

Parameters:

maximumBatchingWindow - The maximum length of a time to wait for events. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-maximumbatchingwindowinseconds

maximumRecordAge

@Stability(Experimental)
public DynamoDBSource.Builder maximumRecordAge(Duration maximumRecordAge)

(experimental) 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.

Default: -1 - EventBridge won't discard old records

Parameters:

maximumRecordAge - Discard records older than the specified age. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-maximumrecordageinseconds

maximumRetryAttempts

@Stability(Experimental)
public DynamoDBSource.Builder maximumRetryAttempts(Number maximumRetryAttempts)

(experimental) 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.

Default: -1 - EventBridge will retry failed records until the record expires in the event source

Parameters:

maximumRetryAttempts - Discard records after the specified number of retries. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-maximumretryattempts

onPartialBatchItemFailure

@Stability(Experimental)
public DynamoDBSource.Builder onPartialBatchItemFailure(OnPartialBatchItemFailure onPartialBatchItemFailure)

(experimental) Define how to handle item process failures.

invalid @link

OnPartialBatchItemFailure.AUTOMATIC_BISECT

halves each batch and will retry each half until all the records are processed or there is one failed message left in the batch.

Default: off - EventBridge will retry the entire batch

Parameters:

onPartialBatchItemFailure - Define how to handle item process failures. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-onpartialbatchitemfailure

parallelizationFactor

@Stability(Experimental)
public DynamoDBSource.Builder parallelizationFactor(Number parallelizationFactor)

(experimental) The number of batches to process concurrently from each shard.

Default: 1

Parameters:

parallelizationFactor - The number of batches to process concurrently from each shard. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcekinesisstreamparameters.html#cfn-pipes-pipe-pipesourcekinesisstreamparameters-parallelizationfactor

startingPosition

@Stability(Experimental)
public DynamoDBSource.Builder startingPosition(DynamoDBStartingPosition startingPosition)

(experimental) The position in a stream from which to start reading.

Parameters:

startingPosition - The position in a stream from which to start reading. This parameter is required.

Returns:

this

See Also:

• https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcedynamodbstreamparameters.html#cfn-pipes-pipe-pipesourcedynamodbstreamparameters-startingposition

build

@Stability(Experimental)
public DynamoDBSource build()

Specified by:

build in interface software.amazon.jsii.Builder<DynamoDBSource>

Returns:

a newly built instance of DynamoDBSource.