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 and Description
HybridSourceSplit	HybridSourceSplitSerializer.deserialize(int version, byte[] serialized)
static HybridSourceSplit	HybridSourceSplit.wrapSplit(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 and Description
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.createEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext)
SourceReader<T,HybridSourceSplit>	HybridSource.createReader(SourceReaderContext readerContext)
SimpleVersionedSerializer<HybridSourceSplit>	HybridSource.getSplitSerializer()
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.restoreEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint)
List<HybridSourceSplit>	HybridSourceReader.snapshotState(long checkpointId)
static List<HybridSourceSplit>	HybridSourceSplit.wrapSplits(List<? extends 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 and Description
byte[]	HybridSourceSplitSerializer.serialize(HybridSourceSplit split)
static 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 and Description
void	HybridSourceReader.addSplits(List<HybridSourceSplit> splits)
void	HybridSourceSplitEnumerator.addSplitsBack(List<HybridSourceSplit> splits, int subtaskId)
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.createEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext)
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState>	HybridSource.restoreEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext, HybridSourceEnumeratorState checkpoint)
static List<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 and Description
HybridSourceSplitEnumerator(SplitEnumeratorContext<HybridSourceSplit> context, List<org.apache.flink.connector.base.source.hybrid.HybridSource.SourceListEntry> sources, int initialSourceIndex, HybridSourceEnumeratorState restoredEnumeratorState)