Interface SourceReaderFactory<T,SplitT extends SourceSplit>
-
- Type Parameters:
T
- The type of the output elements.
- All Superinterfaces:
Serializable
- All Known Subinterfaces:
Source<T,SplitT,EnumChkT>
- All Known Implementing Classes:
AbstractFileSource
,DataGeneratorSource
,FileSource
,FromElementsSource
,HybridSource
,NumberSequenceSource
,SocketSource
@Public public interface SourceReaderFactory<T,SplitT extends SourceSplit> extends Serializable
A factory for creating source reader instances.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description SourceReader<T,SplitT>
createReader(SourceReaderContext readerContext)
Creates a new reader to read data from the splits it gets assigned.
-
-
-
Method Detail
-
createReader
SourceReader<T,SplitT> createReader(SourceReaderContext readerContext) throws Exception
Creates a new reader to read data from the splits it gets assigned. The reader starts fresh and does not have any state to resume.
-
-