| Modifier and Type | Method and Description |
|---|---|
ResultPartitionWriter[] |
RuntimeEnvironment.getAllWriters() |
ResultPartitionWriter[] |
Environment.getAllWriters() |
ResultPartitionWriter |
RuntimeEnvironment.getWriter(int index) |
ResultPartitionWriter |
Environment.getWriter(int index) |
| Modifier and Type | Method and Description |
|---|---|
void |
TaskEventDispatcher.registerWriterForIncomingTaskEvents(ResultPartitionID partitionId,
ResultPartitionWriter writer) |
void |
TaskEventDispatcher.unregisterWriter(ResultPartitionWriter writer) |
| Modifier and Type | Field and Description |
|---|---|
protected ResultPartitionWriter |
RecordWriter.writer |
| Constructor and Description |
|---|
RecordWriter(ResultPartitionWriter writer) |
RecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector) |
| Modifier and Type | Method and Description |
|---|---|
ResultPartitionWriter[] |
Task.getWriters() |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.