alluxio.thrift

Class BlockMasterWorkerService.Client

java.lang.Object

org.apache.thrift.TServiceClient

alluxio.thrift.AlluxioService.Client

alluxio.thrift.BlockMasterWorkerService.Client

All Implemented Interfaces:

AlluxioService.Iface, BlockMasterWorkerService.Iface

Enclosing class:

BlockMasterWorkerService

public static class BlockMasterWorkerService.Client
extends AlluxioService.Client
implements BlockMasterWorkerService.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockMasterWorkerService.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
Client(org.apache.thrift.protocol.TProtocol prot)
Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

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.
BlockHeartbeatTResponse	recv_blockHeartbeat()
CommitBlockTResponse	recv_commitBlock()
GetWorkerIdTResponse	recv_getWorkerId()
RegisterWorkerTResponse	recv_registerWorker()
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.
void	send_blockHeartbeat(long workerId, Map<String,Long> usedBytesOnTiers, List<Long> removedBlockIds, Map<String,List<Long>> addedBlocksOnTiers, BlockHeartbeatTOptions options)
void	send_commitBlock(long workerId, long usedBytesOnTier, String tierAlias, long blockId, long length, CommitBlockTOptions options)
void	send_getWorkerId(WorkerNetAddress workerNetAddress, GetWorkerIdTOptions options)
void	send_registerWorker(long workerId, List<String> storageTiers, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Map<String,List<Long>> currentBlocksOnTiers, RegisterWorkerTOptions options)

Methods inherited from class alluxio.thrift.AlluxioService.Client

getServiceVersion, recv_getServiceVersion, send_getServiceVersion

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.thrift.AlluxioService.Iface

getServiceVersion

Constructor Detail

Client

public Client(org.apache.thrift.protocol.TProtocol prot)

Client

public Client(org.apache.thrift.protocol.TProtocol iprot,
              org.apache.thrift.protocol.TProtocol oprot)

Method Detail

blockHeartbeat

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

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

org.apache.thrift.TException

send_blockHeartbeat

public void send_blockHeartbeat(long workerId,
                                Map<String,Long> usedBytesOnTiers,
                                List<Long> removedBlockIds,
                                Map<String,List<Long>> addedBlocksOnTiers,
                                BlockHeartbeatTOptions options)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_blockHeartbeat

public BlockHeartbeatTResponse recv_blockHeartbeat()
                                            throws AlluxioTException,
                                                   org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

commitBlock

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

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

org.apache.thrift.TException

send_commitBlock

public void send_commitBlock(long workerId,
                             long usedBytesOnTier,
                             String tierAlias,
                             long blockId,
                             long length,
                             CommitBlockTOptions options)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_commitBlock

public CommitBlockTResponse recv_commitBlock()
                                      throws AlluxioTException,
                                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getWorkerId

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

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

org.apache.thrift.TException

send_getWorkerId

public void send_getWorkerId(WorkerNetAddress workerNetAddress,
                             GetWorkerIdTOptions options)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getWorkerId

public GetWorkerIdTResponse recv_getWorkerId()
                                      throws AlluxioTException,
                                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

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,
                                              org.apache.thrift.TException

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

org.apache.thrift.TException

send_registerWorker

public void send_registerWorker(long workerId,
                                List<String> storageTiers,
                                Map<String,Long> totalBytesOnTiers,
                                Map<String,Long> usedBytesOnTiers,
                                Map<String,List<Long>> currentBlocksOnTiers,
                                RegisterWorkerTOptions options)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_registerWorker

public RegisterWorkerTResponse recv_registerWorker()
                                            throws AlluxioTException,
                                                   org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException