Package org.apache.nifi.processors.standard

Class ReplaceTextWithMapping.ReplaceTextCallback

java.lang.Object

org.apache.nifi.processors.standard.ReplaceTextWithMapping.ReplaceTextCallback

All Implemented Interfaces:

org.apache.nifi.processor.io.StreamCallback

Enclosing class:

ReplaceTextWithMapping

private final class ReplaceTextWithMapping.ReplaceTextCallback
extends Object
implements org.apache.nifi.processor.io.StreamCallback

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	buffer
private final Charset	charset
private final org.apache.nifi.flowfile.FlowFile	flowFile
private final int	groupToMatch
private final int	numCapturingGroups
private final org.apache.nifi.expression.AttributeValueDecorator	quotedAttributeDecorator
private final String	regex

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplaceTextCallback(org.apache.nifi.processor.ProcessContext context, org.apache.nifi.flowfile.FlowFile flowFile, int maxBufferSize)

Method Summary

Modifier and Type	Method	Description
void	process(InputStream in, OutputStream out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

charset

private final Charset charset

buffer

private final byte[] buffer

regex

private final String regex

flowFile

private final org.apache.nifi.flowfile.FlowFile flowFile

numCapturingGroups

private final int numCapturingGroups

groupToMatch

private final int groupToMatch

quotedAttributeDecorator

private final org.apache.nifi.expression.AttributeValueDecorator quotedAttributeDecorator

Constructor Details

ReplaceTextCallback

private ReplaceTextCallback(org.apache.nifi.processor.ProcessContext context,
 org.apache.nifi.flowfile.FlowFile flowFile,
 int maxBufferSize)

Method Details

process

public void process(InputStream in,
 OutputStream out)
             throws IOException

Specified by:

process in interface org.apache.nifi.processor.io.StreamCallback

Throws:

IOException