Package org.apache.nifi.processors.standard
package org.apache.nifi.processors.standard
-
ClassDescriptionA base class for common code shared by processors that fetch RDBMS data.Provides common functionality used for processors interacting and manipulating JSON data via JsonPath.Base class for Syslog processors.This processor reads files in as text according to the specified character set and it outputs another text file according to the given character set.Implementations must be thread-safe.Output stream that is used to wrap another output stream in a way that the underlying output stream can be swapped out for a different one when neededThis processor executes an external command on the contents of a flow file, and creates a new flow file with the results of the command.Attempts to detect the MIME Type of a FlowFile by examining its contents.A processor to retrieve a list of tables (and their metadata) from a database connectionHolder class to pass around a flow file and the writer that is writing records to it.PerformanceTracker is responsible for providing a mechanism by which any disk operation can be timed and the timing information can both be used to issue warnings as well as be aggregated for some amount of time, in order to understand how long certain disk operations take and which files may be responsible for causing longer-than-usual operations to be performed.Tracks metrics using a rolling window of time, in which older metrics are 'aged off' by calling
ListFile.RollingMetricPerformanceTracker.purgeTimingInfo(long).Provides a mechanism for timing how long a particular operation takes to complete, logging if it takes longer than the configured threshold.A PerformanceTracker that is capable of tracking which disk access operation is active and which directory is actively being listed, as well as timing specific operations, but does not track metrics over any amount of time.We have this ValueWrapper class here because we want to use it as part of the key to a Map and we want two values that may or may not be arrays.A holder class for a SQL prepared statement and a BitSet indicating which columns are being updated (to determine which values from the record to set on the statement) A value of null for getIncludedColumns indicates that all columns/fields should be included.Simple string serializer, used for serializing the cache keyA simple, immutable data structure to hold a List of FlowFiles and an indicator as to whether or not those FlowFiles represent a "fragmented transaction" - that is, a collection of FlowFiles that all must be executed as a single transaction (we refer to it as a fragment transaction because the information for that transaction, including SQL and the parameters, is fragmented across multiple FlowFiles).A simple, immutable data structure to hold a Prepared Statement and a List of FlowFiles for which that statement should be evaluated.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 transactionThis processor routes a FlowFile based on its flow file attributes by using the Attribute Expression Language.A simple Java class to hold information about our state so that we can maintain this state across multiple invocations of the ProcessorThis class provide a protocol for Wait and Notify processors to work together.