@NotThreadSafe public final class LocalAlluxioJobCluster extends Object
AbstractLocalAlluxioCluster
.Constructor and Description |
---|
LocalAlluxioJobCluster()
Creates a new instance of
LocalAlluxioJobCluster . |
Modifier and Type | Method and Description |
---|---|
String |
getHostname() |
AlluxioJobMasterProcess |
getMaster() |
JobWorkerProcess |
getWorker() |
void |
restartWorker()
Stops the current worker and starts a new one.
|
void |
setProperty(PropertyKey pk,
String value)
Overrides properties for the Job Master and Worker before starting.
|
void |
start()
Starts both master and a worker using the configurations in test conf respectively.
|
void |
stop()
Stops the alluxio job service threads.
|
public LocalAlluxioJobCluster()
LocalAlluxioJobCluster
.public void start() throws IOException, ConnectionFailedException
IOException
- if an I/O error occursConnectionFailedException
- if network connection failedpublic void stop() throws Exception
Exception
- when the operation failspublic AlluxioJobMasterProcess getMaster()
public JobWorkerProcess getWorker()
public String getHostname()
public void restartWorker() throws Exception
Exception
- if the the worker fails to stop or startpublic void setProperty(PropertyKey pk, String value)
pk
- the property key to setvalue
- the value to set for the keyCopyright © 2023. All Rights Reserved.