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

Class QueryIndexPartitionFlatMap

java.lang.Object

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

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

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

All Implemented Interfaces:

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

public class QueryIndexPartitionFlatMap
extends org.apache.flink.api.common.functions.RichFlatMapFunction<String,IndexPartition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
QueryIndexPartitionFlatMap(HRN hrn, String layerId, scala.Option<String> queryString, 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<IndexPartition> 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

QueryIndexPartitionFlatMap

public QueryIndexPartitionFlatMap(HRN hrn,
 String layerId,
 scala.Option<String> queryString,
 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<IndexPartition> out)

Specified by:

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

Specified by:

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