THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
@Public public class IteratorSourceReader< E, IterT extends Iterator<E>, SplitT extends IteratorSourceSplit<E, IterT>> extends IteratorSourceReaderBase<E, E, IterT, SplitT> { public IteratorSourceReader(SourceReaderContext context) { super(context); } @Override public InputStatus pollNext(ReaderOutput<E> output) {...} } |
This FLIP introduces a new DataGeneratorSource
class.
...