alluxio.thrift

Class KeyValueWorkerClientService.Client

java.lang.Object

org.apache.thrift.TServiceClient

alluxio.thrift.AlluxioService.Client

alluxio.thrift.KeyValueWorkerClientService.Client

All Implemented Interfaces:

AlluxioService.Iface, KeyValueWorkerClientService.Iface

Enclosing class:

KeyValueWorkerClientService

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KeyValueWorkerClientService.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
GetTResponse	get(long blockId, ByteBuffer key, GetTOptions options) Looks up a key in the block with the given block id.
GetNextKeysTResponse	getNextKeys(long blockId, ByteBuffer key, int numKeys, GetNextKeysTOptions options) Gets a batch of keys next to the given key in the partition.
GetSizeTResponse	getSize(long blockId, GetSizeTOptions options) Gets the number of key-value pairs in the partition.
GetTResponse	recv_get()
GetNextKeysTResponse	recv_getNextKeys()
GetSizeTResponse	recv_getSize()
void	send_get(long blockId, ByteBuffer key, GetTOptions options)
void	send_getNextKeys(long blockId, ByteBuffer key, int numKeys, GetNextKeysTOptions options)
void	send_getSize(long blockId, GetSizeTOptions 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

get

public GetTResponse get(long blockId,
                        ByteBuffer key,
                        GetTOptions options)
                 throws AlluxioTException,
                        org.apache.thrift.TException

Description copied from interface: KeyValueWorkerClientService.Iface

Looks up a key in the block with the given block id.

Specified by:

get in interface KeyValueWorkerClientService.Iface

Parameters:

blockId - the id of the block being accessed

key - binary of the key

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_get

public void send_get(long blockId,
                     ByteBuffer key,
                     GetTOptions options)
              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_get

public GetTResponse recv_get()
                      throws AlluxioTException,
                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getNextKeys

public GetNextKeysTResponse getNextKeys(long blockId,
                                        ByteBuffer key,
                                        int numKeys,
                                        GetNextKeysTOptions options)
                                 throws AlluxioTException,
                                        org.apache.thrift.TException

Description copied from interface: KeyValueWorkerClientService.Iface

Gets a batch of keys next to the given key in the partition. If current key is null, it means get the initial batch of keys. If there are no more next keys, an empty list is returned.

Specified by:

getNextKeys in interface KeyValueWorkerClientService.Iface

Parameters:

blockId - the id of the partition

key - current key

numKeys - maximum number of keys to get

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_getNextKeys

public void send_getNextKeys(long blockId,
                             ByteBuffer key,
                             int numKeys,
                             GetNextKeysTOptions options)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getNextKeys

public GetNextKeysTResponse recv_getNextKeys()
                                      throws AlluxioTException,
                                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getSize

public GetSizeTResponse getSize(long blockId,
                                GetSizeTOptions options)
                         throws AlluxioTException,
                                org.apache.thrift.TException

Description copied from interface: KeyValueWorkerClientService.Iface

Gets the number of key-value pairs in the partition.

Specified by:

getSize in interface KeyValueWorkerClientService.Iface

Parameters:

blockId - the id of the partition

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_getSize

public void send_getSize(long blockId,
                         GetSizeTOptions options)
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getSize

public GetSizeTResponse recv_getSize()
                              throws AlluxioTException,
                                     org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException