alluxio.thrift

Interface BlockMasterWorkerService.Iface

All Superinterfaces:

AlluxioService.Iface

All Known Implementing Classes:

BlockMasterWorkerService.Client, BlockMasterWorkerServiceHandler

Enclosing class:

BlockMasterWorkerService

public static interface BlockMasterWorkerService.Iface
extends AlluxioService.Iface

This interface contains block master service endpoints for Alluxio workers.

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.
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 interface alluxio.thrift.AlluxioService.Iface

getServiceVersion

Method Detail

blockHeartbeat

BlockHeartbeatTResponse blockHeartbeat(long workerId,
                                       Map<String,Long> usedBytesOnTiers,
                                       List<Long> removedBlockIds,
                                       Map<String,List<Long>> addedBlocksOnTiers,
                                       BlockHeartbeatTOptions options)
                                throws AlluxioTException,
                                       org.apache.thrift.TException

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

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

org.apache.thrift.TException

commitBlock

CommitBlockTResponse commitBlock(long workerId,
                                 long usedBytesOnTier,
                                 String tierAlias,
                                 long blockId,
                                 long length,
                                 CommitBlockTOptions options)
                          throws AlluxioTException,
                                 org.apache.thrift.TException

Marks the given block as committed.

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

org.apache.thrift.TException

getWorkerId

GetWorkerIdTResponse getWorkerId(WorkerNetAddress workerNetAddress,
                                 GetWorkerIdTOptions options)
                          throws AlluxioTException,
                                 org.apache.thrift.TException

Returns a worker id for the given network address.

Parameters:

workerNetAddress - the worker network address

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

registerWorker

RegisterWorkerTResponse registerWorker(long workerId,
                                       List<String> storageTiers,
                                       Map<String,Long> totalBytesOnTiers,
                                       Map<String,Long> usedBytesOnTiers,
                                       Map<String,List<Long>> currentBlocksOnTiers,
                                       RegisterWorkerTOptions options)
                                throws AlluxioTException,
                                       org.apache.thrift.TException

Registers a worker.

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

org.apache.thrift.TException