Package org.apache.nifi.processors.standard

Class ReplaceTextWithMapping

java.lang.Object

org.apache.nifi.components.AbstractConfigurableComponent

org.apache.nifi.processor.AbstractSessionFactoryProcessor

org.apache.nifi.processor.AbstractProcessor

org.apache.nifi.processors.standard.ReplaceTextWithMapping

All Implemented Interfaces:

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

@SideEffectFree
@SupportsBatching
@InputRequirement(INPUT_REQUIRED)
@Tags({"Text","Regular Expression","Update","Change","Replace","Modify","Regex","Mapping"})
@CapabilityDescription("Updates the content of a FlowFile by evaluating a Regular Expression against it and replacing the section of the content that matches the Regular Expression with some alternate value provided in a mapping file.")
public class ReplaceTextWithMapping
extends org.apache.nifi.processor.AbstractProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReplaceTextWithMapping.ConfigurationState
private final class	ReplaceTextWithMapping.ReplaceTextCallback

Field Summary

Fields

Modifier and Type	Field	Description
private final Pattern	backReferencePattern
static final org.apache.nifi.components.PropertyDescriptor	CHARACTER_SET
private final AtomicReference<ReplaceTextWithMapping.ConfigurationState>	configurationStateRef
private final AtomicLong	lastModified
static final org.apache.nifi.components.PropertyDescriptor	MAPPING_FILE
static final org.apache.nifi.components.PropertyDescriptor	MAPPING_FILE_REFRESH_INTERVAL
(package private) final AtomicLong	mappingTestTime
static final org.apache.nifi.components.PropertyDescriptor	MATCHING_GROUP_FOR_LOOKUP_KEY
static final org.apache.nifi.components.PropertyDescriptor	MAX_BUFFER_SIZE
private final ReentrantLock	processorLock
private static final List<org.apache.nifi.components.PropertyDescriptor>	PROPERTY_DESCRIPTORS
static final org.apache.nifi.components.PropertyDescriptor	REGEX
static final org.apache.nifi.processor.Relationship	REL_FAILURE
static final org.apache.nifi.processor.Relationship	REL_SUCCESS
private static final Set<org.apache.nifi.processor.Relationship>	RELATIONSHIPS

Constructor Summary

Constructors

Constructor	Description
ReplaceTextWithMapping()

Method Summary

Modifier and Type	Method	Description
protected Collection<org.apache.nifi.components.ValidationResult>	customValidate(org.apache.nifi.components.ValidationContext context)
protected String	fillReplacementValueBackReferences(String rawReplacementValue, int numCapturingGroups)
Set<org.apache.nifi.processor.Relationship>	getRelationships()
protected List<org.apache.nifi.components.PropertyDescriptor>	getSupportedPropertyDescriptors()
protected Map<String,String>	loadMappingFile(InputStream is)
void	onTrigger(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.processor.ProcessSession session)
private void	updateMapping(org.apache.nifi.processor.ProcessContext context)

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

onTrigger

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

getControllerServiceLookup, getIdentifier, getLogger, getNodeTypeProvider, init, 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

REGEX

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

MATCHING_GROUP_FOR_LOOKUP_KEY

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

MAPPING_FILE

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

MAPPING_FILE_REFRESH_INTERVAL

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

CHARACTER_SET

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

MAX_BUFFER_SIZE

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

PROPERTY_DESCRIPTORS

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

REL_SUCCESS

public static final org.apache.nifi.processor.Relationship REL_SUCCESS

REL_FAILURE

public static final org.apache.nifi.processor.Relationship REL_FAILURE

RELATIONSHIPS

private static final Set<org.apache.nifi.processor.Relationship> RELATIONSHIPS

backReferencePattern

private final Pattern backReferencePattern

processorLock

private final ReentrantLock processorLock

lastModified

private final AtomicLong lastModified

mappingTestTime

final AtomicLong mappingTestTime

configurationStateRef

private final AtomicReference<ReplaceTextWithMapping.ConfigurationState> configurationStateRef

Constructor Details

ReplaceTextWithMapping

public ReplaceTextWithMapping()

Method Details

customValidate

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

Overrides:

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

getSupportedPropertyDescriptors

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

Overrides:

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

getRelationships

public Set<org.apache.nifi.processor.Relationship> getRelationships()

Specified by:

getRelationships in interface org.apache.nifi.processor.Processor

Overrides:

getRelationships in class org.apache.nifi.processor.AbstractSessionFactoryProcessor

onTrigger

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

Specified by:

onTrigger in class org.apache.nifi.processor.AbstractProcessor

Throws:

org.apache.nifi.processor.exception.ProcessException

fillReplacementValueBackReferences

protected String fillReplacementValueBackReferences(String rawReplacementValue,
 int numCapturingGroups)

updateMapping

private void updateMapping(org.apache.nifi.processor.ProcessContext context)

loadMappingFile

protected Map<String,String> loadMappingFile(InputStream is)
                                      throws IOException

Throws:

IOException