Dennis Yung created BEAM-10673:
----------------------------------
Summary: io.aws2.dynamodb.DynamoDBIO.RetryConfiguration missing
method create
Key: BEAM-10673
URL: https://issues.apache.org/jira/browse/BEAM-10673
Project: Beam
Issue Type: Bug
Components: io-java-aws
Affects Versions: 2.23.0
Reporter: Dennis Yung
As described in the documentation, DynamoDBIO is initiated with a
RetryConfiguration passed in withRetryConfiguration()
{code:java}
PCollection<T> data = ...;
data.apply(
DynamoDBIO.<WriteRequest>write()
.withWriteRequestMapperFn(
(SerializableFunction<T, KV<String, WriteRequest>>)
//Transforming your T data into KV<String, WriteRequest>
t -> KV.of(tableName, writeRequest))
.withRetryConfiguration(
DynamoDBIO.RetryConfiguration.create(5,
Duration.standardMinutes(1)))
.withAwsClientsProvider(new BasicDynamoDbProvider(accessKey,
secretKey, region));
{code}
It works with beam-sdks-java-io-amazon-web-services (aws sdk version 1), but
not with beam-sdks-java-io-amazon-web-services2 (aws sdk version 2).
It is because in io.aws2.dynamodb.DynamoDBIO.RetryConfiguration, the method
create() is missing. There does not seem to be alternative public constructors
either.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
