org.apache.hadoop.chukwa.datacollection.agent

Class ChukwaAgent

java.lang.Object

org.apache.hadoop.chukwa.datacollection.agent.ChukwaAgent

All Implemented Interfaces:

AdaptorManager

public class ChukwaAgent
extends Object
implements AdaptorManager

The local agent daemon that runs on each machine. This class is designed to be embeddable, for use in testing.

The agent will start an HTTP REST interface listening on port. Configs for the agent are:

• chukwaAgent.http.port Port to listen on (default=9090).
• chukwaAgent.http.rest.controller.packages Java packages to inspect for JAX-RS annotated classes to be added as servlets to the REST server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ChukwaAgent.AlreadyRunningException
static class	ChukwaAgent.Offset

Field Summary

Fields

Modifier and Type	Field and Description
Connector	connector

Fields inherited from interface org.apache.hadoop.chukwa.datacollection.agent.AdaptorManager

NULL

Method Summary

Modifier and Type	Method and Description
int	adaptorCount()
Adaptor	getAdaptor(String name)
Map<String,String>	getAdaptorList() Expose the adaptor list.
String	getAdaptorName(Adaptor initiator)
OffsetStatsManager<Adaptor>	getAdaptorStatsManager()
static ChukwaAgent	getAgent()
static ChukwaAgent	getAgent(org.apache.hadoop.conf.Configuration conf)
org.apache.hadoop.conf.Configuration	getConfiguration()
Connector	getConnector()
int	getControllerPort()
static org.apache.hadoop.conf.Configuration	getStaticConfiguration()
static void	main(String[] args)
ChukwaAgent.Offset	offset(Adaptor a)
String	processAddCommand(String cmd) Most of the Chukwa wire protocol is implemented in @link{AgentControlSocketListener} Unlike the rest of the chukwa wire protocol, add commands can appear in initial_adaptors and checkpoint files.
String	processAddCommandE(String cmd)
String	reportCommit(Adaptor src, long uuid) Called to update the Agent status table.
void	shutdown()
void	shutdown(boolean force) Triggers agent shutdown.
void	start()
long	stopAdaptor(String name, AdaptorShutdownPolicy shutdownMode) Stop the adaptor with given ID number.
long	stopAdaptor(String name, boolean gracefully)

Methods inherited from class java.lang.Object

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

Field Detail

connector

public Connector connector

Method Detail

getAgent

public static ChukwaAgent getAgent()

getAgent

public static ChukwaAgent getAgent(org.apache.hadoop.conf.Configuration conf)

start

public void start()
           throws ChukwaAgent.AlreadyRunningException

Throws:

ChukwaAgent.AlreadyRunningException

getControllerPort

public int getControllerPort()

getAdaptorStatsManager

public OffsetStatsManager<Adaptor> getAdaptorStatsManager()

main

public static void main(String[] args)
                 throws AdaptorException

Parameters:

args - is command line arguements

Throws:

AdaptorException - if error registering adaptors

adaptorCount

public int adaptorCount()

Specified by:

adaptorCount in interface AdaptorManager

Returns:

the number of running adaptors inside this local agent

processAddCommand

public String processAddCommand(String cmd)

Most of the Chukwa wire protocol is implemented in @link{AgentControlSocketListener} Unlike the rest of the chukwa wire protocol, add commands can appear in initial_adaptors and checkpoint files. So it makes sense to handle them here.

Specified by:

processAddCommand in interface AdaptorManager

processAddCommandE

public String processAddCommandE(String cmd)
                          throws AdaptorException

Throws:

AdaptorException

reportCommit

public String reportCommit(Adaptor src,
                           long uuid)

Description copied from interface: AdaptorManager

Called to update the Agent status table. Most adaptors should not call this. It is designed for adaptors that do some sort of local operation that needs checkpointing, but that doesn't emit chunks. For instance, DirTailingAdaptor uses it to track sweeps.

Specified by:

reportCommit in interface AdaptorManager

Parameters:

src - the adaptor in question

uuid - the number to record as checkpoint. Must be monotonically increasing.

Returns:

the adaptor ID of the associated adaptor, or null if not running.

getAdaptorList

public Map<String,String> getAdaptorList()

Expose the adaptor list. Keys are adaptor ID numbers, values are the adaptor status strings.

Specified by:

getAdaptorList in interface AdaptorManager

Returns:

adaptor list

stopAdaptor

public long stopAdaptor(String name,
                        boolean gracefully)

Specified by:

stopAdaptor in interface AdaptorManager

stopAdaptor

public long stopAdaptor(String name,
                        AdaptorShutdownPolicy shutdownMode)

Stop the adaptor with given ID number. Takes a parameter to indicate whether the adaptor should force out all remaining data, or just exit abruptly. If the adaptor is written correctly, its offset won't change after returning from shutdown.

Specified by:

stopAdaptor in interface AdaptorManager

Parameters:

name - the adaptor to stop

shutdownMode - if true, shutdown, if false, hardStop

Returns:

the number of bytes synched at stop. -1 on error

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface AdaptorManager

getStaticConfiguration

public static org.apache.hadoop.conf.Configuration getStaticConfiguration()

getAdaptor

public Adaptor getAdaptor(String name)

Specified by:

getAdaptor in interface AdaptorManager

offset

public ChukwaAgent.Offset offset(Adaptor a)

getConnector

public Connector getConnector()

shutdown

public void shutdown()

shutdown

public void shutdown(boolean force)

Triggers agent shutdown. For now, this method doesn't shut down adaptors explicitly. It probably should.

Parameters:

force - sets flag to exit forcefully

getAdaptorName

public String getAdaptorName(Adaptor initiator)