Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W X Y Z 

A

A() - Constructor for class org.apache.nifi.util.ReflectionUtilsTest.A
 
ABORT - Static variable in class org.apache.nifi.distributed.cache.protocol.ProtocolHandshake
 
ABORT - Static variable in class org.apache.nifi.remote.RemoteResourceInitiator
 
abort() - Method in class org.apache.nifi.util.hive.HiveWriter
Aborts the current Txn and switches to next Txn.
abortAndCloseWriters() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming
 
abortS3MultipartUpload(AmazonS3Client, String, MultipartUpload) - Method in class org.apache.nifi.processors.aws.s3.PutS3Object
 
abortTxn() - Method in class org.apache.nifi.util.hive.HiveWriter
Aborts current Txn in the txnBatch.
AboutDTO - Class in org.apache.nifi.web.api.dto
Contains details about this NiFi including the title and version.
AboutDTO() - Constructor for class org.apache.nifi.web.api.dto.AboutDTO
 
AboutEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
AboutEntity() - Constructor for class org.apache.nifi.web.api.entity.AboutEntity
 
ABSOLUTE_HDFS_PATH_ATTRIBUTE - Static variable in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
 
AbstractAMQPProcessorTest - Class in org.apache.nifi.amqp.processors
Unit tests for the AbstractAMQPProcessor class
AbstractAMQPProcessorTest() - Constructor for class org.apache.nifi.amqp.processors.AbstractAMQPProcessorTest
 
AbstractAMQPProcessorTest.MockAbstractAMQPProcessor - Class in org.apache.nifi.amqp.processors
Provides a stubbed processor instance for testing
AbstractAWSCredentialsProviderProcessor<ClientType extends com.amazonaws.AmazonWebServiceClient> - Class in org.apache.nifi.processors.aws
Base class for aws processors that uses AWSCredentialsProvider interface for creating aws clients.
AbstractAWSCredentialsProviderProcessor() - Constructor for class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor
 
AbstractAWSLambdaProcessor - Class in org.apache.nifi.processors.aws.lambda
This class is the base class for invoking aws lambda function
AbstractAWSLambdaProcessor() - Constructor for class org.apache.nifi.processors.aws.lambda.AbstractAWSLambdaProcessor
 
AbstractAWSProcessor<ClientType extends com.amazonaws.AmazonWebServiceClient> - Class in org.apache.nifi.processors.aws
Deprecated.
use AbstractAWSCredentialsProviderProcessor instead which uses credentials providers or creating aws clients
AbstractAWSProcessor() - Constructor for class org.apache.nifi.processors.aws.AbstractAWSProcessor
Deprecated.
 
AbstractAzureBlobProcessor - Class in org.apache.nifi.processors.azure
 
AbstractAzureBlobProcessor() - Constructor for class org.apache.nifi.processors.azure.AbstractAzureBlobProcessor
 
AbstractAzureProcessor - Class in org.apache.nifi.processors.azure
 
AbstractAzureProcessor() - Constructor for class org.apache.nifi.processors.azure.AbstractAzureProcessor
 
AbstractBaseKinesisProcessor<ClientType extends com.amazonaws.AmazonWebServiceClient> - Class in org.apache.nifi.processors.aws.kinesis
This class provides processor the base class for kinesis client
AbstractBaseKinesisProcessor() - Constructor for class org.apache.nifi.processors.aws.kinesis.AbstractBaseKinesisProcessor
 
AbstractBinlogEventWriter<T extends BinlogEventInfo> - Class in org.apache.nifi.cdc.mysql.event.io
An abstract base class for writing MYSQL binlog events into flow file(s), e.g.
AbstractBinlogEventWriter() - Constructor for class org.apache.nifi.cdc.mysql.event.io.AbstractBinlogEventWriter
 
AbstractBinlogTableEventWriter<T extends BinlogTableEventInfo> - Class in org.apache.nifi.cdc.mysql.event.io
An abstract base class for writing MYSQL table-related binlog events into flow file(s), e.g.
AbstractBinlogTableEventWriter() - Constructor for class org.apache.nifi.cdc.mysql.event.io.AbstractBinlogTableEventWriter
 
AbstractBooleanCredentialsStrategy - Class in org.apache.nifi.processors.aws.credentials.provider.factory.strategies
Partial implementation of CredentialsStrategy to provide support for credential strategies specified by a single boolean property.
AbstractBooleanCredentialsStrategy(String, PropertyDescriptor) - Constructor for class org.apache.nifi.processors.aws.credentials.provider.factory.strategies.AbstractBooleanCredentialsStrategy
 
AbstractBooleanCredentialsStrategy - Class in org.apache.nifi.processors.gcp.credentials.factory.strategies
Partial implementation of CredentialsStrategy to provide support for credential strategies specified by a single boolean property.
AbstractBooleanCredentialsStrategy(String, PropertyDescriptor) - Constructor for class org.apache.nifi.processors.gcp.credentials.factory.strategies.AbstractBooleanCredentialsStrategy
 
AbstractCacheServer - Class in org.apache.nifi.distributed.cache.server
 
AbstractCacheServer(String, SSLContext, int) - Constructor for class org.apache.nifi.distributed.cache.server.AbstractCacheServer
 
AbstractCassandraProcessor - Class in org.apache.nifi.processors.cassandra
AbstractCassandraProcessor is a base class for Cassandra processors and contains logic and variables common to most processors integrating with Apache Cassandra.
AbstractCassandraProcessor() - Constructor for class org.apache.nifi.processors.cassandra.AbstractCassandraProcessor
 
AbstractCassandraProcessorTest - Class in org.apache.nifi.processors.cassandra
Unit tests for the AbstractCassandraProcessor class
AbstractCassandraProcessorTest() - Constructor for class org.apache.nifi.processors.cassandra.AbstractCassandraProcessorTest
 
AbstractCassandraProcessorTest.MockAbstractCassandraProcessor - Class in org.apache.nifi.processors.cassandra
Provides a stubbed processor instance for testing
AbstractChannelReader - Class in org.apache.nifi.io.nio
 
AbstractChannelReader(String, SelectionKey, BufferPool, StreamConsumerFactory) - Constructor for class org.apache.nifi.io.nio.AbstractChannelReader
 
abstractClearConfigContext() - Method in class org.apache.nifi.controller.AbstractControllerService
 
AbstractCommunicationsSession - Class in org.apache.nifi.remote
 
AbstractCommunicationsSession() - Constructor for class org.apache.nifi.remote.AbstractCommunicationsSession
 
AbstractComparisonEvaluator - Class in org.apache.nifi.hl7.query.evaluator.comparison
 
AbstractComparisonEvaluator(Evaluator<?>, Evaluator<?>) - Constructor for class org.apache.nifi.hl7.query.evaluator.comparison.AbstractComparisonEvaluator
 
AbstractConfigurableComponent - Class in org.apache.nifi.components
 
AbstractConfigurableComponent() - Constructor for class org.apache.nifi.components.AbstractConfigurableComponent
 
AbstractConfiguredComponent - Class in org.apache.nifi.controller
 
AbstractConfiguredComponent(String, ValidationContextFactory, ControllerServiceProvider, String, String, ComponentVariableRegistry, ReloadComponent, boolean) - Constructor for class org.apache.nifi.controller.AbstractConfiguredComponent
 
AbstractControllerService - Class in org.apache.nifi.controller
 
AbstractControllerService() - Constructor for class org.apache.nifi.controller.AbstractControllerService
 
AbstractCouchbaseProcessor - Class in org.apache.nifi.processors.couchbase
Provides common functionalities for Couchbase processors.
AbstractCouchbaseProcessor() - Constructor for class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
 
AbstractCredentialsStrategy - Class in org.apache.nifi.processors.aws.credentials.provider.factory.strategies
Partial implementation of CredentialsStrategy to support most simple property-based strategies.
AbstractCredentialsStrategy(String, PropertyDescriptor[]) - Constructor for class org.apache.nifi.processors.aws.credentials.provider.factory.strategies.AbstractCredentialsStrategy
 
AbstractCredentialsStrategy - Class in org.apache.nifi.processors.gcp.credentials.factory.strategies
Partial implementation of CredentialsStrategy to support most simple property-based strategies.
AbstractCredentialsStrategy(String, PropertyDescriptor[]) - Constructor for class org.apache.nifi.processors.gcp.credentials.factory.strategies.AbstractCredentialsStrategy
 
AbstractDatabaseFetchProcessor - Class in org.apache.nifi.processors.standard
A base class for common code shared by processors that fetch RDBMS data.
AbstractDatabaseFetchProcessor() - Constructor for class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
 
AbstractDynamoDBProcessor - Class in org.apache.nifi.processors.aws.dynamodb
Base class for NiFi dynamo db related processors
AbstractDynamoDBProcessor() - Constructor for class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
 
AbstractDynamoDBTest - Class in org.apache.nifi.processors.aws.dynamodb
Provides reused elements and utilities for the AWS DynamoDB related tests
AbstractDynamoDBTest() - Constructor for class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBTest
 
AbstractElasticsearchHttpProcessor - Class in org.apache.nifi.processors.elasticsearch
A base class for Elasticsearch processors that use the HTTP API
AbstractElasticsearchHttpProcessor() - Constructor for class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchHttpProcessor
 
AbstractElasticsearchProcessor - Class in org.apache.nifi.processors.elasticsearch
A base class for all Elasticsearch processors
AbstractElasticsearchProcessor() - Constructor for class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchProcessor
 
AbstractElasticsearchTransportClientProcessor - Class in org.apache.nifi.processors.elasticsearch
 
AbstractElasticsearchTransportClientProcessor() - Constructor for class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchTransportClientProcessor
 
AbstractEnrichIP - Class in org.apache.nifi.processors
 
AbstractEnrichIP() - Constructor for class org.apache.nifi.processors.AbstractEnrichIP
 
AbstractEnrichProcessor - Class in org.apache.nifi.processors.enrich
 
AbstractEnrichProcessor() - Constructor for class org.apache.nifi.processors.enrich.AbstractEnrichProcessor
 
AbstractEventWriter<T extends EventInfo> - Class in org.apache.nifi.cdc.event.io
An abstract class that outputs common information (event type, timestamp, e.g.) about CDC events.
AbstractEventWriter() - Constructor for class org.apache.nifi.cdc.event.io.AbstractEventWriter
 
AbstractFetchHDFSRecord - Class in org.apache.nifi.processors.hadoop
Base processor for reading a data from HDFS that can be fetched into records.
AbstractFetchHDFSRecord() - Constructor for class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord
 
AbstractFlowFileServerProtocol - Class in org.apache.nifi.remote.protocol
 
AbstractFlowFileServerProtocol() - Constructor for class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
 
AbstractFlumeProcessor - Class in org.apache.nifi.processors.flume
This is a base class that is helpful when building processors interacting with Flume.
AbstractFlumeProcessor() - Constructor for class org.apache.nifi.processors.flume.AbstractFlumeProcessor
 
AbstractGCPProcessor<CloudService extends com.google.cloud.Service<CloudServiceOptions>,CloudServiceRpc,CloudServiceOptions extends com.google.cloud.HttpServiceOptions<CloudService,CloudServiceRpc,CloudServiceOptions>> - Class in org.apache.nifi.processors.gcp
Abstract base class for gcp processors.
AbstractGCPProcessor() - Constructor for class org.apache.nifi.processors.gcp.AbstractGCPProcessor
 
AbstractGCSIT - Class in org.apache.nifi.processors.gcp.storage
Base class for GCS Integration Tests.
AbstractGCSIT() - Constructor for class org.apache.nifi.processors.gcp.storage.AbstractGCSIT
 
AbstractGCSProcessor - Class in org.apache.nifi.processors.gcp.storage
Base class for creating processors which connect to Google Cloud Storage.
AbstractGCSProcessor() - Constructor for class org.apache.nifi.processors.gcp.storage.AbstractGCSProcessor
 
AbstractGCSTest - Class in org.apache.nifi.processors.gcp.storage
Base class for GCS Unit Tests.
AbstractGCSTest() - Constructor for class org.apache.nifi.processors.gcp.storage.AbstractGCSTest
 
AbstractHadoopProcessor - Class in org.apache.nifi.processors.hadoop
This is a base class that is helpful when building processors interacting with HDFS.
AbstractHadoopProcessor() - Constructor for class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
 
AbstractHadoopProcessor.HdfsResources - Class in org.apache.nifi.processors.hadoop
 
AbstractHadoopProcessor.ValidationResources - Class in org.apache.nifi.processors.hadoop
 
AbstractHadoopTest - Class in org.apache.nifi.processors.hadoop
 
AbstractHadoopTest() - Constructor for class org.apache.nifi.processors.hadoop.AbstractHadoopTest
 
AbstractHeartbeatMonitor - Class in org.apache.nifi.cluster.coordination.heartbeat
 
AbstractHeartbeatMonitor(ClusterCoordinator, NiFiProperties) - Constructor for class org.apache.nifi.cluster.coordination.heartbeat.AbstractHeartbeatMonitor
 
AbstractHiveQLProcessor - Class in org.apache.nifi.processors.hive
An abstract base class for HiveQL processors to share common data, methods, etc.
AbstractHiveQLProcessor() - Constructor for class org.apache.nifi.processors.hive.AbstractHiveQLProcessor
 
AbstractHTMLProcessor - Class in org.apache.nifi
 
AbstractHTMLProcessor() - Constructor for class org.apache.nifi.AbstractHTMLProcessor
 
AbstractHTMLTest - Class in org.apache.nifi
 
AbstractHTMLTest() - Constructor for class org.apache.nifi.AbstractHTMLTest
 
AbstractIgniteCacheProcessor - Class in org.apache.nifi.processors.ignite.cache
Base class of Ignite cache based processor
AbstractIgniteCacheProcessor() - Constructor for class org.apache.nifi.processors.ignite.cache.AbstractIgniteCacheProcessor
 
AbstractIgniteProcessor - Class in org.apache.nifi.processors.ignite
Base class for Ignite processors
AbstractIgniteProcessor() - Constructor for class org.apache.nifi.processors.ignite.AbstractIgniteProcessor
 
AbstractJettyWebSocketService - Class in org.apache.nifi.websocket.jetty
 
AbstractJettyWebSocketService() - Constructor for class org.apache.nifi.websocket.jetty.AbstractJettyWebSocketService
 
AbstractJsonPathProcessor - Class in org.apache.nifi.processors.standard
Provides common functionality used for processors interacting and manipulating JSON data via JsonPath.
AbstractJsonPathProcessor() - Constructor for class org.apache.nifi.processors.standard.AbstractJsonPathProcessor
 
AbstractJsonRowRecordReader - Class in org.apache.nifi.json
 
AbstractJsonRowRecordReader(InputStream, ComponentLog) - Constructor for class org.apache.nifi.json.AbstractJsonRowRecordReader
 
AbstractKinesisFirehoseProcessor - Class in org.apache.nifi.processors.aws.kinesis.firehose
This class provides processor the base class for kinesis firehose
AbstractKinesisFirehoseProcessor() - Constructor for class org.apache.nifi.processors.aws.kinesis.firehose.AbstractKinesisFirehoseProcessor
 
AbstractKinesisStreamProcessor - Class in org.apache.nifi.processors.aws.kinesis.stream
This class provides processor the base class for kinesis client
AbstractKinesisStreamProcessor() - Constructor for class org.apache.nifi.processors.aws.kinesis.stream.AbstractKinesisStreamProcessor
 
AbstractKudu - Class in org.apache.nifi.processors.kudu
 
AbstractKudu() - Constructor for class org.apache.nifi.processors.kudu.AbstractKudu
 
AbstractListenEventBatchingProcessor<E extends Event> - Class in org.apache.nifi.processor.util.listen
An abstract processor that extends from AbstractListenEventProcessor and adds common functionality for batching events into a single FlowFile.
AbstractListenEventBatchingProcessor() - Constructor for class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor
 
AbstractListenEventBatchingProcessor.FlowFileEventBatch - Class in org.apache.nifi.processor.util.listen
Wrapper to hold a FlowFile and the events that have been appended to it.
AbstractListenEventProcessor<E extends Event> - Class in org.apache.nifi.processor.util.listen
An abstract processor to extend from when listening for events over a channel.
AbstractListenEventProcessor() - Constructor for class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
 
AbstractListProcessor<T extends ListableEntity> - Class in org.apache.nifi.processor.util.list
An Abstract Processor that is intended to simplify the coding required in order to perform Listing operations of remote resources.
AbstractListProcessor() - Constructor for class org.apache.nifi.processor.util.list.AbstractListProcessor
 
AbstractModuleClassloaderConfigurator - Class in org.apache.nifi.script.impl
This base class provides a common implementation for the getModuleURLsForClasspath method of the ScriptEngineConfigurator interface
AbstractModuleClassloaderConfigurator() - Constructor for class org.apache.nifi.script.impl.AbstractModuleClassloaderConfigurator
 
AbstractMongoDBControllerService - Class in org.apache.nifi.mongodb
 
AbstractMongoDBControllerService() - Constructor for class org.apache.nifi.mongodb.AbstractMongoDBControllerService
 
AbstractMongoProcessor - Class in org.apache.nifi.processors.mongodb
 
AbstractMongoProcessor() - Constructor for class org.apache.nifi.processors.mongodb.AbstractMongoProcessor
 
AbstractMongoProcessorTest - Class in org.apache.nifi.processors.mongodb
 
AbstractMongoProcessorTest() - Constructor for class org.apache.nifi.processors.mongodb.AbstractMongoProcessorTest
 
AbstractMongoProcessorTest.MockAbstractMongoProcessor - Class in org.apache.nifi.processors.mongodb
Provides a stubbed processor instance for testing
AbstractMQTTProcessor - Class in org.apache.nifi.processors.mqtt.common
 
AbstractMQTTProcessor() - Constructor for class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
 
AbstractNodeProtocolSender - Class in org.apache.nifi.cluster.protocol
 
AbstractNodeProtocolSender(SocketConfiguration, ProtocolContext<ProtocolMessage>) - Constructor for class org.apache.nifi.cluster.protocol.AbstractNodeProtocolSender
 
AbstractNodeStatusEndpoint<EntityType extends Entity,DtoType> - Class in org.apache.nifi.cluster.coordination.http.endpoints
 
AbstractNodeStatusEndpoint() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.AbstractNodeStatusEndpoint
 
AbstractNotificationService - Class in org.apache.nifi.bootstrap.notification
 
AbstractNotificationService() - Constructor for class org.apache.nifi.bootstrap.notification.AbstractNotificationService
 
AbstractNumericComparison - Class in org.apache.nifi.hl7.query.evaluator.comparison
 
AbstractNumericComparison(Evaluator<?>, Evaluator<?>) - Constructor for class org.apache.nifi.hl7.query.evaluator.comparison.AbstractNumericComparison
 
abstractOnScheduled(ProcessContext) - Method in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
 
abstractOnStopped() - Method in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
 
AbstractPolicyBasedAuthorizer - Class in org.apache.nifi.authorization
An Authorizer that provides management of users, groups, and policies.
AbstractPolicyBasedAuthorizer() - Constructor for class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
 
AbstractPort - Class in org.apache.nifi.controller
 
AbstractPort(String, String, ProcessGroup, ConnectableType, ProcessScheduler) - Constructor for class org.apache.nifi.controller.AbstractPort
 
AbstractProcessor - Class in org.apache.nifi.processor
 
AbstractProcessor() - Constructor for class org.apache.nifi.processor.AbstractProcessor
 
AbstractPutEventProcessor - Class in org.apache.nifi.processor.util.put
A base class for processors that send data to an external system using TCP or UDP.
AbstractPutEventProcessor() - Constructor for class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
 
AbstractPutEventProcessor.FlowFileMessageBatch - Class in org.apache.nifi.processor.util.put
A wrapper to hold the ranges of a FlowFile that were successful and ranges that failed, and then transfer those ranges appropriately.
AbstractPutEventProcessor.Range - Class in org.apache.nifi.processor.util.put
Represents a range of messages from a FlowFile.
AbstractPutHBase - Class in org.apache.nifi.hbase
Base class for processors that put data to HBase.
AbstractPutHBase() - Constructor for class org.apache.nifi.hbase.AbstractPutHBase
 
AbstractPutHDFSRecord - Class in org.apache.nifi.processors.hadoop
Base class for processors that write Records to HDFS.
AbstractPutHDFSRecord() - Constructor for class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
 
AbstractRecordProcessor - Class in org.apache.nifi.processors.standard
 
AbstractRecordProcessor() - Constructor for class org.apache.nifi.processors.standard.AbstractRecordProcessor
 
AbstractRecordSetWriter - Class in org.apache.nifi.serialization
 
AbstractRecordSetWriter(OutputStream) - Constructor for class org.apache.nifi.serialization.AbstractRecordSetWriter
 
AbstractRecordWriter - Class in org.apache.nifi.provenance
 
AbstractRecordWriter(File, TocWriter) - Constructor for class org.apache.nifi.provenance.AbstractRecordWriter
 
AbstractRecordWriter(String, TocWriter) - Constructor for class org.apache.nifi.provenance.AbstractRecordWriter
 
AbstractReportingTask - Class in org.apache.nifi.reporting
 
AbstractReportingTask() - Constructor for class org.apache.nifi.reporting.AbstractReportingTask
 
AbstractReportingTaskNode - Class in org.apache.nifi.controller.reporting
 
AbstractReportingTaskNode(LoggableComponent<ReportingTask>, String, ControllerServiceProvider, ProcessScheduler, ValidationContextFactory, ComponentVariableRegistry, ReloadComponent) - Constructor for class org.apache.nifi.controller.reporting.AbstractReportingTaskNode
 
AbstractReportingTaskNode(LoggableComponent<ReportingTask>, String, ControllerServiceProvider, ProcessScheduler, ValidationContextFactory, String, String, ComponentVariableRegistry, ReloadComponent, boolean) - Constructor for class org.apache.nifi.controller.reporting.AbstractReportingTaskNode
 
AbstractRouteRecord<T> - Class in org.apache.nifi.processors.standard
 
AbstractRouteRecord() - Constructor for class org.apache.nifi.processors.standard.AbstractRouteRecord
 
AbstractS3IT - Class in org.apache.nifi.processors.aws.s3
Base class for S3 Integration Tests.
AbstractS3IT() - Constructor for class org.apache.nifi.processors.aws.s3.AbstractS3IT
 
AbstractS3Processor - Class in org.apache.nifi.processors.aws.s3
 
AbstractS3Processor() - Constructor for class org.apache.nifi.processors.aws.s3.AbstractS3Processor
 
AbstractScriptedControllerService - Class in org.apache.nifi.script
An abstract class with common methods and variables for reuse among Controller Services
AbstractScriptedControllerService() - Constructor for class org.apache.nifi.script.AbstractScriptedControllerService
 
AbstractScriptedRecordFactory<T> - Class in org.apache.nifi.record.script
An abstract base class containing code common to the Scripted record reader/writer implementations
AbstractScriptedRecordFactory() - Constructor for class org.apache.nifi.record.script.AbstractScriptedRecordFactory
 
AbstractServiceAccountCredentialsStrategy - Class in org.apache.nifi.processors.gcp.credentials.factory.strategies
Abstract class handling any of the service account related credential strategies, whether provided directly to NiFi or through a flat JSON file.
AbstractServiceAccountCredentialsStrategy(String, PropertyDescriptor[]) - Constructor for class org.apache.nifi.processors.gcp.credentials.factory.strategies.AbstractServiceAccountCredentialsStrategy
 
AbstractSessionFactoryProcessor - Class in org.apache.nifi.processor
Provides a standard partial implementation of a Processor.
AbstractSessionFactoryProcessor() - Constructor for class org.apache.nifi.processor.AbstractSessionFactoryProcessor
 
AbstractSingleDTOEndpoint<EntityType extends Entity,DtoType> - Class in org.apache.nifi.cluster.coordination.http.endpoints
 
AbstractSingleDTOEndpoint() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleDTOEndpoint
 
AbstractSingleEntityEndpoint<EntityType extends Entity> - Class in org.apache.nifi.cluster.coordination.http.endpoints
 
AbstractSingleEntityEndpoint() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.AbstractSingleEntityEndpoint
 
AbstractSiteToSiteClient - Class in org.apache.nifi.remote.client
 
AbstractSiteToSiteClient(SiteToSiteClientConfig) - Constructor for class org.apache.nifi.remote.client.AbstractSiteToSiteClient
 
AbstractSiteToSiteReportingTask - Class in org.apache.nifi.reporting
Base class for ReportingTasks that send data over site-to-site.
AbstractSiteToSiteReportingTask() - Constructor for class org.apache.nifi.reporting.AbstractSiteToSiteReportingTask
 
AbstractSNSProcessor - Class in org.apache.nifi.processors.aws.sns
 
AbstractSNSProcessor() - Constructor for class org.apache.nifi.processors.aws.sns.AbstractSNSProcessor
 
AbstractSQSProcessor - Class in org.apache.nifi.processors.aws.sqs
 
AbstractSQSProcessor() - Constructor for class org.apache.nifi.processors.aws.sqs.AbstractSQSProcessor
 
AbstractStandardResource - Class in org.apache.nifi.web.standard.api
 
AbstractStandardResource() - Constructor for class org.apache.nifi.web.standard.api.AbstractStandardResource
 
AbstractStateProvider - Class in org.apache.nifi.controller.state.providers
 
AbstractStateProvider() - Constructor for class org.apache.nifi.controller.state.providers.AbstractStateProvider
 
abstractStoreConfigContext(ConfigurationContext) - Method in class org.apache.nifi.controller.AbstractControllerService
 
AbstractStreamConsumer - Class in org.apache.nifi.io.nio.consumer
 
AbstractStreamConsumer(String) - Constructor for class org.apache.nifi.io.nio.consumer.AbstractStreamConsumer
 
AbstractSyslogProcessor - Class in org.apache.nifi.processors.standard
Base class for Syslog processors.
AbstractSyslogProcessor() - Constructor for class org.apache.nifi.processors.standard.AbstractSyslogProcessor
 
AbstractTestRecordReaderWriter - Class in org.apache.nifi.provenance
 
AbstractTestRecordReaderWriter() - Constructor for class org.apache.nifi.provenance.AbstractTestRecordReaderWriter
 
AbstractTestStateProvider - Class in org.apache.nifi.controller.state.providers
Abstract class that provides a suite of test for State Providers.
AbstractTestStateProvider() - Constructor for class org.apache.nifi.controller.state.providers.AbstractTestStateProvider
 
AbstractTransaction - Class in org.apache.nifi.remote
 
AbstractTransaction(Peer, TransferDirection, boolean, FlowFileCodec, EventReporter, int, int, String) - Constructor for class org.apache.nifi.remote.AbstractTransaction
 
AbstractWebSocketGatewayProcessor - Class in org.apache.nifi.processors.websocket
 
AbstractWebSocketGatewayProcessor() - Constructor for class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
 
AbstractWebSocketGatewayProcessor.WebSocketFunction - Interface in org.apache.nifi.processors.websocket
 
AbstractWebSocketService - Class in org.apache.nifi.websocket
 
AbstractWebSocketService() - Constructor for class org.apache.nifi.websocket.AbstractWebSocketService
 
AbstractWebSocketSession - Class in org.apache.nifi.websocket
 
AbstractWebSocketSession() - Constructor for class org.apache.nifi.websocket.AbstractWebSocketSession
 
AbstractWriteDynamoDBProcessor - Class in org.apache.nifi.processors.aws.dynamodb
 
AbstractWriteDynamoDBProcessor() - Constructor for class org.apache.nifi.processors.aws.dynamodb.AbstractWriteDynamoDBProcessor
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.AttributeNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.BxmlNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.CDataSectionNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.CloseElementNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.CloseEmptyElementNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.CloseStartElementNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.ConditionalSubstitutionNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.EndOfStreamNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.EntityReferenceNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.NameStringNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.NormalSubstitutionNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.OpenStartElementNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.ProcessingInstructionDataNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.ProcessingInstructionTargetNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.RootNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.StreamStartNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.TemplateInstanceNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.TemplateNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.value.VariantTypeNode
 
accept(BxmlNodeVisitor) - Method in class org.apache.nifi.processors.evtx.parser.bxml.ValueNode
 
ACCEPT - Static variable in class org.apache.nifi.processors.standard.PostHTTP
 
ACCEPT_CONTENT_TYPE - Static variable in class org.apache.nifi.processors.standard.GetHTTP
 
ACCEPT_ENCODING - Static variable in class org.apache.nifi.processors.standard.PostHTTP
 
ACCEPT_ENCODING - Static variable in class org.apache.nifi.remote.protocol.http.HttpHeaders
 
ACCEPT_ENCODING_NAME - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
ACCEPT_ENCODING_VALUE - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
ACCEPT_HEADER_NAME - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
ACCEPT_HEADER_VALUE - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
acceptedResponse(HttpRemoteSiteListener, Object, Integer) - Method in class org.apache.nifi.web.api.ApplicationResource.ResponseCreator
 
acceptPathShouldProperlyAcceptPathsWhereTheNonLastComponentStartsWithADot() - Method in class org.apache.nifi.processors.hadoop.inotify.TestNotificationEventPathFilter
 
acceptPathShouldProperlyIgnorePathsWhereTheLastComponentStartsWithADot() - Method in class org.apache.nifi.processors.hadoop.inotify.TestNotificationEventPathFilter
 
acceptPathShouldProperlyMatchAllSubdirectoriesThatMatchWatchDirectoryAndFileFilter() - Method in class org.apache.nifi.processors.hadoop.inotify.TestNotificationEventPathFilter
 
acceptPathShouldProperlyMatchWhenWatchDirectoryMatchesPath() - Method in class org.apache.nifi.processors.hadoop.inotify.TestNotificationEventPathFilter
 
acceptShouldProperlyReturnFalseWithNullPath() - Method in class org.apache.nifi.processors.hadoop.inotify.TestNotificationEventPathFilter
 
ACCESS_KEY - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor
Deprecated.
 
ACCESS_KEY - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors
 
ACCESS_POLICIES_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.AccessPolicyEndpointMerger
 
ACCESS_POLICY_LOOKUP_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.AccessPolicyEndpointMerger
 
ACCESS_POLICY_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.AccessPolicyEndpointMerger
 
ACCESS_TOKEN - Static variable in class org.apache.nifi.processors.twitter.GetTwitter
 
ACCESS_TOKEN - Static variable in class org.apache.nifi.web.security.otp.OtpAuthenticationFilter
 
ACCESS_TOKEN_SECRET - Static variable in class org.apache.nifi.processors.twitter.GetTwitter
 
accessAttempt(Boolean) - Method in class org.apache.nifi.authorization.AuthorizationRequest.Builder
 
AccessConfigurationDTO - Class in org.apache.nifi.web.api.dto
Details for the access configuration.
AccessConfigurationDTO() - Constructor for class org.apache.nifi.web.api.dto.AccessConfigurationDTO
 
AccessConfigurationEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
AccessConfigurationEntity() - Constructor for class org.apache.nifi.web.api.entity.AccessConfigurationEntity
 
AccessControlHelper - Class in org.apache.nifi.integration.accesscontrol
Access control test for the dfm user.
AccessControlHelper() - Constructor for class org.apache.nifi.integration.accesscontrol.AccessControlHelper
 
AccessControlHelper(String) - Constructor for class org.apache.nifi.integration.accesscontrol.AccessControlHelper
 
AccessDeniedException - Exception in org.apache.nifi.authorization
Represents any error that might occur while authorizing user requests.
AccessDeniedException(Throwable) - Constructor for exception org.apache.nifi.authorization.AccessDeniedException
 
AccessDeniedException(String, Throwable) - Constructor for exception org.apache.nifi.authorization.AccessDeniedException
 
AccessDeniedException(String) - Constructor for exception org.apache.nifi.authorization.AccessDeniedException
 
AccessDeniedException() - Constructor for exception org.apache.nifi.authorization.AccessDeniedException
 
AccessDeniedExceptionMapper - Class in org.apache.nifi.web.api.config
Maps access denied exceptions into a client response.
AccessDeniedExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.AccessDeniedExceptionMapper
 
AccessibleScriptingComponentHelper - Interface in org.apache.nifi.processors.script
An interface for retrieving the scripting component helper for a scripting processor.
AccessKeyPairCredentialsStrategy - Class in org.apache.nifi.processors.aws.credentials.provider.factory.strategies
Supports AWS credentials defined by an Access Key and Secret Key pair.
AccessKeyPairCredentialsStrategy() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.factory.strategies.AccessKeyPairCredentialsStrategy
 
AccessPolicy - Class in org.apache.nifi.authorization
Defines a policy for a set of userIdentifiers to perform a set of actions on a given resource.
AccessPolicy.Builder - Class in org.apache.nifi.authorization
Builder for Access Policies.
AccessPolicyAuditor - Class in org.apache.nifi.audit
Audits policy creation/removal and configuration changes.
AccessPolicyAuditor() - Constructor for class org.apache.nifi.audit.AccessPolicyAuditor
 
AccessPolicyAuthorizable - Class in org.apache.nifi.authorization.resource
Authorizable for policies of an Authorizable.
AccessPolicyAuthorizable(Authorizable) - Constructor for class org.apache.nifi.authorization.resource.AccessPolicyAuthorizable
 
AccessPolicyDAO - Interface in org.apache.nifi.web.dao
 
AccessPolicyDTO - Class in org.apache.nifi.web.api.dto
Details for the access configuration.
AccessPolicyDTO() - Constructor for class org.apache.nifi.web.api.dto.AccessPolicyDTO
 
AccessPolicyEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
 
AccessPolicyEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.AccessPolicyEndpointMerger
 
AccessPolicyEndpointMergerTest - Class in org.apache.nifi.cluster.coordination.http.endpoints
 
AccessPolicyEndpointMergerTest() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.AccessPolicyEndpointMergerTest
 
AccessPolicyEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
AccessPolicyEntity() - Constructor for class org.apache.nifi.web.api.entity.AccessPolicyEntity
 
AccessPolicyEntityMerger - Class in org.apache.nifi.cluster.manager
 
AccessPolicyEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.AccessPolicyEntityMerger
 
AccessPolicyEntityMergerTest - Class in org.apache.nifi.cluster.manager
 
AccessPolicyEntityMergerTest() - Constructor for class org.apache.nifi.cluster.manager.AccessPolicyEntityMergerTest
 
AccessPolicyProvider - Interface in org.apache.nifi.authorization
Provides access to AccessPolicies and the configured UserGroupProvider.
AccessPolicyProviderFactory - Class in org.apache.nifi.authorization
 
AccessPolicyProviderInitializationContext - Interface in org.apache.nifi.authorization
Initialization content for AccessPolicyProviders.
AccessPolicyProviderInvocationHandler - Class in org.apache.nifi.authorization
 
AccessPolicyProviderInvocationHandler(AccessPolicyProvider, ClassLoader) - Constructor for class org.apache.nifi.authorization.AccessPolicyProviderInvocationHandler
 
AccessPolicyProviderLookup - Interface in org.apache.nifi.authorization
 
AccessPolicyResource - Class in org.apache.nifi.web.api
RESTful endpoint for managing access policies.
AccessPolicyResource(NiFiServiceFacade, Authorizer, NiFiProperties, RequestReplicator, ClusterCoordinator, FlowController) - Constructor for class org.apache.nifi.web.api.AccessPolicyResource
 
AccessPolicySummaryDTO - Class in org.apache.nifi.web.api.dto
Details for the access configuration.
AccessPolicySummaryDTO() - Constructor for class org.apache.nifi.web.api.dto.AccessPolicySummaryDTO
 
AccessPolicySummaryEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
AccessPolicySummaryEntity() - Constructor for class org.apache.nifi.web.api.entity.AccessPolicySummaryEntity
 
AccessResource - Class in org.apache.nifi.web.api
RESTful endpoint for managing access.
AccessResource() - Constructor for class org.apache.nifi.web.api.AccessResource
 
AccessStatusDTO - Class in org.apache.nifi.web.api.dto
A serialized representation of this class can be placed in the entity body of a response to the API.
AccessStatusDTO() - Constructor for class org.apache.nifi.web.api.dto.AccessStatusDTO
 
AccessStatusDTO.Status - Enum in org.apache.nifi.web.api.dto
 
AccessStatusEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
AccessStatusEntity() - Constructor for class org.apache.nifi.web.api.entity.AccessStatusEntity
 
ACCOUNT_KEY - Static variable in class org.apache.nifi.processors.azure.AzureConstants
 
ACCOUNT_NAME - Static variable in class org.apache.nifi.processors.azure.AzureConstants
 
ACK_MODE_AUTO - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
 
ACK_MODE_CLIENT - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
 
acknowledge(FlowFileRecord) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
 
acknowledge(Collection<FlowFileRecord>) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
 
acknowledge(FlowFileRecord) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
 
acknowledge(Collection<FlowFileRecord>) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
 
ACKNOWLEDGEMENT_MODE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
 
ACL - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_ALL_AUTHENTICATED_USERS - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_AUTHENTICATED_READ - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_BUCKET_OWNER_FULL_CONTROL - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_BUCKET_OWNER_READ - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_PRIVATE - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_PROJECT_PRIVATE - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
ACL_PUBLIC_READ - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject
 
acquireSender(ProcessContext, ProcessSession, FlowFile) - Method in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
Helper method to acquire an available ChannelSender from the pool.
Action - Interface in org.apache.nifi.action
An action taken on the flow by a user.
action(RequestAction) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder
Sets the action for this builder.
action(RequestAction) - Method in class org.apache.nifi.authorization.AuthorizationRequest.Builder
 
Action - Class in org.apache.nifi.update.attributes
 
Action() - Constructor for class org.apache.nifi.update.attributes.Action
 
ACTION_CREATE - Static variable in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
 
ACTION_DELETE - Static variable in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
 
ACTION_SWAPPED_IN - Static variable in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
 
ACTION_SWAPPED_OUT - Static variable in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
 
ACTION_TYPE - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
 
ACTION_TYPE_FIELD - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
 
ACTION_UPDATE - Static variable in class org.apache.nifi.controller.repository.WriteAheadRepositoryRecordSerde
 
ActionDAO - Interface in org.apache.nifi.admin.dao
Action data access.
ActionDetails - Interface in org.apache.nifi.action.details
Provides additional details about a given action.
ActionDetailsDTO - Class in org.apache.nifi.web.api.dto.action.details
 
ActionDetailsDTO() - Constructor for class org.apache.nifi.web.api.dto.action.details.ActionDetailsDTO
 
ActionDTO - Class in org.apache.nifi.update.attributes.dto
 
ActionDTO() - Constructor for class org.apache.nifi.update.attributes.dto.ActionDTO
 
ActionDTO - Class in org.apache.nifi.web.api.dto.action
An action performed in this NiFi.
ActionDTO() - Constructor for class org.apache.nifi.web.api.dto.action.ActionDTO
 
ActionEntity - Class in org.apache.nifi.update.attributes.entity
 
ActionEntity() - Constructor for class org.apache.nifi.update.attributes.entity.ActionEntity
 
ActionEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ActionEntity() - Constructor for class org.apache.nifi.web.api.entity.ActionEntity
 
activateControllerServices(HttpServletRequest, String, ActivateControllerServicesEntity) - Method in class org.apache.nifi.web.api.FlowResource
 
activateControllerServices(String, ControllerServiceState, Set<String>) - Method in class org.apache.nifi.web.dao.impl.StandardProcessGroupDAO
 
activateControllerServices(String, ControllerServiceState, Set<String>) - Method in interface org.apache.nifi.web.dao.ProcessGroupDAO
Enables or disables the controller services in the specified process group
activateControllerServices(String, ControllerServiceState, Map<String, Revision>) - Method in interface org.apache.nifi.web.NiFiServiceFacade
Enables or disables the controller services with the given IDs & Revisions on behalf of the currently logged in user
activateControllerServices(NiFiUser, String, ControllerServiceState, Map<String, Revision>) - Method in interface org.apache.nifi.web.NiFiServiceFacade
Enables or disables the controller services with the given IDs & Revisions on behalf of the given user
activateControllerServices(String, ControllerServiceState, Map<String, Revision>) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
 
activateControllerServices(NiFiUser, String, ControllerServiceState, Map<String, Revision>) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
 
activateControllerServicesAdvice(ProceedingJoinPoint, String, ControllerServiceState) - Method in class org.apache.nifi.audit.ProcessGroupAuditor
Audits the update of controller serivce state
ActivateControllerServicesEntity - Class in org.apache.nifi.web.api.entity
 
ActivateControllerServicesEntity() - Constructor for class org.apache.nifi.web.api.entity.ActivateControllerServicesEntity
 
activateLock(ProceedingJoinPoint) - Method in class org.apache.nifi.web.NiFiServiceFacadeLock
 
ACTIVE_LOCAL_CONNECTION_MODE - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
 
ACTIVE_THREADS - Static variable in interface org.apache.nifi.reporting.ambari.metrics.MetricNames
 
ACTIVE_THREADS - Static variable in interface org.apache.nifi.reporting.datadog.metrics.MetricNames
 
activeBatches - Variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
 
ACTIVEMQ_PROVIDER - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
 
ACTIVITY_RESTORED_MESSAGE - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
 
actualMetricData - Variable in class org.apache.nifi.processors.aws.cloudwatch.MockPutCloudWatchMetric
 
actualNamespace - Variable in class org.apache.nifi.processors.aws.cloudwatch.MockPutCloudWatchMetric
 
AdaptedBulletin - Class in org.apache.nifi.jaxb
 
AdaptedBulletin() - Constructor for class org.apache.nifi.jaxb.AdaptedBulletin
 
AdaptedConnectionRequest - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedConnectionRequest() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedConnectionRequest
 
AdaptedConnectionResponse - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedConnectionResponse() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedConnectionResponse
 
AdaptedCounter - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedCounter() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedCounter
 
AdaptedCounter - Class in org.apache.nifi.jaxb
 
AdaptedCounter() - Constructor for class org.apache.nifi.jaxb.AdaptedCounter
 
AdaptedDataFlow - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedDataFlow() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedDataFlow
 
AdaptedHeartbeat - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedHeartbeat() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedHeartbeat
 
AdaptedNodeBulletins - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedNodeBulletins() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedNodeBulletins
 
AdaptedNodeConnectionStatus - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedNodeConnectionStatus() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedNodeConnectionStatus
 
AdaptedNodeIdentifier - Class in org.apache.nifi.cluster.protocol.jaxb.message
 
AdaptedNodeIdentifier() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.AdaptedNodeIdentifier
 
AdaptedNodeInformation - Class in org.apache.nifi.remote.cluster
 
AdaptedNodeInformation() - Constructor for class org.apache.nifi.remote.cluster.AdaptedNodeInformation
 
add(QueueSize) - Method in class org.apache.nifi.controller.queue.QueueSize
Returns a new QueueSize that is the sum of this QueueSize and the provided QueueSize
add(FlowFileEvent) - Method in class org.apache.nifi.controller.repository.metrics.EventSumValue
 
add(EventSumValue) - Method in class org.apache.nifi.controller.repository.metrics.EventSumValue
 
add(String, FlowFile, RecordReader, ProcessSession, boolean) - Method in class org.apache.nifi.processors.standard.merge.RecordBinManager
Adds the given flowFiles to the first available bin in which it fits for the given group or creates a new bin in the specified group if necessary.
add(JmsProcessingSummary) - Method in class org.apache.nifi.processors.standard.util.JmsProcessingSummary
 
add(T) - Method in class org.apache.nifi.util.RingBuffer
Adds the given value to the RingBuffer and returns the value that was removed in order to make room.
add(T) - Method in class org.apache.nifi.util.timebuffer.TimedBuffer
 
addAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
Adds the given policy ensuring that multiple policies can not be added for the same resource and action.
addAccessPolicy(AccessPolicy) - Method in interface org.apache.nifi.authorization.ConfigurableAccessPolicyProvider
Adds the given policy ensuring that multiple policies can not be added for the same resource and action.
addAccessPolicy(AccessPolicy) - Method in class org.apache.nifi.authorization.FileAccessPolicyProvider
 
addActions(Collection<Action>) - Method in interface org.apache.nifi.admin.service.AuditService
Adds the specified actions.
addActions(Collection<Action>) - Method in class org.apache.nifi.admin.service.impl.StandardAuditService
 
AddActionsAction - Class in org.apache.nifi.admin.service.action
Adds the specified actions.
AddActionsAction(Collection<Action>) - Constructor for class org.apache.nifi.admin.service.action.AddActionsAction
 
addAll(Collection<MockFlowFile>) - Method in class org.apache.nifi.util.MockFlowFileQueue
 
addAllMetrics(Map<String, String>) - Method in class org.apache.nifi.reporting.ambari.api.MetricsBuilder
 
addAllMetrics(Map<String, String>) - Method in class org.apache.nifi.reporting.datadog.api.MetricsBuilder
 
addAndCompare(byte) - Method in class org.apache.nifi.stream.io.util.NonThreadSafeCircularBuffer
 
addAndCompare(byte) - Method in class org.apache.nifi.util.NaiveSearchRingBuffer
Add the given byte to the buffer and notify whether or not the byte completes the desired byte sequence.
addAttribute(String, String) - Method in class org.apache.nifi.controller.repository.StandardFlowFileRecord.Builder
 
addAttributes(Map<String, String>) - Method in class org.apache.nifi.controller.repository.StandardFlowFileRecord.Builder
 
addBackForSelection(SelectionKey) - Method in interface org.apache.nifi.processor.util.listen.dispatcher.AsyncChannelDispatcher
Informs the dispatcher that the connection for the given key can be added back for selection.
addBackForSelection(SelectionKey) - Method in class org.apache.nifi.processor.util.listen.dispatcher.SocketChannelDispatcher
 
addBendPoint(Position) - Method in class org.apache.nifi.connectable.StandardConnection.Builder
 
addBlockOffset(long, long) - Method in class org.apache.nifi.provenance.toc.NopTocWriter
 
addBlockOffset(long, long) - Method in class org.apache.nifi.provenance.toc.StandardTocWriter
 
addBlockOffset(long, long) - Method in interface org.apache.nifi.provenance.toc.TocWriter
Adds the given block offset as the next Block Offset in the Table of Contents
addBody(Reader) - Method in class org.apache.nifi.cluster.manager.testutils.HttpRequest.HttpRequestBuilder
 
addBulletin(Bulletin) - Method in class org.apache.nifi.events.VolatileBulletinRepository
 
addBulletin(Bulletin) - Method in interface org.apache.nifi.reporting.BulletinRepository
Adds a Bulletin to the repository.
addBulletin(Bulletin) - Method in class org.apache.nifi.util.MockBulletinRepository
 
addCheckedHeaders(Map<String, String>) - Method in class org.apache.nifi.cluster.manager.testutils.HttpServer
 
addCheckedParameters(Map<String, List<String>>) - Method in class org.apache.nifi.cluster.manager.testutils.HttpServer
 
addChildFlowFile(FlowFile) - Method in interface org.apache.nifi.provenance.ProvenanceEventBuilder
Adds the given FlowFile as a child for Events of type ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE This is valid only for ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE events and will be ignored for any other event types.
addChildFlowFile(String) - Method in interface org.apache.nifi.provenance.ProvenanceEventBuilder
Adds the given FlowFile identifier as a child for Events of type ProvenanceEventType.FORK and ProvenanceEventType.CLONE
addChildFlowFile(FlowFile) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
 
addChildFlowFile(String) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
 
addChildUuid(String) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
 
addClientConfigurationWriter(ConfigurationWriter<TlsClientConfig>) - Method in class org.apache.nifi.toolkit.tls.manager.TlsClientManager
 
addConfigurationWriter(ConfigurationWriter<TlsConfig>) - Method in class org.apache.nifi.toolkit.tls.manager.BaseTlsManager
Adds a ConfigurationWriter which will have an opportunity to write configuration information
addConnection(Connection) - Method in interface org.apache.nifi.connectable.Connectable
Adds the given connection to this Connectable.
addConnection(Connection) - Method in class org.apache.nifi.connectable.LocalPort
 
addConnection(Connection) - Method in class org.apache.nifi.controller.AbstractPort
 
addConnection(Connection) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addConnection(Connection) - Method in class org.apache.nifi.controller.StandardFunnel
 
addConnection(Connection) - Method in class org.apache.nifi.controller.StandardProcessorNode
 
addConnection(Connection) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given connection to this ProcessGroup.
addConnection(Connection) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addConnection(Relationship) - Method in class org.apache.nifi.util.MockProcessContext
 
addConnection(Relationship) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
addConnection(String) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
addConnection(Relationship) - Method in interface org.apache.nifi.util.TestRunner
Indicates to the Framework that the configured processor has a connection for the given Relationship.
addConnection(String) - Method in interface org.apache.nifi.util.TestRunner
Indicates to the Framework that the configured processor has a connection for the Relationship with the given name.
addConnections(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addControllerService(Element, ControllerServiceNode) - Method in class org.apache.nifi.controller.serialization.StandardFlowSerializer
 
addControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addControllerService(ControllerServiceNode) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given Controller Service to this group
addControllerService(ControllerServiceNode) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addControllerService(ControllerService, String) - Method in class org.apache.nifi.util.MockControllerServiceLookup
 
addControllerService(ControllerService) - Method in class org.apache.nifi.util.MockControllerServiceLookup
 
addControllerService(String, ControllerService, Map<PropertyDescriptor, String>, String) - Method in class org.apache.nifi.util.MockProcessContext
 
addControllerService(String, ControllerService) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
addControllerService(String, ControllerService, Map<String, String>) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
addControllerService(String, ControllerService) - Method in interface org.apache.nifi.util.TestRunner
Adds the given ControllerService to this TestRunner so that the configured Processor can access it using the given identifier.
addControllerService(String, ControllerService, Map<String, String>) - Method in interface org.apache.nifi.util.TestRunner
Adds the given ControllerService to this TestRunner so that the configured Processor can access it using the given identifier.
addControllerServices(MockControllerServiceLookup) - Method in class org.apache.nifi.util.MockControllerServiceLookup
 
addDatagramChannel(InetAddress, int, int) - Method in class org.apache.nifi.io.nio.ChannelListener
Binds to listen for data grams on the given local IPAddress/port
addDatagramChannel(InetAddress, int, int, String, Integer) - Method in class org.apache.nifi.io.nio.ChannelListener
Binds to listen for data grams on the given local IPAddress/port and restricts receipt of datagrams to those from the provided host and port, must specify both.
addElement(Map<String, Object>, String, String, Object, Map<String, String>) - Method in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes
Adds element to the attribute list based on the type
addEvent(FlowFileEvent) - Method in interface org.apache.nifi.controller.repository.metrics.EventContainer
 
addEvent(FlowFileEvent) - Method in class org.apache.nifi.controller.repository.metrics.SecondPrecisionEventContainer
 
addEvent(ProvenanceEventRecord, StorageSummary) - Method in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex
 
addEvent(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.store.ArrayListEventStore
 
addEvents(Map<ProvenanceEventRecord, StorageSummary>) - Method in interface org.apache.nifi.provenance.index.EventIndex
Adds the given events to the index so that they can be queried later.
addEvents(Map<ProvenanceEventRecord, StorageSummary>) - Method in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex
 
addEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.store.ArrayListEventStore
 
addEvents(Iterable<ProvenanceEventRecord>) - Method in interface org.apache.nifi.provenance.store.EventStore
Adds the given events to the store.
addEvents(Iterable<ProvenanceEventRecord>) - Method in interface org.apache.nifi.provenance.store.EventStorePartition
Adds the given events to the store
addEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.store.PartitionedEventStore
 
addEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.store.WriteAheadStorePartition
 
addFailedRange(long, long, Exception) - Method in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor.FlowFileMessageBatch
 
addFilledBuffer(ByteBuffer) - Method in class org.apache.nifi.io.nio.consumer.AbstractStreamConsumer
 
addFilledBuffer(ByteBuffer) - Method in interface org.apache.nifi.io.nio.consumer.StreamConsumer
Will be called by the thread that produces byte buffers with available data to be processed.
addFilledBuffer(ByteBuffer) - Method in class org.apache.nifi.processors.standard.util.UDPStreamConsumer
 
addFilter(byte[], byte[]) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
Causes this stream to write replaceWith in place of toReplace if ByteFilteringOutputStream.write(byte[], int, int) is called where the value to write is equal to toReplace.
addFilter(byte[], byte[], int) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
Causes this stream to write replaceWith in place of toReplace if ByteFilteringOutputStream.write(byte[], int, int) is called where the value to write is equal to toReplace.
addFilter(byte, byte) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
Causes this stream to write replaceWith in place of toReplace if ByteFilteringOutputStream.write(int) is called where the value to write is equal to toReplace.
addFilter(byte, byte, int) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
Causes this stream to write replaceWith in place of toReplace if ByteFilteringOutputStream.write(int) is called where the value to write is equal to toReplace.
addFlowChange(Action) - Method in class org.apache.nifi.util.MockEventAccess
 
addFunnel(Funnel) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addFunnel(Funnel, boolean) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addFunnel(Funnel) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given funnel to this ProcessGroup and starts it.
addFunnel(Funnel, boolean) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given funnel to this ProcessGroup and optionally starts the funnel.
addFunnel(Funnel) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addFunnel(Funnel, boolean) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addFunnels(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addGroup(Group) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
Adds a new group.
addGroup(String) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder
Adds the given group to the builder's set of groups.
addGroup(Group) - Method in class org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider
 
addGroup(Group) - Method in interface org.apache.nifi.authorization.ConfigurableUserGroupProvider
Adds a new group.
addGroup(Group) - Method in class org.apache.nifi.authorization.FileUserGroupProvider
 
addGroup(Group) - Method in class org.apache.nifi.authorization.SimpleConfigurableUserGroupProvider
 
addGroups(Set<String>) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder
Adds all the groups from the provided set to the builder's set of groups.
addHandler(ProtocolHandler) - Method in class org.apache.nifi.cluster.protocol.impl.ClusterCoordinationProtocolSenderListener
 
addHandler(ProtocolHandler) - Method in class org.apache.nifi.cluster.protocol.impl.NodeProtocolSenderListener
 
addHandler(ProtocolHandler) - Method in class org.apache.nifi.cluster.protocol.impl.SocketProtocolListener
 
addHandler(ProtocolHandler) - Method in interface org.apache.nifi.cluster.protocol.ProtocolListener
Registers a handler with the listener.
addHandler(Handler) - Method in class org.apache.nifi.processors.slack.TestServer
 
addHandler(Handler) - Method in class org.apache.nifi.processors.standard.TestServer
 
addHandler(Handler) - Method in class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon
 
addHeader(String) - Method in class org.apache.nifi.cluster.manager.testutils.HttpRequest.HttpRequestBuilder
 
addHeader(String, String) - Method in class org.apache.nifi.cluster.manager.testutils.HttpResponse
 
addHeaders(Map<String, String>) - Method in class org.apache.nifi.cluster.manager.testutils.HttpResponse
 
addIfAbsent(T, Serializer<T>) - Method in interface org.apache.nifi.distributed.cache.client.DistributedSetCacheClient
Adds the specified value to the cache, serializing the value with the given Serializer.
addIfAbsent(T, Serializer<T>) - Method in class org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService
 
addIfAbsent(ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.set.PersistentSetCache
 
addIfAbsent(ByteBuffer) - Method in interface org.apache.nifi.distributed.cache.server.set.SetCache
 
addIfAbsent(ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.set.SimpleSetCache
 
addInputPort(Port) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addInputPort(Port) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds a Port to be used for transferring FlowFiles from external sources to Processors and other Ports within this ProcessGroup.
addInputPort(Port) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addInputPorts(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
ADDITIONAL_CLASSPATH_RESOURCES - Static variable in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
 
ADDITIONAL_DETAILS_HTML - Static variable in class org.apache.nifi.documentation.html.HtmlDocumentationWriter
The filename where additional user specified information may be stored.
ADDITIONAL_METHODS - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
additionalCustomValidation(ValidationContext) - Method in class org.apache.nifi.processor.util.bin.BinFiles
Allows additional custom validation to be done.
additionalCustomValidation(ValidationContext) - Method in class org.apache.nifi.processors.solr.SolrProcessor
Allows additional custom validation to be done.
additionalCustomValidation(ValidationContext) - Method in class org.apache.nifi.processors.standard.MergeContent
 
addKey(String, SecretKey) - Method in class org.apache.nifi.security.kms.FileBasedKeyProvider
Adds the key to the provider and associates it with the given ID.
addKey(String, SecretKey) - Method in interface org.apache.nifi.security.kms.KeyProvider
Adds the key to the provider and associates it with the given ID.
addKey(String, SecretKey) - Method in class org.apache.nifi.security.kms.StaticKeyProvider
Adds the key to the provider and associates it with the given ID.
addLabel(Label) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addLabel(Label) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given Label to this ProcessGroup
addLabel(Label) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addLabels(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addLogMessage(LogLevel, String) - Method in interface org.apache.nifi.logging.LogRepository
 
addLogMessage(LogLevel, String, Throwable) - Method in interface org.apache.nifi.logging.LogRepository
 
addLogMessage(LogLevel, String, Object[]) - Method in interface org.apache.nifi.logging.LogRepository
 
addLogMessage(LogLevel, String, Object[], Throwable) - Method in interface org.apache.nifi.logging.LogRepository
 
addLogMessage(LogLevel, String) - Method in class org.apache.nifi.logging.repository.StandardLogRepository
 
addLogMessage(LogLevel, String, Throwable) - Method in class org.apache.nifi.logging.repository.StandardLogRepository
 
addLogMessage(LogLevel, String, Object[]) - Method in class org.apache.nifi.logging.repository.StandardLogRepository
 
addLogMessage(LogLevel, String, Object[], Throwable) - Method in class org.apache.nifi.logging.repository.StandardLogRepository
 
addMessage(String, GreenMailUser) - Method in class org.apache.nifi.processors.email.TestConsumeEmail
 
addNameStringNode(int, BinaryReader) - Method in class org.apache.nifi.processors.evtx.parser.ChunkHeader
 
addObserver(String, LogLevel, LogObserver) - Method in interface org.apache.nifi.logging.LogRepository
Registers an observer so that it will be notified of all Log Messages whose levels are at least equal to the given level.
addObserver(String, LogLevel, LogObserver) - Method in class org.apache.nifi.logging.repository.StandardLogRepository
 
addOptionNoArg(String, String, String) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
 
addOptionWithArg(String, String, String) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
 
addOptionWithArg(String, String, String, Object) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
 
addOrReset(FlowFileEvent) - Method in class org.apache.nifi.controller.repository.metrics.EventSum
 
addOutputPort(Port) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addOutputPort(Port) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds a Port to be used for transferring FlowFiles to external sources.
addOutputPort(Port) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addOutputPorts(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addParameter(String, String) - Method in class org.apache.nifi.cluster.manager.testutils.HttpRequest.HttpRequestBuilder
 
addParameters(String) - Method in class org.apache.nifi.cluster.manager.testutils.HttpRequest.HttpRequestBuilder
 
addParentFlowFile(FlowFile) - Method in interface org.apache.nifi.provenance.ProvenanceEventBuilder
Adds the given FlowFile as a parent for Events of type, ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE This is valid only for ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE events and will be ignored for any other event types.
addParentFlowFile(FlowFile) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
 
addParentUuid(String) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
 
addPartETag(PartETag) - Method in class org.apache.nifi.processors.aws.s3.PutS3Object.MultipartState
 
addPrivateKeyToKeyStore(KeyPair, String, Certificate...) - Method in class org.apache.nifi.toolkit.tls.manager.BaseTlsManager
Adds the private key of the KeyPair to the KeyStore and returns the entry
addProcessGroup(ProcessGroup) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addProcessGroup(ProcessGroup) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds a reference to a ProgressGroup as a child of this.
addProcessGroup(ProcessGroup) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addProcessGroups(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addProcessor(ProcessorNode) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addProcessor(ProcessorNode) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the already constructed processor instance to this group
addProcessor(ProcessorNode) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addProcessors(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addProvenanceEvent(ProvenanceEventRecord) - Method in class org.apache.nifi.util.MockEventAccess
 
addQueryExecution(Future<?>) - Method in class org.apache.nifi.provenance.AsyncQuerySubmission
 
addRecord(Object...) - Method in class org.apache.nifi.processors.kafka.pubsub.util.MockRecordParser
 
addRecord(Object...) - Method in class org.apache.nifi.serialization.record.MockRecordParser
 
addReference(ConfiguredComponent) - Method in interface org.apache.nifi.controller.service.ControllerServiceNode
Indicates that the given component is now referencing this Controller Service
addReference(ConfiguredComponent) - Method in class org.apache.nifi.controller.service.StandardControllerServiceNode
 
addRemoteProcessGroup(RemoteProcessGroup) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addRemoteProcessGroup(RemoteProcessGroup) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given RemoteProcessGroup to this ProcessGroup
addRemoteProcessGroup(RemoteProcessGroup) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addRemoteProcessGroups(Map<String, Revision>) - Method in class org.apache.nifi.controller.StandardSnippet
 
addReportEntry(FlowFileEvent) - Method in interface org.apache.nifi.controller.repository.RepositoryStatusReport
 
addReportEntry(FlowFileEvent) - Method in class org.apache.nifi.controller.repository.StandardRepositoryStatusReport
Adds an entry to the report.
addReportingTask(Element, ReportingTaskNode, StringEncryptor) - Static method in class org.apache.nifi.controller.serialization.StandardFlowSerializer
 
addRequiredPropertiesToRunner(TestRunner) - Method in class org.apache.nifi.processors.gcp.storage.AbstractGCSTest
 
addRequiredPropertiesToRunner(TestRunner) - Method in class org.apache.nifi.processors.gcp.storage.DeleteGCSObjectTest
 
addRequiredPropertiesToRunner(TestRunner) - Method in class org.apache.nifi.processors.gcp.storage.FetchGCSObjectTest
 
addRequiredPropertiesToRunner(TestRunner) - Method in class org.apache.nifi.processors.gcp.storage.ListGCSBucketTest
 
addRequiredPropertiesToRunner(TestRunner) - Method in class org.apache.nifi.processors.gcp.storage.PutGCSObjectTest
 
addResponse(ChannelResponse) - Method in interface org.apache.nifi.processor.util.listen.response.ChannelResponder
 
addResponse(ChannelResponse) - Method in class org.apache.nifi.processor.util.listen.response.socket.SocketChannelResponder
 
addResponseAction(HttpResponseAction) - Method in class org.apache.nifi.cluster.manager.testutils.HttpServer
 
addResult(String, Map<String, String>, long) - Method in class org.apache.nifi.hbase.MockHBaseClientService
 
addRootControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.FlowController
 
addRow(Object) - Method in class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter
 
addRowBatch(VectorizedRowBatch) - Method in class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter
 
addRule(Rule) - Method in class org.apache.nifi.update.attributes.Criteria
Adds the specified rule to the end of the rule collection.
addSchema(String, RecordSchema) - Method in class org.apache.nifi.serialization.record.MockSchemaRegistry
 
addSchemaField(String, RecordFieldType) - Method in class org.apache.nifi.processors.kafka.pubsub.util.MockRecordParser
 
addSchemaField(String, RecordFieldType) - Method in class org.apache.nifi.serialization.record.MockRecordParser
 
addSearchTerm(SearchTerm) - Method in class org.apache.nifi.provenance.search.Query
 
addServerSocket(InetAddress, int, int) - Method in class org.apache.nifi.io.nio.ChannelListener
Adds a server socket channel for listening to connections.
addService(DiscoverableService) - Method in interface org.apache.nifi.io.socket.multicast.ServicesBroadcaster
Adds the given service to the set of broadcasted services.
addSnippet(StandardSnippet) - Method in class org.apache.nifi.controller.SnippetManager
 
addStatusMetric(MetricDescriptor<?>, Long) - Method in class org.apache.nifi.controller.status.history.StandardStatusSnapshot
 
addStatusSnapshot(StatusSnapshot) - Method in class org.apache.nifi.controller.status.history.StandardStatusHistory
 
addStorageDirectories(Map<String, File>) - Method in class org.apache.nifi.provenance.RepositoryConfiguration
 
addStorageDirectory(String, File) - Method in class org.apache.nifi.provenance.RepositoryConfiguration
Specifies where the repository should store data
addSuccessfulRange(long, long) - Method in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor.FlowFileMessageBatch
 
addSupportedProperties(List<PropertyDescriptor>) - Method in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
Add processor specific properties.
addSupportedProperties(List<PropertyDescriptor>) - Method in class org.apache.nifi.processors.couchbase.GetCouchbaseKey
 
addSupportedProperties(List<PropertyDescriptor>) - Method in class org.apache.nifi.processors.couchbase.PutCouchbaseKey
 
addSupportedRelationships(Set<Relationship>) - Method in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
Add processor specific relationships.
addSupportedRelationships(Set<Relationship>) - Method in class org.apache.nifi.processors.couchbase.GetCouchbaseKey
 
addSupportedRelationships(Set<Relationship>) - Method in class org.apache.nifi.processors.couchbase.PutCouchbaseKey
 
addTemplate(Element, Template) - Static method in class org.apache.nifi.controller.serialization.StandardFlowSerializer
 
addTemplate(Template) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
 
addTemplate(Template) - Method in interface org.apache.nifi.groups.ProcessGroup
Adds the given template to this Process Group
addTemplate(Template) - Method in class org.apache.nifi.groups.StandardProcessGroup
 
addTemplateNode(int, BinaryReader) - Method in class org.apache.nifi.processors.evtx.parser.ChunkHeader
 
addThenQueryWithEmptyQuery() - Method in class org.apache.nifi.provenance.index.lucene.TestLuceneEventIndex
 
addTiming(String, String, long) - Method in class org.apache.nifi.cluster.coordination.http.replication.StandardAsyncClusterResponse
 
addUser(User) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
Adds the given user.
addUser(String) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder
Adds the given user to the builder's set of users.
addUser(User) - Method in class org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider
 
addUser(User) - Method in interface org.apache.nifi.authorization.ConfigurableUserGroupProvider
Adds the given user.
addUser(User) - Method in class org.apache.nifi.authorization.FileUserGroupProvider
 
addUser(String) - Method in class org.apache.nifi.authorization.Group.Builder
Adds the given user to the builder's set of users.
addUser(User) - Method in class org.apache.nifi.authorization.SimpleConfigurableUserGroupProvider
 
addUserMetadata(String, ByteBuffer) - Method in class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter
 
addUsers(Set<String>) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder
Adds all the users from the provided set to the builder's set of users.
addUsers(Set<String>) - Method in class org.apache.nifi.authorization.Group.Builder
Adds all users from the provided set to the builder's set of users.
addValidationError(ValidationError) - Method in class org.apache.nifi.schema.validation.StandardSchemaValidationResult
 
addValidator(Validator) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
 
adjust(long) - Method in interface org.apache.nifi.controller.Counter
 
adjust(long) - Method in class org.apache.nifi.controller.StandardCounter
 
adjustCounter(String, String, long) - Method in interface org.apache.nifi.controller.repository.CounterRepository
 
adjustCounter(String, String, long) - Method in class org.apache.nifi.controller.repository.StandardCounterRepository
 
adjustCounter(String, long, boolean) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
 
adjustCounter(String, long, boolean) - Method in interface org.apache.nifi.processor.ProcessSession
Adjusts counter data for the given counter name and takes care of registering the counter if not already present.
adjustCounter(String, long, boolean) - Method in class org.apache.nifi.util.MockProcessSession
 
adjustCounter(String, long) - Method in class org.apache.nifi.util.SharedSessionState
 
adjustError(BiFunction<C, ErrorTypes, ErrorTypes.Result>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler
Specify a function that adjust ErrorType based on a function context.
adjustRoute - Variable in class org.apache.nifi.processor.util.pattern.Put
 
adjustRoute(PartialFunctions.AdjustRoute<FC>) - Method in class org.apache.nifi.processor.util.pattern.Put
Specify an optional function that adjust routed FlowFiles before transfer it.
AdministrationAction<T> - Interface in org.apache.nifi.admin.service.action
Defines the administration action.
AdministrationException - Exception in org.apache.nifi.admin.service
 
AdministrationException(Throwable) - Constructor for exception org.apache.nifi.admin.service.AdministrationException
 
AdministrationException(String, Throwable) - Constructor for exception org.apache.nifi.admin.service.AdministrationException
 
AdministrationException(String) - Constructor for exception org.apache.nifi.admin.service.AdministrationException
 
AdministrationException() - Constructor for exception org.apache.nifi.admin.service.AdministrationException
 
AdministrationExceptionMapper - Class in org.apache.nifi.web.api.config
Maps administration exceptions into client responses.
AdministrationExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.AdministrationExceptionMapper
 
ADMINISTRATIVE_YIELD_DURATION - Static variable in class org.apache.nifi.util.NiFiProperties
 
AESKeyedCipherProvider - Class in org.apache.nifi.security.util.crypto
This is a standard implementation of KeyedCipherProvider which supports AES cipher families with arbitrary modes of operation (currently only CBC, CTR, and GCM are supported as EncryptionMethods.
AESKeyedCipherProvider() - Constructor for class org.apache.nifi.security.util.crypto.AESKeyedCipherProvider
 
AESProvenanceEventEncryptor - Class in org.apache.nifi.provenance
 
AESProvenanceEventEncryptor() - Constructor for class org.apache.nifi.provenance.AESProvenanceEventEncryptor
 
AESSensitivePropertyProvider - Class in org.apache.nifi.properties
 
AESSensitivePropertyProvider(String) - Constructor for class org.apache.nifi.properties.AESSensitivePropertyProvider
 
AESSensitivePropertyProvider(byte[]) - Constructor for class org.apache.nifi.properties.AESSensitivePropertyProvider
 
AESSensitivePropertyProviderFactory - Class in org.apache.nifi.properties
 
AESSensitivePropertyProviderFactory(String) - Constructor for class org.apache.nifi.properties.AESSensitivePropertyProviderFactory
 
AffectedComponentDTO - Class in org.apache.nifi.web.api.dto
 
AffectedComponentDTO() - Constructor for class org.apache.nifi.web.api.dto.AffectedComponentDTO
 
AffectedComponentEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a response to the API.
AffectedComponentEntity() - Constructor for class org.apache.nifi.web.api.entity.AffectedComponentEntity
 
AffectedComponentEntityMerger - Class in org.apache.nifi.cluster.manager
 
AffectedComponentEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.AffectedComponentEntityMerger
 
after() - Method in class org.apache.nifi.controller.MonitorMemoryTest
 
after() - Method in class org.apache.nifi.controller.scheduling.TestProcessorLifecycle
 
after() - Method in class org.apache.nifi.controller.scheduling.TestStandardProcessScheduler
 
after() - Method in class org.apache.nifi.controller.serialization.StandardFlowSerializerTest
 
after() - Method in class org.apache.nifi.mongodb.TestMongoDBControllerService
 
after() - Method in class org.apache.nifi.mongodb.TestMongoDBLookupService
 
after() - Method in class org.apache.nifi.processors.email.TestListenSMTP
 
after() - Method in class org.apache.nifi.processors.gettcp.ReceivingClientTest
 
after() - Method in class org.apache.nifi.processors.standard.TestInvokeHTTP
 
after() - Method in class org.apache.nifi.processors.standard.TestInvokeHttpSSL
 
after() - Method in class org.apache.nifi.processors.standard.TestLogMessage
 
after() - Method in class org.apache.nifi.remote.client.http.TestHttpClient
 
after(Long) - Method in class org.apache.nifi.reporting.BulletinQuery.Builder
 
afterClass() - Static method in class org.apache.nifi.processors.aws.dynamodb.ITAbstractDynamoDBTest
 
afterClass() - Static method in class org.apache.nifi.processors.kafka.GetKafkaIntegrationTests
 
afterClass() - Static method in class org.apache.nifi.processors.kafka.KafkaPublisherTest
 
afterClass() - Static method in class org.apache.nifi.processors.kafka.PutKafkaTest
 
afterClass() - Static method in class org.apache.nifi.processors.standard.TestInvokeHTTP
 
afterClass() - Static method in class org.apache.nifi.processors.standard.TestInvokeHttpSSL
 
afterExecute(Runnable, Throwable) - Method in class org.apache.nifi.engine.FlowEngine
Hook method called by the thread that executed the given runnable after execution of the runnable completed.
afterPut(FlowFile, ProcessContext, T) - Method in class org.apache.nifi.processors.standard.PutFileTransfer
 
afterPut(FlowFile, ProcessContext, FTPTransfer) - Method in class org.apache.nifi.processors.standard.PutFTP
 
afterRequest(String, String, Set<NodeResponse>) - Method in interface org.apache.nifi.cluster.coordination.http.replication.RequestCompletionCallback
Called after all NodeResponse objects have been gathered for the request
afterRequest(String, String, Set<NodeResponse>) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
Callback that is called after an HTTP Request has been replicated to nodes in the cluster.
AGE_OFF_DURATION - Static variable in class org.apache.nifi.processors.standard.DetectDuplicate
 
AGENT_NAME - Static variable in class org.apache.nifi.processors.flume.ExecuteFlumeSink
 
AGENT_NAME - Static variable in class org.apache.nifi.processors.flume.ExecuteFlumeSource
 
ageoffS3Uploads(ProcessContext, AmazonS3Client, long) - Method in class org.apache.nifi.processors.aws.s3.PutS3Object
 
aggregate(TimedCountSize, TimedCountSize) - Method in class org.apache.nifi.util.timebuffer.CountSizeEntityAccess
 
aggregate(T, T) - Method in interface org.apache.nifi.util.timebuffer.EntityAccess
 
aggregate(TimestampedLong, TimestampedLong) - Method in class org.apache.nifi.util.timebuffer.LongEntityAccess
 
AhoCorasick<T> - Class in org.apache.nifi.util.search.ahocorasick
 
AhoCorasick() - Constructor for class org.apache.nifi.util.search.ahocorasick.AhoCorasick
Constructs a new search object.
algorithm - Variable in class org.apache.nifi.provenance.EncryptionMetadata
 
ALGORITHM - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
 
algorithmIsValid(String) - Static method in class org.apache.nifi.encrypt.StringEncryptor
 
ALIAS - Static variable in class org.apache.nifi.security.util.KeyStoreUtilsTest
 
AllAttributesEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection
 
AllAttributesEvaluator(BooleanEvaluator, MultiAttributeEvaluator) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.AllAttributesEvaluator
 
ALLOW_DELETE - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
ALLOW_GET - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
ALLOW_HEAD - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
ALLOW_OPTIONS - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
ALLOW_POST - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
ALLOW_PUT - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
 
ALLOW_WEAK_CRYPTO - Static variable in class org.apache.nifi.processors.standard.EncryptContent
 
ALLOWABLE_VALUE_CLEAN_SESSION_FALSE - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_CLEAN_SESSION_TRUE - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_MQTT_VERSION_310 - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_MQTT_VERSION_311 - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_MQTT_VERSION_AUTO - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_NUMBER - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
 
ALLOWABLE_VALUE_QOS_0 - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_QOS_1 - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_QOS_2 - Static variable in class org.apache.nifi.processors.mqtt.common.MqttConstants
 
ALLOWABLE_VALUE_STRING - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
 
AllowableValue - Class in org.apache.nifi.components
Represents a valid value for a PropertyDescriptor
AllowableValue(String) - Constructor for class org.apache.nifi.components.AllowableValue
Constructs a new AllowableValue with the given value and and the same display name and no description.
AllowableValue(String, String) - Constructor for class org.apache.nifi.components.AllowableValue
Constructs a new AllowableValue with the given value and display name and no description
AllowableValue(String, String, String) - Constructor for class org.apache.nifi.components.AllowableValue
Constructs a new AllowableValue with the given value, display name, and description
AllowableValueDTO - Class in org.apache.nifi.web.api.dto
The allowable values for a property with a constrained set of options.
AllowableValueDTO() - Constructor for class org.apache.nifi.web.api.dto.AllowableValueDTO
 
AllowableValueEntity - Class in org.apache.nifi.web.api.entity
A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
AllowableValueEntity() - Constructor for class org.apache.nifi.web.api.entity.AllowableValueEntity
 
AllowableValueEntityMerger - Class in org.apache.nifi.cluster.manager
 
AllowableValueEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.AllowableValueEntityMerger
 
allowableValues(Set<String>) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
 
allowableValues(E[]) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
 
allowableValues(String...) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
 
allowableValues(AllowableValue...) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
Sets the Allowable Values for this Property
allowableValues() - Static method in enum org.apache.nifi.processors.hadoop.CompressionType
 
allowableValues(Map<String, String>) - Method in class org.apache.nifi.web.ComponentDescriptor.Builder
 
allWriters - Variable in class org.apache.nifi.processors.hive.PutHiveStreaming
 
AlreadySubscribedException - Exception in org.apache.nifi.processors.windows.event.log
 
AlreadySubscribedException(String) - Constructor for exception org.apache.nifi.processors.windows.event.log.AlreadySubscribedException
 
ALTERNATE_FORMAT_WITH_MILLIS - Static variable in class org.apache.nifi.attribute.expression.language.evaluation.cast.DateCastEvaluator
 
ALTERNATE_FORMAT_WITHOUT_MILLIS - Static variable in class org.apache.nifi.attribute.expression.language.evaluation.cast.DateCastEvaluator
 
ALTERNATE_IDENTIFIER - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
 
ALTERNATE_IDENTIFIER - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
 
ALTERNATE_IDENTIFIER - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
 
ALTERNATE_PATTERN - Static variable in class org.apache.nifi.attribute.expression.language.evaluation.cast.DateCastEvaluator
 
AlternateIdentifierURI - Static variable in class org.apache.nifi.provenance.SearchableFields
 
AlternateKerberosUserDetailsService - Class in org.apache.nifi.web.security.kerberos
 
AlternateKerberosUserDetailsService() - Constructor for class org.apache.nifi.web.security.kerberos.AlternateKerberosUserDetailsService
 
ALWAYS_IMPACTED - Static variable in interface org.apache.nifi.attribute.expression.language.VariableImpact
 
alwaysReplace - Static variable in class org.apache.nifi.processors.standard.ReplaceText
 
amazonDynamoDBClient - Static variable in class org.apache.nifi.processors.aws.dynamodb.ITAbstractDynamoDBTest
 
AmbariReportingTask - Class in org.apache.nifi.reporting.ambari
 
AmbariReportingTask() - Constructor for class org.apache.nifi.reporting.ambari.AmbariReportingTask
 
AMP - Static variable in class org.apache.nifi.processors.evtx.parser.bxml.EntityReferenceNodeTest
 
AMQPConsumerTest - Class in org.apache.nifi.amqp.processors
 
AMQPConsumerTest() - Constructor for class org.apache.nifi.amqp.processors.AMQPConsumerTest
 
AMQPPublisherTest - Class in org.apache.nifi.amqp.processors
 
AMQPPublisherTest() - Constructor for class org.apache.nifi.amqp.processors.AMQPPublisherTest
 
AMQPUtilsTest - Class in org.apache.nifi.amqp.processors
 
AMQPUtilsTest() - Constructor for class org.apache.nifi.amqp.processors.AMQPUtilsTest
 
AndEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
 
AndEvaluator(Evaluator<Boolean>, Evaluator<Boolean>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.AndEvaluator
 
AndEvaluator - Class in org.apache.nifi.hl7.query.evaluator.logic
 
AndEvaluator(BooleanEvaluator, BooleanEvaluator) - Constructor for class org.apache.nifi.hl7.query.evaluator.logic.AndEvaluator
 
andThen(ExceptionHandler.OnError<C, I>) - Method in interface org.apache.nifi.processor.util.pattern.ExceptionHandler.OnError
 
andThen(PartialFunctions.TransferFlowFiles<FC>) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.TransferFlowFiles
 
annotationData(String) - Method in class org.apache.nifi.web.ComponentDetails.Builder
 
anonymous(Boolean) - Method in class org.apache.nifi.authorization.AuthorizationRequest.Builder
 
ANONYMOUS - Static variable in class org.apache.nifi.authorization.user.StandardNiFiUser
 
ANONYMOUS - Static variable in class org.apache.nifi.processor.Relationship
 
ANONYMOUS_IDENTITY - Static variable in class org.apache.nifi.authorization.user.StandardNiFiUser
 
AnonymousCredentialsStrategy - Class in org.apache.nifi.processors.aws.credentials.provider.factory.strategies
Supports Anonymous AWS credentials.
AnonymousCredentialsStrategy() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.factory.strategies.AnonymousCredentialsStrategy
 
anonymousFilterBean() - Method in class org.apache.nifi.web.NiFiWebApiSecurityConfiguration
 
anonymousIp(InetAddress) - Method in class org.apache.nifi.lookup.maxmind.DatabaseReader
Look up an IP address in a GeoIP2 Anonymous IP.
anonymousIp(InetAddress) - Method in class org.apache.nifi.processors.maxmind.DatabaseReader
Look up an IP address in a GeoIP2 Anonymous IP.
AnonymousIpSchema - Class in org.apache.nifi.lookup.maxmind
 
AnonymousIpSchema() - Constructor for class org.apache.nifi.lookup.maxmind.AnonymousIpSchema
 
AnyAttributeEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection
 
AnyAttributeEvaluator(BooleanEvaluator, MultiAttributeEvaluator) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.AnyAttributeEvaluator
 
anyRelationshipAvailable(Connectable) - Static method in class org.apache.nifi.util.Connectables
 
APP - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
 
APP_ID - Static variable in interface org.apache.nifi.reporting.ambari.api.MetricFields
 
APP_ID - Static variable in interface org.apache.nifi.reporting.datadog.api.MetricFields
 
append(FlowFile, OutputStreamCallback) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
 
append(FlowFile, OutputStreamCallback) - Method in interface org.apache.nifi.processor.ProcessSession
Executes the given callback against the content corresponding to the given FlowFile, such that any data written to the OutputStream of the content will be appended to the end of FlowFile.
append(FlowFile, OutputStreamCallback) - Method in class org.apache.nifi.util.MockProcessSession
 
APPEND_ELEMENT - Static variable in class org.apache.nifi.PutHTMLElement
 
APPEND_ELEMENT_VALUE - Static variable in class org.apache.nifi.GetHTMLElement
 
APPEND_RAW_MESSAGE_TO_JSON - Static variable in class org.apache.nifi.processors.standard.ParseCEF
 
APPEND_RESOLUTION - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
 
APPEND_RESOLUTION_AV - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
 
APPENDABLE_CLAIM_LENGTH_CAP - Static variable in class org.apache.nifi.controller.repository.FileSystemRepository
 
AppendEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
 
AppendEvaluator(Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.AppendEvaluator
 
appendStripe(byte[], int, int, StripeInformation, OrcProto.StripeStatistics) - Method in class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter
 
appendUserMetadata(List<OrcProto.UserMetadataItem>) - Method in class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter
 
appendValue - Static variable in class org.apache.nifi.processors.standard.ReplaceText
 
APPLICATION_FLOW_FILE_V1 - Static variable in class org.apache.nifi.processors.standard.PostHTTP
 
APPLICATION_FLOW_FILE_V1 - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
APPLICATION_FLOW_FILE_V2 - Static variable in class org.apache.nifi.processors.standard.PostHTTP
 
APPLICATION_FLOW_FILE_V2 - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
APPLICATION_FLOW_FILE_V3 - Static variable in class org.apache.nifi.processors.standard.PostHTTP
 
APPLICATION_FLOW_FILE_V3 - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
 
APPLICATION_JSON - Static variable in interface org.apache.nifi.cdc.event.io.EventWriter
 
APPLICATION_JSON - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
 
APPLICATION_XML - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
 
applicationId(String) - Method in class org.apache.nifi.reporting.ambari.api.MetricBuilder
 
applicationId(String) - Method in class org.apache.nifi.reporting.ambari.api.MetricsBuilder
 
applicationId(String) - Method in class org.apache.nifi.reporting.datadog.api.MetricBuilder
 
applicationId(String) - Method in class org.apache.nifi.reporting.datadog.api.MetricsBuilder
 
ApplicationResource - Class in org.apache.nifi.web.api
Base class for controllers.
ApplicationResource() - Constructor for class org.apache.nifi.web.api.ApplicationResource
 
ApplicationResource.ReplicationTarget - Enum in org.apache.nifi.web.api
 
ApplicationResource.ResponseCreator - Class in org.apache.nifi.web.api
 
ApplicationStartupContextListener - Class in org.apache.nifi.web.contextlistener
Application context listener for starting the application.
ApplicationStartupContextListener() - Constructor for class org.apache.nifi.web.contextlistener.ApplicationStartupContextListener
 
apply() - Method in class org.apache.nifi.cluster.manager.testutils.HttpResponseAction
 
apply(C, I, ErrorTypes.Result, Exception) - Method in interface org.apache.nifi.processor.util.pattern.ExceptionHandler.OnError
 
apply(I) - Method in interface org.apache.nifi.processor.util.pattern.ExceptionHandler.Procedure
 
apply(ProcessContext, ProcessSession, FC, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.AdjustRoute
 
apply(ProcessContext, ProcessSession, FC, C) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.Cleanup
 
apply(ProcessContext, ProcessSession, FC, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.FetchFlowFiles
 
apply(ProcessContext, ProcessSession, FC) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.InitConnection
 
apply(ProcessContext, ProcessSession, FC, C) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.OnCompleted
 
apply(ProcessContext, ProcessSession, FC, C, Exception) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.OnFailed
 
apply(ProcessContext, ProcessSession, FC, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.TransferFlowFiles
 
apply(ProcessContext, ProcessSession, FC, C, FlowFile, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.Put.PutFlowFile
 
apply(ProcessContext, ProcessSession, FC, C, List<FlowFile>, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PutGroup.GroupFlowFiles
 
apply(ProcessContext, ProcessSession, FC, C, FFG, RoutingResult) - Method in interface org.apache.nifi.processor.util.pattern.PutGroup.PutFlowFiles
 
approved() - Static method in class org.apache.nifi.authorization.AuthorizationResult
 
archive(Path) - Method in class org.apache.nifi.controller.repository.FileSystemRepository
 
archive() - Method in class org.apache.nifi.persistence.FlowConfigurationArchiveManager
Archive current flow configuration file by copying the original file to the archive directory.
ARCHIVE_DIR_NAME - Static variable in class org.apache.nifi.controller.repository.FileSystemRepository
 
areGroupsSame(String, String) - Method in class org.apache.nifi.controller.FlowController
Indicates whether or not the two ID's point to the same ProcessGroup.
ArgumentUtils - Class in org.apache.nifi.processors.standard.util
 
ArgumentUtils() - Constructor for class org.apache.nifi.processors.standard.util.ArgumentUtils
 
ARN - Static variable in class org.apache.nifi.processors.aws.sns.AbstractSNSProcessor
 
ARN_TYPE - Static variable in class org.apache.nifi.processors.aws.sns.AbstractSNSProcessor
 
ARN_TYPE_TARGET - Static variable in class org.apache.nifi.processors.aws.sns.AbstractSNSProcessor
 
ARN_TYPE_TOPIC - Static variable in class org.apache.nifi.processors.aws.sns.AbstractSNSProcessor
 
ARRAY_JSON_PATH_EXPRESSION - Static variable in class org.apache.nifi.processors.standard.SplitJson
 
ArrayDataType - Class in org.apache.nifi.serialization.record.type
 
ArrayDataType(DataType) - Constructor for class org.apache.nifi.serialization.record.type.ArrayDataType
 
ArrayIndexFieldValue - Class in org.apache.nifi.record.path
 
ArrayIndexFieldValue(Object, RecordField, FieldValue, int) - Constructor for class org.apache.nifi.record.path.ArrayIndexFieldValue
 
ArrayIndexPath - Class in org.apache.nifi.record.path.paths
 
ArrayListEventStore - Class in org.apache.nifi.provenance.store
 
ArrayListEventStore() - Constructor for class org.apache.nifi.provenance.store.ArrayListEventStore
 
ArrayManagedOutputStream - Class in org.apache.nifi.controller.repository.io
 
ArrayManagedOutputStream(MemoryManager) - Constructor for class org.apache.nifi.controller.repository.io.ArrayManagedOutputStream
 
asBoolean() - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asBoolean() - Method in interface org.apache.nifi.components.PropertyValue
 
asBoolean() - Method in class org.apache.nifi.util.MockPropertyValue
 
asBytes(String, RecordFieldType, Record, boolean, String) - Method in class org.apache.nifi.hbase.PutHBaseRecord
 
ASCII_TRANSFER_MODE - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
 
asControllerService() - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asControllerService(Class<T>) - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asControllerService() - Method in interface org.apache.nifi.components.PropertyValue
 
asControllerService(Class<T>) - Method in interface org.apache.nifi.components.PropertyValue
 
asControllerService() - Method in class org.apache.nifi.util.MockPropertyValue
 
asControllerService(Class<T>) - Method in class org.apache.nifi.util.MockPropertyValue
 
asDataSize(DataUnit) - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asDataSize(DataUnit) - Method in interface org.apache.nifi.components.PropertyValue
 
asDataSize(DataUnit) - Method in class org.apache.nifi.util.MockPropertyValue
 
asDouble() - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asDouble() - Method in interface org.apache.nifi.components.PropertyValue
 
asDouble() - Method in class org.apache.nifi.util.MockPropertyValue
 
asFloat() - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asFloat() - Method in interface org.apache.nifi.components.PropertyValue
 
asFloat() - Method in class org.apache.nifi.util.MockPropertyValue
 
asInteger() - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asInteger() - Method in interface org.apache.nifi.components.PropertyValue
 
asInteger() - Method in class org.apache.nifi.util.MockPropertyValue
 
asList() - Method in class org.apache.nifi.util.RingBuffer
 
asLong() - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asLong() - Method in interface org.apache.nifi.components.PropertyValue
 
asLong() - Method in class org.apache.nifi.util.MockPropertyValue
 
asQueryable(QueryProvider, SchemaPlus, String) - Method in class org.apache.nifi.queryrecord.FlowFileTable
 
assertAllConditionsMet(String, Predicate<MockFlowFile>) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
Asserts that all FlowFiles meet all conditions.
assertAllConditionsMet(Relationship, Predicate<MockFlowFile>) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
Asserts that all FlowFiles meet all conditions.
assertAllConditionsMet(String, Predicate<MockFlowFile>) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles meet all conditions.
assertAllConditionsMet(Relationship, Predicate<MockFlowFile>) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles meet all conditions.
assertAllFlowFiles(FlowFileValidator) - Method in class org.apache.nifi.util.MockProcessSession
Asserts that all FlowFiles that were transferred are compliant with the given validator.
assertAllFlowFiles(Relationship, FlowFileValidator) - Method in class org.apache.nifi.util.MockProcessSession
Asserts that all FlowFiles that were transferred in the given relationship are compliant with the given validator.
assertAllFlowFiles(FlowFileValidator) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFiles(Relationship, FlowFileValidator) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFiles(FlowFileValidator) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred are compliant with the given validator.
assertAllFlowFiles(Relationship, FlowFileValidator) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred in the given relationship are compliant with the given validator.
assertAllFlowFilesContainAttribute(String) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFilesContainAttribute(Relationship, String) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFilesContainAttribute(String) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred contain the given attribute.
assertAllFlowFilesContainAttribute(Relationship, String) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred to the given relationship contain the given attribute.
assertAllFlowFilesTransferred(String) - Method in class org.apache.nifi.util.MockProcessSession
Asserts that all FlowFiles that were transferred were transferred to the given relationship
assertAllFlowFilesTransferred(Relationship) - Method in class org.apache.nifi.util.MockProcessSession
Asserts that all FlowFiles that were transferred were transferred to the given relationship
assertAllFlowFilesTransferred(Relationship, int) - Method in class org.apache.nifi.util.MockProcessSession
Asserts that all FlowFiles that were transferred were transferred to the given relationship and that the number of FlowFiles transferred is equal to count
assertAllFlowFilesTransferred(String, int) - Method in class org.apache.nifi.util.MockProcessSession
Asserts that all FlowFiles that were transferred were transferred to the given relationship and that the number of FlowFiles transferred is equal to count
assertAllFlowFilesTransferred(String) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFilesTransferred(Relationship) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFilesTransferred(String, int) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFilesTransferred(Relationship, int) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertAllFlowFilesTransferred(String) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred were transferred to the given relationship
assertAllFlowFilesTransferred(Relationship) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred were transferred to the given relationship
assertAllFlowFilesTransferred(String, int) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred were transferred to the given relationship and that the number of FlowFiles transferred is equal to count
assertAllFlowFilesTransferred(Relationship, int) - Method in interface org.apache.nifi.util.TestRunner
Asserts that all FlowFiles that were transferred were transferred to the given relationship and that the number of FlowFiles transferred is equal to count
assertAttributeEquals(String, String) - Method in class org.apache.nifi.util.MockFlowFile
 
assertAttributeExists(String) - Method in class org.apache.nifi.util.MockFlowFile
 
assertAttributeNotEquals(String, String) - Method in class org.apache.nifi.util.MockFlowFile
 
assertAttributeNotExists(String) - Method in class org.apache.nifi.util.MockFlowFile
 
assertCommitted() - Method in class org.apache.nifi.util.MockProcessSession
Assert that MockProcessSession.commit() has been called
assertConnectedEvent(CountDownLatch, AtomicReference<String>, InvocationOnMock) - Method in class org.apache.nifi.websocket.jetty.TestJettyWebSocketCommunication
 
assertConsumeBinaryMessage(CountDownLatch, String, InvocationOnMock) - Method in class org.apache.nifi.websocket.jetty.TestJettyWebSocketCommunication
 
assertConsumeTextMessage(CountDownLatch, String, InvocationOnMock) - Method in class org.apache.nifi.websocket.jetty.TestJettyWebSocketCommunication
 
assertContains(String, String) - Static method in class org.apache.nifi.documentation.html.XmlValidator
 
assertContentEquals(File) - Method in class org.apache.nifi.util.MockFlowFile
Asserts that the content of this FlowFile is the same as the content of the given file
assertContentEquals(Path) - Method in class org.apache.nifi.util.MockFlowFile
Asserts that the content of this FlowFile is the same as the content of the given path
assertContentEquals(byte[]) - Method in class org.apache.nifi.util.MockFlowFile
Asserts that the content of this FlowFile is the same as the content of the given byte array
assertContentEquals(String) - Method in class org.apache.nifi.util.MockFlowFile
 
assertContentEquals(String, String) - Method in class org.apache.nifi.util.MockFlowFile
 
assertContentEquals(String, Charset) - Method in class org.apache.nifi.util.MockFlowFile
 
assertContentEquals(InputStream) - Method in class org.apache.nifi.util.MockFlowFile
Asserts that the content of this FlowFile is the same as the content of the given InputStream.
assertFlowFile(WebSocketSession, String, String, MockFlowFile, WebSocketMessage.Type) - Method in class org.apache.nifi.processors.websocket.TestListenWebSocket
 
assertFlowFile(FlowFile) - Method in interface org.apache.nifi.util.FlowFileValidator
Define a verification method to validate the given FlowFile
assertMatch(Record, GenericRecord) - Method in class org.apache.nifi.avro.TestWriteAvroResult
 
assertNodeConnects(NodeIdentifier, long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Node
Assert that the node with the given ID connects (According to this node!) within the given amount of time
assertNodeDisconnects(NodeIdentifier, long, TimeUnit) - Method in class org.apache.nifi.cluster.integration.Node
Assert that the node with the given ID disconnects (According to this node!) within the given amount of time
assertNodeIsConnected(NodeIdentifier) - Method in class org.apache.nifi.cluster.integration.Node
Asserts that the node with the given ID is currently connected (According to this node!)
assertNotCommitted() - Method in class org.apache.nifi.util.MockProcessSession
Assert that MockProcessSession.commit() has not been called
assertNotContains(String, String) - Static method in class org.apache.nifi.documentation.html.XmlValidator
 
assertNotRolledBack() - Method in class org.apache.nifi.util.MockProcessSession
Assert that MockProcessSession.rollback() has not been called
assertNotValid() - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertNotValid(ControllerService) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertNotValid() - Method in interface org.apache.nifi.util.TestRunner
Assert that the currently configured set of properties/annotation data are NOT valid
assertNotValid(ControllerService) - Method in interface org.apache.nifi.util.TestRunner
Assert that the currently configured set of properties/annotation data are NOT valid for the given Controller Service.
assertPenalizeCount(int) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertPenalizeCount(int) - Method in interface org.apache.nifi.util.TestRunner
Assert that the number of FlowFiles that were penalized is equal to the given count
assertPrivateAndPublicKeyMatch(PrivateKey, PublicKey) - Static method in class org.apache.nifi.toolkit.tls.service.TlsCertificateAuthorityTest
 
assertQueueEmpty() - Method in class org.apache.nifi.util.MockProcessSession
Assert that there are no FlowFiles left on the input queue.
assertQueueEmpty() - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertQueueEmpty() - Method in interface org.apache.nifi.util.TestRunner
Assert that there are no FlowFiles left on the input queue.
assertQueueNotEmpty() - Method in class org.apache.nifi.util.MockProcessSession
Assert that at least one FlowFile is on the input queue
assertQueueNotEmpty() - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertQueueNotEmpty() - Method in interface org.apache.nifi.util.TestRunner
Assert that there is at least one FlowFile left on the input queue.
assertRolledBack() - Method in class org.apache.nifi.util.MockProcessSession
Assert that MockProcessSession.rollback() has been called
assertStateEquals(String, String, Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that the state with the given key and scope is set to the given value, or else the test will fail
assertStateEquals(Map<String, String>, Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that the state is equal to the given values
assertStateNotEquals(Map<String, String>, Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that the state is not equal to the given values
assertStateNotEquals(String, String, Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that the state with the given key and scope is not set to the given value, or else the test will fail
assertStateNotSet(String, Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that no value is set for the given key and scope, or else the test will fail
assertStateNotSet(Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that the state was not set for the given scope
assertStateSet(String, Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that some value is set for the given key and scope, or else the test will fail
assertStateSet(Scope) - Method in class org.apache.nifi.state.MockStateManager
Ensures that the state was set for the given scope, regardless of what the value was.
assertTransferCount(Relationship, int) - Method in class org.apache.nifi.util.MockProcessSession
Assert that the number of FlowFiles transferred to the given relationship is equal to the given count
assertTransferCount(String, int) - Method in class org.apache.nifi.util.MockProcessSession
Assert that the number of FlowFiles transferred to the given relationship is equal to the given count
assertTransferCount(Relationship, int) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertTransferCount(String, int) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertTransferCount(Relationship, int) - Method in interface org.apache.nifi.util.TestRunner
Assert that the number of FlowFiles transferred to the given relationship is equal to the given count
assertTransferCount(String, int) - Method in interface org.apache.nifi.util.TestRunner
Assert that the number of FlowFiles transferred to the given relationship is equal to the given count
assertValid() - Method in class org.apache.nifi.util.MockProcessContext
 
assertValid() - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertValid(ControllerService) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
 
assertValid() - Method in interface org.apache.nifi.util.TestRunner
Assert that the currently configured set of properties/annotation data are valid
assertValid(ControllerService) - Method in interface org.apache.nifi.util.TestRunner
Assert that the currently configured set of properties/annotation data are valid for the given Controller Service.
assertXmlValid(String) - Static method in class org.apache.nifi.documentation.html.XmlValidator
 
associate(FlowFile, String, String) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
 
associate(FlowFile, String, String) - Method in interface org.apache.nifi.provenance.ProvenanceReporter
Emits a Provenance Event of type ADDINFO that provides a linkage between the given FlowFile and alternate identifier.
associate(FlowFile, String, String) - Method in class org.apache.nifi.util.MockProvenanceReporter
 
ASSUME_ROLE_ARN - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors
AWS Role Arn used for cross account access
ASSUME_ROLE_ARN - Static variable in class org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService
 
ASSUME_ROLE_EXTERNAL_ID - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors
The ExternalId used while creating aws role.
ASSUME_ROLE_NAME - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors
The role name while creating aws role
ASSUME_ROLE_NAME - Static variable in class org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService
 
ASSUME_ROLE_PROXY_HOST - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors
Assume Role Proxy variables for configuring proxy to retrieve keys
ASSUME_ROLE_PROXY_PORT - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors
 
AssumeRoleCredentialsStrategy - Class in org.apache.nifi.processors.aws.credentials.provider.factory.strategies
Supports AWS credentials via Assume Role.
AssumeRoleCredentialsStrategy() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.factory.strategies.AssumeRoleCredentialsStrategy
 
asTimePeriod(TimeUnit) - Method in class org.apache.nifi.attribute.expression.language.StandardPropertyValue
 
asTimePeriod(TimeUnit) - Method in interface org.apache.nifi.components.PropertyValue
 
asTimePeriod(TimeUnit) - Method in class org.apache.nifi.util.MockPropertyValue
 
AsyncChannelDispatcher - Interface in org.apache.nifi.processor.util.listen.dispatcher
A ChannelDispatcher that handles channels asynchronously.
AsyncClusterResponse - Interface in org.apache.nifi.cluster.coordination.http.replication
A response that is provided when an HTTP Request is made that must be federated to nodes in the cluster
AsyncLineageSubmission - Class in org.apache.nifi.provenance
 
AsyncLineageSubmission(LineageComputationType, Long, Collection<String>, int, String) - Constructor for class org.apache.nifi.provenance.AsyncLineageSubmission
 
AsyncQuerySubmission - Class in org.apache.nifi.provenance
 
AsyncQuerySubmission(Query, int, String) - Constructor for class org.apache.nifi.provenance.AsyncQuerySubmission
Constructs an AsyncQuerySubmission with the given query and the given number of steps, indicating how many results must be added to this AsyncQuerySubmission before it is considered finished
ATL_ID - Variable in class org.apache.nifi.AbstractHTMLTest
 
ATL_WEATHER_LINK - Variable in class org.apache.nifi.AbstractHTMLTest
 
ATL_WEATHER_TEXT - Variable in class org.apache.nifi.AbstractHTMLTest
 
ATOM_VALUE - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
 
AtomicCacheEntry<K,V,R> - Class in org.apache.nifi.distributed.cache.client
 
AtomicCacheEntry(K, V, R) - Constructor for class org.apache.nifi.distributed.cache.client.AtomicCacheEntry
Create new cache entry.
AtomicDistributedMapCacheClient<R> - Interface in org.apache.nifi.distributed.cache.client
This interface defines an API that can be used for interacting with a Distributed Cache that functions similarly to a Map.
ATTACH_FILE - Static variable in class org.apache.nifi.processors.standard.PutEmail
 
ATTACHMENT_ORIGINAL_FILENAME - Static variable in class org.apache.nifi.processors.email.ExtractEmailAttachments
 
ATTACHMENT_ORIGINAL_FILENAME - Static variable in class org.apache.nifi.processors.email.ExtractTNEFAttachments
 
ATTACHMENT_ORIGINAL_UUID - Static variable in class org.apache.nifi.processors.email.ExtractEmailAttachments
 
ATTACHMENT_ORIGINAL_UUID - Static variable in class org.apache.nifi.processors.email.ExtractTNEFAttachments
 
attemptAuthentication(HttpServletRequest) - Method in class org.apache.nifi.web.security.jwt.JwtAuthenticationFilter
 
attemptAuthentication(HttpServletRequest) - Method in class org.apache.nifi.web.security.knox.KnoxAuthenticationFilter
 
attemptAuthentication(HttpServletRequest) - Method in class org.apache.nifi.web.security.NiFiAuthenticationFilter
Attempt to extract an authentication attempt from the specified request.
attemptAuthentication(HttpServletRequest) - Method in class org.apache.nifi.web.security.otp.OtpAuthenticationFilter
 
attemptAuthentication(HttpServletRequest) - Method in class org.apache.nifi.web.security.x509.X509AuthenticationFilter
 
ATTR_DESCRIPTION - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_DETAIL - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
 
ATTR_EXPECTED_ORDER - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
 
ATTR_HOST - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_METRIC - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_RESULT - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
 
ATTR_SERVICE - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_STARTED_AT - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
 
ATTR_STATE - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_TAGS - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_TIME - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_TTL - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
 
ATTR_WS_CS_ID - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTR_WS_ENDPOINT_ID - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTR_WS_FAILURE_DETAIL - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTR_WS_LOCAL_ADDRESS - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTR_WS_MESSAGE_TYPE - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTR_WS_REMOTE_ADDRESS - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTR_WS_SESSION_ID - Static variable in class org.apache.nifi.processors.websocket.WebSocketProcessorAttributes
 
ATTRIBUTE_CACHE_REGEX - Static variable in class org.apache.nifi.processors.standard.Notify
 
ATTRIBUTE_COPY_KEEP_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.Wait
 
ATTRIBUTE_COPY_MODE - Static variable in class org.apache.nifi.processors.standard.Wait
 
ATTRIBUTE_COPY_REPLACE - Static variable in class org.apache.nifi.processors.standard.Wait
 
ATTRIBUTE_EXPRESSION_LANGUAGE_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
 
ATTRIBUTE_KEY - Static variable in class org.apache.nifi.GetHTMLElement
 
ATTRIBUTE_KEY - Static variable in class org.apache.nifi.ModifyHTMLElement
 
ATTRIBUTE_KEY_PROPERTY_NAME_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
 
ATTRIBUTE_KEY_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
 
ATTRIBUTE_NAME - Static variable in class org.apache.nifi.controller.repository.schema.FlowFileSchema
 
ATTRIBUTE_NAME - Static variable in class org.apache.nifi.processors.evtx.parser.bxml.AttributeNodeTest
 
ATTRIBUTE_NAME - Static variable in class org.apache.nifi.processors.standard.HashContent
 
ATTRIBUTE_NAME - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
 
ATTRIBUTE_NAME - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
 
ATTRIBUTE_NAME - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
 
ATTRIBUTE_PATTERN - Static variable in class org.apache.nifi.processors.standard.ScanAttribute
 
ATTRIBUTE_PREFIX - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
 
ATTRIBUTE_RATE - Static variable in class org.apache.nifi.processors.standard.ControlRate
 
ATTRIBUTE_RATE_VALUE - Static variable in class org.apache.nifi.processors.standard.ControlRate
 
ATTRIBUTE_STRATEGY - Static variable in class org.apache.nifi.processors.standard.merge.AttributeStrategyUtil
 
ATTRIBUTE_STRATEGY_ALL_COMMON - Static variable in class org.apache.nifi.processors.standard.merge.AttributeStrategyUtil
 
ATTRIBUTE_STRATEGY_ALL_UNIQUE - Static variable in class org.apache.nifi.processors.standard.merge.AttributeStrategyUtil
 
ATTRIBUTE_TOKEN - Static variable in class org.apache.nifi.processors.evtx.parser.bxml.BxmlNode
 
ATTRIBUTE_TYPE_SUFFIX - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
 
ATTRIBUTE_VALUE - Static variable in class org.apache.nifi.controller.repository.schema.FlowFileSchema
 
ATTRIBUTE_VALUE - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
 
ATTRIBUTE_VALUE_OPTIONAL - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
 
ATTRIBUTE_VALUE_OPTIONAL - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
 
ATTRIBUTE_VALUE_REQUIRED - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
 
ATTRIBUTE_VALUE_REQUIRED - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
 
AttributeDTO - Class in org.apache.nifi.web.api.dto.provenance
Represents a processor's attribute for a provenance event.
AttributeDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.AttributeDTO
 
AttributeEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.selection
 
AttributeEvaluator(Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.selection.AttributeEvaluator
 
AttributeExpression - Interface in org.apache.nifi.expression
Defines a type of expression language statement that can be applied parametrized by various attributes and properties as specified in each of the method calls.
AttributeExpression.ResultType - Enum in org.apache.nifi.expression
 
AttributeExpressionLanguageException - Exception in org.apache.nifi.attribute.expression.language.exception
 
AttributeExpressionLanguageException(String) - Constructor for exception org.apache.nifi.attribute.expression.language.exception.AttributeExpressionLanguageException
 
AttributeExpressionLanguageException(String, Throwable) - Constructor for exception org.apache.nifi.attribute.expression.language.exception.AttributeExpressionLanguageException
 
AttributeExpressionLanguageException(Throwable) - Constructor for exception org.apache.nifi.attribute.expression.language.exception.AttributeExpressionLanguageException
 
AttributeExpressionLanguageParsingException - Exception in org.apache.nifi.attribute.expression.language.exception
 
AttributeExpressionLanguageParsingException(String) - Constructor for exception org.apache.nifi.attribute.expression.language.exception.AttributeExpressionLanguageParsingException
 
AttributeExpressionLanguageParsingException(String, Throwable) - Constructor for exception org.apache.nifi.attribute.expression.language.exception.AttributeExpressionLanguageParsingException
 
AttributeExpressionLanguageParsingException(Throwable) - Constructor for exception org.apache.nifi.attribute.expression.language.exception.AttributeExpressionLanguageParsingException
 
AttributeNode - Class in org.apache.nifi.processors.evtx.parser.bxml
Node representing an xml attribute
AttributeNode(BinaryReader, ChunkHeader, BxmlNode) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.AttributeNode
 
AttributeNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml
 
AttributeNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.AttributeNodeTest
 
AttributeRollingWindow - Class in org.apache.nifi.processors.stateful.analysis
 
AttributeRollingWindow() - Constructor for class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
 
ATTRIBUTES - Static variable in class org.apache.nifi.controller.repository.schema.FlowFileSchema
 
ATTRIBUTES_AS_HEADERS_REGEX - Static variable in class org.apache.nifi.processors.standard.PostHTTP
 
ATTRIBUTES_LIST - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
 
ATTRIBUTES_REGEX - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
 
ATTRIBUTES_TO_IGNORE_CSV - Static variable in class org.apache.nifi.processors.standard.LogAttribute
 
ATTRIBUTES_TO_IGNORE_CSV - Static variable in class org.apache.nifi.test.processors.StubAttributeLoggerProcessor
 
ATTRIBUTES_TO_IGNORE_REGEX - Static variable in class org.apache.nifi.processors.standard.LogAttribute
 
ATTRIBUTES_TO_JMS_PROPS - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
 
ATTRIBUTES_TO_LOG_CSV - Static variable in class org.apache.nifi.processors.standard.LogAttribute
 
ATTRIBUTES_TO_LOG_CSV - Static variable in class org.apache.nifi.test.processors.StubAttributeLoggerProcessor
 
ATTRIBUTES_TO_LOG_REGEX - Static variable in class org.apache.nifi.processors.standard.LogAttribute
 
AttributesAndState - Class in org.apache.nifi.attribute.expression.language
 
AttributesAndState(Map<String, String>, Map<String, String>) - Constructor for class org.apache.nifi.attribute.expression.language.AttributesAndState
 
AttributesSentHandler() - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.AttributesSentHandler
 
AttributesToJSON - Class in org.apache.nifi.processors.standard
 
AttributesToJSON() - Constructor for class org.apache.nifi.processors.standard.AttributesToJSON
 
AttributeStrategy - Interface in org.apache.nifi.processors.standard.merge
 
AttributeStrategyUtil - Class in org.apache.nifi.processors.standard.merge
 
AttributeStrategyUtil() - Constructor for class org.apache.nifi.processors.standard.merge.AttributeStrategyUtil
 
AttributeValueDecorator - Interface in org.apache.nifi.expression
 
auditAccessAttempt(AuthorizationRequest, AuthorizationResult) - Method in interface org.apache.nifi.authorization.AuthorizationAuditor
Audits an authorization request.
auditAccessAttempt(AuthorizationRequest, AuthorizationResult) - Method in class org.apache.nifi.ranger.authorization.RangerNiFiAuthorizer
 
AuditDataSourceFactoryBean - Class in org.apache.nifi.admin
 
AuditDataSourceFactoryBean() - Constructor for class org.apache.nifi.admin.AuditDataSourceFactoryBean
 
AuditService - Interface in org.apache.nifi.admin.service
Allows NiFi actions to be audited.
auditUpdateProcessGroupConfiguration(ProceedingJoinPoint, RemoteProcessGroupDTO, RemoteProcessGroupDAO) - Method in class org.apache.nifi.audit.RemoteProcessGroupAuditor
Audits the update of remote process group configuration.
auditUpdateProcessGroupInputPortConfiguration(ProceedingJoinPoint, String, RemoteProcessGroupPortDTO, RemoteProcessGroupDAO) - Method in class org.apache.nifi.audit.RemoteProcessGroupAuditor
Audits the update of remote process group input port configuration.
auditUpdateProcessGroupOutputPortConfiguration(ProceedingJoinPoint, String, RemoteProcessGroupPortDTO, RemoteProcessGroupDAO) - Method in class org.apache.nifi.audit.RemoteProcessGroupAuditor
Audits the update of remote process group output port configuration.
authenticate(LoginCredentials) - Method in interface org.apache.nifi.authentication.LoginIdentityProvider
Authenticates the specified login credentials.
authenticate(LoginCredentials) - Method in class org.apache.nifi.integration.util.NiFiTestLoginIdentityProvider
 
authenticate(LoginCredentials) - Method in class org.apache.nifi.kerberos.KerberosProvider
 
authenticate(LoginCredentials) - Method in class org.apache.nifi.ldap.LdapProvider
 
authenticate(Route, Response) - Method in class org.apache.nifi.processors.standard.util.ProxyAuthenticator
 
authenticate(Configuration, String, String, long, ComponentLog) - Method in class org.apache.nifi.util.hive.HiveConfigurator
 
authenticate(Authentication) - Method in class org.apache.nifi.web.security.jwt.JwtAuthenticationProvider
 
authenticate(Authentication) - Method in class org.apache.nifi.web.security.knox.KnoxAuthenticationProvider
 
authenticate(Authentication) - Method in class org.apache.nifi.web.security.otp.OtpAuthenticationProvider
 
authenticate(Authentication) - Method in class org.apache.nifi.web.security.x509.X509AuthenticationProvider
 
authenticate(X509Certificate[]) - Method in class org.apache.nifi.web.security.x509.X509IdentityProvider
Authenticates the specified request by checking certificate validity.
AUTHENTICATION_CHALLENGE_HEADER_NAME - Static variable in class org.apache.nifi.web.security.kerberos.KerberosService
 
AuthenticationCredentialsNotFoundExceptionMapper - Class in org.apache.nifi.web.api.config
Maps exceptions that occur because no valid credentials were found into the corresponding response.
AuthenticationCredentialsNotFoundExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.AuthenticationCredentialsNotFoundExceptionMapper
 
AuthenticationFailedException - Exception in org.apache.nifi.util.hive
 
AuthenticationFailedException(String, Exception) - Constructor for exception org.apache.nifi.util.hive.AuthenticationFailedException
 
authenticationManagerBean() - Method in class org.apache.nifi.web.NiFiWebApiSecurityConfiguration
 
AuthenticationResponse - Class in org.apache.nifi.authentication
Authentication response for a user login attempt.
AuthenticationResponse(String, String, long, String) - Constructor for class org.apache.nifi.authentication.AuthenticationResponse
Creates an authentication response.
AUTHOR_NAME - Variable in class org.apache.nifi.AbstractHTMLTest
 
Authorizable - Interface in org.apache.nifi.authorization.resource
 
AuthorizableLookup - Interface in org.apache.nifi.authorization
 
AUTHORIZATION - Static variable in class org.apache.nifi.web.security.jwt.JwtAuthenticationFilter
 
AUTHORIZATION_HEADER_NAME - Static variable in class org.apache.nifi.web.security.kerberos.KerberosService
 
AUTHORIZATION_NEGOTIATE - Static variable in class org.apache.nifi.web.security.kerberos.KerberosService
 
AuthorizationAccessException - Exception in org.apache.nifi.authorization.exception
Represents the case when an authorization decision could not be made because the Authorizer was unable to access the underlying data store.
AuthorizationAccessException(String, Throwable) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizationAccessException
 
AuthorizationAccessException(String) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizationAccessException
 
AuthorizationAccessExceptionMapper - Class in org.apache.nifi.web.api.config
Maps authorization access exceptions into client responses.
AuthorizationAccessExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.AuthorizationAccessExceptionMapper
 
AuthorizationAuditor - Interface in org.apache.nifi.authorization
 
AuthorizationCheck - Interface in org.apache.nifi.provenance.authorization
 
AuthorizationRequest - Class in org.apache.nifi.authorization
Represents an authorization request for a given user/entity performing an action against a resource within some userContext.
AuthorizationRequest.Builder - Class in org.apache.nifi.authorization
AuthorizationRequest builder.
AuthorizationResult - Class in org.apache.nifi.authorization
Represents a decision whether authorization is granted.
AuthorizationResult.Result - Enum in org.apache.nifi.authorization
 
AuthorizationsHolder - Class in org.apache.nifi.authorization
A holder to provide atomic access to data structures.
AuthorizationsHolder(Authorizations) - Constructor for class org.apache.nifi.authorization.AuthorizationsHolder
Creates a new holder and populates all convenience authorizations data structures.
authorize(AuthorizationRequest) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer
 
authorize(AuthorizableLookup) - Method in interface org.apache.nifi.authorization.AuthorizeAccess
 
authorize(AuthorizationRequest) - Method in interface org.apache.nifi.authorization.Authorizer
Determines if the specified user/entity is authorized to access the specified resource within the given context.
authorize(Authorizer, RequestAction, NiFiUser, Map<String, String>) - Method in class org.apache.nifi.authorization.resource.AccessPolicyAuthorizable
 
authorize(Authorizer, RequestAction, NiFiUser, Map<String, String>) - Method in interface org.apache.nifi.authorization.resource.Authorizable
Authorizes the current user for the specified action on the specified resource.
authorize(Authorizer, RequestAction, NiFiUser) - Method in interface org.apache.nifi.authorization.resource.Authorizable
Authorizes the current user for the specified action on the specified resource.
authorize(Authorizer, RequestAction, NiFiUser, Map<String, String>) - Method in class org.apache.nifi.authorization.resource.DataAuthorizable
 
authorize(AuthorizationRequest) - Method in class org.apache.nifi.authorization.StandardManagedAuthorizer
 
authorize(Authorizer, RequestAction, NiFiUser, Map<String, String>) - Method in class org.apache.nifi.connectable.StandardConnection
 
authorize(Authorizer, RequestAction, NiFiUser, Map<String, String>) - Method in interface org.apache.nifi.controller.ConfiguredComponent
 
authorize(AuthorizationRequest) - Method in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer
 
authorize(AuthorizationRequest) - Method in class org.apache.nifi.integration.util.NiFiTestAuthorizer
 
authorize(ProvenanceEventRecord) - Method in interface org.apache.nifi.provenance.authorization.EventAuthorizer
Authorizes the current user for the specified action on the specified resource.
authorize(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.authorization.UserEventAuthorizer
 
authorize(ProvenanceEventRecord, NiFiUser) - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
 
authorize(ProvenanceEventRecord, NiFiUser) - Method in class org.apache.nifi.provenance.VolatileProvenanceRepository
 
authorize(AuthorizationRequest) - Method in class org.apache.nifi.ranger.authorization.RangerNiFiAuthorizer
 
AuthorizeAccess - Interface in org.apache.nifi.authorization
 
authorizeAccess(AuthorizeAccess) - Method in interface org.apache.nifi.web.NiFiServiceFacade
Authorizes access to the service facade.
authorizeAccess(AuthorizeAccess) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
 
AuthorizeControllerServiceReference - Class in org.apache.nifi.authorization
Authorizes references to Controller Services.
AuthorizeControllerServiceReference() - Constructor for class org.apache.nifi.authorization.AuthorizeControllerServiceReference
 
authorizeControllerServiceReferences(ComponentAuthorizable, Authorizer, AuthorizableLookup, boolean) - Static method in class org.apache.nifi.authorization.AuthorizeControllerServiceReference
Authorizes any referenced controller services from the specified configurable component.
authorizeControllerServiceReferences(Map<String, String>, ComponentAuthorizable, Authorizer, AuthorizableLookup) - Static method in class org.apache.nifi.authorization.AuthorizeControllerServiceReference
Authorizes the proposed properties for the specified authorizable.
AUTHORIZED_DN_PATTERN - Static variable in class org.apache.nifi.processors.standard.ListenHTTP
 
authorizeDataTransfer(AuthorizableLookup, ResourceType, String) - Method in class org.apache.nifi.web.api.DataTransferResource
Authorizes access to data transfers.
authorizeProcessGroup(ProcessGroupAuthorizable, Authorizer, AuthorizableLookup, RequestAction, boolean, boolean, boolean, boolean) - Method in class org.apache.nifi.web.api.ApplicationResource
Authorizes the specified process group.
Authorizer - Interface in org.apache.nifi.authorization
Authorizes user requests.
AUTHORIZER_CONFIGURATION_FILE - Static variable in class org.apache.nifi.util.NiFiProperties
 
AuthorizerCapabilityDetection - Class in org.apache.nifi.authorization
 
AuthorizerConfigurationContext - Interface in org.apache.nifi.authorization
 
AuthorizerContext - Annotation Type in org.apache.nifi.authorization.annotation
 
AuthorizerCreationException - Exception in org.apache.nifi.authorization.exception
Represents the exceptional case when an Authorizer fails instantiation.
AuthorizerCreationException() - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerCreationException
 
AuthorizerCreationException(String) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerCreationException
 
AuthorizerCreationException(Throwable) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerCreationException
 
AuthorizerCreationException(String, Throwable) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerCreationException
 
AuthorizerDestructionException - Exception in org.apache.nifi.authorization.exception
Represents the exceptional case when an Authorizer fails destruction.
AuthorizerDestructionException() - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerDestructionException
 
AuthorizerDestructionException(String) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerDestructionException
 
AuthorizerDestructionException(Throwable) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerDestructionException
 
AuthorizerDestructionException(String, Throwable) - Constructor for exception org.apache.nifi.authorization.exception.AuthorizerDestructionException
 
AuthorizerFactory - Class in org.apache.nifi.authorization
 
AuthorizerFactoryBean - Class in org.apache.nifi.authorization
Factory bean for loading the configured authorizer.
AuthorizerFactoryBean() - Constructor for class org.apache.nifi.authorization.AuthorizerFactoryBean
 
AuthorizerFactoryTest - Class in org.apache.nifi.authorization
 
AuthorizerFactoryTest() - Constructor for class org.apache.nifi.authorization.AuthorizerFactoryTest
 
AuthorizerInitializationContext - Interface in org.apache.nifi.authorization
Initialization content for Authorizers.
AuthorizerInvocationHandler - Class in org.apache.nifi.authorization
 
AuthorizerInvocationHandler(Authorizer, ClassLoader) - Constructor for class org.apache.nifi.authorization.AuthorizerInvocationHandler
 
AuthorizerLookup - Interface in org.apache.nifi.authorization
 
authorizeSiteToSite() - Method in class org.apache.nifi.web.api.SiteToSiteResource
Authorizes access to Site To Site details.
authorizeSnippet(SnippetAuthorizable, Authorizer, AuthorizableLookup, RequestAction, boolean, boolean) - Method in class org.apache.nifi.web.api.ApplicationResource
Authorizes the specified Snippet with the specified request action.
AuthorizingEventIterator - Class in org.apache.nifi.provenance.store.iterator
 
AuthorizingEventIterator(EventIterator, EventAuthorizer, EventTransformer) - Constructor for class org.apache.nifi.provenance.store.iterator.AuthorizingEventIterator
 
authToken - Variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchTransportClientProcessor
 
AUTO_DELETE - Static variable in class org.apache.nifi.processors.aws.sqs.GetSQS
 
AUTO_DETECT_FORMAT_NAME - Static variable in class org.apache.nifi.processors.standard.UnpackContent
 
AUTO_OFFSET_RESET - Static variable in class org.apache.nifi.processors.kafka.GetKafka
 
AUTO_RESUME_STATE - Static variable in class org.apache.nifi.util.NiFiProperties
 
AUTOCREATE_PARTITIONS - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
 
autoCreatePartitions - Variable in class org.apache.nifi.util.hive.HiveOptions
 
autoTerminateDefault(boolean) - Method in class org.apache.nifi.processor.Relationship.Builder
 
Availability - Enum in org.apache.nifi.web.util
Where a given controller service or reporting task should run.
available() - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream
 
available() - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream
 
available() - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream
 
available() - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream
 
available() - Method in class org.apache.nifi.processors.kafka.pubsub.PublisherPool
Returns the number of leases that are currently available
available() - Method in class org.apache.nifi.provenance.LoopingInputStream
 
available() - Method in class org.apache.nifi.remote.io.InterruptableInputStream
 
available() - Method in class org.apache.nifi.remote.io.socket.SocketChannelInputStream
 
available() - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
 
available() - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelInputStream
 
available() - Method in class org.apache.nifi.stream.io.LimitingInputStream
 
available() - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream
 
available() - Method in class org.apache.nifi.util.LimitingInputStream
 
availablePort() - Static method in class org.apache.nifi.remote.io.socket.NetworkUtils
Will determine the available port
availablePort() - Static method in class org.apache.nifi.snmp.processors.SNMPTestUtil
Will determine an available port.
AVRO - Static variable in class org.apache.nifi.processors.hive.SelectHiveQL
 
AVRO_FIELDNAME_VALIDATOR - Static variable in class org.apache.nifi.processors.kite.ConvertAvroSchema
Validates that the input and output fields (from dynamic properties) are all valid avro field names including "." to step into records.
AVRO_FILE_EXTENSION - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
 
AVRO_FORMAT - Static variable in class org.apache.nifi.processors.cassandra.QueryCassandra
 
AVRO_MIME_TYPE - Static variable in class org.apache.nifi.processors.hive.SelectHiveQL
 
AVRO_MIME_TYPE - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
 
AVRO_RECORD_NAME_PATTERN - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
 
AVRO_SCHEMA_ATTRIBUTE_NAME - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
 
AVRO_SCHEMA_FORMAT - Static variable in class org.apache.nifi.avro.AvroTypeUtil
 
AvroConversionException(String, IOException) - Constructor for exception org.apache.nifi.processors.kite.AvroRecordConverter.AvroConversionException
 
AvroConversionException(String) - Constructor for exception org.apache.nifi.processors.kite.AvroRecordConverter.AvroConversionException
 
AvroParquetHDFSRecordReader - Class in org.apache.nifi.processors.parquet.record
HDFSRecordReader that reads Parquet files using Avro.
AvroParquetHDFSRecordReader(ParquetReader<GenericRecord>) - Constructor for class org.apache.nifi.processors.parquet.record.AvroParquetHDFSRecordReader
 
AvroParquetHDFSRecordWriter - Class in org.apache.nifi.processors.parquet.record
HDFSRecordWriter that writes Parquet files using Avro as the schema representation.
AvroParquetHDFSRecordWriter(ParquetWriter<GenericRecord>, Schema) - Constructor for class org.apache.nifi.processors.parquet.record.AvroParquetHDFSRecordWriter
 
AvroReader - Class in org.apache.nifi.avro
 
AvroReader() - Constructor for class org.apache.nifi.avro.AvroReader
 
AvroReaderWithEmbeddedSchema - Class in org.apache.nifi.avro
 
AvroReaderWithEmbeddedSchema(InputStream) - Constructor for class org.apache.nifi.avro.AvroReaderWithEmbeddedSchema
 
AvroReaderWithExplicitSchema - Class in org.apache.nifi.avro
 
AvroReaderWithExplicitSchema(InputStream, RecordSchema, Schema) - Constructor for class org.apache.nifi.avro.AvroReaderWithExplicitSchema
 
AvroRecordConverter - Class in org.apache.nifi.processors.kite
Responsible for converting records of one Avro type to another.
AvroRecordConverter(Schema, Schema, Map<String, String>) - Constructor for class org.apache.nifi.processors.kite.AvroRecordConverter
 
AvroRecordConverter(Schema, Schema, Map<String, String>, Locale) - Constructor for class org.apache.nifi.processors.kite.AvroRecordConverter
 
AvroRecordConverter.AvroConversionException - Exception in org.apache.nifi.processors.kite
Exception thrown when Avro conversion fails.
AvroRecordReader - Class in org.apache.nifi.avro
 
AvroRecordReader() - Constructor for class org.apache.nifi.avro.AvroRecordReader
 
AvroRecordSetWriter - Class in org.apache.nifi.avro
 
AvroRecordSetWriter() - Constructor for class org.apache.nifi.avro.AvroRecordSetWriter
 
AvroSchemaRegistry - Class in org.apache.nifi.schemaregistry.services
 
AvroSchemaRegistry() - Constructor for class org.apache.nifi.schemaregistry.services.AvroSchemaRegistry
 
AvroSchemaTextStrategy - Class in org.apache.nifi.schema.access
 
AvroSchemaTextStrategy(PropertyValue) - Constructor for class org.apache.nifi.schema.access.AvroSchemaTextStrategy
 
AvroSchemaValidator - Class in org.apache.nifi.avro
 
AvroSchemaValidator() - Constructor for class org.apache.nifi.avro.AvroSchemaValidator
 
AvroSchemaValidator - Class in org.apache.nifi.schemaregistry.services
 
AvroSchemaValidator() - Constructor for class org.apache.nifi.schemaregistry.services.AvroSchemaValidator
 
AvroTestUtil - Class in org.apache.nifi.processors.avro
 
AvroTestUtil() - Constructor for class org.apache.nifi.processors.avro.AvroTestUtil
 
AvroTypeUtil - Class in org.apache.nifi.avro
 
AvroTypeUtil() - Constructor for class org.apache.nifi.avro.AvroTypeUtil
 
awaitCompletion(long, TimeUnit) - Method in interface org.apache.nifi.provenance.lineage.ComputeLineageResult
 
awaitCompletion(long, TimeUnit) - Method in interface org.apache.nifi.provenance.search.QueryResult
 
awaitCompletion(long, TimeUnit) - Method in class org.apache.nifi.provenance.StandardLineageResult
 
awaitCompletion(long, TimeUnit) - Method in class org.apache.nifi.provenance.StandardQueryResult
 
awaitMergedResponse() - Method in interface org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse
Blocks until the request has completed and then returns the merged response
awaitMergedResponse(long, TimeUnit) - Method in interface org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse
Blocks until the request has completed or until the given timeout elapses.
awaitMergedResponse() - Method in class org.apache.nifi.cluster.coordination.http.replication.StandardAsyncClusterResponse
 
awaitMergedResponse(long, TimeUnit) - Method in class org.apache.nifi.cluster.coordination.http.replication.StandardAsyncClusterResponse
 
AWS_CREDENTIALS_PROVIDER_SERVICE - Static variable in class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor
AWS credentials provider service
AWS_DYNAMO_DB_ITEM_SIZE_ERROR - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
 
AWS_KINESIS_ERROR_CODE - Static variable in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream
Kinesis put record response error code
AWS_KINESIS_ERROR_MESSAGE - Static variable in class org.apache.nifi.processors.aws.kinesis.AbstractBaseKinesisProcessor
Kinesis put record response error message
AWS_KINESIS_FIREHOSE_ERROR_CODE - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose
Kinesis put record response error code
AWS_KINESIS_FIREHOSE_ERROR_MESSAGE - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose
Kinesis put record response error message
AWS_KINESIS_FIREHOSE_RECORD_ID - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose
Kinesis put record response record id
AWS_KINESIS_SEQUENCE_NUMBER - Static variable in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream
 
AWS_KINESIS_SHARD_ID - Static variable in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream
 
AWS_LAMBDA_EXCEPTION_CAUSE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda exception field
AWS_LAMBDA_EXCEPTION_ERROR_CODE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda exception field
AWS_LAMBDA_EXCEPTION_ERROR_TYPE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda exception field
AWS_LAMBDA_EXCEPTION_MESSAGE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda exception field
AWS_LAMBDA_EXCEPTION_REQUEST_ID - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda exception field
AWS_LAMBDA_EXCEPTION_STATUS_CODE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda exception field
AWS_LAMBDA_FUNCTION_NAME - Static variable in class org.apache.nifi.processors.aws.lambda.AbstractAWSLambdaProcessor
 
AWS_LAMBDA_FUNCTION_QUALIFIER - Static variable in class org.apache.nifi.processors.aws.lambda.AbstractAWSLambdaProcessor
 
AWS_LAMBDA_RESULT_FUNCTION_ERROR - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda result function error message
AWS_LAMBDA_RESULT_LOG - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda response log tail (4kb)
AWS_LAMBDA_RESULT_PAYLOAD - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda payload in response
AWS_LAMBDA_RESULT_STATUS_CODE - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
Lambda response status code
AWSCredentialsProviderControllerService - Class in org.apache.nifi.processors.aws.credentials.provider.service
Implementation of AWSCredentialsProviderService interface
AWSCredentialsProviderControllerService() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService
 
AWSCredentialsProviderControllerServiceTest - Class in org.apache.nifi.processors.aws.credentials.provider.service
 
AWSCredentialsProviderControllerServiceTest() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerServiceTest
 
AWSCredentialsProviderService - Interface in org.apache.nifi.processors.aws.credentials.provider.service
AWSCredentialsProviderService interface to support getting AWSCredentialsProvider used for instantiating aws clients
AWSProcessorProxyTest - Class in org.apache.nifi.processors.aws.credentials.provider.service
 
AWSProcessorProxyTest() - Constructor for class org.apache.nifi.processors.aws.credentials.provider.service.AWSProcessorProxyTest
 
AzureConstants - Class in org.apache.nifi.processors.azure
 
A B C D E F G H I J K L M N O P Q R S T U V W X Y Z 
Skip navigation links