Modifier and Type | Method and Description |
---|---|
default void |
SplitEnumerator.handleSourceEvent(int subtaskId,
SourceEvent sourceEvent)
Handles a custom source event from the source reader.
|
default void |
SourceReader.handleSourceEvents(SourceEvent sourceEvent)
Handle a source event sent by the
SplitEnumerator . |
void |
SplitEnumeratorContext.sendEventToSourceReader(int subtaskId,
SourceEvent event)
Send a source event to a source reader.
|
void |
SourceReaderContext.sendSourceEventToCoordinator(SourceEvent sourceEvent)
Send a source event to the source coordinator.
|
Modifier and Type | Method and Description |
---|---|
void |
SourceReaderBase.handleSourceEvents(SourceEvent sourceEvent) |
Modifier and Type | Method and Description |
---|---|
void |
SourceCoordinatorContext.sendEventToSourceReader(int subtaskId,
SourceEvent event) |
Modifier and Type | Method and Description |
---|---|
SourceEvent |
SourceEventWrapper.getSourceEvent() |
Constructor and Description |
---|
SourceEventWrapper(SourceEvent sourceEvent) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.