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

Class HybridSourceSplit

java.lang.Object

org.apache.flink.connector.base.source.hybrid.HybridSourceSplit

All Implemented Interfaces:

SourceSplit

public class HybridSourceSplit
extends Object
implements SourceSplit

Source split that wraps the actual split type.

Constructor Summary

Constructors

Constructor	Description
HybridSourceSplit(int sourceIndex, byte[] wrappedSplit, int serializerVersion, String splitId)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HybridSourceSplit

public HybridSourceSplit(int sourceIndex,
                         byte[] wrappedSplit,
                         int serializerVersion,
                         String splitId)

Method Detail

sourceIndex

public int sourceIndex()

wrappedSplitBytes

public byte[] wrappedSplitBytes()

wrappedSplitSerializerVersion

public int wrappedSplitSerializerVersion()

splitId

public String splitId()

Description copied from interface: SourceSplit

Get the split id of this source split.

Specified by:

splitId in interface SourceSplit

Returns:

id of this source split.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

wrapSplits

public static List<HybridSourceSplit> wrapSplits(List<? extends SourceSplit> state,
                                                 int readerIndex,
                                                 org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

wrapSplit

public static HybridSourceSplit wrapSplit(SourceSplit split,
                                          int sourceIndex,
                                          org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

unwrapSplits

public static List<SourceSplit> unwrapSplits(List<HybridSourceSplit> splits,
                                             org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

unwrapSplit

public static SourceSplit unwrapSplit(HybridSourceSplit split,
                                      org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)