Package io.github.flink.gcp.connector.base.source

package io.github.flink.gcp.connector.base.source

Class	Description
EnumeratorCounters	The three counters a PullAssignmentSplitEnumerator reports, registered by the connector under its own names.
PullAssignmentSplitEnumerator<SplitT extends org.apache.flink.api.connector.source.SourceSplit,StateT,PlanT>	A bounded source's split enumerator that plans once, asynchronously, and then hands the plan out one split per request.
ReaderInitializationContext	Adapts a SourceReaderContext to the context a DeserializationSchema expects when a source opens it.
StartPosition	Where a change-stream source starts reading when no checkpointed state is restored.
StartPositionResolver	Resolves change-stream start positions against one startup instant and one retention window.
StartPositionResolver.RestoreExpiry	The retained-window evidence for one expired restored partition.
StartPositionResolver.RetentionLookup	Discovers how long a connector's change stream retains records.
SynchronousDeserializationCollector	Runs one source deserialization call with a direct, non-null collector.
SynchronousDeserializationCollector.Invocation<T,E extends Exception>	One deserialization call that emits through the supplied collector.