Package org.apache.nifi.processors.standard

Class PutUDP

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.util.put.AbstractPutEventProcessor<byte[]>

org.apache.nifi.processors.standard.PutUDP

All Implemented Interfaces:

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

@CapabilityDescription("The PutUDP processor receives a FlowFile and packages the FlowFile content into a single UDP datagram packet which is then transmitted to the configured UDP server. The user must ensure that the FlowFile content being fed to this processor is not larger than the maximum size for the underlying UDP transport. The maximum transport size will vary based on the platform setup but is generally just under 64KB. FlowFiles will be marked as failed if their content is larger than the maximum transport size.")
@InputRequirement(INPUT_REQUIRED)
@SeeAlso({ListenUDP.class,PutTCP.class})
@Tags({"remote","egress","put","udp"})
@SupportsBatching
public class PutUDP
extends AbstractPutEventProcessor<byte[]>

Nested Class Summary

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

AbstractPutEventProcessor.FlowFileMessageBatch, AbstractPutEventProcessor.Range

Field Summary

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
PutUDP()

Method Summary

Modifier and Type	Method	Description
protected NettyEventSenderFactory<byte[]>	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 byte[]	readContent(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, getAdditionalProperties, 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

Constructor Details

PutUDP

public PutUDP()

Method Details

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<byte[]>

getNettyEventSenderFactory

protected NettyEventSenderFactory<byte[]> getNettyEventSenderFactory(String hostname,
 int port,
 String protocol)

Specified by:

getNettyEventSenderFactory in class AbstractPutEventProcessor<byte[]>

readContent

private byte[] readContent(org.apache.nifi.processor.ProcessSession session,
 org.apache.nifi.flowfile.FlowFile flowFile)
                    throws IOException

Throws:

IOException