Class Hierarchy
- java.lang.Object
- org.apache.flink.connector.datagen.source.DataGeneratorSource<OUT> (implements org.apache.flink.streaming.api.operators.OutputTypeConfigurable<OUT>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.api.connector.source.Source<T,SplitT,EnumChkT>)
- org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase<E,O,IterT,SplitT> (implements org.apache.flink.api.connector.source.SourceReader<T,SplitT>)
- org.apache.flink.connector.datagen.source.DoubleEmittingSourceReaderWithCheckpointsInBetween<E,O,IterT,SplitT>
- org.apache.flink.connector.datagen.source.GeneratingIteratorSourceReader<E,O,IterT,SplitT>
Interface Hierarchy
- java.io.Serializable
- org.apache.flink.api.common.functions.Function
- org.apache.flink.connector.datagen.source.GeneratorFunction<T,O>
- org.apache.flink.api.common.functions.Function