alluxio.client.file.policy

Interface FileWriteLocationPolicy

All Known Implementing Classes:

LocalFirstAvoidEvictionPolicy, LocalFirstPolicy, MostAvailableFirstPolicy, RoundRobinPolicy, SpecificHostPolicy

@PublicApi
public interface FileWriteLocationPolicy

Interface for the location policy of which workers a file's blocks are written into. A location policy instance is used only once per file write.

The FileOutStream calls getWorkerForNextBlock(java.lang.Iterable<alluxio.client.block.BlockWorkerInfo>, long) to decide which worker to write the next block per block write.

A policy must have an empty constructor to be used as default policy.

Method Summary

Modifier and Type	Method and Description
WorkerNetAddress	getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList, long blockSizeBytes) Gets the worker's host name for the next block to write to.

Method Detail

getWorkerForNextBlock

WorkerNetAddress getWorkerForNextBlock(Iterable<BlockWorkerInfo> workerInfoList,
                                       long blockSizeBytes)

Gets the worker's host name for the next block to write to.

Parameters:

workerInfoList - the info of the active workers

blockSizeBytes - the size of the block in bytes

Returns:

the address of the worker to write to, null if no worker can be selected