public interface ReplicationHandler
Modifier and Type | Method and Description |
---|---|
long |
evict(AlluxioURI uri,
long blockId,
int numReplicas)
Decreases the block replication level by a target number of replicas.
|
long |
migrate(AlluxioURI uri,
long blockId,
String workerHost,
String mediumType)
Migrate blocks to the correctly pinned locations.
|
long |
replicate(AlluxioURI uri,
long blockId,
int numReplicas)
Increases the block replication level by a target number of replicas.
|
long evict(AlluxioURI uri, long blockId, int numReplicas) throws AlluxioException, IOException
uri
- URI of the file the block belongs toblockId
- ID of the blocknumReplicas
- how many replicas to removeAlluxioException
- if an Alluxio error is encounteredIOException
- if a non-Alluxio error is encounteredlong replicate(AlluxioURI uri, long blockId, int numReplicas) throws AlluxioException, IOException
uri
- URI of the file the block belongs toblockId
- ID of the blocknumReplicas
- how many replicas to addAlluxioException
- if an Alluxio error is encounteredIOException
- if a non-Alluxio error is encounteredlong migrate(AlluxioURI uri, long blockId, String workerHost, String mediumType) throws AlluxioException, IOException
uri
- URI of the file the block belongs toblockId
- ID of the blockworkerHost
- worker host this block is located atmediumType
- medium type to migrate this block toAlluxioException
- if an Alluxio error is encounteredIOException
- if a non-Alluxio error is encounteredCopyright © 2023. All Rights Reserved.