alluxio.master.keyvalue

Class DefaultKeyValueMaster

java.lang.Object

alluxio.master.AbstractMaster

alluxio.master.keyvalue.DefaultKeyValueMaster

All Implemented Interfaces:

JournalEntryIterable, JournalEntryStateMachine, KeyValueMaster, Master, Server<Boolean>

@ThreadSafe
public class DefaultKeyValueMaster
extends AbstractMaster
implements KeyValueMaster

This master stores key-value store information in Alluxio, including the partitions of each key-value store.

Field Summary

Fields inherited from class alluxio.master.AbstractMaster

mBackupManager, mClock, mPauseStateLock, mSafeModeManager, mStateChangeLock

Method Summary

Modifier and Type	Method and Description
void	completePartition(AlluxioURI path, PartitionInfo info) Marks a partition complete and adds it to an incomplete key-value store.
void	completeStore(AlluxioURI path) Marks a key-value store complete.
void	createStore(AlluxioURI path) Creates a new key-value store.
void	deleteStore(AlluxioURI uri) Deletes a completed key-value store.
Set<Class<? extends Server>>	getDependencies()
Iterator<Journal.JournalEntry>	getJournalEntryIterator()
String	getName()
List<PartitionInfo>	getPartitionInfo(AlluxioURI path) Gets a list of partitions of a given key-value store.
Map<String,org.apache.thrift.TProcessor>	getServices()
void	mergeStore(AlluxioURI fromUri, AlluxioURI toUri) Merges one completed key-value store to another completed key-value store.
void	processJournalEntry(Journal.JournalEntry entry) Applies a journal entry to the state machine.
void	renameStore(AlluxioURI oldUri, AlluxioURI newUri) Renames one completed key-value store.
void	resetState() Resets the journaled internal state of the state machine.
void	start(Boolean isLeader) Starts the Alluxio server.

Methods inherited from class alluxio.master.AbstractMaster

createJournalContext, getExecutorService, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.Master

createJournalContext

Methods inherited from interface alluxio.Server

stop

Method Detail

getServices

public Map<String,org.apache.thrift.TProcessor> getServices()

Specified by:

getServices in interface Server<Boolean>

Returns:

a map from service names to TProcessors that serve RPCs for this server

getName

public String getName()

Specified by:

getName in interface JournalEntryStateMachine

Specified by:

getName in interface Server<Boolean>

Returns:

the name of this journal entry state machine

getDependencies

public Set<Class<? extends Server>> getDependencies()

Specified by:

getDependencies in interface Server<Boolean>

Overrides:

getDependencies in class AbstractMaster

Returns:

the server dependencies

processJournalEntry

public void processJournalEntry(Journal.JournalEntry entry)
                         throws IOException

Description copied from interface: JournalEntryStateMachine

Applies a journal entry to the state machine.

Specified by:

processJournalEntry in interface JournalEntryStateMachine

Parameters:

entry - the entry to process to update the state of the state machine

Throws:

IOException

resetState

public void resetState()

Description copied from interface: JournalEntryStateMachine

Resets the journaled internal state of the state machine.

Specified by:

resetState in interface JournalEntryStateMachine

getJournalEntryIterator

public Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an Iterator that iterates all the journal entries

start

public void start(Boolean isLeader)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<Boolean>

Overrides:

start in class AbstractMaster

Parameters:

isLeader - the start options

Throws:

IOException

completePartition

public void completePartition(AlluxioURI path,
                              PartitionInfo info)
                       throws AccessControlException,
                              FileDoesNotExistException,
                              InvalidPathException,
                              UnavailableException

Description copied from interface: KeyValueMaster

Marks a partition complete and adds it to an incomplete key-value store.

Specified by:

completePartition in interface KeyValueMaster

Parameters:

path - URI of the key-value store

info - information of this completed partition

Throws:

AccessControlException - if permission checking fails

FileDoesNotExistException - if the key-value store URI does not exists

InvalidPathException - if the path is invalid

UnavailableException

completeStore

public void completeStore(AlluxioURI path)
                   throws FileDoesNotExistException,
                          InvalidPathException,
                          AccessControlException,
                          UnavailableException

Description copied from interface: KeyValueMaster

Marks a key-value store complete.

Specified by:

completeStore in interface KeyValueMaster

Parameters:

path - URI of the key-value store

Throws:

FileDoesNotExistException - if the key-value store URI does not exists

InvalidPathException - if the path is not valid

AccessControlException - if permission checking fails

UnavailableException

createStore

public void createStore(AlluxioURI path)
                 throws FileAlreadyExistsException,
                        InvalidPathException,
                        AccessControlException,
                        UnavailableException

Description copied from interface: KeyValueMaster

Creates a new key-value store.

Specified by:

createStore in interface KeyValueMaster

Parameters:

path - URI of the key-value store

Throws:

FileAlreadyExistsException - if a key-value store URI exists

InvalidPathException - if the given path is invalid

AccessControlException - if permission checking fails

UnavailableException

deleteStore

public void deleteStore(AlluxioURI uri)
                 throws IOException,
                        InvalidPathException,
                        FileDoesNotExistException,
                        AlluxioException

Description copied from interface: KeyValueMaster

Deletes a completed key-value store.

Specified by:

deleteStore in interface KeyValueMaster

Parameters:

uri - AlluxioURI to the store

Throws:

InvalidPathException - if the uri exists but is not a key-value store

FileDoesNotExistException - if the uri does not exist

IOException

AlluxioException

renameStore

public void renameStore(AlluxioURI oldUri,
                        AlluxioURI newUri)
                 throws IOException,
                        AlluxioException

Description copied from interface: KeyValueMaster

Renames one completed key-value store.

Specified by:

renameStore in interface KeyValueMaster

Parameters:

oldUri - the old AlluxioURI to the store

newUri - the AlluxioURI to the store

Throws:

IOException

AlluxioException

mergeStore

public void mergeStore(AlluxioURI fromUri,
                       AlluxioURI toUri)
                throws IOException,
                       FileDoesNotExistException,
                       InvalidPathException,
                       AlluxioException

Description copied from interface: KeyValueMaster

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

Specified by:

mergeStore in interface KeyValueMaster

Parameters:

fromUri - the AlluxioURI to the store to be merged

toUri - the AlluxioURI to the store to be merged to

Throws:

FileDoesNotExistException - if the uri does not exist

InvalidPathException - if the uri exists but is not a key-value store

IOException

AlluxioException

getPartitionInfo

public List<PartitionInfo> getPartitionInfo(AlluxioURI path)
                                     throws FileDoesNotExistException,
                                            AccessControlException,
                                            InvalidPathException,
                                            UnavailableException

Description copied from interface: KeyValueMaster

Gets a list of partitions of a given key-value store.

Specified by:

getPartitionInfo in interface KeyValueMaster

Parameters:

path - URI of the key-value store

Returns:

a list of partition information

Throws:

FileDoesNotExistException - if the key-value store URI does not exists

AccessControlException - if permission checking fails

InvalidPathException - if the path is invalid

UnavailableException