Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.metrics | |
org.apache.flink.runtime.io.network.partition |
Modifier and Type | Method and Description |
---|---|
List<ResultPartition> |
NettyShuffleEnvironment.createResultPartitionWriters(ShuffleIOOwnerContext ownerContext,
List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors) |
Modifier and Type | Method and Description |
---|---|
static void |
NettyShuffleMetricFactory.registerOutputMetrics(boolean isDetailedMetrics,
MetricGroup outputGroup,
ResultPartition[] resultPartitions) |
static void |
ResultPartitionMetrics.registerQueueLengthMetrics(MetricGroup parent,
ResultPartition[] partitions) |
Constructor and Description |
---|
OutputBufferPoolUsageGauge(ResultPartition[] resultPartitions) |
OutputBuffersGauge(ResultPartition[] resultPartitions) |
Modifier and Type | Class and Description |
---|---|
class |
ReleaseOnConsumptionResultPartition
ResultPartition that releases itself once all subpartitions have been consumed.
|
Modifier and Type | Field and Description |
---|---|
protected ResultPartition |
ResultSubpartition.parent
The parent partition this subpartition belongs to.
|
Modifier and Type | Method and Description |
---|---|
ResultPartition |
ResultPartitionFactory.create(String taskNameWithSubtaskAndId,
int partitionIndex,
ResultPartitionDeploymentDescriptor desc) |
ResultPartition |
ResultPartitionFactory.create(String taskNameWithSubtaskAndId,
int partitionIndex,
ResultPartitionID id,
ResultPartitionType type,
int numberOfSubpartitions,
int maxParallelism,
FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory) |
Modifier and Type | Method and Description |
---|---|
abstract org.apache.flink.runtime.io.network.partition.BoundedBlockingSubpartition |
BoundedBlockingSubpartitionType.create(int index,
ResultPartition parent,
File tempFile,
int readBufferSize)
Creates BoundedBlockingSubpartition of this type.
|
void |
ResultPartitionManager.registerResultPartition(ResultPartition partition) |
Constructor and Description |
---|
ResultSubpartition(int index,
ResultPartition parent) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.