org.apache.flink.streaming.api.functions.source.datagen

Interface DataGenerator<T>

All Superinterfaces:

Iterator<T>, Serializable

All Known Implementing Classes:

DataGeneratorMapper, DecimalDataRandomGenerator, RandomGenerator, RowDataGenerator, SequenceGenerator

@Experimental
public interface DataGenerator<T>
extends Serializable, Iterator<T>

Stateful and re-scalable data generator.

Method Summary

Modifier and Type	Method and Description
void	open(String name, FunctionInitializationContext context, RuntimeContext runtimeContext) Open and initialize state for DataGenerator.
default void	snapshotState(FunctionSnapshotContext context) Snapshot state for DataGenerator.

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Method Detail

open

void open(String name,
          FunctionInitializationContext context,
          RuntimeContext runtimeContext)
   throws Exception

Open and initialize state for DataGenerator. See CheckpointedFunction.initializeState(org.apache.flink.runtime.state.FunctionInitializationContext).

Parameters:

name - The state of DataGenerator should related to this name, make sure the name of state is different.

Throws:

Exception

snapshotState

default void snapshotState(FunctionSnapshotContext context)
                    throws Exception

Snapshot state for DataGenerator. See CheckpointedFunction.snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext).

Throws:

Exception