org.apache.nifi.reporting

Class SiteToSiteMetricsReportingTask

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.reporting.AbstractReportingTask

org.apache.nifi.reporting.AbstractSiteToSiteReportingTask

org.apache.nifi.reporting.SiteToSiteMetricsReportingTask

All Implemented Interfaces:

ConfigurableComponent, ReportingTask, VerifiableReportingTask

@Tags(value={"status","metrics","site","site to site"})
 @CapabilityDescription(value="Publishes same metrics as the Ambari Reporting task using the Site To Site protocol.")
public class SiteToSiteMetricsReportingTask
extends AbstractSiteToSiteReportingTask

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static AllowableValue	AMBARI_FORMAT
(package private) static PropertyDescriptor	APPLICATION_ID
(package private) static PropertyDescriptor	FORMAT
(package private) static PropertyDescriptor	HOSTNAME
private MetricsService	metricsService
(package private) static AllowableValue	RECORD_FORMAT

Fields inherited from class org.apache.nifi.reporting.AbstractSiteToSiteReportingTask

ALLOW_NULL_VALUES, DESTINATION_URL_PATH, LAST_EVENT_ID_KEY, RECORD_WRITER, recordSchema, siteToSiteClient, TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
SiteToSiteMetricsReportingTask()

Method Summary

Modifier and Type	Method and Description
protected Collection<ValidationResult>	customValidate(ValidationContext validationContext)
protected List<PropertyDescriptor>	getSupportedPropertyDescriptors()
void	onTrigger(ReportingContext context)

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

addField, addField, addField, addField, getClient, getData, sendData, setup, shutdown, verify

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

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

AMBARI_FORMAT

static final AllowableValue AMBARI_FORMAT

RECORD_FORMAT

static final AllowableValue RECORD_FORMAT

APPLICATION_ID

static final PropertyDescriptor APPLICATION_ID

HOSTNAME

static final PropertyDescriptor HOSTNAME

FORMAT

static final PropertyDescriptor FORMAT

metricsService

private final MetricsService metricsService

Constructor Detail

SiteToSiteMetricsReportingTask

public SiteToSiteMetricsReportingTask()
                               throws IOException

Throws:

IOException

Method Detail

getSupportedPropertyDescriptors

protected List<PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class AbstractSiteToSiteReportingTask

customValidate

protected Collection<ValidationResult> customValidate(ValidationContext validationContext)

Overrides:

customValidate in class AbstractConfigurableComponent

onTrigger

public void onTrigger(ReportingContext context)