public abstract class UnderFileSystemCluster extends Object
Modifier and Type | Field and Description |
---|---|
protected String |
mBaseDir |
protected TachyonConf |
mTachyonConf |
Constructor and Description |
---|
UnderFileSystemCluster(String baseDir,
TachyonConf tachyonConf) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
To clean up the test environment over underfs cluster system, so that we can re-use the running
system for the next test round instead of turning on/off it from time to time.
|
static UnderFileSystemCluster |
get(String baseDir,
TachyonConf tachyonConf)
To start the underfs test bed and register the shutdown hook
|
abstract String |
getUnderFilesystemAddress() |
static UnderFileSystemCluster |
getUnderFilesystemCluster(String baseDir,
TachyonConf tachyonConf) |
abstract boolean |
isStarted()
Check if the cluster started.
|
static boolean |
readEOFReturnsNegative()
This method is only used by the
FileOutStreamIntegrationTest unit-test |
void |
registerJVMOnExistHook()
Add a shutdown hook.
|
abstract void |
shutdown()
To stop the underfs cluster system
|
abstract void |
start()
To start the underfs cluster system
|
protected String mBaseDir
protected final TachyonConf mTachyonConf
public UnderFileSystemCluster(String baseDir, TachyonConf tachyonConf)
public static UnderFileSystemCluster get(String baseDir, TachyonConf tachyonConf) throws IOException
IOException
InterruptedException
public static UnderFileSystemCluster getUnderFilesystemCluster(String baseDir, TachyonConf tachyonConf)
public static boolean readEOFReturnsNegative()
FileOutStreamIntegrationTest
unit-testpublic void cleanup() throws IOException
IOException
public abstract String getUnderFilesystemAddress()
public abstract boolean isStarted()
public void registerJVMOnExistHook() throws IOException
shutdown()
phase will be automatically called while the process
exists.InterruptedException
IOException
public abstract void shutdown() throws IOException
IOException
public abstract void start() throws IOException
IOException
Copyright © 2015. All Rights Reserved.