Package com.amazonaws.services.dynamodbv2.streamsadapter

Class DynamoDBStreamsLeaseManagementFactory

java.lang.Object
software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory
com.amazonaws.services.dynamodbv2.streamsadapter.DynamoDBStreamsLeaseManagementFactory
All Implemented Interfaces:
software.amazon.kinesis.leases.LeaseManagementFactory
public class DynamoDBStreamsLeaseManagementFactory extends software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory

  • Constructor Summary

    Constructors
    Constructor
    Description
    DynamoDBStreamsLeaseManagementFactory(@NonNull software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisClient, @NonNull software.amazon.kinesis.leases.LeaseManagementConfig leaseManagementConfig, @NonNull software.amazon.kinesis.retrieval.RetrievalConfig retrievalConfig)
    Constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    software.amazon.kinesis.leases.LeaseCleanupManager
    createLeaseCleanupManager(software.amazon.kinesis.metrics.MetricsFactory metricsFactory)
     
    software.amazon.kinesis.leases.ShardDetector
    createShardDetector(software.amazon.kinesis.common.StreamConfig streamConfig)
     
    software.amazon.kinesis.leases.ShardSyncTaskManager
    createShardSyncTaskManager(software.amazon.kinesis.metrics.MetricsFactory metricsFactory, software.amazon.kinesis.common.StreamConfig streamConfig, software.amazon.kinesis.coordinator.DeletedStreamListProvider deletedStreamListProvider)
     
    software.amazon.kinesis.leases.ShardSyncTaskManager
    createShardSyncTaskManager(software.amazon.kinesis.metrics.MetricsFactory metricsFactory, software.amazon.kinesis.common.StreamConfig streamConfig, software.amazon.kinesis.coordinator.DeletedStreamListProvider deletedStreamListProvider, software.amazon.kinesis.coordinator.StreamInfoManager streamInfoManager)
     

    Methods inherited from class software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory

    canEqual, createLeaseCoordinator, createLeaseCoordinator, createLeaseCoordinator, createLeaseRefresher, createStreamIdCacheManager, createStreamInfoManager, equals, getBillingMode, getCacheMissWarningModulus, getCustomShardDetectorProvider, getDynamoDBClient, getDynamoDbRequestTimeout, getEpsilonMillis, getExecutorService, getFailoverTimeMillis, getGracefulLeaseHandoffConfig, getInitialLeaseTableReadCapacity, getInitialLeaseTableWriteCapacity, getKinesisClient, getLeaseAssignmentIntervalMillis, getLeaseCleanupConfig, getLeaseSerializer, getListShardsBackoffTimeMillis, getListShardsCacheAllowedAgeInSeconds, getMaxCacheMissesBeforeReload, getMaxLeaseRenewalThreads, getMaxLeasesForWorker, getMaxLeasesToStealAtOneTime, getMaxListShardsRetryAttempts, getShardSyncIntervalMillis, getStreamConfig, getTableCreatorCallback, getTableName, getTags, getWorkerIdentifier, getWorkerUtilizationAwareAssignmentConfig, hashCode, isCleanupLeasesUponShardCompletion, isConsistentReads, isEnablePriorityLeaseAssignment, isIgnoreUnexpectedChildShards, isLeaseTableDeletionProtectionEnabled, isLeaseTablePitrEnabled, isMultiStreamMode, setCustomShardDetectorProvider, setLeaseAssignmentIntervalMillis, setStreamConfig, toString

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface software.amazon.kinesis.leases.LeaseManagementFactory

    createShardDetector, createShardSyncTaskManager, createShardSyncTaskManager

  • Constructor Details

    • DynamoDBStreamsLeaseManagementFactory

      public DynamoDBStreamsLeaseManagementFactory(@NonNull @NonNull software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisClient, @NonNull @NonNull software.amazon.kinesis.leases.LeaseManagementConfig leaseManagementConfig, @NonNull @NonNull software.amazon.kinesis.retrieval.RetrievalConfig retrievalConfig)
      Constructor.
      Parameters:
      kinesisClient - the KinesisAsyncClient
      leaseManagementConfig - the LeaseManagementConfig
      retrievalConfig - the RetrievalConfig

  • Method Details

    • createShardDetector

      public software.amazon.kinesis.leases.ShardDetector createShardDetector(software.amazon.kinesis.common.StreamConfig streamConfig)
      Specified by:
      createShardDetector in interface software.amazon.kinesis.leases.LeaseManagementFactory
      Overrides:
      createShardDetector in class software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory

    • createShardSyncTaskManager

      public software.amazon.kinesis.leases.ShardSyncTaskManager createShardSyncTaskManager(software.amazon.kinesis.metrics.MetricsFactory metricsFactory, software.amazon.kinesis.common.StreamConfig streamConfig, software.amazon.kinesis.coordinator.DeletedStreamListProvider deletedStreamListProvider)
      Specified by:
      createShardSyncTaskManager in interface software.amazon.kinesis.leases.LeaseManagementFactory
      Overrides:
      createShardSyncTaskManager in class software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory

    • createShardSyncTaskManager

      public software.amazon.kinesis.leases.ShardSyncTaskManager createShardSyncTaskManager(software.amazon.kinesis.metrics.MetricsFactory metricsFactory, software.amazon.kinesis.common.StreamConfig streamConfig, software.amazon.kinesis.coordinator.DeletedStreamListProvider deletedStreamListProvider, software.amazon.kinesis.coordinator.StreamInfoManager streamInfoManager)
      Specified by:
      createShardSyncTaskManager in interface software.amazon.kinesis.leases.LeaseManagementFactory
      Overrides:
      createShardSyncTaskManager in class software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory

    • createLeaseCleanupManager

      public software.amazon.kinesis.leases.LeaseCleanupManager createLeaseCleanupManager(software.amazon.kinesis.metrics.MetricsFactory metricsFactory)
      Specified by:
      createLeaseCleanupManager in interface software.amazon.kinesis.leases.LeaseManagementFactory
      Overrides:
      createLeaseCleanupManager in class software.amazon.kinesis.leases.dynamodb.DynamoDBLeaseManagementFactory