org.apache.flink.connector.datagen.source

Class GeneratingIteratorSourceReader<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>

java.lang.Object

org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase<E,O,IterT,SplitT>

org.apache.flink.connector.datagen.source.GeneratingIteratorSourceReader<E,O,IterT,SplitT>

All Implemented Interfaces:

AutoCloseable, CheckpointListener, SourceReader<O,SplitT>

@Experimental
public class GeneratingIteratorSourceReader<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>
extends IteratorSourceReaderBase<E,O,IterT,SplitT>

A SourceReader that takes the values of an iterator, supplied via an IteratorSourceSplit, and applies a GeneratorFunction to them to perform arbitrary transformations.

Constructor Summary

Constructors

Constructor and Description
GeneratingIteratorSourceReader(SourceReaderContext context, GeneratorFunction<E,O> generatorFunction)

Method Summary

Modifier and Type	Method and Description
void	close()
protected O	convert(E value)
void	start(SourceReaderContext context)

Methods inherited from class org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase

addSplits, isAvailable, notifyNoMoreSplits, pollNext, snapshotState, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.connector.source.SourceReader

handleSourceEvents, notifyCheckpointComplete, pauseOrResumeSplits

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

GeneratingIteratorSourceReader

public GeneratingIteratorSourceReader(SourceReaderContext context,
                                      GeneratorFunction<E,O> generatorFunction)

Method Detail

convert

protected O convert(E value)

Specified by:

convert in class IteratorSourceReaderBase<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>

start

public void start(SourceReaderContext context)

Overrides:

start in class IteratorSourceReaderBase<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class IteratorSourceReaderBase<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>

Throws:

Exception