alluxio.master.keyvalue

Class KeyValueMasterClientServiceHandler

java.lang.Object

alluxio.master.keyvalue.KeyValueMasterClientServiceHandler

All Implemented Interfaces:

AlluxioService.Iface, KeyValueMasterClientService.Iface

@ThreadSafe
public final class KeyValueMasterClientServiceHandler
extends Object
implements KeyValueMasterClientService.Iface

This class is a Thrift handler for key-value master RPCs invoked by an Alluxio client.

Method Summary

Modifier and Type	Method and Description
CompletePartitionTResponse	completePartition(String path, PartitionInfo info, CompletePartitionTOptions options) Marks a partition complete and adds it to the store.
CompleteStoreTResponse	completeStore(String path, CompleteStoreTOptions options) Marks a store complete with its filesystem path.
CreateStoreTResponse	createStore(String path, CreateStoreTOptions options) Creates a new key-value store on master.
DeleteStoreTResponse	deleteStore(String path, DeleteStoreTOptions options) Deletes a completed key-value store.
GetPartitionInfoTResponse	getPartitionInfo(String path, GetPartitionInfoTOptions options) Gets the partition information for the key-value store at the given filesystem path.
GetServiceVersionTResponse	getServiceVersion(GetServiceVersionTOptions options) Returns the version of the master service.
MergeStoreTResponse	mergeStore(String fromPath, String toPath, MergeStoreTOptions options) Merges one completed key-value store to another completed key-value store.
RenameStoreTResponse	renameStore(String oldPath, String newPath, RenameStoreTOptions options) Renames a completed key-value store.

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

completePartition

public CompletePartitionTResponse completePartition(String path,
                                                    PartitionInfo info,
                                                    CompletePartitionTOptions options)
                                             throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Marks a partition complete and adds it to the store.

Specified by:

completePartition in interface KeyValueMasterClientService.Iface

Parameters:

path - the path of the store

info - information about the partition to mark complete

options - the method options

Throws:

AlluxioTException

createStore

public CreateStoreTResponse createStore(String path,
                                        CreateStoreTOptions options)
                                 throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Creates a new key-value store on master.

Specified by:

createStore in interface KeyValueMasterClientService.Iface

Parameters:

path - the path of the store

options - the method options

Throws:

AlluxioTException

completeStore

public CompleteStoreTResponse completeStore(String path,
                                            CompleteStoreTOptions options)
                                     throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Marks a store complete with its filesystem path.

Specified by:

completeStore in interface KeyValueMasterClientService.Iface

Parameters:

path - the path of the store

options - the method options

Throws:

AlluxioTException

deleteStore

public DeleteStoreTResponse deleteStore(String path,
                                        DeleteStoreTOptions options)
                                 throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Deletes a completed key-value store.

Specified by:

deleteStore in interface KeyValueMasterClientService.Iface

Parameters:

path - the path of the store

options - the method options

Throws:

AlluxioTException

getPartitionInfo

public GetPartitionInfoTResponse getPartitionInfo(String path,
                                                  GetPartitionInfoTOptions options)
                                           throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Gets the partition information for the key-value store at the given filesystem path.

Specified by:

getPartitionInfo in interface KeyValueMasterClientService.Iface

Parameters:

path - the path of the store

options - the method options

Throws:

AlluxioTException

mergeStore

public MergeStoreTResponse mergeStore(String fromPath,
                                      String toPath,
                                      MergeStoreTOptions options)
                               throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Merges one completed key-value store to another completed key-value store.

Specified by:

mergeStore in interface KeyValueMasterClientService.Iface

Parameters:

fromPath - the path of the store to be merged

toPath - the path of the store to be merged to

options - the method options

Throws:

AlluxioTException

renameStore

public RenameStoreTResponse renameStore(String oldPath,
                                        String newPath,
                                        RenameStoreTOptions options)
                                 throws AlluxioTException

Description copied from interface: KeyValueMasterClientService.Iface

Renames a completed key-value store.

Specified by:

renameStore in interface KeyValueMasterClientService.Iface

Parameters:

oldPath - the old path of the store

newPath - the new path of the store

options - the method options

Throws:

AlluxioTException