Package | Description |
---|---|
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.io.network.partition.consumer | |
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 |
---|---|
SingleInputGate |
SingleInputGateFactory.create(ShuffleIOOwnerContext owner,
int gateIndex,
InputGateDeploymentDescriptor igdd,
PartitionProducerStateProvider partitionProducerStateProvider)
Creates an input gate and all of its input channels.
|
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–2022 The Apache Software Foundation. All rights reserved.