alluxio.job.plan.replicate

Interface ReplicationHandler

All Known Implementing Classes:

DefaultReplicationHandler

public interface ReplicationHandler

Interface for adjusting the replication level of blocks.

Method Summary

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.
List<Long>	findJobs(String jobName, Set<Status> statusList)
Status	getJobStatus(long jobId)
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.

Method Detail

getJobStatus

Status getJobStatus(long jobId)
             throws IOException

Parameters:

jobId - the job id returned by evict, replicate, or migrate

Returns:

the job status (running, completed, failed, etc.)

Throws:

IOException - if a non-Alluxio error is encountered

findJobs

List<Long> findJobs(String jobName,
                    Set<Status> statusList)
             throws IOException

Parameters:

jobName - name of the job

statusList - job status

Returns:

a list of job ids that match the criteria

Throws:

IOException - if a non-Alluxio error is encountered

evict

long evict(AlluxioURI uri,
           long blockId,
           int numReplicas)
    throws AlluxioException,
           IOException

Decreases the block replication level by a target number of replicas.

Parameters:

uri - URI of the file the block belongs to

blockId - ID of the block

numReplicas - how many replicas to remove

Returns:

the ID of the replicate job

Throws:

AlluxioException - if an Alluxio error is encountered

IOException - if a non-Alluxio error is encountered

replicate

long replicate(AlluxioURI uri,
               long blockId,
               int numReplicas)
        throws AlluxioException,
               IOException

Increases the block replication level by a target number of replicas.

Parameters:

uri - URI of the file the block belongs to

blockId - ID of the block

numReplicas - how many replicas to add

Returns:

the ID of the replicate job

Throws:

AlluxioException - if an Alluxio error is encountered

IOException - if a non-Alluxio error is encountered

migrate

long migrate(AlluxioURI uri,
             long blockId,
             String workerHost,
             String mediumType)
      throws AlluxioException,
             IOException

Migrate blocks to the correctly pinned locations.

Parameters:

uri - URI of the file the block belongs to

blockId - ID of the block

workerHost - worker host this block is located at

mediumType - medium type to migrate this block to

Returns:

the ID of the replicate job

Throws:

AlluxioException - if an Alluxio error is encountered

IOException - if a non-Alluxio error is encountered