Package com.here.platform.data.client.flink.impl
package com.here.platform.data.client.flink.impl
-
ClassDescriptionShared FLIP-27 Source utilities for continuous (unbounded) polling sources that carry a timestamp as checkpoint state.Thread-safe availability notifier for bridging push (background thread) to pull (pollNext).Filters out dummy messagesEmits dummy messages with the main stream is finished we need it to let all the downstream logic to complete properlyFLIP-27 continuous source for IML feature ID batches with polling.SourceReader that never emits – just keeps the source alive.NoOpSink<T>A simple no-op Sink v2 that discards all elements.POJO Class have to https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html#pojo-typesPOJO Class have to https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html#pojo-typesPOJO Class have to https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html#pojo-typesPOJO Class have to https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html#pojo-typesFLIP-27 continuous source for index layer partitions with polling.FLIP-27 source for continuous versioned layer reading with notification subscription.FLIP-27 source for continuous versioned layer part data reading.FLIP-27 continuous source for volatile layer partition ID groups with polling.FLIP-27 continuous source for volatile layer partitions with polling.Filters out dummy messagesEmits dummy messages with the main stream is finished we need it to let all the downstream logic to complete properlyShared FLIP-27 Source utilities for bounded (one-shot) sources.Trivial split carrying only a string identifier.Assigns one split per subtask for parallel consumption.Sink V2 implementation for stream layer rows.SourceReader for stream layer rows with checkpoint-aware offset commit.