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

Class ImlFeatureStreamProviderFromGeometry

java.lang.Object

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

All Implemented Interfaces:

InteractiveMapProvider, ImlFeatureStreamProvider

public class ImlFeatureStreamProviderFromGeometry
extends Object
implements ImlFeatureStreamProvider

Constructor Summary

Constructors

Constructor

Description

ImlFeatureStreamProviderFromGeometry(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv, HRN hrn, Settings settings, String layerId, FeaturesInGeometry imlParsedQuery, String query, boolean ignoreInvalidPartitions, Geometry geometry, scala.collection.immutable.Seq<String> initialQuadKeys, scala.collection.immutable.Set<SearchParam> searchParam, scala.collection.immutable.Set<String> selection, long layerRefreshInterval, long writeAggregationInterval, int writeParallelism, long writeTimeout, int readParallelism, int readMaxFeaturesPerRequest, long readTimeout, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory, PublishApiFactory publishApiFactory)

Method Summary

Modifier and Type	Method	Description
DataClientFlinkContextFactory	contextFactory()
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	execEnv()
scala.Option<org.locationtech.jts.geom.Geometry>	filterGeometry()
Geometry	geometry()
org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo>	getDataStream()
HRN	hrn()
boolean	ignoreInvalidPartitions()
FeaturesInGeometry	imlParsedQuery()
scala.collection.immutable.Seq<String>	initialQuadKeys()
String	layerId()
long	layerRefreshInterval()
PublishApiFactory	publishApiFactory()
String	query()
QueryApiFactory	queryApiFactory()
int	readMaxFeaturesPerRequest()
int	readParallelism()
long	readTimeout()
scala.collection.immutable.Set<SearchParam>	searchParam()
scala.collection.immutable.Set<String>	selection()
Settings	settings()
long	writeAggregationInterval()
int	writeParallelism()
long	writeTimeout()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.here.platform.data.client.flink.impl.ImlFeatureStreamProvider

consumeDataStream

Constructor Details

ImlFeatureStreamProviderFromGeometry

public ImlFeatureStreamProviderFromGeometry(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv,
 HRN hrn,
 Settings settings,
 String layerId,
 FeaturesInGeometry imlParsedQuery,
 String query,
 boolean ignoreInvalidPartitions,
 Geometry geometry,
 scala.collection.immutable.Seq<String> initialQuadKeys,
 scala.collection.immutable.Set<SearchParam> searchParam,
 scala.collection.immutable.Set<String> selection,
 long layerRefreshInterval,
 long writeAggregationInterval,
 int writeParallelism,
 long writeTimeout,
 int readParallelism,
 int readMaxFeaturesPerRequest,
 long readTimeout,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory,
 PublishApiFactory publishApiFactory)

Method Details

execEnv

public org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv()

hrn

public HRN hrn()

Specified by:

hrn in interface ImlFeatureStreamProvider

settings

public Settings settings()

Specified by:

settings in interface ImlFeatureStreamProvider

layerId

public String layerId()

Specified by:

layerId in interface ImlFeatureStreamProvider

imlParsedQuery

public FeaturesInGeometry imlParsedQuery()

query

public String query()

ignoreInvalidPartitions

public boolean ignoreInvalidPartitions()

geometry

public Geometry geometry()

initialQuadKeys

public scala.collection.immutable.Seq<String> initialQuadKeys()

searchParam

public scala.collection.immutable.Set<SearchParam> searchParam()

selection

public scala.collection.immutable.Set<String> selection()

layerRefreshInterval

public long layerRefreshInterval()

Specified by:

layerRefreshInterval in interface ImlFeatureStreamProvider

writeAggregationInterval

public long writeAggregationInterval()

Specified by:

writeAggregationInterval in interface ImlFeatureStreamProvider

writeParallelism

public int writeParallelism()

Specified by:

writeParallelism in interface ImlFeatureStreamProvider

writeTimeout

public long writeTimeout()

Specified by:

writeTimeout in interface ImlFeatureStreamProvider

readParallelism

public int readParallelism()

readMaxFeaturesPerRequest

public int readMaxFeaturesPerRequest()

readTimeout

public long readTimeout()

contextFactory

public DataClientFlinkContextFactory contextFactory()

Specified by:

contextFactory in interface ImlFeatureStreamProvider

queryApiFactory

public QueryApiFactory queryApiFactory()

publishApiFactory

public PublishApiFactory publishApiFactory()

Specified by:

publishApiFactory in interface ImlFeatureStreamProvider

filterGeometry

public scala.Option<org.locationtech.jts.geom.Geometry> filterGeometry()

getDataStream

public org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo> getDataStream()

Specified by:

getDataStream in interface ImlFeatureStreamProvider

Specified by:

getDataStream in interface InteractiveMapProvider