Package com.amazonaws.services.dynamodbv2.streamsadapter.polling

Class DynamoDBStreamsPollingConfig

java.lang.Object
software.amazon.kinesis.retrieval.polling.PollingConfig
com.amazonaws.services.dynamodbv2.streamsadapter.polling.DynamoDBStreamsPollingConfig
All Implemented Interfaces:
software.amazon.kinesis.retrieval.RetrievalSpecificConfig
public class DynamoDBStreamsPollingConfig extends software.amazon.kinesis.retrieval.polling.PollingConfig

  • Field Summary

    Fields inherited from class software.amazon.kinesis.retrieval.polling.PollingConfig

    DEFAULT_MAX_PENDING_PROCESS_RECORDS_INPUT_LIMIT, DEFAULT_MAX_RECORDS, DEFAULT_MILLIS_BEHIND_LATEST_THRESHOLD_FOR_REDUCED_TPS, DEFAULT_REQUEST_TIMEOUT, MIN_IDLE_MILLIS_BETWEEN_READS

  • Constructor Summary

    Constructors
    Constructor
    Description
    DynamoDBStreamsPollingConfig(String streamName, software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient)
     
    DynamoDBStreamsPollingConfig(software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    DynamoDBStreamsPollingConfig
    idleTimeBetweenReadsInMillis(long idleTimeBetweenReadsInMillis)
     
    software.amazon.kinesis.retrieval.RetrievalFactory
    retrievalFactory()
     

    Methods inherited from class software.amazon.kinesis.retrieval.polling.PollingConfig

    canEqual, dataFetcherProvider, dataFetcherProvider, equals, hashCode, idleTimeBetweenReadsInMillis, kinesisClient, kinesisRequestTimeout, kinesisRequestTimeout, maxGetRecordsThreadPool, maxGetRecordsThreadPool, maxPendingProcessRecordsInput, maxPendingProcessRecordsInput, maxRecords, maxRecords, millisBehindLatestThresholdForReducedTps, millisBehindLatestThresholdForReducedTps, recordsFetcherFactory, recordsFetcherFactory, retryGetRecordsInSeconds, retryGetRecordsInSeconds, setIdleTimeBetweenReadsInMillis, sleepTimeController, sleepTimeController, streamName, streamName, toString, usePollingConfigIdleTimeValue, usePollingConfigIdleTimeValue, validateState

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • DynamoDBStreamsPollingConfig

      public DynamoDBStreamsPollingConfig(software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient)

    • DynamoDBStreamsPollingConfig

      public DynamoDBStreamsPollingConfig(String streamName, software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient)

  • Method Details

    • idleTimeBetweenReadsInMillis

      public DynamoDBStreamsPollingConfig idleTimeBetweenReadsInMillis(long idleTimeBetweenReadsInMillis)
      Overrides:
      idleTimeBetweenReadsInMillis in class software.amazon.kinesis.retrieval.polling.PollingConfig

    • retrievalFactory

      public software.amazon.kinesis.retrieval.RetrievalFactory retrievalFactory()
      Specified by:
      retrievalFactory in interface software.amazon.kinesis.retrieval.RetrievalSpecificConfig
      Overrides:
      retrievalFactory in class software.amazon.kinesis.retrieval.polling.PollingConfig