com.bigdata.counters.ganglia

Class BigdataGangliaService

java.lang.Object

com.bigdata.ganglia.GangliaService

com.bigdata.counters.ganglia.BigdataGangliaService

All Implemented Interfaces:

IGangliaMetricsReporter, Runnable

public class BigdataGangliaService
extends GangliaService

A utility class which may be used to run the bigdata performance counter collection system within an embedded GangliaService.

Author:

Bryan Thompson TODO Provide *service* heartbeat. This would be a well known counter for the embedded GangliaService in the GangliaService.serviceName namespace. The interval for that counter should be configured separately. The main purpose is to allow applications to decide that some service is missing. TODO Research how to make ganglia recognize a value which is not being reported as "not available" rather than just painting the last reported value. Tmax? DMax? TODO Can metrics be declared which automatically collect history from the sampled counters? It would be nice to abstract that stuff out of bigdata. TODO We should be reporting out the CPU context switches and interrupts per second data from vmstat. Ganglia does not collect this stuff and it provides interesting insight into the CPU workload and instruction stalls, especially when correlated with the application workload (load, vs closure, vs query).

Field Summary

Fields inherited from class com.bigdata.ganglia.GangliaService

HOSTNAME

Constructor Summary

Constructors

Constructor and Description
BigdataGangliaService(String hostName, String serviceName, InetSocketAddress[] metricsServers, InetAddress listenGroup, int listenPort, boolean listen, boolean report, boolean mock, int quietPeriod, int initialDelay, int heartbeatInterval, int monitoringInterval, int globalDMax, IGangliaMetadataFactory metadataFactory)

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(String[] args) Runs a GangliaService as a standalone application.

Methods inherited from class com.bigdata.ganglia.GangliaService

addMetricCollector, gatherMetrics, getCanonicalHostName, getDefaultHostReportOn, getGangliaState, getHostName, getHostReport, getHostReport, getHostReport, getMetadataFactory, isListening, isQuietPeriod, removeMetricCollector, run, sendMessage, setMetric, uptime

Methods inherited from class java.lang.Object

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

Constructor Detail

BigdataGangliaService

public BigdataGangliaService(String hostName,
                     String serviceName,
                     InetSocketAddress[] metricsServers,
                     InetAddress listenGroup,
                     int listenPort,
                     boolean listen,
                     boolean report,
                     boolean mock,
                     int quietPeriod,
                     int initialDelay,
                     int heartbeatInterval,
                     int monitoringInterval,
                     int globalDMax,
                     IGangliaMetadataFactory metadataFactory)

Method Detail

main

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

Runs a GangliaService as a standalone application.

Note: This routine is mainly for test as the primary purpose of the GangliaService is to embed it within another application.

Parameters:

args -

Throws:

Exception