Class ImlFeatureStreamProviderFactory
java.lang.Object
com.here.platform.data.client.flink.impl.ImlFeatureStreamProviderFactory
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic ImlFeatureStreamProviderapply(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)
-
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)
-