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

Class DataGeneratorMapper<A,B>

java.lang.Object

org.apache.flink.connector.datagen.table.types.DataGeneratorMapper<A,B>

All Implemented Interfaces:

Serializable, Iterator<B>, DataGenerator<B>

@Internal
public class DataGeneratorMapper<A,B>
extends Object
implements DataGenerator<B>

Utility for mapping the output of a DataGenerator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataGeneratorMapper(DataGenerator<A> generator, SerializableFunction<A,B> mapper)

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
B	next()
void	open(String name, FunctionInitializationContext context, RuntimeContext runtimeContext) Open and initialize 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 org.apache.flink.streaming.api.functions.source.datagen.DataGenerator

snapshotState

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

DataGeneratorMapper

public DataGeneratorMapper(DataGenerator<A> generator,
                           SerializableFunction<A,B> mapper)

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<B>

Parameters:

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

Throws:

Exception

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<B>

next

public B next()

Specified by:

next in interface Iterator<B>