io.druid.emitter.ambari.metrics

Class SendAllTimelineEventConverter

java.lang.Object

io.druid.emitter.ambari.metrics.SendAllTimelineEventConverter

All Implemented Interfaces:

DruidToTimelineMetricConverter

public class SendAllTimelineEventConverter
extends Object
implements DruidToTimelineMetricConverter

Emits all the events instance of ServiceMetricEvent.

All the dimensions will be retained and lexicographically order using dimensions name.

The metric name of the timeline event is: ...

Note that this name will be sanitized by replacing all the `.` or `space` to `_` AmbariMetricsEmitter.sanitize(String)

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_APP_NAME

Constructor Summary

Constructors

Constructor and Description
SendAllTimelineEventConverter(String namespacePrefix, String appName)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.metrics2.sink.timeline.TimelineMetric	druidEventToTimelineMetric(ServiceMetricEvent serviceMetricEvent) This function acts as a filter.
boolean	equals(Object o)
String	getNamespacePrefix()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_APP_NAME

public static final String DEFAULT_APP_NAME

See Also:

Constant Field Values

Constructor Detail

SendAllTimelineEventConverter

public SendAllTimelineEventConverter(String namespacePrefix,
                                     String appName)

Method Detail

getNamespacePrefix

public String getNamespacePrefix()

druidEventToTimelineMetric

public org.apache.hadoop.metrics2.sink.timeline.TimelineMetric druidEventToTimelineMetric(ServiceMetricEvent serviceMetricEvent)

Description copied from interface: DruidToTimelineMetricConverter

This function acts as a filter. It returns null if the event is not suppose to be emitted to Ambari Server Also This function will define the mapping between the druid event dimension's values and Ambari Metric Name

Specified by:

druidEventToTimelineMetric in interface DruidToTimelineMetricConverter

Parameters:

serviceMetricEvent - Druid event ot type ServiceMetricEvent

Returns:

TimelineMetric or null

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object