Package org.apache.flink.connector.file.src.impl

Class FileSourceReader<T,SplitT extends FileSourceSplit>

java.lang.Object

org.apache.flink.connector.base.source.reader.SourceReaderBase<E,T,SplitT,SplitStateT>

org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<RecordAndPosition<T>,T,SplitT,FileSourceSplitState<SplitT>>

org.apache.flink.connector.file.src.impl.FileSourceReader<T,SplitT>

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<T,SplitT>

@Internal
public final class FileSourceReader<T,SplitT extends FileSourceSplit>
extends org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase<RecordAndPosition<T>,T,SplitT,FileSourceSplitState<SplitT>>

A SourceReader that read records from FileSourceSplit.

Field Summary

Fields inherited from class org.apache.flink.connector.base.source.reader.SourceReaderBase

config, context, eofRecordEvaluator, options, recordEmitter, splitFetcherManager

Constructor Summary

Constructors

Constructor	Description
FileSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext, BulkFormat<T,SplitT> readerFormat, org.apache.flink.configuration.Configuration config)

Method Summary

Modifier and Type	Method	Description
protected FileSourceSplitState<SplitT>	initializedState(SplitT split)
protected void	onSplitFinished(Map<String,FileSourceSplitState<SplitT>> finishedSplitIds)
void	start()
protected SplitT	toSplitType(String splitId, FileSourceSplitState<SplitT> splitState)

Methods inherited from class org.apache.flink.connector.base.source.reader.SourceReaderBase

addSplits, close, getNumberOfCurrentlyAssignedSplits, handleSourceEvents, isAvailable, notifyCheckpointComplete, notifyNoMoreSplits, pauseOrResumeSplits, pollNext, snapshotState

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

FileSourceReader

public FileSourceReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext,
                        BulkFormat<T,SplitT> readerFormat,
                        org.apache.flink.configuration.Configuration config)

Method Detail

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SourceReader<T,SplitT extends FileSourceSplit>

Overrides:

start in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,SplitT extends FileSourceSplit,FileSourceSplitState<SplitT extends FileSourceSplit>>

onSplitFinished

protected void onSplitFinished(Map<String,FileSourceSplitState<SplitT>> finishedSplitIds)

Specified by:

onSplitFinished in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,SplitT extends FileSourceSplit,FileSourceSplitState<SplitT extends FileSourceSplit>>

initializedState

protected FileSourceSplitState<SplitT> initializedState(SplitT split)

Specified by:

initializedState in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,SplitT extends FileSourceSplit,FileSourceSplitState<SplitT extends FileSourceSplit>>

toSplitType

protected SplitT toSplitType(String splitId,
                             FileSourceSplitState<SplitT> splitState)

Specified by:

toSplitType in class org.apache.flink.connector.base.source.reader.SourceReaderBase<RecordAndPosition<T>,T,SplitT extends FileSourceSplit,FileSourceSplitState<SplitT extends FileSourceSplit>>