Modifier and Type | Method and Description |
---|---|
ResultPartitionWriter[] |
Environment.getAllWriters() |
ResultPartitionWriter |
Environment.getWriter(int index) |
Modifier and Type | Method and Description |
---|---|
static RecordWriter |
RecordWriter.createRecordWriter(ResultPartitionWriter writer,
ChannelSelector channelSelector,
long timeout,
String taskName) |
static RecordWriter |
RecordWriter.createRecordWriter(ResultPartitionWriter writer,
ChannelSelector channelSelector,
String taskName) |
Constructor and Description |
---|
BroadcastRecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector,
long timeout,
String taskName) |
RecordWriter(ResultPartitionWriter writer) |
RecordWriter(ResultPartitionWriter writer,
ChannelSelector<T> channelSelector,
long timeout,
String taskName) |
Modifier and Type | Class and Description |
---|---|
class |
ResultPartition
A result partition for data produced by a single task.
|
Modifier and Type | Method and Description |
---|---|
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,
TaskStateManager taskStateManager,
GlobalAggregateManager aggregateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.