Uses of Class
org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState
-
Packages that use HybridSourceEnumeratorState Package Description org.apache.flink.connector.base.source.hybrid -
-
Uses of HybridSourceEnumeratorState in org.apache.flink.connector.base.source.hybrid
Methods in org.apache.flink.connector.base.source.hybrid that return HybridSourceEnumeratorState Modifier and Type Method Description HybridSourceEnumeratorStateHybridSourceEnumeratorStateSerializer. deserialize(int version, byte[] serialized)HybridSourceEnumeratorStateHybridSourceSplitEnumerator. snapshotState(long checkpointId)Methods in org.apache.flink.connector.base.source.hybrid that return types with arguments of type HybridSourceEnumeratorState Modifier and Type Method Description org.apache.flink.api.connector.source.SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>HybridSource. createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> enumContext)org.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceEnumeratorState>HybridSource. getEnumeratorCheckpointSerializer()org.apache.flink.api.connector.source.SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>HybridSource. restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint)Methods in org.apache.flink.connector.base.source.hybrid with parameters of type HybridSourceEnumeratorState Modifier and Type Method Description org.apache.flink.api.connector.source.SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>HybridSource. restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint)byte[]HybridSourceEnumeratorStateSerializer. serialize(HybridSourceEnumeratorState enumState)Constructors in org.apache.flink.connector.base.source.hybrid with parameters of type HybridSourceEnumeratorState Constructor Description HybridSourceSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> context, List<org.apache.flink.connector.base.source.hybrid.HybridSource.SourceListEntry> sources, int initialSourceIndex, HybridSourceEnumeratorState restoredEnumeratorState)
-