haddop GangliaSink31 代码
文件路径：/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/metrics2/sink/ganglia/GangliaSink31.java
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.hadoop.metrics2.sink.ganglia;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
/**
* This code supports Ganglia 3.1
*
*/
public class GangliaSink31 extends GangliaSink30 {
public final Logger LOG = LoggerFactory.getLogger(this.getClass());
/**
* The method sends metrics to Ganglia servers. The method has been taken from
* org.apache.hadoop.metrics.ganglia.GangliaContext31 with minimal changes in
* order to keep it in sync.
* @param groupName The group name of the metric
* @param name The metric name
* @param type The type of the metric
* @param value The value of the metric
* @param gConf The GangliaConf for this metric
* @param gSlope The slope for this metric
* @throws IOException raised on errors performing I/O.
*/
@Override
protected void emitMetric(String groupName, String name, String type,
String value, GangliaConf gConf, GangliaSlope gSlope)
throws IOException {
if (name == null) {
LOG.warn("Metric was emitted with no name.");
return;
} else if (value == null) {
LOG.warn("Metric name " + name +" was emitted with a null value.");
return;
} else if (type == null) {
LOG.warn("Metric name " + name + ", value " + value + " has no type.");
return;
}
if (LOG.isDebugEnabled()) {
LOG.debug("Emitting metric " + name + ", type " + type + ", value " + value
+ ", slope " + gSlope.name()+ " from hostname " + getHostName());
}
/ The following XDR recipe was done through a careful reading of
/ gm_protocol.x in Ganglia 3.1 and carefully examining the output of
/ the gmetric utility with strace.
/ First we send out a metadata message
xdr_int(128); / metric_id = metadata_msg
xdr_string(getHostName()); / hostname
xdr_string(name); / metric name
xdr_int(0); / spoof = False
xdr_string(type); / metric type
xdr_string(name); / metric name
xdr_string(gConf.getUnits()); / units
xdr_int(gSlope.ordinal()); / slope
xdr_int(gConf.getTmax()); / tmax, the maximum time between metrics
xdr_int(gConf.getDmax()); / dmax, the maximum data value
xdr_int(1); /*Num of the entries in extra_value field for
Ganglia 3.1.x*/
xdr_string("GROUP"); /*Group attribute*/
xdr_string(groupName); /*Group value*/
/ send the metric to Ganglia hosts
emitToGangliaHosts();
/ Now we send out a message with the actual value.
/ Technically, we only need to send out the metadata message once for
/ each metric, but I don't want to have to record which metrics we did and
/ did not send.
xdr_int(133); / we are sending a string value
xdr_string(getHostName()); / hostName
xdr_string(name); / metric name
xdr_int(0); / spoof = False
xdr_string("%s"); / format field
xdr_string(value); / metric value
/ send the metric to Ganglia hosts
emitToGangliaHosts();
}
}