Versions Compared

Old Version 22

changes.mady.by.user Alexander Fedulov

Saved on

compared with

New Version 23

changes.mady.by.user Alexander Fedulov

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
titleIteratorSourceReaderBase
@Experimental
abstract class IteratorSourceReaderBase<
                E, O, IterT extends Iterator<E>, SplitT extends IteratorSourceSplit<E, IterT>>
        implements SourceReader<O, SplitT> {...}


Reader:

Code Block
languagejava
firstlinetitleIteratorSourceReader
@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) {...}
}

...


}


Code Block
languagejava
titleMappingIteratorSourceReader
@Experimental
public class MappingIteratorSourceReader<
                E, O, IterT extends Iterator<E>, SplitT extends IteratorSourceSplit<E, IterT>>
        extends IteratorSourceReaderBase<E, O, IterT, SplitT> {

    public MappingIteratorSourceReader(
            SourceReaderContext context, MapFunction<E, O> generatorFunction) {...} 

    @Override
    public InputStatus pollNext(ReaderOutput<O> output)  {...} 
}


The envisioned usage looks like this:

...