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

Class DynamoDBSource

java.lang.Object

software.amazon.jsii.JsiiObject

software.amazon.awscdk.services.pipes.alpha.SourceWithDeadLetterTarget

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

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

All Implemented Interfaces:

ISource, software.amazon.jsii.JsiiSerializable

@Generated(value="jsii-pacmak/1.119.0 (build 1634eac)",
           date="2025-11-13T16:10:18.833Z")
@Stability(Experimental)
public class DynamoDBSource
extends StreamSource

(experimental) A source that reads from an DynamoDB stream.

Example:

 Queue targetQueue;
 TableV2 table = TableV2.Builder.create(this, "MyTable")
         .partitionKey(Attribute.builder()
                 .name("id")
                 .type(AttributeType.STRING)
                 .build())
         .dynamoStream(StreamViewType.NEW_IMAGE)
         .build();
 DynamoDBSource pipeSource = DynamoDBSource.Builder.create(table)
         .startingPosition(DynamoDBStartingPosition.LATEST)
         .build();
 Pipe pipe = Pipe.Builder.create(this, "Pipe")
         .source(pipeSource)
         .target(new SqsTarget(targetQueue))
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DynamoDBSource.Builder	(experimental) A fluent builder for DynamoDBSource.

Nested classes/interfaces inherited from class software.amazon.jsii.JsiiObject

software.amazon.jsii.JsiiObject.InitializationMode

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.pipes.alpha.ISource

ISource.Jsii$Default

Constructor Summary

Constructors

Modifier	Constructor	Description
	DynamoDBSource(ITableV2 table, DynamoDBSourceParameters parameters)
protected	DynamoDBSource(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	DynamoDBSource(software.amazon.jsii.JsiiObjectRef objRef)

Method Summary

Modifier and Type	Method	Description
SourceConfig	bind(IPipe _pipe)	(experimental) Bind the source to a pipe.
void	grantRead(IRole grantee)	(experimental) Grant the pipe role read access to the source.

Methods inherited from class software.amazon.awscdk.services.pipes.sources.alpha.StreamSource

getSourceArn, getSourceParameters

Methods inherited from class software.amazon.awscdk.services.pipes.alpha.SourceWithDeadLetterTarget

getDeadLetterTarget, getDeadLetterTargetArn, getDeadLetterTargetArn, grantPush, grantPush, isSourceWithDeadLetterTarget

Methods inherited from class software.amazon.jsii.JsiiObject

jsiiAsyncCall, jsiiAsyncCall, jsiiCall, jsiiCall, jsiiGet, jsiiGet, jsiiSet, jsiiStaticCall, jsiiStaticCall, jsiiStaticGet, jsiiStaticGet, jsiiStaticSet, jsiiStaticSet

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.jsii.JsiiSerializable

$jsii$toJson

Constructor Details

DynamoDBSource

protected DynamoDBSource(software.amazon.jsii.JsiiObjectRef objRef)

DynamoDBSource

protected DynamoDBSource(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

DynamoDBSource

@Stability(Experimental)
public DynamoDBSource(@NotNull
 ITableV2 table,
 @NotNull
 DynamoDBSourceParameters parameters)

Parameters:

table - This parameter is required.

parameters - This parameter is required.

Method Details

bind

@Stability(Experimental)
@NotNull
public SourceConfig bind(@NotNull
 IPipe _pipe)

(experimental) Bind the source to a pipe.

Specified by:

bind in interface ISource

Specified by:

bind in class SourceWithDeadLetterTarget

Parameters:

_pipe - This parameter is required.

grantRead

@Stability(Experimental)
public void grantRead(@NotNull
 IRole grantee)

(experimental) Grant the pipe role read access to the source.

Specified by:

grantRead in interface ISource

Specified by:

grantRead in class SourceWithDeadLetterTarget

Parameters:

grantee - This parameter is required.