alluxio.worker.keyvalue

Class KeyValueWorkerClientServiceHandler

java.lang.Object

alluxio.worker.keyvalue.KeyValueWorkerClientServiceHandler

All Implemented Interfaces:

AlluxioService.Iface, KeyValueWorkerClientService.Iface

@ThreadSafe
public final class KeyValueWorkerClientServiceHandler
extends Object
implements KeyValueWorkerClientService.Iface

RPC service handler on worker side to read a local key-value block.

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.
GetServiceVersionTResponse	getServiceVersion(GetServiceVersionTOptions options) Returns the version of the master service.
GetSizeTResponse	getSize(long blockId, GetSizeTOptions options) Gets the number of key-value pairs in the partition.

Methods inherited from class java.lang.Object

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

Method Detail

getServiceVersion

public GetServiceVersionTResponse getServiceVersion(GetServiceVersionTOptions options)

Description copied from interface: AlluxioService.Iface

Returns the version of the master service. NOTE: The version should be updated every time a backwards incompatible API change occurs.

Specified by:

getServiceVersion in interface AlluxioService.Iface

Parameters:

options - the method options

get

public GetTResponse get(long blockId,
                        ByteBuffer key,
                        GetTOptions options)
                 throws AlluxioTException

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

getNextKeys

public GetNextKeysTResponse getNextKeys(long blockId,
                                        ByteBuffer key,
                                        int numKeys,
                                        GetNextKeysTOptions options)
                                 throws AlluxioTException

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

getSize

public GetSizeTResponse getSize(long blockId,
                                GetSizeTOptions options)
                         throws AlluxioTException

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