Package org.apache.nifi.processors.standard

Class PutTCP

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.util.put.AbstractPutEventProcessor<InputStream>

org.apache.nifi.processors.standard.PutTCP

All Implemented Interfaces:

org.apache.nifi.components.ConfigurableComponent, org.apache.nifi.processor.Processor

@CapabilityDescription("Sends serialized FlowFiles or Records over TCP to a configurable destination with optional support for TLS")
@InputRequirement(INPUT_REQUIRED)
@SeeAlso({ListenTCP.class,PutUDP.class})
@Tags({"remote","egress","put","tcp"})
@SupportsBatching
@WritesAttributes(@WritesAttribute(attribute="record.count.transmitted",description="Count of records transmitted to configured destination address"))
public class PutTCP
extends AbstractPutEventProcessor<InputStream>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	PutTCP.ReusableByteArrayInputStream

Nested classes/interfaces inherited from class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

AbstractPutEventProcessor.FlowFileMessageBatch, AbstractPutEventProcessor.Range

Field Summary

Fields

Modifier and Type	Field	Description
private static final List<org.apache.nifi.components.PropertyDescriptor>	ADDITIONAL_PROPERTIES
(package private) static final org.apache.nifi.components.PropertyDescriptor	DEPENDENT_CHARSET
(package private) static final org.apache.nifi.components.PropertyDescriptor	DEPENDENT_OUTGOING_MESSAGE_DELIMITER
static final String	RECORD_COUNT_TRANSMITTED
(package private) static final org.apache.nifi.components.PropertyDescriptor	RECORD_READER
(package private) static final org.apache.nifi.components.PropertyDescriptor	RECORD_WRITER
(package private) static final org.apache.nifi.components.PropertyDescriptor	TRANSMISSION_STRATEGY

Fields inherited from class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

activeBatches, CHARSET, completeBatches, CONNECTION_PER_FLOWFILE, eventSender, HOSTNAME, IDLE_EXPIRATION, MAX_SOCKET_SEND_BUFFER_SIZE, MESSAGE_DELIMITER, OUTGOING_MESSAGE_DELIMITER, PORT, PROTOCOL, REL_FAILURE, REL_SUCCESS, SSL_CONTEXT_SERVICE, TCP_VALUE, TIMEOUT, transitUri, UDP_VALUE

Constructor Summary

Constructors

Constructor	Description
PutTCP()

Method Summary

Modifier and Type	Method	Description
protected List<org.apache.nifi.components.PropertyDescriptor>	getAdditionalProperties()
protected NettyEventSenderFactory<InputStream>	getNettyEventSenderFactory(String hostname, int port, String protocol)
protected String	getProtocol(org.apache.nifi.processor.ProcessContext context)
void	onTrigger(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSessionFactory sessionFactory)
private void	sendFlowFile(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile flowFile)
private int	sendRecords(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session, org.apache.nifi.flowfile.FlowFile flowFile)

Methods inherited from class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

closeSenders, createTransitUri, getAdditionalRelationships, getEventSender, getOutgoingMessageDelimiter, getRelationships, getSupportedPropertyDescriptors, init, onScheduled

Methods inherited from class org.apache.nifi.processor.AbstractSessionFactoryProcessor

getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, initialize, isConfigurationRestored, isScheduled, toString, updateConfiguredRestoredTrue, updateScheduledFalse, updateScheduledTrue

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

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

Methods inherited from class java.lang.Object

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

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

getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Methods inherited from interface org.apache.nifi.processor.Processor

isStateful, migrateProperties, migrateRelationships

Field Details

RECORD_COUNT_TRANSMITTED

public static final String RECORD_COUNT_TRANSMITTED

See Also:

• Constant Field Values

TRANSMISSION_STRATEGY

static final org.apache.nifi.components.PropertyDescriptor TRANSMISSION_STRATEGY

DEPENDENT_CHARSET

static final org.apache.nifi.components.PropertyDescriptor DEPENDENT_CHARSET

DEPENDENT_OUTGOING_MESSAGE_DELIMITER

static final org.apache.nifi.components.PropertyDescriptor DEPENDENT_OUTGOING_MESSAGE_DELIMITER

RECORD_READER

static final org.apache.nifi.components.PropertyDescriptor RECORD_READER

RECORD_WRITER

static final org.apache.nifi.components.PropertyDescriptor RECORD_WRITER

ADDITIONAL_PROPERTIES

private static final List<org.apache.nifi.components.PropertyDescriptor> ADDITIONAL_PROPERTIES

Constructor Details

PutTCP

public PutTCP()

Method Details

getAdditionalProperties

protected List<org.apache.nifi.components.PropertyDescriptor> getAdditionalProperties()

Overrides:

getAdditionalProperties in class AbstractPutEventProcessor<InputStream>

onTrigger

public void onTrigger(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.processor.ProcessSessionFactory sessionFactory)
               throws org.apache.nifi.processor.exception.ProcessException

Throws:

org.apache.nifi.processor.exception.ProcessException

getProtocol

protected String getProtocol(org.apache.nifi.processor.ProcessContext context)

Overrides:

getProtocol in class AbstractPutEventProcessor<InputStream>

getNettyEventSenderFactory

protected NettyEventSenderFactory<InputStream> getNettyEventSenderFactory(String hostname,
 int port,
 String protocol)

Specified by:

getNettyEventSenderFactory in class AbstractPutEventProcessor<InputStream>

sendFlowFile

private void sendFlowFile(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile flowFile)

sendRecords

private int sendRecords(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile flowFile)