org.apache.hadoop.chukwa.datacollection.adaptor

Class JMXAdaptor

java.lang.Object

org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

org.apache.hadoop.chukwa.datacollection.adaptor.JMXAdaptor

All Implemented Interfaces:

Adaptor

public class JMXAdaptor
extends AbstractAdaptor

Query metrics through JMX interface.
1. Enable remote jmx monitoring for the target jvm by specifying -Dcom.sun.management.jmxremote.port=jmx_port
2. Enable authentication with -Dcom.sun.management.jmxremote.authenticate=true
-Dcom.sun.management.jmxremote.password.file=${CHUKWA_CONF_DIR}/jmxremote.password
-Dcom.sun.management.jmxremote.access.file=${CHUKWA_CONF_DIR}/jmxremote.access
3. Optionally specify these jvm options
-Djava.net.preferIPv4Stack=true -Dcom.sun.management.jmxremote.ssl=false
4. Connect to the jmx agent using jconsole and find out which domain you want to collect data for 5. Add the jmx adaptor. Ex: To collect metrics from a hadoop datanode that has enabled jmx on 8007, at 60s interval, use command
"add JMXAdaptor DatanodeProcessor localhost 8007 60 Hadoop:*"

Your JMX adaptor is now good to go and will send out the collected metrics as chunks to the collector.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JMXAdaptor.JMXConnect A thread which creates a new connection to JMX and retries every 10s if the connection is not successful.
class	JMXAdaptor.JMXTimer A TimerTask which queries the mbean server for all mbeans that match the pattern specified in the JMXAdaptor arguments, constructs a json object of all data and sends it as a chunk.

Field Summary

Fields inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

adaptorID, control, dest, type

Constructor Summary

Constructors

Constructor and Description
JMXAdaptor()

Method Summary

Methods

Modifier and Type	Method and Description
String	getCurrentStatus() Return the adaptor's state Should not include class name or byte offset, which are written by caller.
String	parseArgs(String s)
long	shutdown(AdaptorShutdownPolicy shutdownPolicy) Signals this adaptor to come to an orderly stop.
void	start(long offset)

Methods inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

deregisterAndStop, getType, hardStop, parseArgs, shutdown, start

Methods inherited from class java.lang.Object

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

Constructor Detail

JMXAdaptor

public JMXAdaptor()

Method Detail

getCurrentStatus

public String getCurrentStatus()

Description copied from interface: Adaptor

Return the adaptor's state Should not include class name or byte offset, which are written by caller. The datatype should, however, be written by this method.

Returns:

the adaptor state as a string

shutdown

public long shutdown(AdaptorShutdownPolicy shutdownPolicy)
              throws AdaptorException

Description copied from interface: Adaptor

Signals this adaptor to come to an orderly stop. The adaptor ought to push out all the data it can before exiting depending of the shutdown policy

Returns:

the logical offset at which the adaptor was when the method return

Throws:

AdaptorException

start

public void start(long offset)
           throws AdaptorException

Specified by:

start in class AbstractAdaptor

Throws:

AdaptorException

parseArgs

public String parseArgs(String s)

Specified by:

parseArgs in class AbstractAdaptor