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

Class VersionPartitionsByPartFlatMap

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichFlatMapFunction<PartData,com.here.platform.data.client.scaladsl.Partition>

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

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.FlatMapFunction<PartData,com.here.platform.data.client.scaladsl.Partition>, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

public class VersionPartitionsByPartFlatMap
extends org.apache.flink.api.common.functions.RichFlatMapFunction<PartData,com.here.platform.data.client.scaladsl.Partition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
VersionPartitionsByPartFlatMap(HRN hrn, Settings settings, String layerId, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory)

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.actor.ActorSystem	actorSystem()
void	close()
void	flatMap(PartData value, org.apache.flink.util.Collector<com.here.platform.data.client.scaladsl.Partition> out)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Details

VersionPartitionsByPartFlatMap

public VersionPartitionsByPartFlatMap(HRN hrn,
 Settings settings,
 String layerId,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory)

Method Details

actorSystem

public org.apache.pekko.actor.ActorSystem actorSystem()

flatMap

public void flatMap(PartData value,
 org.apache.flink.util.Collector<com.here.platform.data.client.scaladsl.Partition> out)

Specified by:

flatMap in interface org.apache.flink.api.common.functions.FlatMapFunction<PartData,com.here.platform.data.client.scaladsl.Partition>

Specified by:

flatMap in class org.apache.flink.api.common.functions.RichFlatMapFunction<PartData,com.here.platform.data.client.scaladsl.Partition>

close

public void close()

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction