Modifier and Type | Method and Description |
---|---|
ResultPartitionWriter[] |
Environment.getAllWriters() |
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.targetPartition |
Constructor and Description |
---|
RecordWriter(ResultPartitionWriter writer) |
RecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionWriter[] |
Task.getAllWriters() |
ResultPartitionWriter[] |
RuntimeEnvironment.getAllWriters() |
ResultPartitionWriter |
RuntimeEnvironment.getWriter(int index) |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
CheckpointResponder checkpointResponder,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask) |
Constructor and Description |
---|
StreamRecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector,
long timeout) |
StreamRecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector,
long timeout,
String taskName) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.