alluxio.hub.agent.process

Class AgentProcess

java.lang.Object

alluxio.hub.agent.process.AgentProcess

All Implemented Interfaces:

AutoCloseable

public class AgentProcess
extends Object
implements AutoCloseable

The main class responsible for launching Hub agents.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
AgentProcess(AlluxioConfiguration conf) Creates a new AgentProcess.

Method Summary

Modifier and Type	Method and Description
void	awaitTermination() Blocks until the RPC server is terminated.
void	close()
int	getRpcPort()
static void	main(String[] args) Launch the agent process.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

AgentProcess

public AgentProcess(AlluxioConfiguration conf)
             throws Exception

Creates a new AgentProcess.

Parameters:

conf - the alluxio configuration

Throws:

Exception - if any of the servers fail to start

Method Detail

awaitTermination

public void awaitTermination()

Blocks until the RPC server is terminated.

close

public void close()

Specified by:

close in interface AutoCloseable

getRpcPort

public int getRpcPort()

Returns:

the running RPC server port

main

public static void main(String[] args)

Launch the agent process.

Parameters:

args - program arguments