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

Class ImlFeatureStreamProviderFromFeatureIds

java.lang.Object

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

All Implemented Interfaces:

InteractiveMapProvider, ImlFeatureStreamProvider

public class ImlFeatureStreamProviderFromFeatureIds
extends Object
implements ImlFeatureStreamProvider

Constructor Summary

Constructors

Constructor

Description

ImlFeatureStreamProviderFromFeatureIds(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv, HRN hrn, Settings settings, String layerId, scala.collection.immutable.Seq<String> ids, scala.collection.immutable.Set<String> selection, long layerRefreshInterval, long writeAggregationInterval, int writeParallelism, long writeTimeout, int downloadParallelism, long downloadTimeout, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory, PublishApiFactory publishApiFactory)

Method Summary

Modifier and Type	Method	Description
DataClientFlinkContextFactory	contextFactory()
int	downloadParallelism()
long	downloadTimeout()
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	execEnv()
org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo>	getDataStream()
HRN	hrn()
scala.collection.immutable.Seq<String>	ids()
String	layerId()
long	layerRefreshInterval()
PublishApiFactory	publishApiFactory()
QueryApiFactory	queryApiFactory()
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

ImlFeatureStreamProviderFromFeatureIds

public ImlFeatureStreamProviderFromFeatureIds(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv,
 HRN hrn,
 Settings settings,
 String layerId,
 scala.collection.immutable.Seq<String> ids,
 scala.collection.immutable.Set<String> selection,
 long layerRefreshInterval,
 long writeAggregationInterval,
 int writeParallelism,
 long writeTimeout,
 int downloadParallelism,
 long downloadTimeout,
 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

ids

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

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

downloadParallelism

public int downloadParallelism()

downloadTimeout

public long downloadTimeout()

contextFactory

public DataClientFlinkContextFactory contextFactory()

Specified by:

contextFactory in interface ImlFeatureStreamProvider

queryApiFactory

public QueryApiFactory queryApiFactory()

publishApiFactory

public PublishApiFactory publishApiFactory()

Specified by:

publishApiFactory in interface ImlFeatureStreamProvider

getDataStream

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

Specified by:

getDataStream in interface ImlFeatureStreamProvider

Specified by:

getDataStream in interface InteractiveMapProvider