public abstract static class DynamoDBIO.Write<T> extends PTransform<PCollection<T>,PCollection<java.lang.Void>>
name, resourceHints
Constructor and Description |
---|
Write() |
Modifier and Type | Method and Description |
---|---|
PCollection<java.lang.Void> |
expand(PCollection<T> input)
Override this method to specify how this
PTransform should be expanded on the given
InputT . |
DynamoDBIO.Write<T> |
withAwsClientsProvider(AwsClientsProvider awsClientsProvider) |
DynamoDBIO.Write<T> |
withAwsClientsProvider(java.lang.String awsAccessKey,
java.lang.String awsSecretKey,
Regions region) |
DynamoDBIO.Write<T> |
withAwsClientsProvider(java.lang.String awsAccessKey,
java.lang.String awsSecretKey,
Regions region,
java.lang.String serviceEndpoint) |
DynamoDBIO.Write<T> |
withDeduplicateKeys(java.util.List<java.lang.String> deduplicateKeys) |
DynamoDBIO.Write<T> |
withRetryConfiguration(DynamoDBIO.RetryConfiguration retryConfiguration)
Provides configuration to retry a failed request to publish a set of records to DynamoDB.
|
DynamoDBIO.Write<T> |
withWriteRequestMapperFn(SerializableFunction<T,KV<java.lang.String,WriteRequest>> writeItemMapperFn) |
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate
public DynamoDBIO.Write<T> withAwsClientsProvider(AwsClientsProvider awsClientsProvider)
public DynamoDBIO.Write<T> withAwsClientsProvider(java.lang.String awsAccessKey, java.lang.String awsSecretKey, Regions region, java.lang.String serviceEndpoint)
public DynamoDBIO.Write<T> withAwsClientsProvider(java.lang.String awsAccessKey, java.lang.String awsSecretKey, Regions region)
public DynamoDBIO.Write<T> withRetryConfiguration(DynamoDBIO.RetryConfiguration retryConfiguration)
Example use:
DynamoDBIO.write()
.withRetryConfiguration(DynamoDBIO.RetryConfiguration.create(5, Duration.standardMinutes(1))
...
retryConfiguration
- the rules which govern the retry behaviorDynamoDBIO.Write
with retrying configuredpublic DynamoDBIO.Write<T> withWriteRequestMapperFn(SerializableFunction<T,KV<java.lang.String,WriteRequest>> writeItemMapperFn)
public DynamoDBIO.Write<T> withDeduplicateKeys(java.util.List<java.lang.String> deduplicateKeys)
public PCollection<java.lang.Void> expand(PCollection<T> input)
PTransform
PTransform
should be expanded on the given
InputT
.
NOTE: This method should not be called directly. Instead apply the PTransform
should
be applied to the InputT
using the apply
method.
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
expand
in class PTransform<PCollection<T>,PCollection<java.lang.Void>>