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

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

java.lang.Object

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

类型参数:

SplitT -

所有已实现的接口:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT>>

public class FlinkSourceReader<SplitT extends org.apache.seatunnel.api.source.SourceSplit>
extends Object
implements org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT>>

The implementation of SourceReader, used for proxy all SourceReader in flink.

构造器概要

构造器

构造器	说明
FlinkSourceReader(org.apache.seatunnel.api.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitT> sourceReader, org.apache.seatunnel.api.source.SourceReader.Context context, org.apache.seatunnel.shade.com.typesafe.config.Config envConfig)

方法概要

修饰符和类型	方法	说明
void	addSplits(List<SplitWrapper<SplitT>> splits)
void	close()
void	handleSourceEvents(org.apache.flink.api.connector.source.SourceEvent sourceEvent)
CompletableFuture<Void>	isAvailable()
void	notifyCheckpointAborted(long checkpointId)
void	notifyCheckpointComplete(long checkpointId)
void	notifyNoMoreSplits()
org.apache.flink.core.io.InputStatus	pollNext(org.apache.flink.api.connector.source.ReaderOutput<org.apache.seatunnel.api.table.type.SeaTunnelRow> output)
List<SplitWrapper<SplitT>>	snapshotState(long checkpointId)
void	start()

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

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

构造器详细资料

FlinkSourceReader

public FlinkSourceReader(org.apache.seatunnel.api.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitT> sourceReader,
                         org.apache.seatunnel.api.source.SourceReader.Context context,
                         org.apache.seatunnel.shade.com.typesafe.config.Config envConfig)

方法详细资料

start

public void start()

指定者:

start 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

pollNext

public org.apache.flink.core.io.InputStatus pollNext(org.apache.flink.api.connector.source.ReaderOutput<org.apache.seatunnel.api.table.type.SeaTunnelRow> output)
                                              throws Exception

指定者:

pollNext 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

抛出:

Exception

snapshotState

public List<SplitWrapper<SplitT>> snapshotState(long checkpointId)

指定者:

snapshotState 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

isAvailable

public CompletableFuture<Void> isAvailable()

指定者:

isAvailable 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

addSplits

public void addSplits(List<SplitWrapper<SplitT>> splits)

指定者:

addSplits 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

notifyNoMoreSplits

public void notifyNoMoreSplits()

指定者:

notifyNoMoreSplits 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

handleSourceEvents

public void handleSourceEvents(org.apache.flink.api.connector.source.SourceEvent sourceEvent)

指定者:

handleSourceEvents 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

close

public void close()
           throws Exception

指定者:

close 在接口中 AutoCloseable

抛出:

Exception

notifyCheckpointComplete

public void notifyCheckpointComplete(long checkpointId)
                              throws Exception

指定者:

notifyCheckpointComplete 在接口中 org.apache.flink.api.common.state.CheckpointListener

指定者:

notifyCheckpointComplete 在接口中 org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>>

抛出:

Exception

notifyCheckpointAborted

public void notifyCheckpointAborted(long checkpointId)
                             throws Exception

指定者:

notifyCheckpointAborted 在接口中 org.apache.flink.api.common.state.CheckpointListener

抛出:

Exception