public class ConsumedPartitionGroup extends Object implements Iterable<IntermediateResultPartitionID>
IntermediateResultPartitionID
s.clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public static ConsumedPartitionGroup fromMultiplePartitions(int numConsumers, List<IntermediateResultPartitionID> resultPartitions, ResultPartitionType resultPartitionType)
public static ConsumedPartitionGroup fromSinglePartition(int numConsumers, IntermediateResultPartitionID resultPartition, ResultPartitionType resultPartitionType)
public Iterator<IntermediateResultPartitionID> iterator()
iterator
in interface Iterable<IntermediateResultPartitionID>
public int size()
public boolean isEmpty()
public int getNumConsumers()
public IntermediateResultPartitionID getFirst()
public IntermediateDataSetID getIntermediateDataSetID()
public int partitionUnfinished()
public int partitionFinished()
@VisibleForTesting public int getNumberOfUnfinishedPartitions()
public boolean areAllPartitionsFinished()
public ResultPartitionType getResultPartitionType()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.