org.apache.nifi.processors

Class AbstractEnrichIP

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.AbstractProcessor

org.apache.nifi.processors.AbstractEnrichIP

All Implemented Interfaces:

ConfigurableComponent, Processor

Direct Known Subclasses:

GeoEnrichIP, ISPEnrichIP

public abstract class AbstractEnrichIP
extends AbstractProcessor

Field Summary

Fields

Modifier and Type	Field and Description
static PropertyDescriptor	GEO_DATABASE_FILE
static PropertyDescriptor	IP_ADDRESS_ATTRIBUTE
static Relationship	REL_FOUND
static Relationship	REL_NOT_FOUND

Constructor Summary

Constructors

Constructor and Description
AbstractEnrichIP()

Method Summary

Modifier and Type	Method and Description
void	closeReader()
java.util.Set<Relationship>	getRelationships()
protected java.util.List<PropertyDescriptor>	getSupportedPropertyDescriptors() Allows subclasses to register which property descriptor objects are supported.
protected void	init(ProcessorInitializationContext context) Provides subclasses the ability to perform initialization logic
void	onScheduled(ProcessContext context)

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

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

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

Field Detail

GEO_DATABASE_FILE

public static final PropertyDescriptor GEO_DATABASE_FILE

IP_ADDRESS_ATTRIBUTE

public static final PropertyDescriptor IP_ADDRESS_ATTRIBUTE

REL_FOUND

public static final Relationship REL_FOUND

REL_NOT_FOUND

public static final Relationship REL_NOT_FOUND

Constructor Detail

AbstractEnrichIP

public AbstractEnrichIP()

Method Detail

getRelationships

public java.util.Set<Relationship> getRelationships()

Specified by:

getRelationships in interface Processor

Overrides:

getRelationships in class AbstractSessionFactoryProcessor

Returns:

Set of all relationships this processor expects to transfer a flow file to. An empty set indicates this processor does not have any destination relationships. Guaranteed non null.

getSupportedPropertyDescriptors

protected java.util.List<PropertyDescriptor> getSupportedPropertyDescriptors()

Description copied from class: AbstractConfigurableComponent

Allows subclasses to register which property descriptor objects are supported. Default return is an empty set.

Overrides:

getSupportedPropertyDescriptors in class AbstractConfigurableComponent

Returns:

PropertyDescriptor objects this processor currently supports

onScheduled

@OnScheduled
public void onScheduled(ProcessContext context)
                              throws java.io.IOException

Throws:

java.io.IOException

closeReader

@OnStopped
public void closeReader()
                            throws java.io.IOException

Throws:

java.io.IOException

init

protected void init(ProcessorInitializationContext context)

Description copied from class: AbstractSessionFactoryProcessor

Provides subclasses the ability to perform initialization logic

Overrides:

init in class AbstractSessionFactoryProcessor

Parameters:

context - in which to perform initialization