Represents the result from the DataFetcher, and allows the receiver to accept a result
This class is used as a cache for Prefetching data from Kinesis.
Represents a strategy to retrieve records from Kinesis.
This class uses the GetRecordsRetrievalStrategy class to retrieve the next set of records and update the cache.
Used in conjunction with periodic shard sync.
Represents the class that decides if a lease is eligible for cleanup.
This factory is used to create the records fetcher to retrieve data from Kinesis for a given shard.
Provides logic to prioritize or filter shards before their execution.
Facade of methods that can be invoked at different points in KCL application execution to perform certain actions related to shard-sync.
A shutdown request to the ShardConsumer
A listener for callbacks on changes worker state
This is the BlockingGetRecordsCache class.
A special IPreparedCheckpointer that does nothing, which can be used when preparing a checkpoint at the current checkpoint sequence number where it is never necessary to do another checkpoint.
Class that houses the entities needed to specify the position in the stream from where a new application should start.
Configuration for the Amazon Kinesis Client Library.
Shard Prioritization that returns the same original list of shards without any modifications.
Shard Prioritization that prioritizes parent shards first.
This is the prefetch caching class, this class spins up a thread if prefetching is enabled.
Objects of this class are prepared to checkpoint at a specific sequence number.
This class provides some methods for validating sequence numbers.
Used to pass shard related info among different classes and as a key to the map of shard consumers.
Worker is the high level class that Kinesis applications use to start processing data.
Builder to construct a Worker instance.
Used to specify the position in the stream where a new application should start from.
Types of ShardSyncStrategy} implemented in KCL.
Reason the RecordProcessor is being shutdown.
Enumerates types of tasks executed as part of processing a shard.
Copyright © 2019. All rights reserved.