alluxio.master

Class NoopMaster

java.lang.Object

alluxio.master.NoopMaster

All Implemented Interfaces:

JournalEntryIterable, JournalEntryStateMachine, Master, Server<Boolean>

public class NoopMaster
extends Object
implements Master

Master implementation that does nothing. This is useful for testing and for situations where we don't want to run a real master, e.g. when formatting the journal.

Constructor Summary

Constructors

Constructor and Description
NoopMaster() Creates a new NoopMaster.
NoopMaster(String name) Creates a new NoopMaster with the given name.

Method Summary

Modifier and Type	Method and Description
JournalContext	createJournalContext()
Set<Class<? extends Server>>	getDependencies()
Iterator<Journal.JournalEntry>	getJournalEntryIterator()
String	getName()
Map<String,org.apache.thrift.TProcessor>	getServices()
void	processJournalEntry(Journal.JournalEntry entry) Applies a journal entry to the state machine.
void	resetState() Resets the journaled internal state of the state machine.
void	start(Boolean options) Starts the Alluxio server.
void	stop() Stops the Alluxio server.

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopMaster

public NoopMaster()

Creates a new NoopMaster.

NoopMaster

public NoopMaster(String name)

Creates a new NoopMaster with the given name.

Parameters:

name - the master name

Method Detail

getDependencies

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

Specified by:

getDependencies in interface Server<Boolean>

Returns:

the server dependencies

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

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

start

public void start(Boolean options)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<Boolean>

Parameters:

options - the start options

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: Server

Stops the Alluxio server. Here, anything created or started in #start(T) should be cleaned up and shutdown.

Specified by:

stop in interface Server<Boolean>

Throws:

IOException

getJournalEntryIterator

public Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an Iterator that iterates all the journal entries

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

createJournalContext

public JournalContext createJournalContext()

Specified by:

createJournalContext in interface Master

Returns:

a journal context for writing journal entries to the master