...
Code Block |
---|
language | java |
---|
title | IteratorSourceReaderBase |
---|
|
@Experimental
abstract class IteratorSourceReaderBase<
E, O, IterT extends Iterator<E>, SplitT extends IteratorSourceSplit<E, IterT>>
implements SourceReader<O, SplitT> {...} |
Reader:
Code Block |
---|
language | java |
---|
firstlinetitle | IteratorSourceReader |
---|
|
@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 |
---|
language | java |
---|
title | MappingIteratorSourceReader |
---|
|
@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:
...