Class Hierarchy
- java.lang.Object
- io.github.flink.gcp.connector.base.source.EnumeratorCounters
- io.github.flink.gcp.connector.base.source.PullAssignmentSplitEnumerator<SplitT,
StateT, PlanT> (implements org.apache.flink.api.connector.source.SplitEnumerator<SplitT, CheckpointT>) - io.github.flink.gcp.connector.base.source.ReaderInitializationContext (implements org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext)
- io.github.flink.gcp.connector.base.source.StartPosition (implements java.io.Serializable)
- io.github.flink.gcp.connector.base.source.StartPositionResolver
- io.github.flink.gcp.connector.base.source.StartPositionResolver.RestoreExpiry
- io.github.flink.gcp.connector.base.source.SynchronousDeserializationCollector
Interface Hierarchy
- io.github.flink.gcp.connector.base.source.StartPositionResolver.RetentionLookup
- io.github.flink.gcp.connector.base.source.SynchronousDeserializationCollector.Invocation<T,
E>