Package org.apache.nifi.processor.util

Class FlowFileFilters

java.lang.Object

org.apache.nifi.processor.util.FlowFileFilters

public class FlowFileFilters
extends Object

Constructor Summary

Constructors

Constructor	Description
FlowFileFilters()

Method Summary

Modifier and Type	Method	Description
static org.apache.nifi.processor.FlowFileFilter	newSizeBasedFilter(double maxSize, org.apache.nifi.processor.DataUnit unit, int maxCount)	Returns a new FlowFileFilter that will pull FlowFiles until the maximum file size has been reached, or the maximum FlowFile Count was been reached (this is important because FlowFiles may be 0 bytes!).

Methods inherited from class java.lang.Object

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

Constructor Details

FlowFileFilters

public FlowFileFilters()

Method Details

newSizeBasedFilter

public static org.apache.nifi.processor.FlowFileFilter newSizeBasedFilter(double maxSize,
 org.apache.nifi.processor.DataUnit unit,
 int maxCount)

Returns a new FlowFileFilter that will pull FlowFiles until the maximum file size has been reached, or the maximum FlowFile Count was been reached (this is important because FlowFiles may be 0 bytes!). If the first FlowFile exceeds the max size, the FlowFile will be selected and no other FlowFile will be.

Parameters:

maxSize - the maximum size of the group of FlowFiles

unit - the unit of the maxSize argument

maxCount - the maximum number of FlowFiles to pull

Returns:

filter