org.apache.ambari.server.metrics.system.impl

Class AmbariMetricSinkImpl

java.lang.Object

org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

org.apache.ambari.server.metrics.system.impl.AmbariMetricSinkImpl

All Implemented Interfaces:

MetricsSink

public class AmbariMetricSinkImpl
extends org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink
implements MetricsSink

Ambari Server Metrics Sink implementation to push collected metrics to AMS.

Field Summary

Fields inherited from class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

allKnownLiveCollectors, collectionPeriodMillis, COLLECTOR_HOSTS_PROPERTY, COLLECTOR_LIVE_NODES_PATH, COLLECTOR_PORT, COLLECTOR_PROTOCOL, COLLECTOR_ZOOKEEPER_QUORUM, collectorHAHelper, COOKIE, DEFAULT_POST_TIMEOUT_SECONDS, failedCollectorConnectionsCounter, HOST_IN_MEMORY_AGGREGATION_ENABLED_PROPERTY, HOST_IN_MEMORY_AGGREGATION_PORT_PROPERTY, HOST_IN_MEMORY_AGGREGATION_PROTOCOL_PROPERTY, INSTANCE_ID_PROPERTY, LOG, mapper, MAX_METRIC_ROW_CACHE_SIZE, METRICS_POST_TIMEOUT_SECONDS, METRICS_SEND_INTERVAL, metricSinkWriteShardStrategy, nullCollectorCounter, NUMBER_OF_NULL_COLLECTOR_EXCEPTIONS, NUMBER_OF_SKIPPED_COLLECTOR_EXCEPTIONS, RPC_METRIC_PREFIX, SET_INSTANCE_ID_PROPERTY, shardExpired, SKIP_COUNTER_TRANSFROMATION, SSL_KEYSTORE_PASSWORD_PROPERTY, SSL_KEYSTORE_PATH_PROPERTY, SSL_KEYSTORE_TYPE_PROPERTY, TAGS_FOR_PREFIX_PROPERTY_PREFIX, targetCollectorHostSupplier, WS_V1_TIMELINE_METRICS, ZK_CONNECT_TRY_COUNT, ZK_SLEEP_BETWEEN_RETRY_TIME, ZOOKEEPER_QUORUM

Constructor Summary

Constructors

Constructor and Description
AmbariMetricSinkImpl(AmbariManagementController amc)

Method Summary

Modifier and Type	Method and Description
protected String	getCollectorPort()
protected String	getCollectorProtocol()
protected String	getCollectorUri(String host) Get a pre-formatted URI for the collector
protected Collection<String>	getConfiguredCollectorHosts() Get pre-configured list of collectors available
protected int	getHostInMemoryAggregationPort()
protected String	getHostInMemoryAggregationProtocol()
protected String	getHostname() Get hostname used for calculating write shard.
protected int	getTimeoutSeconds()
protected String	getZookeeperQuorum() Get the zookeeper quorum for the cluster used to find collector
void	init(MetricsConfiguration configuration) initialize Sink passing in configuration
protected boolean	isHostInMemoryAggregationEnabled()
boolean	isInitialized() Returns if the sink is initialized.
void	publish(List<SingleMetric> metrics) Publish metrics to AMS.

Methods inherited from class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

alignMetricsByMinuteMark, cleanupInputStream, constructTimelineMetricUri, emitMetrics, emitMetrics, emitMetricsJson, findPreferredCollectHost, getAppCookieManager, getConnection, getCurrentCollectorHost, getMetricsPostCache, getSSLConnection, init, loadTruststore, parseHostsStringIntoCollection

Methods inherited from class java.lang.Object

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

Constructor Detail

AmbariMetricSinkImpl

public AmbariMetricSinkImpl(AmbariManagementController amc)

Method Detail

init

public void init(MetricsConfiguration configuration)

Description copied from interface: MetricsSink

initialize Sink passing in configuration

Specified by:

init in interface MetricsSink

publish

public void publish(List<SingleMetric> metrics)

Publish metrics to AMS.

Specified by:

publish in interface MetricsSink

Parameters:

metrics - Set of metrics

isInitialized

public boolean isInitialized()

Description copied from interface: MetricsSink

Returns if the sink is initialized.

Specified by:

isInitialized in interface MetricsSink

getCollectorUri

protected String getCollectorUri(String host)

Get a pre-formatted URI for the collector

Specified by:

getCollectorUri in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

Parameters:

host -

getCollectorProtocol

protected String getCollectorProtocol()

Specified by:

getCollectorProtocol in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

getCollectorPort

protected String getCollectorPort()

Specified by:

getCollectorPort in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

getTimeoutSeconds

protected int getTimeoutSeconds()

Specified by:

getTimeoutSeconds in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

getZookeeperQuorum

protected String getZookeeperQuorum()

Get the zookeeper quorum for the cluster used to find collector

Specified by:

getZookeeperQuorum in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

Returns:

String "host1:port1,host2:port2"

getConfiguredCollectorHosts

protected Collection<String> getConfiguredCollectorHosts()

Get pre-configured list of collectors available

Specified by:

getConfiguredCollectorHosts in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

Returns:

Collection host1,host2

getHostname

protected String getHostname()

Get hostname used for calculating write shard.

Specified by:

getHostname in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

Returns:

String "host1"

isHostInMemoryAggregationEnabled

protected boolean isHostInMemoryAggregationEnabled()

Specified by:

isHostInMemoryAggregationEnabled in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

getHostInMemoryAggregationPort

protected int getHostInMemoryAggregationPort()

Specified by:

getHostInMemoryAggregationPort in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink

getHostInMemoryAggregationProtocol

protected String getHostInMemoryAggregationProtocol()

Specified by:

getHostInMemoryAggregationProtocol in class org.apache.hadoop.metrics2.sink.timeline.AbstractTimelineMetricsSink