public class HybridSourceSplit extends Object implements SourceSplit
Constructor and Description |
---|
HybridSourceSplit(int sourceIndex,
byte[] wrappedSplit,
int serializerVersion,
String splitId) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
int |
sourceIndex() |
String |
splitId()
Get the split id of this source split.
|
String |
toString() |
static SourceSplit |
unwrapSplit(HybridSourceSplit split,
org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources) |
static List<SourceSplit> |
unwrapSplits(List<HybridSourceSplit> splits,
org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources) |
byte[] |
wrappedSplitBytes() |
int |
wrappedSplitSerializerVersion() |
static HybridSourceSplit |
wrapSplit(SourceSplit split,
int sourceIndex,
org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources) |
static List<HybridSourceSplit> |
wrapSplits(List<? extends SourceSplit> state,
int readerIndex,
org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources) |
public HybridSourceSplit(int sourceIndex, byte[] wrappedSplit, int serializerVersion, String splitId)
public int sourceIndex()
public byte[] wrappedSplitBytes()
public int wrappedSplitSerializerVersion()
public String splitId()
SourceSplit
splitId
in interface SourceSplit
public static List<HybridSourceSplit> wrapSplits(List<? extends SourceSplit> state, int readerIndex, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
public static HybridSourceSplit wrapSplit(SourceSplit split, int sourceIndex, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
public static List<SourceSplit> unwrapSplits(List<HybridSourceSplit> splits, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
public static SourceSplit unwrapSplit(HybridSourceSplit split, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.