org.apache.nifi.reporting.sink

Class SiteToSiteReportingRecordSink

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.controller.AbstractControllerService

org.apache.nifi.reporting.sink.SiteToSiteReportingRecordSink

All Implemented Interfaces:

ConfigurableComponent, ControllerService, RecordSinkService

@Tags(value={"db","s2s","site","record"})
 @CapabilityDescription(value="Provides a service to write records using a configured RecordSetWriter over a Site-to-Site connection.")
public class SiteToSiteReportingRecordSink
extends AbstractControllerService
implements RecordSinkService

Field Summary

Fields

Modifier and Type	Field and Description
private List<PropertyDescriptor>	properties
private SiteToSiteClient	siteToSiteClient
private StateManager	stateManager
private RecordSetWriterFactory	writerFactory

Fields inherited from interface org.apache.nifi.record.sink.RecordSinkService

RECORD_WRITER_FACTORY

Constructor Summary

Constructors

Constructor and Description
SiteToSiteReportingRecordSink()

Method Summary

Modifier and Type	Method and Description
protected SiteToSiteClient	getClient()
protected List<PropertyDescriptor>	getSupportedPropertyDescriptors()
protected RecordSetWriterFactory	getWriterFactory()
protected void	init(ControllerServiceInitializationContext context)
void	onEnabled(ConfigurationContext context)
WriteResult	sendData(RecordSet recordSet, Map<String,String> attributes, boolean sendZeroResults)
void	stop()

Methods inherited from class org.apache.nifi.controller.AbstractControllerService

abstractClearConfigContext, abstractStoreConfigContext, disabled, enabled, getConfigurationContext, getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, getProperty, getStateManager, initialize, isEnabled

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.record.sink.RecordSinkService

reset

Methods inherited from interface org.apache.nifi.controller.ControllerService

initialize, isStateful

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

getIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

properties

private List<PropertyDescriptor> properties

siteToSiteClient

private volatile SiteToSiteClient siteToSiteClient

writerFactory

private volatile RecordSetWriterFactory writerFactory

stateManager

private volatile StateManager stateManager

Constructor Detail

SiteToSiteReportingRecordSink

public SiteToSiteReportingRecordSink()

Method Detail

init

protected void init(ControllerServiceInitializationContext context)

Overrides:

init in class AbstractControllerService

getSupportedPropertyDescriptors

protected List<PropertyDescriptor> getSupportedPropertyDescriptors()

Overrides:

getSupportedPropertyDescriptors in class AbstractConfigurableComponent

onEnabled

@OnEnabled
public void onEnabled(ConfigurationContext context)
                          throws InitializationException

Throws:

InitializationException

sendData

public WriteResult sendData(RecordSet recordSet,
                            Map<String,String> attributes,
                            boolean sendZeroResults)
                     throws IOException

Specified by:

sendData in interface RecordSinkService

Throws:

IOException

stop

@OnDisabled
public void stop()
                      throws IOException

Throws:

IOException

getClient

protected SiteToSiteClient getClient()

getWriterFactory

protected RecordSetWriterFactory getWriterFactory()