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

Class QueryIndexPartitionsSourceReader

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

public class QueryIndexPartitionsSourceReader
extends Object
implements org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

Constructor Summary

Constructors

Constructor	Description
QueryIndexPartitionsSourceReader(HRN hrn, Settings settings, String layerId, String query, long layerRefreshInterval, DataClientFlinkContextFactory contextFactory, QueryApiFactory queryApiFactory)

Method Summary

Modifier and Type	Method	Description
void	addSplits(List<ContinuousSourceUtils.TimestampSplit> splits)
void	close()
CompletableFuture<Void>	isAvailable()
void	notifyNoMoreSplits()
org.apache.flink.core.io.InputStatus	pollNext(org.apache.flink.api.connector.source.ReaderOutput<com.here.platform.data.client.scaladsl.IndexPartition> 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

QueryIndexPartitionsSourceReader

public QueryIndexPartitionsSourceReader(HRN hrn,
 Settings settings,
 String layerId,
 String query,
 long layerRefreshInterval,
 DataClientFlinkContextFactory contextFactory,
 QueryApiFactory queryApiFactory)

Method Details

addSplits

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

Specified by:

addSplits in interface org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

close

public void close()

Specified by:

close in interface AutoCloseable

isAvailable

public CompletableFuture<Void> isAvailable()

Specified by:

isAvailable in interface org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

notifyNoMoreSplits

public void notifyNoMoreSplits()

Specified by:

notifyNoMoreSplits in interface org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

pollNext

public org.apache.flink.core.io.InputStatus pollNext(org.apache.flink.api.connector.source.ReaderOutput<com.here.platform.data.client.scaladsl.IndexPartition> output)

Specified by:

pollNext in interface org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

snapshotState

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

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SourceReader<com.here.platform.data.client.scaladsl.IndexPartition,ContinuousSourceUtils.TimestampSplit>