Modifier and Type | Method and Description |
---|---|
ResultPartitionWriter[] |
Environment.getAllWriters() |
ResultPartitionWriter |
Environment.getWriter(int index) |
Modifier and Type | Method and Description |
---|---|
void |
NettyShuffleEnvironment.registerLegacyNetworkMetrics(MetricGroup metricGroup,
ResultPartitionWriter[] producedPartitions,
InputGate[] inputGates)
Deprecated.
should be removed in future
|
Modifier and Type | Method and Description |
---|---|
RecordWriter<T> |
RecordWriterBuilder.build(ResultPartitionWriter writer) |
Modifier and Type | Method and Description |
---|---|
static void |
NettyShuffleMetricFactory.registerLegacyNetworkMetrics(boolean isDetailedMetrics,
MetricGroup metricGroup,
ResultPartitionWriter[] producedPartitions,
InputGate[] inputGates)
Deprecated.
should be removed in future
|
Modifier and Type | Class and Description |
---|---|
class |
ReleaseOnConsumptionResultPartition
ResultPartition that releases itself once all subpartitions have been consumed.
|
class |
ResultPartition
A result partition for data produced by a single task.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ShuffleEnvironment<P extends ResultPartitionWriter,G extends IndexedInputGate>
Interface for the implementation of shuffle service local environment.
|
interface |
ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate>
Interface for shuffle service factory implementations.
|
Modifier and Type | Class and Description |
---|---|
class |
ConsumableNotifyingResultPartitionWriterDecorator
A wrapper of result partition writer for handling the logic of consumable notification.
|
Modifier and Type | Method and Description |
---|---|
static ResultPartitionWriter[] |
ConsumableNotifyingResultPartitionWriterDecorator.decorate(Collection<ResultPartitionDeploymentDescriptor> descs,
ResultPartitionWriter[] partitionWriters,
TaskActions taskActions,
JobID jobId,
ResultPartitionConsumableNotifier notifier) |
ResultPartitionWriter[] |
RuntimeEnvironment.getAllWriters() |
ResultPartitionWriter |
RuntimeEnvironment.getWriter(int index) |
Modifier and Type | Method and Description |
---|---|
static ResultPartitionWriter[] |
ConsumableNotifyingResultPartitionWriterDecorator.decorate(Collection<ResultPartitionDeploymentDescriptor> descs,
ResultPartitionWriter[] partitionWriters,
TaskActions taskActions,
JobID jobId,
ResultPartitionConsumableNotifier notifier) |
static void |
Task.setupPartitionsAndGates(ResultPartitionWriter[] producedPartitions,
InputGate[] inputGates) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionWriter[] |
SavepointEnvironment.getAllWriters() |
ResultPartitionWriter |
SavepointEnvironment.getWriter(int index) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.