Package 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<org.apache.flink.table.data.RowData>, org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<org.apache.flink.table.data.RowData>

@Internal
public class RowDataGenerator
extends Object
implements org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<org.apache.flink.table.data.RowData>

Data generator for Flink's internal RowData type.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RowDataGenerator(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<?>[] fieldGenerators, List<String> fieldNames, float nullRate)

Method Summary

Modifier and Type	Method	Description
boolean	hasNext()
org.apache.flink.table.data.RowData	next()
void	open(String name, org.apache.flink.runtime.state.FunctionInitializationContext context, org.apache.flink.api.common.functions.RuntimeContext runtimeContext)
void	snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext context)

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(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<?>[] fieldGenerators,
                        List<String> fieldNames,
                        float nullRate)

Method Detail

open

public void open(String name,
                 org.apache.flink.runtime.state.FunctionInitializationContext context,
                 org.apache.flink.api.common.functions.RuntimeContext runtimeContext)
          throws Exception

Specified by:

open in interface org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<org.apache.flink.table.data.RowData>

Throws:

Exception

snapshotState

public void snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext context)
                   throws Exception

Specified by:

snapshotState in interface org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<org.apache.flink.table.data.RowData>

Throws:

Exception

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<org.apache.flink.table.data.RowData>

next

public org.apache.flink.table.data.RowData next()

Specified by:

next in interface Iterator<org.apache.flink.table.data.RowData>