@from(eventtable = "eagle", servicemetric = "GenericMetricServicehadoop.jmx.metric", hostquery = "localhost", port GenericMetricService[@site == "9090")
define table MetricTable(tags object, timestamp long, value double);
@from(eventtable\"sandbox\"]{*}", host = "eaglelocalhost", metricport = "hadoop.jmx.metric9090")
define table CPUMetricTable(site string, component string, host string, timestamp long, value double);
@from(eventtable = "eagle", metric = "hadoop.jmx.metric.max")
define table CPUMetricAggTable(site string, component string, host string, timestamp long, value double);
from CPUMetricTable[site == "sandbox" and timestamp > CURRENT_TIME - 0.5h and timestamp < CURRENT_TIME]
select max(value) as value, component, max(timestamp) as timestamp "hadoop.jmx.metric.max" as metric, groupby component insert into MetricTable; |