org.apache.flink.runtime.io.network.partition

Interface ClusterPartitionManager

All Known Subinterfaces:

ResourceManagerGateway

All Known Implementing Classes:

ActiveResourceManager, ResourceManager, StandaloneResourceManager

public interface ClusterPartitionManager

Interface for components that manage cluster partitions.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Map<IntermediateDataSetID,DataSetMetaInfo>>	listDataSets() Returns all datasets for which partitions are being tracked.
CompletableFuture<Void>	releaseClusterPartitions(IntermediateDataSetID dataSetToRelease) Releases all partitions associated with the given dataset.

Method Detail

listDataSets

CompletableFuture<Map<IntermediateDataSetID,DataSetMetaInfo>> listDataSets()

Returns all datasets for which partitions are being tracked.

Returns:

tracked datasets

releaseClusterPartitions

CompletableFuture<Void> releaseClusterPartitions(IntermediateDataSetID dataSetToRelease)

Releases all partitions associated with the given dataset.

Parameters:

dataSetToRelease - dataset for which all associated partitions should be released

Returns:

future that is completed once all partitions have been released