Class TieredStorageResourceRegistry
- java.lang.Object
-
- org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage.TieredStorageResourceRegistry
-
public class TieredStorageResourceRegistry extends Object
A registry that maintains local or remote resources that correspond to a certain set of data in the Tiered Storage.
-
-
Constructor Summary
Constructors Constructor Description TieredStorageResourceRegistry()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearResourceFor(TieredStorageDataIdentifier owner)
Remove all resources for the given owner.void
registerResource(TieredStorageDataIdentifier owner, TieredStorageResource tieredStorageResource)
Register a new resource for the given owner.
-
-
-
Method Detail
-
registerResource
public void registerResource(TieredStorageDataIdentifier owner, TieredStorageResource tieredStorageResource)
Register a new resource for the given owner.- Parameters:
owner
- identifier of the data that the resource corresponds to.tieredStorageResource
- the tiered storage resources to be registered.
-
clearResourceFor
public void clearResourceFor(TieredStorageDataIdentifier owner)
Remove all resources for the given owner.- Parameters:
owner
- identifier of the data that the resources correspond to.
-
-