Package org.apache.nifi.processors.standard

Class ListenUDP

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.AbstractProcessor

org.apache.nifi.processor.util.listen.AbstractListenEventProcessor<StandardEvent>

org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor<StandardEvent>

org.apache.nifi.processors.standard.ListenUDP

All Implemented Interfaces:

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

@SupportsBatching
@Tags({"ingest","udp","listen","source"})
@InputRequirement(INPUT_FORBIDDEN)
@CapabilityDescription("Listens for Datagram Packets on a given port. The default behavior produces a FlowFile per datagram, however for higher throughput the Max Batch Size property may be increased to specify the number of datagrams to batch together in a single FlowFile. This processor can be restricted to listening for datagrams from  a specific remote host and port by specifying the Sending Host and Sending Host Port properties, otherwise it will listen for datagrams from all hosts and ports.")
@WritesAttribute(attribute="udp.sender",description="The sending host of the messages.") @WritesAttribute(attribute="udp.port",description="The sending port the messages were received.")
public class ListenUDP
extends AbstractListenEventBatchingProcessor<StandardEvent>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ListenUDP.HostValidator

Nested classes/interfaces inherited from class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

AbstractListenEventBatchingProcessor.FlowFileEventBatch

Field Summary

Fields

Modifier and Type	Field	Description
private static final List<org.apache.nifi.components.PropertyDescriptor>	ADDITIONAL_PROPERTIES
static final org.apache.nifi.components.PropertyDescriptor	SENDING_HOST
static final org.apache.nifi.components.PropertyDescriptor	SENDING_HOST_PORT
static final String	UDP_PORT_ATTR
static final String	UDP_SENDER_ATTR

Fields inherited from class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

messageDemarcatorBytes

Fields inherited from class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

charset, CHARSET, descriptors, dispatcher, errorEvents, events, MAX_MESSAGE_QUEUE_SIZE, MAX_SOCKET_BUFFER_SIZE, POLL_TIMEOUT_MS, port, PORT, RECV_BUFFER_SIZE, REL_SUCCESS, relationships

Constructor Summary

Constructors

Constructor	Description
ListenUDP()

Method Summary

Modifier and Type	Method	Description
protected ChannelDispatcher	createDispatcher(org.apache.nifi.processor.ProcessContext context, BlockingQueue<StandardEvent> events)
protected Collection<org.apache.nifi.components.ValidationResult>	customValidate(org.apache.nifi.components.ValidationContext validationContext)
protected List<org.apache.nifi.components.PropertyDescriptor>	getAdditionalProperties()
protected Map<String,String>	getAttributes(AbstractListenEventBatchingProcessor<StandardEvent>.FlowFileEventBatch batch)
protected String	getTransitUri(AbstractListenEventBatchingProcessor<StandardEvent>.FlowFileEventBatch batch)

Methods inherited from class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

getBatches, getBatchKey, init, onScheduled, onTrigger, postProcess

Methods inherited from class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

closeDispatcher, getAdditionalRelationships, getDispatcherPort, getErrorQueueSize, getListeningPort, getLongPollTimeout, getMessage, getQueueSize, getRelationships, getSupportedPropertyDescriptors

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

onTrigger

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

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

SENDING_HOST

public static final org.apache.nifi.components.PropertyDescriptor SENDING_HOST

SENDING_HOST_PORT

public static final org.apache.nifi.components.PropertyDescriptor SENDING_HOST_PORT

ADDITIONAL_PROPERTIES

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

UDP_PORT_ATTR

public static final String UDP_PORT_ATTR

See Also:

• Constant Field Values

UDP_SENDER_ATTR

public static final String UDP_SENDER_ATTR

See Also:

• Constant Field Values

Constructor Details

ListenUDP

public ListenUDP()

Method Details

getAdditionalProperties

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

Overrides:

getAdditionalProperties in class AbstractListenEventProcessor<StandardEvent>

customValidate

protected Collection<org.apache.nifi.components.ValidationResult> customValidate(org.apache.nifi.components.ValidationContext validationContext)

Overrides:

customValidate in class org.apache.nifi.components.AbstractConfigurableComponent

createDispatcher

protected ChannelDispatcher createDispatcher(org.apache.nifi.processor.ProcessContext context,
 BlockingQueue<StandardEvent> events)

Specified by:

createDispatcher in class AbstractListenEventProcessor<StandardEvent>

getAttributes

protected Map<String,String> getAttributes(AbstractListenEventBatchingProcessor<StandardEvent>.FlowFileEventBatch batch)

Specified by:

getAttributes in class AbstractListenEventBatchingProcessor<StandardEvent>

getTransitUri

protected String getTransitUri(AbstractListenEventBatchingProcessor<StandardEvent>.FlowFileEventBatch batch)

Specified by:

getTransitUri in class AbstractListenEventBatchingProcessor<StandardEvent>