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

Class QueryVolatileChangesSource

java.lang.Object

com.here.platform.data.client.flink.scaladsl.QueryApiSource<Partition>

com.here.platform.data.client.flink.javadsl.QueryVolatileChangesSource

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<Partition,SingleSplitSourceUtils.Split,Collection<SingleSplitSourceUtils.Split>>, org.apache.flink.api.connector.source.SourceReaderFactory<Partition,SingleSplitSourceUtils.Split>

public class QueryVolatileChangesSource
extends com.here.platform.data.client.flink.scaladsl.QueryApiSource<Partition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
QueryVolatileChangesSource(HRN hrn, Settings settings, VolatilePartitionsFilter filter, String layer, scala.collection.immutable.Set<AdditionalField> additionalFields, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<Partition,org.apache.pekko.NotUsed>>	partitionsProvider(com.here.platform.data.client.scaladsl.QueryApi queryApi)

Methods inherited from class com.here.platform.data.client.flink.scaladsl.QueryApiSource

createEnumerator, createReader, declareWatermarks, getBoundedness, getEnumeratorCheckpointSerializer, getSplitSerializer, restoreEnumerator

Methods inherited from class java.lang.Object

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

Constructor Details

QueryVolatileChangesSource

public QueryVolatileChangesSource(HRN hrn,
 Settings settings,
 VolatilePartitionsFilter filter,
 String layer,
 scala.collection.immutable.Set<AdditionalField> additionalFields,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory)

Method Details

partitionsProvider

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<Partition,org.apache.pekko.NotUsed>> partitionsProvider(com.here.platform.data.client.scaladsl.QueryApi queryApi)

Specified by:

partitionsProvider in class com.here.platform.data.client.flink.scaladsl.QueryApiSource<Partition>