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

类 FlinkSourceSplitEnumeratorContext<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

java.lang.Object

org.apache.seatunnel.translation.flink.source.FlinkSourceSplitEnumeratorContext<SplitT>

类型参数:

SplitT -

所有已实现的接口:

org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT>

public class FlinkSourceSplitEnumeratorContext<SplitT extends org.apache.seatunnel.api.source.SourceSplit>
extends Object
implements org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT>

The implementation of SourceSplitEnumerator.Context for flink engine.

字段概要

字段

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

构造器概要

构造器

构造器	说明
FlinkSourceSplitEnumeratorContext(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)

方法概要

修饰符和类型	方法	说明
void	assignSplit(int subtaskId, List<SplitT> splits)
int	currentParallelism()
org.apache.seatunnel.api.event.EventListener	getEventListener()
org.apache.seatunnel.api.common.metrics.MetricsContext	getMetricsContext()
Set<Integer>	registeredReaders()
void	sendEventToSourceReader(int subtaskId, org.apache.seatunnel.api.source.SourceEvent event)
void	signalNoMoreSplits(int subtask)

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

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

从接口继承的方法 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context

assignSplit

字段详细资料

eventListener

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

构造器详细资料

FlinkSourceSplitEnumeratorContext

public FlinkSourceSplitEnumeratorContext(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)

方法详细资料

currentParallelism

public int currentParallelism()

指定者:

currentParallelism 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

registeredReaders

public Set<Integer> registeredReaders()

指定者:

registeredReaders 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

assignSplit

public void assignSplit(int subtaskId,
                        List<SplitT> splits)

指定者:

assignSplit 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

signalNoMoreSplits

public void signalNoMoreSplits(int subtask)

指定者:

signalNoMoreSplits 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

sendEventToSourceReader

public void sendEventToSourceReader(int subtaskId,
                                    org.apache.seatunnel.api.source.SourceEvent event)

指定者:

sendEventToSourceReader 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

getMetricsContext

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

指定者:

getMetricsContext 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

getEventListener

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

指定者:

getEventListener 在接口中 org.apache.seatunnel.api.source.SourceSplitEnumerator.Context<SplitT extends org.apache.seatunnel.api.source.SourceSplit>