Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.shuffle |
Modifier and Type | Method and Description |
---|---|
ShuffleIOOwnerContext |
NettyShuffleEnvironment.createShuffleIOOwnerContext(String ownerName,
ExecutionAttemptID executionAttemptID,
MetricGroup parentGroup) |
Modifier and Type | Method and Description |
---|---|
List<SingleInputGate> |
NettyShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext,
PartitionProducerStateProvider partitionProducerStateProvider,
List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) |
List<ResultPartition> |
NettyShuffleEnvironment.createResultPartitionWriters(ShuffleIOOwnerContext ownerContext,
List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors) |
Modifier and Type | Method and Description |
---|---|
ShuffleIOOwnerContext |
ShuffleEnvironment.createShuffleIOOwnerContext(String ownerName,
ExecutionAttemptID executionAttemptID,
MetricGroup parentGroup)
Create a context of the shuffle input/output owner used to create partitions or gates
belonging to the owner.
|
Modifier and Type | Method and Description |
---|---|
List<G> |
ShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext,
PartitionProducerStateProvider partitionProducerStateProvider,
List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors)
Factory method for the
InputGates to consume result partitions. |
List<P> |
ShuffleEnvironment.createResultPartitionWriters(ShuffleIOOwnerContext ownerContext,
List<ResultPartitionDeploymentDescriptor> resultPartitionDeploymentDescriptors)
Factory method for the
ResultPartitionWriters to produce result
partitions. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.