- 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
-
- 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
-
- addChildFlowFile(String) - Method in interface org.apache.nifi.provenance.ProvenanceEventBuilder
-
- 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
-
- addFilter(byte[], byte[], int) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
-
- addFilter(byte, byte) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
-
- addFilter(byte, byte, int) - Method in class org.apache.nifi.processors.hadoop.util.ByteFilteringOutputStream
-
- 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
FlowFile
s from
external sources to
Processor
s and other
Port
s 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
FlowFile
s 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
-
- 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
EncryptionMethod
s.
- 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
-
- 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
-
- 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
-
- assertNotContains(String, String) - Static method in class org.apache.nifi.documentation.html.XmlValidator
-
- assertNotRolledBack() - Method in class org.apache.nifi.util.MockProcessSession
-
- 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
-
- 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
-