public final class LocalTachyonCluster extends Object
Constructor and Description |
---|
LocalTachyonCluster(long workerCapacityBytes,
int quotaUnitBytes,
int userBlockSize) |
Modifier and Type | Method and Description |
---|---|
TachyonFS |
getClient() |
String |
getEditLogPath() |
String |
getImagePath() |
InetSocketAddress |
getMasterAddress() |
String |
getMasterHostname() |
MasterInfo |
getMasterInfo() |
int |
getMasterPort() |
TachyonConf |
getMasterTachyonConf() |
String |
getMasterUri() |
String |
getTachyonHome() |
String |
getTempFolderInUnderFs() |
BlockWorker |
getWorker() |
NetAddress |
getWorkerAddress() |
String |
getWorkerDataFolder() |
TachyonConf |
getWorkerTachyonConf() |
static void |
main(String[] args) |
void |
start() |
void |
start(TachyonConf tachyonConf) |
void |
stop()
Stop both of the tachyon and underfs service threads.
|
void |
stopTFS()
Stop the tachyon filesystem's service thread only
|
void |
stopUFS()
Cleanup the underfs cluster test folder only
|
void |
stopWorker() |
public LocalTachyonCluster(long workerCapacityBytes, int quotaUnitBytes, int userBlockSize)
public TachyonFS getClient() throws IOException
IOException
public String getEditLogPath()
public String getImagePath()
public TachyonConf getMasterTachyonConf()
public InetSocketAddress getMasterAddress()
public String getMasterHostname()
public MasterInfo getMasterInfo()
public String getMasterUri()
public int getMasterPort()
public String getTachyonHome()
public String getTempFolderInUnderFs()
public BlockWorker getWorker()
public TachyonConf getWorkerTachyonConf()
public NetAddress getWorkerAddress()
public String getWorkerDataFolder()
public void start() throws IOException
IOException
public void start(TachyonConf tachyonConf) throws IOException
IOException
public void stop() throws Exception
Exception
public void stopTFS() throws Exception
Exception
public void stopUFS() throws Exception
Exception
Copyright © 2015. All Rights Reserved.