public class ContinuousFileSplitEnumerator extends Object implements org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
Constructor and Description |
---|
ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
Collection<FileStoreSourceSplit> remainSplits,
Long nextSnapshotId,
long discoveryInterval,
SnapshotEnumerator snapshotEnumerator) |
Modifier and Type | Method and Description |
---|---|
void |
addReader(int subtaskId) |
void |
addSplitsBack(List<FileStoreSourceSplit> splits,
int subtaskId) |
void |
close() |
void |
handleSourceEvent(int subtaskId,
org.apache.flink.api.connector.source.SourceEvent sourceEvent) |
void |
handleSplitRequest(int subtaskId,
String requesterHostname) |
PendingSplitsCheckpoint |
snapshotState(long checkpointId) |
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context, Collection<FileStoreSourceSplit> remainSplits, Long nextSnapshotId, long discoveryInterval, SnapshotEnumerator snapshotEnumerator)
public void start()
start
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
public void close() throws IOException
close
in interface AutoCloseable
close
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
IOException
public void addReader(int subtaskId)
addReader
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
public void handleSplitRequest(int subtaskId, @Nullable String requesterHostname)
handleSplitRequest
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
public void handleSourceEvent(int subtaskId, org.apache.flink.api.connector.source.SourceEvent sourceEvent)
handleSourceEvent
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
public void addSplitsBack(List<FileStoreSourceSplit> splits, int subtaskId)
addSplitsBack
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
public PendingSplitsCheckpoint snapshotState(long checkpointId)
snapshotState
in interface org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.