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

Class ContinuousSourceUtils.SingleSplitEnumerator

java.lang.Object

com.here.platform.data.client.flink.impl.ContinuousSourceUtils.SingleSplitEnumerator

All Implemented Interfaces:

AutoCloseable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

Enclosing class:

ContinuousSourceUtils

public static final class ContinuousSourceUtils.SingleSplitEnumerator
extends Object
implements org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

Constructor Summary

Constructors

Constructor	Description
SingleSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<ContinuousSourceUtils.TimestampSplit> context, ArrayList<ContinuousSourceUtils.TimestampSplit> pending)

Method Summary

Modifier and Type	Method	Description
void	addReader(int subtaskId)
void	addSplitsBack(List<ContinuousSourceUtils.TimestampSplit> splits, int subtaskId)
void	close()
void	handleSplitRequest(int subtaskId, String requesterHostname)
Collection<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.SplitEnumerator

handleSourceEvent, notifyCheckpointComplete

Constructor Details

SingleSplitEnumerator

public SingleSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<ContinuousSourceUtils.TimestampSplit> context,
 ArrayList<ContinuousSourceUtils.TimestampSplit> pending)

Method Details

addReader

public void addReader(int subtaskId)

Specified by:

addReader in interface org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

addSplitsBack

public void addSplitsBack(List<ContinuousSourceUtils.TimestampSplit> splits,
 int subtaskId)

Specified by:

addSplitsBack in interface org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

handleSplitRequest

public void handleSplitRequest(int subtaskId,
 String requesterHostname)

Specified by:

handleSplitRequest in interface org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

snapshotState

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

Specified by:

snapshotState in interface org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>

start

public void start()

Specified by:

start in interface org.apache.flink.api.connector.source.SplitEnumerator<ContinuousSourceUtils.TimestampSplit,Collection<ContinuousSourceUtils.TimestampSplit>>