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

Class VolatileLayerFormatterMapFunction

java.lang.Object

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

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 VolatileLayerFormatterMapFunction
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
VolatileLayerFormatterMapFunction(PartitionEncoder encoder)

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

VolatileLayerFormatterMapFunction

public VolatileLayerFormatterMapFunction(PartitionEncoder encoder)

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>