Package org.apache.flink.connector.datagen.source

Interface Summary

Interface	Description
GeneratorFunction<T,O>	Base interface for data generator functions.

Class Summary

Class	Description
DataGeneratorSource<OUT>	A data source that produces N data points in parallel.
DoubleEmittingSourceReaderWithCheckpointsInBetween<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>	A SourceReader that synchronizes emission of N elements on the arrival of the checkpoint barriers It 1) emits a list of elements without checkpoints in-between, 2) then waits for two checkpoints to complete, 3) then re-emits the same elements before 4) waiting for another two checkpoints and 5) exiting.
GeneratingIteratorSourceReader<E,O,IterT extends Iterator<E>,SplitT extends IteratorSourceSplit<E,IterT>>	A SourceReader that takes the values of an iterator, supplied via an IteratorSourceSplit, and applies a GeneratorFunction to them to perform arbitrary transformations.