Modifier and Type | Method and Description |
---|---|
static TachyonWorker |
createWorker(InetSocketAddress masterAddress,
InetSocketAddress workerAddress,
int dataPort,
int selectorThreads,
int acceptQueueSizePerThreads,
int workerThreads,
String localFolder,
long spaceLimitBytes)
Create a new TachyonWorker
|
static TachyonWorker |
createWorker(String masterAddress,
String workerAddress,
int dataPort,
int selectorThreads,
int acceptQueueSizePerThreads,
int workerThreads,
String localFolder,
long spaceLimitBytes)
Create a new TachyonWorker
|
static void |
main(String[] args) |
void |
run() |
void |
start()
Start the data server thread and heartbeat thread of this TachyonWorker.
|
void |
stop()
Stop this TachyonWorker.
|
public static TachyonWorker createWorker(InetSocketAddress masterAddress, InetSocketAddress workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes)
masterAddress
- The TachyonMaster's addressworkerAddress
- This TachyonWorker's addressdataPort
- This TachyonWorker's data server's portselectorThreads
- The number of selector threads of the worker's thrift serveracceptQueueSizePerThreads
- The accept queue size per thread of the worker's thrift serverworkerThreads
- The number of threads of the worker's thrift serverlocalFolder
- This TachyonWorker's local folder's pathspaceLimitBytes
- The maximum memory space this TachyonWorker can use, in bytespublic static TachyonWorker createWorker(String masterAddress, String workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads, String localFolder, long spaceLimitBytes)
masterAddress
- The TachyonMaster's address. e.g., localhost:19998workerAddress
- This TachyonWorker's address. e.g., localhost:29998dataPort
- This TachyonWorker's data server's portselectorThreads
- The number of selector threads of the worker's thrift serveracceptQueueSizePerThreads
- The accept queue size per thread of the worker's thrift serverworkerThreads
- The number of threads of the worker's thrift serverlocalFolder
- This TachyonWorker's local folder's pathspaceLimitBytes
- The maximum memory space this TachyonWorker can use, in bytespublic static void main(String[] args) throws UnknownHostException
UnknownHostException
public void start()
public void stop() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2014. All rights reserved.