alluxio.thrift

Class BlockMasterWorkerService.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

alluxio.thrift.AlluxioService.AsyncClient

alluxio.thrift.BlockMasterWorkerService.AsyncClient

All Implemented Interfaces:

AlluxioService.AsyncIface, BlockMasterWorkerService.AsyncIface

Enclosing class:

BlockMasterWorkerService

public static class BlockMasterWorkerService.AsyncClient
extends AlluxioService.AsyncClient
implements BlockMasterWorkerService.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockMasterWorkerService.AsyncClient.blockHeartbeat_call
static class	BlockMasterWorkerService.AsyncClient.commitBlock_call
static class	BlockMasterWorkerService.AsyncClient.Factory
static class	BlockMasterWorkerService.AsyncClient.getWorkerId_call
static class	BlockMasterWorkerService.AsyncClient.registerWorker_call

Nested classes/interfaces inherited from class alluxio.thrift.AlluxioService.AsyncClient

AlluxioService.AsyncClient.getServiceVersion_call

Field Summary

Fields inherited from class org.apache.thrift.async.TAsyncClient

___currentMethod, ___manager, ___protocolFactory, ___transport

Constructor Summary

Constructors

Constructor and Description
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

Method Summary

Modifier and Type	Method and Description
void	blockHeartbeat(long workerId, Map<String,Long> usedBytesOnTiers, List<Long> removedBlockIds, Map<String,List<Long>> addedBlocksOnTiers, BlockHeartbeatTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	commitBlock(long workerId, long usedBytesOnTier, String tierAlias, long blockId, long length, CommitBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getWorkerId(WorkerNetAddress workerNetAddress, GetWorkerIdTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	registerWorker(long workerId, List<String> storageTiers, Map<String,Long> totalBytesOnTiers, Map<String,Long> usedBytesOnTiers, Map<String,List<Long>> currentBlocksOnTiers, RegisterWorkerTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)

Methods inherited from class alluxio.thrift.AlluxioService.AsyncClient

getServiceVersion

Methods inherited from class org.apache.thrift.async.TAsyncClient

checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout

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.AsyncIface

getServiceVersion

Constructor Detail

AsyncClient

public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
                   org.apache.thrift.async.TAsyncClientManager clientManager,
                   org.apache.thrift.transport.TNonblockingTransport transport)

Method Detail

blockHeartbeat

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

Specified by:

blockHeartbeat in interface BlockMasterWorkerService.AsyncIface

Throws:

org.apache.thrift.TException

commitBlock

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

Specified by:

commitBlock in interface BlockMasterWorkerService.AsyncIface

Throws:

org.apache.thrift.TException

getWorkerId

public void getWorkerId(WorkerNetAddress workerNetAddress,
                        GetWorkerIdTOptions options,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

getWorkerId in interface BlockMasterWorkerService.AsyncIface

Throws:

org.apache.thrift.TException

registerWorker

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

Specified by:

registerWorker in interface BlockMasterWorkerService.AsyncIface

Throws:

org.apache.thrift.TException