@PublicEvolving public interface SupportsHandleExecutionAttemptSourceEvent
SplitEnumeratorwhich allows to handle
SourceEventsent from a specific execution attempt.
The split enumerator must implement this interface if it needs to deal with custom source events and is used in cases that a subtask can have multiple concurrent execution attempts, e.g. if speculative execution is enabled. Otherwise an error will be thrown when the split enumerator receives a custom source event.
|Modifier and Type||Method and Description|
Handles a custom source event from the source reader.
void handleSourceEvent(int subtaskId, int attemptNumber, SourceEvent sourceEvent)
SplitEnumerator.handleSourceEvent(int, SourceEvent)but is aware of the subtask execution attempt who sent this event.
subtaskId- the subtask id of the source reader who sent the source event.
attemptNumber- the attempt number of the source reader who sent the source event.
sourceEvent- the source event from the source reader.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.