Package org.apache.nifi.processors.standard

Class ControlRate.ThrottleFilter

java.lang.Object

org.apache.nifi.processors.standard.ControlRate.ThrottleFilter

All Implemented Interfaces:

org.apache.nifi.processor.FlowFileFilter

Enclosing class:

ControlRate

private class ControlRate.ThrottleFilter
extends Object
implements org.apache.nifi.processor.FlowFileFilter

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.nifi.processor.FlowFileFilter

org.apache.nifi.processor.FlowFileFilter.FlowFileFilterResult

Field Summary

Fields

Modifier and Type	Field	Description
private final LongSupplier	currentTimeSupplier
private int	flowFilesInBatch
private final int	flowFilesPerBatch

Constructor Summary

Constructors

Constructor	Description
ThrottleFilter(int maxFFPerBatch, LongSupplier currentTimeSupplier)

Method Summary

Modifier and Type	Method	Description
org.apache.nifi.processor.FlowFileFilter.FlowFileFilterResult	filter(org.apache.nifi.flowfile.FlowFile flowFile)

Methods inherited from class java.lang.Object

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

Field Details

flowFilesPerBatch

private final int flowFilesPerBatch

currentTimeSupplier

private final LongSupplier currentTimeSupplier

flowFilesInBatch

private int flowFilesInBatch

Constructor Details

ThrottleFilter

ThrottleFilter(int maxFFPerBatch,
 LongSupplier currentTimeSupplier)

Method Details

filter

public org.apache.nifi.processor.FlowFileFilter.FlowFileFilterResult filter(org.apache.nifi.flowfile.FlowFile flowFile)

Specified by:

filter in interface org.apache.nifi.processor.FlowFileFilter