Interface | Description |
---|---|
RecordEmitter.RecordQueue<T> |
Accepts records from readers.
|
Class | Description |
---|---|
AWSUtil |
Some utilities specific to Amazon Web Service.
|
AwsV2Util |
Utility methods specific to Amazon Web Service SDK v2.x.
|
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.
|
StreamConsumerRegistrarUtil |
A utility class that creates instances of
StreamConsumerRegistrar and handles batch
operations. |
TimeoutLatch |
Internal use.
|
UniformShardAssigner |
A
KinesisShardAssigner that maps Kinesis shard hash-key ranges to Flink subtasks. |
WatermarkTracker |
The watermark tracker is responsible for aggregating watermarks across distributed operators.
|
WatermarkTracker.WatermarkState |
Watermark state.
|
Exception | Description |
---|---|
StreamConsumerRegistrarUtil.FlinkKinesisStreamConsumerRegistrarException |
A semantic
RuntimeException thrown to indicate errors de-/registering stream
consumers. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.