@Internal
public class ContinuousIcebergEnumerator
extends java.lang.Object
Constructor and Description |
---|
ContinuousIcebergEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumeratorContext,
SplitAssigner assigner,
ScanContext scanContext,
ContinuousSplitPlanner splitPlanner,
IcebergEnumeratorState enumState) |
Modifier and Type | Method and Description |
---|---|
void |
addReader(int subtaskId) |
void |
addSplitsBack(java.util.List<IcebergSourceSplit> splits,
int subtaskId) |
void |
close() |
void |
handleSourceEvent(int subtaskId,
org.apache.flink.api.connector.source.SourceEvent sourceEvent) |
void |
handleSplitRequest(int subtaskId,
java.lang.String requesterHostname) |
protected boolean |
shouldWaitForMoreSplits()
return true if enumerator should wait for splits like in the continuous enumerator case
|
IcebergEnumeratorState |
snapshotState(long checkpointId) |
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ContinuousIcebergEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<IcebergSourceSplit> enumeratorContext, SplitAssigner assigner, ScanContext scanContext, ContinuousSplitPlanner splitPlanner, @Nullable IcebergEnumeratorState enumState)
public void start()
start
in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>
public void close() throws java.io.IOException
close
in interface java.lang.AutoCloseable
close
in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>
java.io.IOException
protected boolean shouldWaitForMoreSplits()
public IcebergEnumeratorState snapshotState(long checkpointId)
public void handleSplitRequest(int subtaskId, @Nullable java.lang.String requesterHostname)
handleSplitRequest
in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>
public void handleSourceEvent(int subtaskId, org.apache.flink.api.connector.source.SourceEvent sourceEvent)
handleSourceEvent
in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>
public void addSplitsBack(java.util.List<IcebergSourceSplit> splits, int subtaskId)
addSplitsBack
in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>
public void addReader(int subtaskId)
addReader
in interface org.apache.flink.api.connector.source.SplitEnumerator<IcebergSourceSplit,IcebergEnumeratorState>