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

Class ImlFeatureIdsSourceReader

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

public class ImlFeatureIdsSourceReader
extends Object
implements org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

Constructor Summary

Constructors

Constructor	Description
ImlFeatureIdsSourceReader(scala.collection.immutable.Seq<String> ids, long layerRefreshInterval, DataClientFlinkContextFactory contextFactory)

Method Summary

Modifier and Type	Method	Description
void	addSplits(List<ContinuousSourceUtils.TimestampSplit> splits)
void	close()
scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>>	idChunks()
CompletableFuture<Void>	isAvailable()
void	notifyNoMoreSplits()
org.apache.flink.core.io.InputStatus	pollNext(org.apache.flink.api.connector.source.ReaderOutput<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>> output)
List<ContinuousSourceUtils.TimestampSplit>	snapshotState(long checkpointId)
void	start()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Methods inherited from interface org.apache.flink.api.connector.source.SourceReader

handleSourceEvents, notifyCheckpointComplete, pauseOrResumeSplits

Constructor Details

ImlFeatureIdsSourceReader

public ImlFeatureIdsSourceReader(scala.collection.immutable.Seq<String> ids,
 long layerRefreshInterval,
 DataClientFlinkContextFactory contextFactory)

Method Details

addSplits

public void addSplits(List<ContinuousSourceUtils.TimestampSplit> splits)

Specified by:

addSplits in interface org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

close

public void close()

Specified by:

close in interface AutoCloseable

idChunks

public scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> idChunks()

isAvailable

public CompletableFuture<Void> isAvailable()

Specified by:

isAvailable in interface org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

notifyNoMoreSplits

public void notifyNoMoreSplits()

Specified by:

notifyNoMoreSplits in interface org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

pollNext

public org.apache.flink.core.io.InputStatus pollNext(org.apache.flink.api.connector.source.ReaderOutput<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>> output)

Specified by:

pollNext in interface org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

snapshotState

public List<ContinuousSourceUtils.TimestampSplit> snapshotState(long checkpointId)

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SourceReader<scala.Tuple2<Object,scala.collection.immutable.Seq<String>>,ContinuousSourceUtils.TimestampSplit>