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

Class ImlFeatureStreamProviderWriteOnly

java.lang.Object

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

All Implemented Interfaces:

InteractiveMapProvider, ImlFeatureStreamProvider

public class ImlFeatureStreamProviderWriteOnly
extends Object
implements ImlFeatureStreamProvider

Constructor Summary

Constructors

Constructor	Description
ImlFeatureStreamProviderWriteOnly(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv, HRN hrn, Settings settings, String layerId, long layerRefreshInterval, long writeAggregationInterval, int writeParallelism, long writeTimeout, DataClientFlinkContextFactory contextFactory, PublishApiFactory publishApiFactory)

Method Summary

Modifier and Type	Method	Description
DataClientFlinkContextFactory	contextFactory()
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment	execEnv()
org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo>	getDataStream()
HRN	hrn()
String	layerId()
long	layerRefreshInterval()
PublishApiFactory	publishApiFactory()
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

ImlFeatureStreamProviderWriteOnly

public ImlFeatureStreamProviderWriteOnly(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv,
 HRN hrn,
 Settings settings,
 String layerId,
 long layerRefreshInterval,
 long writeAggregationInterval,
 int writeParallelism,
 long writeTimeout,
 DataClientFlinkContextFactory contextFactory,
 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

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

contextFactory

public DataClientFlinkContextFactory contextFactory()

Specified by:

contextFactory in interface ImlFeatureStreamProvider

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