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

Class GetPartitionsFlatMap

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.GetPartitionsFlatMap

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 GetPartitionsFlatMap
extends org.apache.flink.api.common.functions.RichFlatMapFunction<String,Partition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
GetPartitionsFlatMap(HRN hrn, String layerId, long version, 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

GetPartitionsFlatMap

public GetPartitionsFlatMap(HRN hrn,
 String layerId,
 long version,
 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>