Package org.apache.nifi.processors.standard

Class PutSQL.TransactionalFlowFileFilter

java.lang.Object

org.apache.nifi.processors.standard.PutSQL.TransactionalFlowFileFilter

All Implemented Interfaces:

org.apache.nifi.processor.FlowFileFilter

Enclosing class:

PutSQL

static class PutSQL.TransactionalFlowFileFilter
extends Object
implements org.apache.nifi.processor.FlowFileFilter

A FlowFileFilter that is responsible for ensuring that the FlowFiles returned either belong to the same "fragmented transaction" (i.e., 1 transaction whose information is fragmented across multiple FlowFiles) or that none of the FlowFiles belongs to a fragmented transaction

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 boolean	ignoreFragmentIdentifiers
private final org.apache.nifi.processor.FlowFileFilter	nonFragmentedTransactionFilter
private int	numSelected
private String	selectedId

Constructor Summary

Constructors

Constructor	Description
TransactionalFlowFileFilter(org.apache.nifi.processor.FlowFileFilter nonFragmentedTransactionFilter)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

nonFragmentedTransactionFilter

private final org.apache.nifi.processor.FlowFileFilter nonFragmentedTransactionFilter

selectedId

private String selectedId

numSelected

private int numSelected

ignoreFragmentIdentifiers

private boolean ignoreFragmentIdentifiers

Constructor Details

TransactionalFlowFileFilter

public TransactionalFlowFileFilter(org.apache.nifi.processor.FlowFileFilter nonFragmentedTransactionFilter)

Method Details

isFragmentedTransaction

public boolean isFragmentedTransaction()

filterNonFragmentedTransaction

private org.apache.nifi.processor.FlowFileFilter.FlowFileFilterResult filterNonFragmentedTransaction(org.apache.nifi.flowfile.FlowFile flowFile)

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