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 fromHybridSourceSplitEnumerator
toHybridSourceReader
to switch to the indicated reader.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SwitchSourceEvent(int sourceIndex, Source source, boolean finalSource)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isFinalSource()
Source
source()
int
sourceIndex()
String
toString()
-
-
-
Constructor Detail
-
SwitchSourceEvent
public SwitchSourceEvent(int sourceIndex, Source source, boolean finalSource)
Constructor.- Parameters:
sourceIndex
-
-
-