public final class LocalTachyonMaster extends Object
LocalTachyonCluster
and
LocalTachyonClusterMultiMaster
.
Isolated is defined as having its own root directory, and port.Modifier and Type | Method and Description |
---|---|
void |
cleanupUnderfs() |
void |
clearClients() |
static LocalTachyonMaster |
create(String tachyonHome,
TachyonConf tachyonConf)
Creates a new local tachyon master with a isolated port.
|
static LocalTachyonMaster |
create(TachyonConf tachyonConf)
Creates a new local tachyon master with a isolated home and port.
|
TachyonFS |
getClient() |
String |
getEditLogPath() |
String |
getImagePath() |
MasterInfo |
getMasterInfo() |
int |
getMetaPort() |
TachyonConf |
getTachyonConf() |
String |
getUri() |
boolean |
isStarted() |
void |
start() |
void |
stop()
Stops the master and cleans up client connections.
|
public static LocalTachyonMaster create(TachyonConf tachyonConf) throws IOException
IOException
- unable to do file operation or listen on portpublic static LocalTachyonMaster create(String tachyonHome, TachyonConf tachyonConf) throws IOException
UnderFileSystems.deleteDir(tachyonHome);
UnderFileSystems.mkdirIfNotExists(tachyonHome);
IOException
- unable to do file operation or listen on portpublic void start()
public void stop() throws Exception
UnderFileSystemUtils
data. To do that you
must call cleanupUnderfs()
.Exception
public void clearClients() throws IOException
IOException
public void cleanupUnderfs() throws IOException
IOException
public int getMetaPort()
public String getUri()
public TachyonFS getClient() throws IOException
IOException
public String getEditLogPath()
public String getImagePath()
public MasterInfo getMasterInfo()
public boolean isStarted()
public TachyonConf getTachyonConf()
Copyright © 2015. All Rights Reserved.