...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
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(); } |
...