org.apache.flink.connector.datagen.table.types

Class RowDataGenerator

java.lang.Object

org.apache.flink.connector.datagen.table.types.RowDataGenerator

All Implemented Interfaces:

Serializable, Iterator<RowData>, DataGenerator<RowData>

@Internal
public class RowDataGenerator
extends Object
implements DataGenerator<RowData>

Data generator for Flink's internal RowData type.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowDataGenerator(DataGenerator<?>[] fieldGenerators, List<String> fieldNames, float nullRate)

Method Summary

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

RowDataGenerator

public RowDataGenerator(DataGenerator<?>[] fieldGenerators,
                        List<String> fieldNames,
                        float nullRate)

Method Detail

open

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

Description copied from interface: DataGenerator

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

Specified by:

open in interface DataGenerator<RowData>

Parameters:

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

Throws:

Exception

snapshotState

public void snapshotState(FunctionSnapshotContext context)
                   throws Exception

Description copied from interface: DataGenerator

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

Specified by:

snapshotState in interface DataGenerator<RowData>

Throws:

Exception

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<RowData>

next

public RowData next()

Specified by:

next in interface Iterator<RowData>