Interface ImlFeatureStreamProvider
- All Superinterfaces:
InteractiveMapProvider
- All Known Implementing Classes:
ImlFeatureStreamProviderFromFeatureIds,ImlFeatureStreamProviderFromGeometry,ImlFeatureStreamProviderWriteOnly
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.flink.streaming.api.datastream.DataStreamSink<?>consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo> dataStream) org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo>hrn()layerId()longsettings()longintlong
-
Method Details
-
consumeDataStream
org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo> dataStream) - Specified by:
consumeDataStreamin interfaceInteractiveMapProvider
-
contextFactory
DataClientFlinkContextFactory contextFactory() -
getDataStream
org.apache.flink.streaming.api.datastream.DataStream<InteractiveMapFeaturePojo> getDataStream()- Specified by:
getDataStreamin interfaceInteractiveMapProvider
-
hrn
HRN hrn() -
layerId
String layerId() -
layerRefreshInterval
long layerRefreshInterval() -
publishApiFactory
PublishApiFactory publishApiFactory() -
settings
Settings settings() -
writeAggregationInterval
long writeAggregationInterval() -
writeParallelism
int writeParallelism() -
writeTimeout
long writeTimeout()
-