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

Class QueryChangesSource

java.lang.Object

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

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

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 QueryChangesSource
extends com.here.platform.data.client.flink.scaladsl.QueryApiSource<Partition>

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
QueryChangesSource(HRN hrn, Settings settings, long startVersion, long endVersion, String layer, VersionedLayerContext context, 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

QueryChangesSource

public QueryChangesSource(HRN hrn,
 Settings settings,
 long startVersion,
 long endVersion,
 String layer,
 VersionedLayerContext context,
 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>