| Class | Description |
|---|---|
| KinesisCheckpointState |
This is a helper class for managing checkpoint clocks.
|
| KinesisReceiver |
Custom AWS Kinesis-specific implementation of Spark Streaming's Receiver.
|
| KinesisRecordProcessor |
Kinesis-specific implementation of the Kinesis Client Library (KCL) IRecordProcessor.
|
| KinesisUtils |
Helper class to create Amazon Kinesis Input Stream
:: Experimental ::
|