You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Dennis Yung (Jira)" <ji...@apache.org> on 2020/08/11 10:53:00 UTC

[jira] [Created] (BEAM-10673) io.aws2.dynamodb.DynamoDBIO.RetryConfiguration missing method create

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)