Package org.apache.flink.streaming.connectors.kinesis.util

Interface Summary

Interface	Description
RecordEmitter.RecordQueue<T>	Accepts records from readers.

Class Summary

Class	Description
AWSUtil	Some utilities specific to Amazon Web Service.
BeanDeserializerModifierForIgnorables	Jackson bean deserializer utility that allows skipping of properties, for example because they cannot be handled by the default serializer or should be ignored for other reason.
JobManagerWatermarkTracker	A WatermarkTracker that shares state through GlobalAggregateManager.
JobManagerWatermarkTracker.WatermarkResult	Watermark aggregation result.
JobManagerWatermarkTracker.WatermarkUpdate	Watermark aggregation input.
KinesisConfigUtil	Utilities for Flink Kinesis connector configuration.
RecordEmitter<T extends TimestampedValue>	Emitter that handles event time synchronization between producer threads.
TimeoutLatch	Internal use.
WatermarkTracker	The watermark tracker is responsible for aggregating watermarks across distributed operators.
WatermarkTracker.WatermarkState	Watermark state.