public class TaskEventDispatcher extends Object
Backwards events only work for tasks, which produce pipelined results, where both the producing and consuming task are running at the same time.
Constructor and Description |
---|
TaskEventDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
clearAll() |
boolean |
publish(ResultPartitionID partitionId,
TaskEvent event)
Publishes the event to the registered
ResultPartitionWriter instances. |
void |
registerWriterForIncomingTaskEvents(ResultPartitionID partitionId,
ResultPartitionWriter writer) |
void |
unregisterWriter(ResultPartitionWriter writer) |
public void registerWriterForIncomingTaskEvents(ResultPartitionID partitionId, ResultPartitionWriter writer)
public void unregisterWriter(ResultPartitionWriter writer)
public boolean publish(ResultPartitionID partitionId, TaskEvent event)
ResultPartitionWriter
instances.
This method is either called directly from a LocalInputChannel
or the network I/O
thread on behalf of a RemoteInputChannel
.
public void clearAll()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.