Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle

Class TieredInternalShuffleMaster

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle.TieredInternalShuffleMaster

public class TieredInternalShuffleMaster
extends Object

A wrapper internal shuffle master class for tiered storage. All the tiered storage operations with the shuffle master should be wrapped in this class.

Constructor Summary

Constructors

Constructor	Description
TieredInternalShuffleMaster(org.apache.flink.configuration.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	addPartition(ResultPartitionID resultPartitionID)
void	releasePartition(ResultPartitionID resultPartitionID)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TieredInternalShuffleMaster

public TieredInternalShuffleMaster(org.apache.flink.configuration.Configuration conf)

Method Detail

addPartition

public void addPartition(ResultPartitionID resultPartitionID)

releasePartition

public void releasePartition(ResultPartitionID resultPartitionID)