Page History

interface SourceReader {

    void start() throws IOException;

    CompletableFuture<?> available() throws IOException;


    ReaderStatus emitNext(SourceOutput<E> output) throws IOException;


    void addSplits(List<SplitT> splits) throws IOException;


    List<SplitT> snapshotState();
}