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

Class HybridSourceSplit

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.api.connector.source.SourceSplit

public class HybridSourceSplit
extends Object
implements org.apache.flink.api.connector.source.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()
String	toString()
static org.apache.flink.api.connector.source.SourceSplit	unwrapSplit(HybridSourceSplit split, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
static List<org.apache.flink.api.connector.source.SourceSplit>	unwrapSplits(List<HybridSourceSplit> splits, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
byte[]	wrappedSplitBytes()
int	wrappedSplitSerializerVersion()
static HybridSourceSplit	wrapSplit(org.apache.flink.api.connector.source.SourceSplit split, int sourceIndex, org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)
static List<HybridSourceSplit>	wrapSplits(List<? extends org.apache.flink.api.connector.source.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()

Specified by:

splitId in interface org.apache.flink.api.connector.source.SourceSplit

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 org.apache.flink.api.connector.source.SourceSplit> state,
                                                 int readerIndex,
                                                 org.apache.flink.connector.base.source.hybrid.SwitchedSources switchedSources)

wrapSplit

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

unwrapSplits

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

unwrapSplit

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