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 |
---|---|
NetworkBufferPool |
NettyShuffleEnvironment.getNetworkBufferPool() |
Modifier and Type | Method and Description |
---|---|
static void |
NettyShuffleMetricFactory.registerShuffleMetrics(MetricGroup metricGroup,
NetworkBufferPool networkBufferPool) |
Modifier and Type | Field and Description |
---|---|
protected NetworkBufferPool |
SingleInputGateFactory.networkBufferPool |
Constructor and Description |
---|
SingleInputGateFactory(ResourceID taskExecutorResourceId,
NettyShuffleEnvironmentConfiguration networkConfig,
ConnectionManager connectionManager,
ResultPartitionManager partitionManager,
TaskEventPublisher taskEventPublisher,
NetworkBufferPool networkBufferPool) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.