Class DynamoDBIO.Read<T>

java.lang.Object
org.apache.beam.sdk.transforms.PTransform<PBegin,PCollection<T>>
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Read<T>
All Implemented Interfaces:
Serializable, HasDisplayData
Enclosing class:
DynamoDBIO

public abstract static class DynamoDBIO.Read<T> extends PTransform<PBegin,PCollection<T>>
Read data from DynamoDB using getScanRequestFn() and emit an element of type DynamoDBIO.Read for each ScanResponse using the mapping function getScanResponseMapperFn().
See Also:
  • Constructor Details

    • Read

      public Read()
  • Method Details

    • withClientConfiguration

      public DynamoDBIO.Read<T> withClientConfiguration(ClientConfiguration config)
      Configuration of DynamoDB client.
    • withScanRequestFn

      public DynamoDBIO.Read<T> withScanRequestFn(SerializableFunction<Void,ScanRequest> fn)
      Can't pass ScanRequest object directly from client since this object is not full serializable.
    • withScanResponseMapperFn

      public DynamoDBIO.Read<T> withScanResponseMapperFn(SerializableFunction<ScanResponse,T> scanResultMapperFn)
    • items

    • withCoder

      public DynamoDBIO.Read<T> withCoder(Coder<T> coder)
    • expand

      public PCollection<T> expand(PBegin input)
      Description copied from class: PTransform
      Override this method to specify how this 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).

      Specified by:
      expand in class PTransform<PBegin,PCollection<T>>