org.apache.nifi.reporting.datadog

Class DataDogReportingTask

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.reporting.AbstractReportingTask

org.apache.nifi.reporting.datadog.DataDogReportingTask

All Implemented Interfaces:

ConfigurableComponent, ReportingTask

@Tags(value={"reporting","datadog","metrics"})
 @CapabilityDescription(value="Publishes metrics from NiFi to datadog. For accurate and informative reporting, components should have unique names.")
public class DataDogReportingTask
extends AbstractReportingTask

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DataDogReportingTask.MetricGauge

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static PropertyDescriptor	API_KEY
(package private) static AllowableValue	DATADOG_AGENT
(package private) static AllowableValue	DATADOG_HTTP
(package private) static PropertyDescriptor	DATADOG_TRANSPORT
private DDMetricRegistryBuilder	ddMetricRegistryBuilder
private Map<String,String>	defaultTags
private String	environment
(package private) static PropertyDescriptor	ENVIRONMENT
private org.slf4j.Logger	logger
private com.codahale.metrics.MetricRegistry	metricRegistry
(package private) static PropertyDescriptor	METRICS_PREFIX
private ConcurrentHashMap<String,Double>	metricsMap
private String	metricsPrefix
private MetricsService	metricsService
private String	statusId
private JmxJvmMetrics	virtualMachineMetrics

Constructor Summary

Constructors

Constructor and Description
DataDogReportingTask()

Method Summary

Modifier and Type	Method and Description
private String	buildMetricName(String metricName)
protected com.codahale.metrics.MetricRegistry	getMetricRegistry()
protected DDMetricRegistryBuilder	getMetricRegistryBuilder()
protected ConcurrentHashMap<String,Double>	getMetricsMap()
protected MetricsService	getMetricsService()
protected List<PropertyDescriptor>	getSupportedPropertyDescriptors()
void	onTrigger(ReportingContext context)
private void	populateConnectionStatuses(ProcessGroupStatus groupStatus, List<ConnectionStatus> statuses)
private void	populateInputPortStatuses(ProcessGroupStatus groupStatus, List<PortStatus> statuses)
private void	populateOutputPortStatuses(ProcessGroupStatus groupStatus, List<PortStatus> statuses)
private void	populateProcessorStatuses(ProcessGroupStatus groupStatus, List<ProcessorStatus> statuses)
void	setup(ConfigurationContext context)
private void	updateAllMetricGroups(ProcessGroupStatus processGroupStatus)
private void	updateDataDogTransport(ReportingContext context)
protected void	updateMetrics(Map<String,Double> metrics, Map<String,String> tags)

Methods inherited from class org.apache.nifi.reporting.AbstractReportingTask

getControllerServiceLookup, getIdentifier, getLogger, getName, getNodeTypeProvider, getSchedulingPeriod, init, initialize, setComponentInfo

Methods inherited from class org.apache.nifi.components.AbstractConfigurableComponent

customValidate, equals, getPropertyDescriptor, getPropertyDescriptors, getSupportedDynamicPropertyDescriptor, hashCode, onPropertyModified, toString, validate

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.nifi.reporting.ReportingTask

isStateful

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

DATADOG_AGENT

static final AllowableValue DATADOG_AGENT

DATADOG_HTTP

static final AllowableValue DATADOG_HTTP

DATADOG_TRANSPORT

static final PropertyDescriptor DATADOG_TRANSPORT

API_KEY

static final PropertyDescriptor API_KEY

METRICS_PREFIX

static final PropertyDescriptor METRICS_PREFIX

ENVIRONMENT

static final PropertyDescriptor ENVIRONMENT

metricsService

private MetricsService metricsService

ddMetricRegistryBuilder

private DDMetricRegistryBuilder ddMetricRegistryBuilder

metricRegistry

private com.codahale.metrics.MetricRegistry metricRegistry

metricsPrefix

private String metricsPrefix

environment

private String environment

statusId

private String statusId

metricsMap

private ConcurrentHashMap<String,Double> metricsMap

defaultTags

private Map<String,String> defaultTags

virtualMachineMetrics

private volatile JmxJvmMetrics virtualMachineMetrics

logger

private org.slf4j.Logger logger

Constructor Detail

DataDogReportingTask

public DataDogReportingTask()

Method Detail

setup

@OnScheduled
public void setup(ConfigurationContext context)

getSupportedPropertyDescriptors

protected List<PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class AbstractConfigurableComponent

onTrigger

public void onTrigger(ReportingContext context)

updateMetrics

protected void updateMetrics(Map<String,Double> metrics,
                             Map<String,String> tags)

updateAllMetricGroups

private void updateAllMetricGroups(ProcessGroupStatus processGroupStatus)

updateDataDogTransport

private void updateDataDogTransport(ReportingContext context)
                             throws IOException

Throws:

IOException

populateProcessorStatuses

private void populateProcessorStatuses(ProcessGroupStatus groupStatus,
                                       List<ProcessorStatus> statuses)

populateConnectionStatuses

private void populateConnectionStatuses(ProcessGroupStatus groupStatus,
                                        List<ConnectionStatus> statuses)

populateInputPortStatuses

private void populateInputPortStatuses(ProcessGroupStatus groupStatus,
                                       List<PortStatus> statuses)

populateOutputPortStatuses

private void populateOutputPortStatuses(ProcessGroupStatus groupStatus,
                                        List<PortStatus> statuses)

buildMetricName

private String buildMetricName(String metricName)

getMetricsService

protected MetricsService getMetricsService()

getMetricRegistryBuilder

protected DDMetricRegistryBuilder getMetricRegistryBuilder()

getMetricRegistry

protected com.codahale.metrics.MetricRegistry getMetricRegistry()

getMetricsMap

protected ConcurrentHashMap<String,Double> getMetricsMap()