org.apache.flink.connector.datagen.functions

Class IndexLookupGeneratorFunction<OUT>

java.lang.Object

org.apache.flink.connector.datagen.functions.IndexLookupGeneratorFunction<OUT>

Type Parameters:

OUT - The type of elements returned by this function.

All Implemented Interfaces:

Serializable, Function, GeneratorFunction<Long,OUT>

@Internal
public class IndexLookupGeneratorFunction<OUT>
extends Object
implements GeneratorFunction<Long,OUT>

A stream generator function that returns elements from the collection based on their index.

This generator function serializes the elements using Flink's type information. That way, any object transport using Java serialization will not be affected by the serializability of the elements.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IndexLookupGeneratorFunction(TypeInformation<OUT> typeInfo, ExecutionConfig config, Iterable<OUT> elements)
IndexLookupGeneratorFunction(TypeInformation<OUT> typeInfo, Iterable<OUT> elements)

Method Summary

Modifier and Type	Method and Description
TypeSerializer<OUT>	getSerializer()
OUT	map(Long index)
void	open(SourceReaderContext readerContext) Initialization method for the function.

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.connector.datagen.source.GeneratorFunction

close

Constructor Detail

IndexLookupGeneratorFunction

public IndexLookupGeneratorFunction(TypeInformation<OUT> typeInfo,
                                    Iterable<OUT> elements)

IndexLookupGeneratorFunction

public IndexLookupGeneratorFunction(TypeInformation<OUT> typeInfo,
                                    ExecutionConfig config,
                                    Iterable<OUT> elements)

Method Detail

getSerializer

@VisibleForTesting
 @Nullable
public TypeSerializer<OUT> getSerializer()

open

public void open(SourceReaderContext readerContext)
          throws Exception

Description copied from interface: GeneratorFunction

Initialization method for the function. It is called once before the actual data mapping methods.

Specified by:

open in interface GeneratorFunction<Long,OUT>

Throws:

Exception

map

public OUT map(Long index)
        throws Exception

Specified by:

map in interface GeneratorFunction<Long,OUT>

Throws:

Exception