public class ResultPartitionManager extends Object implements ResultPartitionProvider
Constructor and Description |
---|
ResultPartitionManager() |
Modifier and Type | Method and Description |
---|---|
ResultSubpartitionView |
createSubpartitionView(ResultPartitionID partitionId,
int subpartitionIndex,
BufferAvailabilityListener availabilityListener)
Returns the requested intermediate result partition input view.
|
Collection<ResultPartitionID> |
getUnreleasedPartitions() |
void |
registerResultPartition(ResultPartition partition) |
void |
releasePartition(ResultPartitionID partitionId,
Throwable cause) |
void |
shutdown() |
public void registerResultPartition(ResultPartition partition)
public ResultSubpartitionView createSubpartitionView(ResultPartitionID partitionId, int subpartitionIndex, BufferAvailabilityListener availabilityListener) throws IOException
ResultPartitionProvider
createSubpartitionView
in interface ResultPartitionProvider
IOException
public void releasePartition(ResultPartitionID partitionId, Throwable cause)
public void shutdown()
public Collection<ResultPartitionID> getUnreleasedPartitions()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.