Modifier and Type | Method and Description |
---|---|
static TachyonWorker |
createWorker(InetSocketAddress masterAddress,
InetSocketAddress workerAddress,
int dataPort,
int selectorThreads,
int acceptQueueSizePerThreads,
int workerThreads)
Create a new TachyonWorker
|
static TachyonWorker |
createWorker(String masterAddress,
String workerAddress,
int dataPort,
int selectorThreads,
int acceptQueueSizePerThreads,
int workerThreads)
Create a new TachyonWorker
|
int |
getDataPort()
Gets the data port of the worker.
|
int |
getMetaPort()
Gets the metadata port of the worker.
|
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)
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 serverpublic static TachyonWorker createWorker(String masterAddress, String workerAddress, int dataPort, int selectorThreads, int acceptQueueSizePerThreads, int workerThreads)
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 serverpublic static void main(String[] args) throws UnknownHostException
UnknownHostException
public int getDataPort()
public int getMetaPort()
public void start() throws IOException
IOException
public void stop() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2015. All Rights Reserved.