程序包 org.apache.seatunnel.translation.flink.source

类 NoMoreElementEvent

java.lang.Object

org.apache.seatunnel.translation.flink.source.NoMoreElementEvent

所有已实现的接口:

Serializable, org.apache.flink.api.connector.source.SourceEvent

public final class NoMoreElementEvent
extends Object
implements org.apache.flink.api.connector.source.SourceEvent

This event represents that there is no more data to read, the execution process is as follows:

1. When a SourceReader has no more data to read, it will invoke SourceReader.Context.signalNoMoreElement() and send this event to FlinkSourceEnumerator.
2. After FlinkSourceEnumerator received this event and invoke SplitEnumeratorContext.sendEventToSourceReader(int, SourceEvent) send this event to FlinkSourceReader.
3. After FlinkSourceReader received this event and change InputStatus from MORE_AVAILABLE to END_INPUT.

另请参阅:

序列化表格

构造器概要

构造器

构造器	说明
NoMoreElementEvent(int subTaskIndex)

方法概要

修饰符和类型	方法	说明
int	getSubTaskIndex()

从类继承的方法 java.lang.Object

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

构造器详细资料

NoMoreElementEvent

public NoMoreElementEvent(int subTaskIndex)

方法详细资料

getSubTaskIndex

public int getSubTaskIndex()