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

类 FlinkSourceReaderContext

java.lang.Object

org.apache.seatunnel.translation.flink.source.FlinkSourceReaderContext

所有已实现的接口:

org.apache.seatunnel.api.source.SourceReader.Context

public class FlinkSourceReaderContext
extends Object
implements org.apache.seatunnel.api.source.SourceReader.Context

The implementation of SourceReader.Context for flink engine.

字段概要

字段

修饰符和类型	字段	说明
protected org.apache.seatunnel.api.event.EventListener	eventListener

构造器概要

构造器

构造器	说明
FlinkSourceReaderContext(org.apache.flink.api.connector.source.SourceReaderContext readerContext, org.apache.seatunnel.api.source.SeaTunnelSource source)

方法概要

修饰符和类型	方法	说明
org.apache.seatunnel.api.source.Boundedness	getBoundedness()
org.apache.seatunnel.api.event.EventListener	getEventListener()
int	getIndexOfSubtask()
org.apache.seatunnel.api.common.metrics.MetricsContext	getMetricsContext()
boolean	isSendNoMoreElementEvent()
void	sendSourceEventToEnumerator(org.apache.seatunnel.api.source.SourceEvent sourceEvent)
void	sendSplitRequest()
void	signalNoMoreElement()

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

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

字段详细资料

eventListener

protected final org.apache.seatunnel.api.event.EventListener eventListener

构造器详细资料

FlinkSourceReaderContext

public FlinkSourceReaderContext(org.apache.flink.api.connector.source.SourceReaderContext readerContext,
                                org.apache.seatunnel.api.source.SeaTunnelSource source)

方法详细资料

getIndexOfSubtask

public int getIndexOfSubtask()

指定者:

getIndexOfSubtask 在接口中 org.apache.seatunnel.api.source.SourceReader.Context

getBoundedness

public org.apache.seatunnel.api.source.Boundedness getBoundedness()

指定者:

getBoundedness 在接口中 org.apache.seatunnel.api.source.SourceReader.Context

signalNoMoreElement

public void signalNoMoreElement()

指定者:

signalNoMoreElement 在接口中 org.apache.seatunnel.api.source.SourceReader.Context

sendSplitRequest

public void sendSplitRequest()

指定者:

sendSplitRequest 在接口中 org.apache.seatunnel.api.source.SourceReader.Context

sendSourceEventToEnumerator

public void sendSourceEventToEnumerator(org.apache.seatunnel.api.source.SourceEvent sourceEvent)

指定者:

sendSourceEventToEnumerator 在接口中 org.apache.seatunnel.api.source.SourceReader.Context

getMetricsContext

public org.apache.seatunnel.api.common.metrics.MetricsContext getMetricsContext()

指定者:

getMetricsContext 在接口中 org.apache.seatunnel.api.source.SourceReader.Context

isSendNoMoreElementEvent

public boolean isSendNoMoreElementEvent()

getEventListener

public org.apache.seatunnel.api.event.EventListener getEventListener()

指定者:

getEventListener 在接口中 org.apache.seatunnel.api.source.SourceReader.Context