Uses of Class
org.apache.flink.connector.base.source.hybrid.HybridSourceSplit

Packages that use HybridSourceSplit

Package	Description
org.apache.flink.connector.base.source.hybrid

Uses of HybridSourceSplit in org.apache.flink.connector.base.source.hybrid

Methods in org.apache.flink.connector.base.source.hybrid that return HybridSourceSplit

Modifier and Type	Method	Description
HybridSourceSplit	HybridSourceSplitSerializer.deserialize(int version, byte[] serialized)
static HybridSourceSplit	HybridSourceSplit.wrapSplit(org.apache.flink.api.connector.source.SourceSplit split, int sourceIndex, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

Methods in org.apache.flink.connector.base.source.hybrid that return types with arguments of type HybridSourceSplit

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.api.connector.source.SourceReader<T,HybridSourceSplit>	HybridSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.core.io.SimpleVersionedSerializer<HybridSourceSplit>	HybridSource.getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint)
List<HybridSourceSplit>	HybridSourceReader.snapshotState(long checkpointId)
static List<HybridSourceSplit>	HybridSourceSplit.wrapSplits(List<? extends org.apache.flink.api.connector.source.SourceSplit> state, int readerIndex, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

Methods in org.apache.flink.connector.base.source.hybrid with parameters of type HybridSourceSplit

Modifier and Type	Method	Description
byte[]	HybridSourceSplitSerializer.serialize(HybridSourceSplit split)
static org.apache.flink.api.connector.source.SourceSplit	HybridSourceSplit.unwrapSplit(HybridSourceSplit split, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

Method parameters in org.apache.flink.connector.base.source.hybrid with type arguments of type HybridSourceSplit

Modifier and Type	Method	Description
void	HybridSourceReader.addSplits(List<HybridSourceSplit> splits)
void	HybridSourceSplitEnumerator.addSplitsBack(List<HybridSourceSplit> splits, int subtaskId)
org.apache.flink.api.connector.source.SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> enumContext)
org.apache.flink.api.connector.source.SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint)
static List<org.apache.flink.api.connector.source.SourceSplit>	HybridSourceSplit.unwrapSplits(List<HybridSourceSplit> splits, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

Constructor parameters in org.apache.flink.connector.base.source.hybrid with type arguments of type HybridSourceSplit

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)