public class ConsumedPartitionGroup extends Object implements Iterable<IntermediateResultPartitionID>
IntermediateResultPartitionID
s.Modifier and Type | Method and Description |
---|---|
boolean |
areAllPartitionsFinished() |
static ConsumedPartitionGroup |
fromMultiplePartitions(List<IntermediateResultPartitionID> resultPartitions) |
static ConsumedPartitionGroup |
fromSinglePartition(IntermediateResultPartitionID resultPartition) |
IntermediateResultPartitionID |
getFirst() |
IntermediateDataSetID |
getIntermediateDataSetID()
Get the ID of IntermediateDataSet this ConsumedPartitionGroup belongs to.
|
int |
getNumberOfUnfinishedPartitions() |
boolean |
isEmpty() |
Iterator<IntermediateResultPartitionID> |
iterator() |
int |
partitionFinished() |
int |
partitionUnfinished() |
int |
size() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public static ConsumedPartitionGroup fromMultiplePartitions(List<IntermediateResultPartitionID> resultPartitions)
public static ConsumedPartitionGroup fromSinglePartition(IntermediateResultPartitionID resultPartition)
public Iterator<IntermediateResultPartitionID> iterator()
iterator
in interface Iterable<IntermediateResultPartitionID>
public int size()
public boolean isEmpty()
public IntermediateResultPartitionID getFirst()
public IntermediateDataSetID getIntermediateDataSetID()
public int partitionUnfinished()
public int partitionFinished()
@VisibleForTesting public int getNumberOfUnfinishedPartitions()
public boolean areAllPartitionsFinished()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.