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

Class SwitchSourceEvent

java.lang.Object

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

All Implemented Interfaces:

Serializable, SourceEvent

public class SwitchSourceEvent
extends Object
implements SourceEvent

Event sent from HybridSourceSplitEnumerator to HybridSourceReader to switch to the indicated reader.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SwitchSourceEvent(int sourceIndex, Source source, boolean finalSource) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	isFinalSource()
Source	source()
int	sourceIndex()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SwitchSourceEvent

public SwitchSourceEvent(int sourceIndex,
                         Source source,
                         boolean finalSource)

Constructor.

Parameters:

sourceIndex -

Method Detail

sourceIndex

public int sourceIndex()

source

public Source source()

isFinalSource

public boolean isFinalSource()

toString

public String toString()

Overrides:

toString in class Object