Interface SourceReaderFactory<T,​SplitT extends SourceSplit>

    • 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.
        Parameters:
        readerContext - The context for the source reader.
        Returns:
        A new SourceReader.
        Throws:
        Exception - The implementor is free to forward all exceptions directly. Exceptions thrown from this method cause task failure/recovery.