Package com.here.platform.data.client.flink.impl

Class IndexLayerFormatterMapFunction

java.lang.Object

com.here.platform.data.client.flink.impl.IndexLayerFormatterMapFunction

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.MapFunction<org.apache.flink.types.Row,PendingPartition>

public class IndexLayerFormatterMapFunction
extends Object
implements org.apache.flink.api.common.functions.MapFunction<org.apache.flink.types.Row,PendingPartition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
IndexLayerFormatterMapFunction(PartitionConverter formatter)

Method Summary

Modifier and Type	Method	Description
PendingPartition	map(org.apache.flink.types.Row value)

Methods inherited from class java.lang.Object

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

Constructor Details

IndexLayerFormatterMapFunction

public IndexLayerFormatterMapFunction(PartitionConverter formatter)

Method Details

map

public PendingPartition map(org.apache.flink.types.Row value)

Specified by:

map in interface org.apache.flink.api.common.functions.MapFunction<org.apache.flink.types.Row,PendingPartition>