org.apache.nifi.reporting

Class AbstractSiteToSiteReportingTask

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.reporting.AbstractReportingTask

org.apache.nifi.reporting.AbstractSiteToSiteReportingTask

All Implemented Interfaces:

ConfigurableComponent, ReportingTask, VerifiableReportingTask

Direct Known Subclasses:

SiteToSiteBulletinReportingTask, SiteToSiteMetricsReportingTask, SiteToSiteProvenanceReportingTask, SiteToSiteStatusReportingTask

public abstract class AbstractSiteToSiteReportingTask
extends AbstractReportingTask
implements VerifiableReportingTask

Base class for ReportingTasks that send data over site-to-site.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	AbstractSiteToSiteReportingTask.JsonRecordReader

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static PropertyDescriptor	ALLOW_NULL_VALUES
protected static String	DESTINATION_URL_PATH
private static String	ESTABLISH_COMMUNICATION
protected static String	LAST_EVENT_ID_KEY
(package private) static PropertyDescriptor	RECORD_WRITER
protected RecordSchema	recordSchema
protected SiteToSiteClient	siteToSiteClient
protected static String	TIMESTAMP_FORMAT

Constructor Summary

Constructors

Constructor and Description
AbstractSiteToSiteReportingTask()

Method Summary

Modifier and Type	Method and Description
protected void	addField(javax.json.JsonObjectBuilder builder, String key, Boolean value, boolean allowNullValues)
protected void	addField(javax.json.JsonObjectBuilder builder, String key, Integer value, boolean allowNullValues)
protected void	addField(javax.json.JsonObjectBuilder builder, String key, Long value, boolean allowNullValues)
protected void	addField(javax.json.JsonObjectBuilder builder, String key, String value, boolean allowNullValues)
protected SiteToSiteClient	getClient()
protected byte[]	getData(ReportingContext context, InputStream in, Map<String,String> attributes)
protected List<PropertyDescriptor>	getSupportedPropertyDescriptors()
protected void	sendData(ReportingContext context, Transaction transaction, Map<String,String> attributes, javax.json.JsonArray jsonArray)
void	setup(PropertyContext reportContext)
void	shutdown()
List<ConfigVerificationResult>	verify(ConfigurationContext context, ComponentLog verificationLogger)

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, onTrigger

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

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

ESTABLISH_COMMUNICATION

private static final String ESTABLISH_COMMUNICATION

See Also:

Constant Field Values

LAST_EVENT_ID_KEY

protected static final String LAST_EVENT_ID_KEY

See Also:

Constant Field Values

DESTINATION_URL_PATH

protected static final String DESTINATION_URL_PATH

See Also:

Constant Field Values

TIMESTAMP_FORMAT

protected static final String TIMESTAMP_FORMAT

See Also:

Constant Field Values

RECORD_WRITER

static final PropertyDescriptor RECORD_WRITER

ALLOW_NULL_VALUES

static final PropertyDescriptor ALLOW_NULL_VALUES

siteToSiteClient

protected volatile SiteToSiteClient siteToSiteClient

recordSchema

protected volatile RecordSchema recordSchema

Constructor Detail

AbstractSiteToSiteReportingTask

public AbstractSiteToSiteReportingTask()

Method Detail

getSupportedPropertyDescriptors

protected List<PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class AbstractConfigurableComponent

setup

public void setup(PropertyContext reportContext)
           throws IOException

Throws:

IOException

shutdown

@OnStopped
public void shutdown()
                         throws IOException

Throws:

IOException

getClient

protected SiteToSiteClient getClient()

sendData

protected void sendData(ReportingContext context,
                        Transaction transaction,
                        Map<String,String> attributes,
                        javax.json.JsonArray jsonArray)
                 throws IOException

Throws:

IOException

getData

protected byte[] getData(ReportingContext context,
                         InputStream in,
                         Map<String,String> attributes)

addField

protected void addField(javax.json.JsonObjectBuilder builder,
                        String key,
                        Boolean value,
                        boolean allowNullValues)

addField

protected void addField(javax.json.JsonObjectBuilder builder,
                        String key,
                        Long value,
                        boolean allowNullValues)

addField

protected void addField(javax.json.JsonObjectBuilder builder,
                        String key,
                        Integer value,
                        boolean allowNullValues)

addField

protected void addField(javax.json.JsonObjectBuilder builder,
                        String key,
                        String value,
                        boolean allowNullValues)

verify

public List<ConfigVerificationResult> verify(ConfigurationContext context,
                                             ComponentLog verificationLogger)

Specified by:

verify in interface VerifiableReportingTask