alluxio.master.block

Class BlockMasterWorkerServiceHandler

java.lang.Object

alluxio.master.block.BlockMasterWorkerServiceHandler

All Implemented Interfaces:

AlluxioService.Iface, BlockMasterWorkerService.Iface

@NotThreadSafe
public final class BlockMasterWorkerServiceHandler
extends Object
implements BlockMasterWorkerService.Iface

This class is a Thrift handler for block master RPCs invoked by an Alluxio worker.

Method Summary

Modifier and Type	Method and Description
BlockHeartbeatTResponse	blockHeartbeat(long workerId, Map<String,Long> usedBytesOnTiers, List<Long> removedBlockIds, Map<String,List<Long>> addedBlocksOnTiers, BlockHeartbeatTOptions options) Periodic block worker heartbeat returns an optional command for the block worker to execute.
CommitBlockTResponse	commitBlock(long workerId, long usedBytesOnTier, String tierAlias, long blockId, long length, CommitBlockTOptions options) Marks the given block as committed.
GetServiceVersionTResponse	getServiceVersion(GetServiceVersionTOptions options) Returns the version of the master service.
GetWorkerIdTResponse	getWorkerId(WorkerNetAddress workerNetAddress, GetWorkerIdTOptions options) Returns a worker id for the given network address.
RegisterWorkerTResponse	registerWorker(long workerId, List<String> storageTiers, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Map<String,List<Long>> currentBlocksOnTiers, RegisterWorkerTOptions options) Registers a worker.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getServiceVersion

public GetServiceVersionTResponse getServiceVersion(GetServiceVersionTOptions options)

Description copied from interface: AlluxioService.Iface

Returns the version of the master service. NOTE: The version should be updated every time a backwards incompatible API change occurs.

Specified by:

getServiceVersion in interface AlluxioService.Iface

Parameters:

options - the method options

blockHeartbeat

public BlockHeartbeatTResponse blockHeartbeat(long workerId,
                                              Map<String,Long> usedBytesOnTiers,
                                              List<Long> removedBlockIds,
                                              Map<String,List<Long>> addedBlocksOnTiers,
                                              BlockHeartbeatTOptions options)
                                       throws AlluxioTException

Description copied from interface: BlockMasterWorkerService.Iface

Periodic block worker heartbeat returns an optional command for the block worker to execute.

Specified by:

blockHeartbeat in interface BlockMasterWorkerService.Iface

Parameters:

workerId - the id of the worker

usedBytesOnTiers - the map of space used in bytes on all tiers

removedBlockIds - the list of removed block ids

addedBlocksOnTiers - the map of added blocks on all tiers

options - the method options

Throws:

AlluxioTException

commitBlock

public CommitBlockTResponse commitBlock(long workerId,
                                        long usedBytesOnTier,
                                        String tierAlias,
                                        long blockId,
                                        long length,
                                        CommitBlockTOptions options)
                                 throws AlluxioTException

Description copied from interface: BlockMasterWorkerService.Iface

Marks the given block as committed.

Specified by:

commitBlock in interface BlockMasterWorkerService.Iface

Parameters:

workerId - the id of the worker

usedBytesOnTier - the space used in bytes on the target tier

tierAlias - the alias of the target tier

blockId - the id of the block being committed

length - the length of the block being committed

options - the method options

Throws:

AlluxioTException

getWorkerId

public GetWorkerIdTResponse getWorkerId(WorkerNetAddress workerNetAddress,
                                        GetWorkerIdTOptions options)
                                 throws AlluxioTException

Description copied from interface: BlockMasterWorkerService.Iface

Returns a worker id for the given network address.

Specified by:

getWorkerId in interface BlockMasterWorkerService.Iface

Parameters:

workerNetAddress - the worker network address

options - the method options

Throws:

AlluxioTException

registerWorker

public RegisterWorkerTResponse registerWorker(long workerId,
                                              List<String> storageTiers,
                                              Map<String,Long> totalBytesOnTiers,
                                              Map<String,Long> usedBytesOnTiers,
                                              Map<String,List<Long>> currentBlocksOnTiers,
                                              RegisterWorkerTOptions options)
                                       throws AlluxioTException

Description copied from interface: BlockMasterWorkerService.Iface

Registers a worker.

Specified by:

registerWorker in interface BlockMasterWorkerService.Iface

Parameters:

workerId - the id of the worker

storageTiers - the list of storage tiers

totalBytesOnTiers - the map of total bytes on each tier

usedBytesOnTiers - the map of used bytes on each tier

currentBlocksOnTiers - the map of list of blocks on each tier

options - the method options

Throws:

AlluxioTException