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

Class GetChangesFlatMap

java.lang.Object

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

org.apache.flink.api.common.functions.RichFlatMapFunction<String,Partition>

com.here.platform.data.client.flink.javadsl.GetChangesFlatMap

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.FlatMapFunction<String,Partition>, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

public class GetChangesFlatMap
extends org.apache.flink.api.common.functions.RichFlatMapFunction<String,Partition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
GetChangesFlatMap(HRN hrn, String layerId, long startVersion, long endVersion, VersionedLayerContext queryContext, scala.collection.immutable.Set<AdditionalField> additionalFields, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory)

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.actor.ActorSystem	actorSystem()
scala.concurrent.ExecutionContext	executor()
void	flatMap(String part, org.apache.flink.util.Collector<Partition> out)

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

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Details

GetChangesFlatMap

public GetChangesFlatMap(HRN hrn,
 String layerId,
 long startVersion,
 long endVersion,
 VersionedLayerContext queryContext,
 scala.collection.immutable.Set<AdditionalField> additionalFields,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory)

Method Details

executor

public scala.concurrent.ExecutionContext executor()

actorSystem

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

flatMap

public void flatMap(String part,
 org.apache.flink.util.Collector<Partition> out)

Specified by:

flatMap in interface org.apache.flink.api.common.functions.FlatMapFunction<String,Partition>

Specified by:

flatMap in class org.apache.flink.api.common.functions.RichFlatMapFunction<String,Partition>