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 custom 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 |
ContinuousFileSplitEnumerator.handleSourceEvent(int subtaskId,
SourceEvent sourceEvent) |
void |
StaticFileSplitEnumerator.handleSourceEvent(int subtaskId,
SourceEvent sourceEvent) |
Modifier and Type | Method and Description |
---|---|
Map<Integer,List<SourceEvent>> |
TestingSplitEnumeratorContext.getSentEvents() |
List<SourceEvent> |
TestingReaderContext.getSentEvents() |
Modifier and Type | Method and Description |
---|---|
void |
TestingSplitEnumeratorContext.sendEventToSourceReader(int subtaskId,
SourceEvent event) |
void |
TestingReaderContext.sendSourceEventToCoordinator(SourceEvent sourceEvent) |
Modifier and Type | Method and Description |
---|---|
void |
ContinuousHiveSplitEnumerator.handleSourceEvent(int subtaskId,
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.