alluxio.thrift

Class BlockWorkerClientService.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

alluxio.thrift.AlluxioService.AsyncClient

alluxio.thrift.BlockWorkerClientService.AsyncClient

All Implemented Interfaces:

AlluxioService.AsyncIface, BlockWorkerClientService.AsyncIface

Enclosing class:

BlockWorkerClientService

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockWorkerClientService.AsyncClient.accessBlock_call
static class	BlockWorkerClientService.AsyncClient.cacheBlock_call
static class	BlockWorkerClientService.AsyncClient.cancelBlock_call
static class	BlockWorkerClientService.AsyncClient.Factory
static class	BlockWorkerClientService.AsyncClient.lockBlock_call
static class	BlockWorkerClientService.AsyncClient.promoteBlock_call
static class	BlockWorkerClientService.AsyncClient.removeBlock_call
static class	BlockWorkerClientService.AsyncClient.requestBlockLocation_call
static class	BlockWorkerClientService.AsyncClient.requestSpace_call
static class	BlockWorkerClientService.AsyncClient.sessionBlockHeartbeat_call
static class	BlockWorkerClientService.AsyncClient.unlockBlock_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	accessBlock(long blockId, AccessBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	cacheBlock(long sessionId, long blockId, CacheBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	cancelBlock(long sessionId, long blockId, CancelBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	lockBlock(long blockId, long sessionId, LockBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	promoteBlock(long blockId, PromoteBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	removeBlock(long blockId, RemoveBlockTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	requestBlockLocation(long sessionId, long blockId, long initialBytes, int writeTier, RequestBlockLocationTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	requestSpace(long sessionId, long blockId, long requestBytes, RequestSpaceTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	sessionBlockHeartbeat(long sessionId, List<Long> metrics, SessionBlockHeartbeatTOptions options, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	unlockBlock(long blockId, long sessionId, UnlockBlockTOptions 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

accessBlock

public void accessBlock(long blockId,
                        AccessBlockTOptions options,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

accessBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

cacheBlock

public void cacheBlock(long sessionId,
                       long blockId,
                       CacheBlockTOptions options,
                       org.apache.thrift.async.AsyncMethodCallback resultHandler)
                throws org.apache.thrift.TException

Specified by:

cacheBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

cancelBlock

public void cancelBlock(long sessionId,
                        long blockId,
                        CancelBlockTOptions options,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

cancelBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

lockBlock

public void lockBlock(long blockId,
                      long sessionId,
                      LockBlockTOptions options,
                      org.apache.thrift.async.AsyncMethodCallback resultHandler)
               throws org.apache.thrift.TException

Specified by:

lockBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

promoteBlock

public void promoteBlock(long blockId,
                         PromoteBlockTOptions options,
                         org.apache.thrift.async.AsyncMethodCallback resultHandler)
                  throws org.apache.thrift.TException

Specified by:

promoteBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

removeBlock

public void removeBlock(long blockId,
                        RemoveBlockTOptions options,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

removeBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

requestBlockLocation

public void requestBlockLocation(long sessionId,
                                 long blockId,
                                 long initialBytes,
                                 int writeTier,
                                 RequestBlockLocationTOptions options,
                                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                          throws org.apache.thrift.TException

Specified by:

requestBlockLocation in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

requestSpace

public void requestSpace(long sessionId,
                         long blockId,
                         long requestBytes,
                         RequestSpaceTOptions options,
                         org.apache.thrift.async.AsyncMethodCallback resultHandler)
                  throws org.apache.thrift.TException

Specified by:

requestSpace in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

sessionBlockHeartbeat

public void sessionBlockHeartbeat(long sessionId,
                                  List<Long> metrics,
                                  SessionBlockHeartbeatTOptions options,
                                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
                           throws org.apache.thrift.TException

Specified by:

sessionBlockHeartbeat in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException

unlockBlock

public void unlockBlock(long blockId,
                        long sessionId,
                        UnlockBlockTOptions options,
                        org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Specified by:

unlockBlock in interface BlockWorkerClientService.AsyncIface

Throws:

org.apache.thrift.TException