Package com.amazonaws.services.dynamodbv2.streamsadapter.adapter

Class DynamoDBStreamsGetRecordsResponseAdapter

java.lang.Object
com.amazonaws.services.dynamodbv2.streamsadapter.adapter.DynamoDBStreamsGetRecordsResponseAdapter
All Implemented Interfaces:
software.amazon.kinesis.retrieval.GetRecordsResponseAdapter
public class DynamoDBStreamsGetRecordsResponseAdapter extends Object implements software.amazon.kinesis.retrieval.GetRecordsResponseAdapter

  • Constructor Details

    • DynamoDBStreamsGetRecordsResponseAdapter

      public DynamoDBStreamsGetRecordsResponseAdapter(software.amazon.awssdk.services.dynamodb.model.GetRecordsResponse response)

  • Method Details

    • records

      public List<software.amazon.kinesis.retrieval.KinesisClientRecord> records()
      Specified by:
      records in interface software.amazon.kinesis.retrieval.GetRecordsResponseAdapter

    • millisBehindLatest

      public Long millisBehindLatest()
      Specified by:
      millisBehindLatest in interface software.amazon.kinesis.retrieval.GetRecordsResponseAdapter

    • childShards

      public List<software.amazon.awssdk.services.kinesis.model.ChildShard> childShards()
      Specified by:
      childShards in interface software.amazon.kinesis.retrieval.GetRecordsResponseAdapter

    • nextShardIterator

      public String nextShardIterator()
      Specified by:
      nextShardIterator in interface software.amazon.kinesis.retrieval.GetRecordsResponseAdapter

    • requestId

      public String requestId()
      Specified by:
      requestId in interface software.amazon.kinesis.retrieval.GetRecordsResponseAdapter

    • addChildShards

      public void addChildShards(List<software.amazon.awssdk.services.kinesis.model.ChildShard> childShards)