See: Description
| Interface | Description |
|---|---|
| AWSClientsProvider |
Provides instances of AWS clients.
|
| KinesisPartitioner |
Kinesis interface for custom partitioner.
|
| WatermarkPolicy |
Implement this interface to define a custom watermark calculation heuristic.
|
| WatermarkPolicyFactory |
Implement this interface to create a
WatermarkPolicy. |
| Class | Description |
|---|---|
| KinesisIO |
PTransforms for reading from and writing to Kinesis streams. |
| KinesisIO.Read |
Implementation of
KinesisIO.read(). |
| KinesisIO.Write |
Implementation of
KinesisIO.write(). |
| KinesisRecord |
UserRecord enhanced with utility methods. |
| WatermarkParameters |
WatermarkParameters contains the parameters used for watermark computation. |
| WatermarkPolicyFactory.ArrivalTimeWatermarkPolicy |
ArrivalTimeWatermarkPolicy uses
WatermarkPolicyFactory.CustomWatermarkPolicy for watermark computation. |
| WatermarkPolicyFactory.CustomWatermarkPolicy |
CustomWatermarkPolicy uses parameters defined in
WatermarkParameters to compute
watermarks. |
| WatermarkPolicyFactory.ProcessingTimeWatermarkPolicy |
Watermark policy where the processing time is used as the event time.
|