alluxio.thrift

Interface BlockMasterWorkerService.AsyncIface

All Superinterfaces:

AlluxioService.AsyncIface

All Known Implementing Classes:

BlockMasterWorkerService.AsyncClient

Enclosing class:

BlockMasterWorkerService

public static interface BlockMasterWorkerService.AsyncIface
extends AlluxioService.AsyncIface

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

getServiceVersion

Method Detail

blockHeartbeat

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

Throws:

org.apache.thrift.TException

commitBlock

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

Throws:

org.apache.thrift.TException

getWorkerId

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

Throws:

org.apache.thrift.TException

registerWorker

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

Throws:

org.apache.thrift.TException