Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ResultPartitionDeploymentDescriptor.getPartitionId() |
Constructor and Description |
---|
ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int maxParallelism,
boolean lazyScheduling) |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
IntermediateResultPartition.getPartitionId() |
Modifier and Type | Method and Description |
---|---|
Map<IntermediateResultPartitionID,IntermediateResultPartition> |
ExecutionVertex.getProducedPartitions() |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartition |
IntermediateResult.getPartitionById(IntermediateResultPartitionID resultPartitionId)
Returns the partition with the given ID.
|
Modifier and Type | Field and Description |
---|---|
com.google.common.collect.Table<ExecutionAttemptID,IntermediateResultPartitionID,ResultPartition> |
ResultPartitionManager.registeredPartitions |
Modifier and Type | Method and Description |
---|---|
IntermediateResultPartitionID |
ResultPartitionID.getPartitionId() |
Constructor and Description |
---|
ResultPartitionID(IntermediateResultPartitionID partitionId,
ExecutionAttemptID producerId) |
Modifier and Type | Method and Description |
---|---|
void |
SingleInputGate.retriggerPartitionRequest(IntermediateResultPartitionID partitionId)
Retriggers a partition request.
|
void |
SingleInputGate.setInputChannel(IntermediateResultPartitionID partitionId,
InputChannel inputChannel) |
Modifier and Type | Method and Description |
---|---|
static IntermediateResultPartitionID |
IntermediateResultPartitionID.fromByteBuf(io.netty.buffer.ByteBuf buf) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.