Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.metrics | |
org.apache.flink.runtime.io.network.partition.consumer |
Modifier and Type | Method and Description |
---|---|
List<SingleInputGate> |
NettyShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext,
PartitionProducerStateProvider partitionProducerStateProvider,
List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
Modifier and Type | Field and Description |
---|---|
protected SingleInputGate[] |
AbstractBuffersUsageGauge.inputGates |
Modifier and Type | Method and Description |
---|---|
int |
FloatingBuffersUsageGauge.calculateTotalBuffers(SingleInputGate inputGate) |
int |
ExclusiveBuffersUsageGauge.calculateTotalBuffers(SingleInputGate inputGate) |
int |
CreditBasedInputBuffersUsageGauge.calculateTotalBuffers(SingleInputGate inputGate) |
abstract int |
AbstractBuffersUsageGauge.calculateTotalBuffers(SingleInputGate inputGate) |
int |
FloatingBuffersUsageGauge.calculateUsedBuffers(SingleInputGate inputGate) |
int |
ExclusiveBuffersUsageGauge.calculateUsedBuffers(SingleInputGate inputGate) |
int |
CreditBasedInputBuffersUsageGauge.calculateUsedBuffers(SingleInputGate inputGate) |
abstract int |
AbstractBuffersUsageGauge.calculateUsedBuffers(SingleInputGate inputGate) |
static void |
NettyShuffleMetricFactory.registerInputMetrics(boolean isDetailedMetrics,
MetricGroup inputGroup,
SingleInputGate[] inputGates) |
static void |
InputGateMetrics.registerQueueLengthMetrics(MetricGroup parent,
SingleInputGate[] gates) |
Constructor and Description |
---|
CreditBasedInputBuffersUsageGauge(FloatingBuffersUsageGauge floatingBuffersUsageGauge,
ExclusiveBuffersUsageGauge exclusiveBuffersUsageGauge,
SingleInputGate[] inputGates) |
ExclusiveBuffersUsageGauge(SingleInputGate[] inputGates) |
FloatingBuffersUsageGauge(SingleInputGate[] inputGates) |
InputBuffersGauge(SingleInputGate[] inputGates) |
Modifier and Type | Field and Description |
---|---|
protected SingleInputGate |
InputChannel.inputGate |
Modifier and Type | Method and Description |
---|---|
SingleInputGate |
SingleInputGateFactory.create(String owningTaskName,
int gateIndex,
InputGateDeploymentDescriptor igdd,
PartitionProducerStateProvider partitionProducerStateProvider,
InputChannelMetrics metrics)
Creates an input gate and all of its input channels.
|
Modifier and Type | Method and Description |
---|---|
protected InputChannel |
SingleInputGateFactory.createKnownInputChannel(SingleInputGate inputGate,
int index,
NettyShuffleDescriptor inputChannelDescriptor,
SingleInputGateFactory.ChannelStatistics channelStatistics,
InputChannelMetrics metrics) |
Constructor and Description |
---|
InputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
int initialBackoff,
int maxBackoff,
Counter numBytesIn,
Counter numBuffersIn) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
Counter numBytesIn,
Counter numBuffersIn) |
LocalInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
int initialBackoff,
int maxBackoff,
Counter numBytesIn,
Counter numBuffersIn) |
RemoteInputChannel(SingleInputGate inputGate,
int channelIndex,
ResultPartitionID partitionId,
ConnectionID connectionId,
ConnectionManager connectionManager,
int initialBackOff,
int maxBackoff,
Counter numBytesIn,
Counter numBuffersIn) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.