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

Class ImlFeatureStreamProviderFactory

java.lang.Object

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

public class ImlFeatureStreamProviderFactory
extends Object

Constructor Summary

Constructors

Constructor	Description
ImlFeatureStreamProviderFactory()

Method Summary

Modifier and Type	Method	Description
static ImlFeatureStreamProvider	apply(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv, HRN hrn, Settings settings, String layerId, String query, boolean ignoreInvalidPartitions, long layerRefreshInterval, long aggregationInterval, int writeParallelism, long writeTimeout, int readParallelism, int readMaxFeaturesPerRequest, long readTimeout, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory, PublishApiFactory publishApiFactory)

Methods inherited from class java.lang.Object

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

Constructor Details

ImlFeatureStreamProviderFactory

public ImlFeatureStreamProviderFactory()

Method Details

apply

public static ImlFeatureStreamProvider apply(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv,
 HRN hrn,
 Settings settings,
 String layerId,
 String query,
 boolean ignoreInvalidPartitions,
 long layerRefreshInterval,
 long aggregationInterval,
 int writeParallelism,
 long writeTimeout,
 int readParallelism,
 int readMaxFeaturesPerRequest,
 long readTimeout,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory,
 PublishApiFactory publishApiFactory)