Modifier and Type | Method and Description |
---|---|
boolean |
TaskEventDispatcher.publish(ResultPartitionID partitionId,
TaskEvent event)
Publishes the event to the registered
ResultPartitionWriter instances. |
Modifier and Type | Method and Description |
---|---|
void |
TaskEventHandler.publish(TaskEvent event)
Publishes the task event to all subscribed event listeners.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskEventHandler.subscribe(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
TaskEventHandler.subscribe(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
TaskEventHandler.unsubscribe(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
TaskEventHandler.unsubscribe(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractReader.publish(TaskEvent event) |
void |
ReaderBase.sendTaskEvent(TaskEvent event) |
void |
AbstractReader.sendTaskEvent(TaskEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
ReaderBase.registerTaskEventListener(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
ReaderBase.registerTaskEventListener(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
AbstractReader.registerTaskEventListener(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
void |
AbstractReader.registerTaskEventListener(EventListener<TaskEvent> listener,
Class<? extends TaskEvent> eventType) |
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.onEvent(TaskEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
ResultPartitionWriter.subscribeToEvent(EventListener<TaskEvent> eventListener,
Class<? extends TaskEvent> eventType) |
void |
ResultPartitionWriter.subscribeToEvent(EventListener<TaskEvent> eventListener,
Class<? extends TaskEvent> eventType) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionRequestClient.sendTaskEvent(ResultPartitionID partitionId,
TaskEvent event,
RemoteInputChannel inputChannel)
Sends a task event backwards to an intermediate result partition producer.
|
Modifier and Type | Method and Description |
---|---|
void |
UnionInputGate.sendTaskEvent(TaskEvent event) |
void |
SingleInputGate.sendTaskEvent(TaskEvent event) |
void |
InputGate.sendTaskEvent(TaskEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
SuperstepBarrier.onEvent(TaskEvent event)
barrier will release the waiting thread if an event occurs
|
Modifier and Type | Class and Description |
---|---|
class |
AllWorkersDoneEvent |
class |
IterationEventWithAggregators |
class |
TerminationEvent
Signals that the iteration is completely executed, participating tasks must terminate now
|
class |
WorkerDoneEvent |
Modifier and Type | Method and Description |
---|---|
void |
SyncEventHandler.onEvent(TaskEvent event) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.