AbstractGangliaSink (Hadoop 1.2.2-SNAPSHOT API)

java.lang.Object
- org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink

所有已实现的接口:

MetricsPlugin, MetricsSink

直接已知子类:

GangliaSink30
```
public abstract class AbstractGangliaSink
extends Object
implements MetricsSink
```
This the base class for Ganglia sink classes using metrics2. Lot of the code has been derived from org.apache.hadoop.metrics.ganglia.GangliaContext. As per the documentation, sink implementations doesn't have to worry about thread safety. Hence the code wasn't written for thread safety and should be modified in case the above assumption changes in the future.

嵌套类概要

嵌套类
限定符和类型	类和说明
`static class`	`AbstractGangliaSink.GangliaConfType` define enum for various type of conf
`static class`	`AbstractGangliaSink.GangliaSlope` ganglia slope values which equal the ordinal

字段概要

字段
限定符和类型	字段和说明
`static int`	`BUFFER_SIZE`
`static int`	`DEFAULT_DMAX`
`static int`	`DEFAULT_PORT`
`static AbstractGangliaSink.GangliaSlope`	`DEFAULT_SLOPE`
`static int`	`DEFAULT_TMAX`
`static String`	`DEFAULT_UNITS`
`static String`	`EQUAL`
`protected org.apache.hadoop.metrics2.sink.ganglia.GangliaMetricVisitor`	`gangliaMetricVisitor` Used for visiting Metrics
`org.apache.commons.logging.Log`	`LOG`
`static String`	`SERVERS_PROPERTY`
`static boolean`	`SUPPORT_SPARSE_METRICS_DEFAULT`
`static String`	`SUPPORT_SPARSE_METRICS_PROPERTY`

构造器概要

构造器
构造器和说明

AbstractGangliaSink()

构造器
构造器和说明
`AbstractGangliaSink()`

方法概要

方法
限定符和类型	方法和说明
`protected void`	`emitToGangliaHosts()` Sends Ganglia Metrics to the configured hosts
`void`	`flush()` Flush any buffered metrics
`protected org.apache.hadoop.metrics2.sink.ganglia.GangliaConf`	`getGangliaConfForMetric(String metricName)` Lookup GangliaConf from cache.
`protected String`	`getHostName()`
`void`	`init(org.apache.commons.configuration.SubsetConfiguration conf)` Initialize the plugin
`protected boolean`	`isSupportSparseMetrics()`
`protected void`	`xdr_int(int i)` Puts an integer into the buffer as 4 bytes, big-endian.
`protected void`	`xdr_string(String s)` Puts a string into the buffer by first writing the size of the string as an int, followed by the bytes of the string, padded if necessary to a multiple of 4.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.metrics2.MetricsSink
putMetrics

- 字段详细资料
  - LOG
```
public final org.apache.commons.logging.Log LOG
```
  - DEFAULT_UNITS
```
public static final String DEFAULT_UNITS
```
    另请参阅:
    常量字段值
  - DEFAULT_TMAX
```
public static final int DEFAULT_TMAX
```
    另请参阅:
    常量字段值
  - DEFAULT_DMAX
```
public static final int DEFAULT_DMAX
```
    另请参阅:
    常量字段值
  - DEFAULT_SLOPE
```
public static final AbstractGangliaSink.GangliaSlope DEFAULT_SLOPE
```
  - DEFAULT_PORT
```
public static final int DEFAULT_PORT
```
    另请参阅:
    常量字段值
  - SERVERS_PROPERTY
```
public static final String SERVERS_PROPERTY
```
    另请参阅:
    常量字段值
  - BUFFER_SIZE
```
public static final int BUFFER_SIZE
```
    另请参阅:
    常量字段值
  - SUPPORT_SPARSE_METRICS_PROPERTY
```
public static final String SUPPORT_SPARSE_METRICS_PROPERTY
```
    另请参阅:
    常量字段值
  - SUPPORT_SPARSE_METRICS_DEFAULT
```
public static final boolean SUPPORT_SPARSE_METRICS_DEFAULT
```
    另请参阅:
    常量字段值
  - EQUAL
```
public static final String EQUAL
```
    另请参阅:
    常量字段值
  - gangliaMetricVisitor
```
protected final org.apache.hadoop.metrics2.sink.ganglia.GangliaMetricVisitor gangliaMetricVisitor
```
    Used for visiting Metrics
- 构造器详细资料
  - AbstractGangliaSink
```
public AbstractGangliaSink()
```
- 方法详细资料
  - init
```
public void init(org.apache.commons.configuration.SubsetConfiguration conf)
```
    从接口复制的说明: MetricsPlugin
    
    Initialize the plugin
    
    指定者:
    
    init 在接口中 MetricsPlugin
    
    参数:
    conf - the configuration object for the plugin
  - flush
```
public void flush()
```
    从接口复制的说明: MetricsSink
    
    Flush any buffered metrics
    
    指定者:
    
    flush 在接口中 MetricsSink
  - getGangliaConfForMetric
```
protected org.apache.hadoop.metrics2.sink.ganglia.GangliaConf getGangliaConfForMetric(String metricName)
```
    Lookup GangliaConf from cache. If not found, return default values
    
    参数:
    metricName -
    
    返回:
    looked up GangliaConf
  - getHostName
```
protected String getHostName()
```
    返回:
    the hostName
  - xdr_string
```
protected void xdr_string(String s)
```
    Puts a string into the buffer by first writing the size of the string as an int, followed by the bytes of the string, padded if necessary to a multiple of 4.
    
    参数:
    s - the string to be written to buffer at offset location
  - xdr_int
```
protected void xdr_int(int i)
```
    Puts an integer into the buffer as 4 bytes, big-endian.
  - emitToGangliaHosts
```
protected void emitToGangliaHosts()
                           throws IOException
```
    Sends Ganglia Metrics to the configured hosts
    
    抛出:
    
    IOException
  - isSupportSparseMetrics
```
protected boolean isSupportSparseMetrics()
```
    返回:
    whether sparse metrics are supported

类 AbstractGangliaSink

嵌套类概要

字段概要

构造器概要

方法概要

从类继承的方法 java.lang.Object

从接口继承的方法 org.apache.hadoop.metrics2.MetricsSink

字段详细资料

LOG

DEFAULT_UNITS

DEFAULT_TMAX

DEFAULT_DMAX

DEFAULT_SLOPE

DEFAULT_PORT

SERVERS_PROPERTY

BUFFER_SIZE

SUPPORT_SPARSE_METRICS_PROPERTY

SUPPORT_SPARSE_METRICS_DEFAULT

EQUAL

gangliaMetricVisitor

构造器详细资料

AbstractGangliaSink

方法详细资料

init

flush

getGangliaConfForMetric

getHostName

xdr_string

xdr_int

emitToGangliaHosts

isSupportSparseMetrics