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

O

ObjectFactory - Class in org.apache.nifi.cluster.protocol.jaxb.message

ObjectFactory() - Constructor for class org.apache.nifi.cluster.protocol.jaxb.message.ObjectFactory

ObjectIdSerializer - Class in org.apache.nifi.processors.mongodb

ObjectIdSerializer() - Constructor for class org.apache.nifi.processors.mongodb.ObjectIdSerializer

ObjectMapperResolver - Class in org.apache.nifi.processors.yandex.util

ObjectMapperResolver() - Constructor for class org.apache.nifi.processors.yandex.util.ObjectMapperResolver

ObjectMapperResolver - Class in org.apache.nifi.update.attributes.api

ObjectMapperResolver() - Constructor for class org.apache.nifi.update.attributes.api.ObjectMapperResolver

ObjectMapperResolver - Class in org.apache.nifi.web.util

ObjectMapperResolver() - Constructor for class org.apache.nifi.web.util.ObjectMapperResolver

ObjectSerDe - Class in org.apache.nifi.hbase.util

ObjectSerDe() - Constructor for class org.apache.nifi.hbase.util.ObjectSerDe

obtainConsumer(ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumerPool

Obtains a consumer from the pool if one is available or lazily initializes a new one if deemed necessary.

obtainPublisher() - Method in class org.apache.nifi.processors.kafka.pubsub.PublisherPool

obtainReadLock(File) - Method in class org.apache.nifi.provenance.store.EventFileManager

obtainWriteLock(File) - Method in class org.apache.nifi.provenance.store.EventFileManager

OcspCertificateValidator - Class in org.apache.nifi.web.security.x509.ocsp

OcspCertificateValidator(NiFiProperties) - Constructor for class org.apache.nifi.web.security.x509.ocsp.OcspCertificateValidator

OcspCertificateValidatorTest - Class in org.apache.nifi.web.security.x509.ocsp

OcspCertificateValidatorTest() - Constructor for class org.apache.nifi.web.security.x509.ocsp.OcspCertificateValidatorTest

OcspRequest - Class in org.apache.nifi.web.security.x509.ocsp

A request to verify/validate the specified subject certificate via OCSP.

OcspRequest(X509Certificate, X509Certificate) - Constructor for class org.apache.nifi.web.security.x509.ocsp.OcspRequest

OcspStatus - Class in org.apache.nifi.web.security.x509.ocsp

OcspStatus() - Constructor for class org.apache.nifi.web.security.x509.ocsp.OcspStatus

OcspStatus.ResponseStatus - Enum in org.apache.nifi.web.security.x509.ocsp

OcspStatus.ValidationStatus - Enum in org.apache.nifi.web.security.x509.ocsp

OcspStatus.VerificationStatus - Enum in org.apache.nifi.web.security.x509.ocsp

OCTET_STREAM - Static variable in class org.apache.nifi.processors.standard.UnpackContent

of(ProvenanceEventRecord...) - Static method in interface org.apache.nifi.provenance.store.iterator.EventIterator

of(String) - Static method in enum org.apache.nifi.serialization.record.RecordFieldType

of(RecordSchema, Record...) - Static method in interface org.apache.nifi.serialization.record.RecordSet

of(String, long, int) - Static method in interface org.apache.nifi.serialization.record.SchemaIdentifier

of(Supplier<Object>, String) - Static method in interface org.apache.nifi.serialization.record.SerializedForm

of(Object, String) - Static method in interface org.apache.nifi.serialization.record.SerializedForm

of(int, Map<String, String>) - Static method in interface org.apache.nifi.serialization.WriteResult

Creates a WriteResult with the given record count and attributes

offer(Connectable) - Method in class org.apache.nifi.controller.EventDrivenWorkerQueue

offer(Connectable) - Method in interface org.apache.nifi.controller.WorkerQueue

offer(FlowFile, ProcessSession) - Method in class org.apache.nifi.processor.util.bin.Bin

If this bin has enough room for the size of the given flow file then it is added otherwise it is not

offer(String, FlowFile, ProcessSession, ProcessSessionFactory) - Method in class org.apache.nifi.processor.util.bin.BinManager

Adds the given flowFile to the first available bin in which it fits for the given group or creates a new bin in the specified group if necessary.

offer(String, Collection<FlowFile>, ProcessSession, ProcessSessionFactory) - Method in class org.apache.nifi.processor.util.bin.BinManager

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.

offer(E) - Method in class org.apache.nifi.processor.util.listen.event.EventQueue

Offers the given event to the events queue with a wait time, if the offer fails the event is dropped an error is logged.

offer(FlowFile, RecordReader, ProcessSession, boolean) - Method in class org.apache.nifi.processors.standard.merge.RecordBin

offer(EndpointConnection) - Method in class org.apache.nifi.remote.client.socket.EndpointConnectionPool

offer(MockFlowFile) - Method in class org.apache.nifi.util.MockFlowFileQueue

ofName(String) - Static method in interface org.apache.nifi.serialization.record.SchemaIdentifier

OID - Static variable in class org.apache.nifi.snmp.processors.GetSNMP

OID to request (if walk, it is the root ID of the request)

oidcCallback(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.api.AccessResource

oidcExchange(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.api.AccessResource

OidcIdentityProvider - Interface in org.apache.nifi.web.security.oidc

oidcRequest(HttpServletRequest, HttpServletResponse) - Method in class org.apache.nifi.web.api.AccessResource

OidcService - Class in org.apache.nifi.web.security.oidc

OidcService is a service for managing the OpenId Connect Authorization flow.

OidcService(OidcIdentityProvider) - Constructor for class org.apache.nifi.web.security.oidc.OidcService

Creates a new OtpService with an expiration of 1 minute.

OidcService(OidcIdentityProvider, int, TimeUnit) - Constructor for class org.apache.nifi.web.security.oidc.OidcService

Creates a new OtpService.

OidcServiceTest - Class in org.apache.nifi.web.security.oidc

OidcServiceTest() - Constructor for class org.apache.nifi.web.security.oidc.OidcServiceTest

ok(int) - Static method in class org.apache.nifi.processors.beats.response.BeatsResponse

ok(long) - Static method in class org.apache.nifi.processors.lumberjack.response.LumberjackResponse

OK - Static variable in class org.apache.nifi.processors.standard.relp.response.RELPResponse

ok(long) - Static method in class org.apache.nifi.processors.standard.relp.response.RELPResponse

Utility method to create a default "OK" response.

OLDEST_INDEX_FIRST - Static variable in class org.apache.nifi.provenance.util.DirectoryUtils

OldestFirstPrioritizerTest - Class in org.apache.nifi.prioritizer

OldestFirstPrioritizerTest() - Constructor for class org.apache.nifi.prioritizer.OldestFirstPrioritizerTest

OldestFirstPrioritizerTest.SimpleProcessor - Class in org.apache.nifi.prioritizer

OldestFlowFileFirstPrioritizer - Class in org.apache.nifi.prioritizer

OldestFlowFileFirstPrioritizer() - Constructor for class org.apache.nifi.prioritizer.OldestFlowFileFirstPrioritizer

OnAdded - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a Processor, ControllerService, or ReportingTask implementation can use to indicate a method should be called whenever the component is added to the flow.

onBeginRecordSet() - Method in class org.apache.nifi.avro.WriteAvroResultWithExternalSchema

onBeginRecordSet() - Method in class org.apache.nifi.csv.WriteCSVResult

onBeginRecordSet() - Method in class org.apache.nifi.json.WriteJsonResult

onBeginRecordSet() - Method in class org.apache.nifi.serialization.AbstractRecordSetWriter

Method that is called as a result of AbstractRecordSetWriter.beginRecordSet() being called.

once() - Method in class org.apache.nifi.processors.elasticsearch.TestPutElasticsearchHttp

onCommunicationFailure(BinaryLogClient, Exception) - Method in class org.apache.nifi.cdc.mysql.event.BinlogLifecycleListener

onCompleted - Variable in class org.apache.nifi.processor.util.pattern.Put

onCompleted(PartialFunctions.OnCompleted<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put

Specify an optional function which will be called if input FlowFiles were successfully put to a target storage.

onCompletion(AsyncClusterResponse) - Method in interface org.apache.nifi.cluster.coordination.http.replication.CompletionCallback

onComponentRemoved(String) - Method in class org.apache.nifi.cluster.integration.NopStateProvider

onComponentRemoved(String) - Method in interface org.apache.nifi.components.state.StateManagerProvider

Notifies the State Manager Provider that the component with the given ID has been removed from the NiFi instance and will no longer be needed, so the appropriate resource cleanup can take place.

onComponentRemoved(String) - Method in interface org.apache.nifi.components.state.StateProvider

This method is called whenever a component is removed from the NiFi instance.

onComponentRemoved(String) - Method in class org.apache.nifi.controller.state.manager.StandardStateManagerProvider

onComponentRemoved(String) - Method in class org.apache.nifi.controller.state.providers.local.WriteAheadLocalStateProvider

onComponentRemoved(String) - Method in class org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider

onComponentRemoved(String) - Method in class org.apache.nifi.redis.state.RedisStateProvider

OnConfigurationRestored - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker Annotation that a Processor, Reporting Task, or Controller Service can use to indicate that the method with this Annotation should be invoked whenever the component's configuration is restored after a restart of NiFi.

onConfigure(ConfigurationContext) - Method in class org.apache.nifi.reporting.ganglia.StandardGangliaReporter

onConfigured(LoginIdentityProviderConfigurationContext) - Method in interface org.apache.nifi.authentication.LoginIdentityProvider

Called to configure the AuthorityProvider.

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.AbstractPolicyBasedAuthorizer

onConfigured(AuthorizerConfigurationContext) - Method in interface org.apache.nifi.authorization.AccessPolicyProvider

Called to configure the Authorizer.

onConfigured(AuthorizerConfigurationContext) - Method in interface org.apache.nifi.authorization.Authorizer

Called to configure the Authorizer.

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.CompositeUserGroupProvider

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.FileAccessPolicyProvider

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.FileUserGroupProvider

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.SimpleUserGroupProvider

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.authorization.StandardManagedAuthorizer

onConfigured(AuthorizerConfigurationContext) - Method in interface org.apache.nifi.authorization.UserGroupProvider

Called to configure the Authorizer.

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.controller.ControllerStatusReportingTask

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.controller.MonitorMemory

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.couchbase.CouchbaseClusterService

Establish a connection to a Couchbase cluster.

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.dbcp.DBCPConnectionPool

Configures connection pool by creating an instance of the BasicDataSource based on configuration provided with ConfigurationContext.

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.dbcp.hive.HiveConnectionPool

Configures connection pool by creating an instance of the BasicDataSource based on configuration provided with ConfigurationContext.

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientMapCacheService

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.http.StandardHttpContextMap

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.integration.util.NiFiTestAuthorizer

onConfigured(LoginIdentityProviderConfigurationContext) - Method in class org.apache.nifi.integration.util.NiFiTestLoginIdentityProvider

onConfigured(LoginIdentityProviderConfigurationContext) - Method in class org.apache.nifi.kerberos.KerberosProvider

onConfigured(LoginIdentityProviderConfigurationContext) - Method in class org.apache.nifi.ldap.LdapProvider

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.processors.gcp.credentials.service.GCPCredentialsControllerService

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.ranger.authorization.ManagedRangerAuthorizer

onConfigured(AuthorizerConfigurationContext) - Method in class org.apache.nifi.ranger.authorization.RangerNiFiAuthorizer

onConfigured(ConfigurationContext) - Method in class org.apache.nifi.ssl.StandardSSLContextService

onConnect(BinaryLogClient) - Method in class org.apache.nifi.cdc.mysql.event.BinlogLifecycleListener

onConnectionAdded(Connection) - Method in class org.apache.nifi.controller.FlowController

onConnectionRemoved(Connection) - Method in class org.apache.nifi.controller.FlowController

onConsumerDone() - Method in class org.apache.nifi.io.nio.consumer.AbstractStreamConsumer

Convenience method that is called when the consumer is done processing based on being told the signal is end of stream and has processed all given buffers.

onConsumerDone() - Method in class org.apache.nifi.io.nio.example.UselessStreamConsumer

onDisable() - Method in class org.apache.nifi.mongodb.MongoDBControllerService

OnDisabled - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a ControllerService can use to indicate a method should be called whenever the service is disabled.

onDisabled(ConfigurationContext) - Method in class org.apache.nifi.lookup.script.ScriptedLookupService

onDisabled() - Method in class org.apache.nifi.redis.service.RedisConnectionPoolService

onDisabled() - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService

onDisconnect(BinaryLogClient) - Method in class org.apache.nifi.cdc.mysql.event.BinlogLifecycleListener

ONE_MB - Static variable in class org.apache.nifi.processors.standard.LogAttribute

ONE_MB - Static variable in class org.apache.nifi.test.processors.StubAttributeLoggerProcessor

ONE_OR_MORE_FILE_EXISTS_VALIDATOR - Static variable in interface org.apache.nifi.processors.hadoop.HadoopValidators

OnEnabled - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a ControllerService can use to indicate a method should be called whenever the service is enabled.

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.json.JsonRecordSetWriter

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.lookup.configuration2.CommonsConfigurationLookupService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.lookup.maxmind.IPLookupService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.lookup.script.ScriptedLookupService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.lookup.SimpleCsvFileLookupService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.mongodb.MongoDBControllerService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.mongodb.MongoDBLookupService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.record.script.ScriptedReader

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.record.script.ScriptedRecordSetWriter

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.redis.service.RedisConnectionPoolService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.script.AbstractScriptedControllerService

onEnabled(ConfigurationContext) - Method in class org.apache.nifi.text.FreeFormTextRecordSetWriter

onError(ExceptionHandler.OnError<C, ?>) - Method in class org.apache.nifi.processor.util.pattern.ExceptionHandler

Specify a default OnError function that will be called if one is not explicitly specified when ExceptionHandler.execute(Object, Object, Procedure) is called.

oneTimeSetup() - Static method in class org.apache.nifi.processors.aws.s3.AbstractS3IT

oneTimeTearDown() - Static method in class org.apache.nifi.processors.aws.s3.AbstractS3IT

OneUpSequenceEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

OneUpSequenceEvaluator() - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.OneUpSequenceEvaluator

onEvent(Event) - Method in class org.apache.nifi.cdc.mysql.event.BinlogEventListener

onEvent(Connectable) - Method in class org.apache.nifi.controller.scheduling.EventDrivenSchedulingAgent

onEvent(Connectable) - Method in class org.apache.nifi.controller.scheduling.QuartzSchedulingAgent

onEvent(Connectable) - Method in interface org.apache.nifi.controller.scheduling.SchedulingAgent

onEvent(Connectable) - Method in class org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent

onEvent(int, WinDef.PVOID, WinNT.HANDLE) - Method in class org.apache.nifi.processors.windows.event.log.jna.EventSubscribeXmlRenderingCallback

onEvent(int, WinDef.PVOID, WinNT.HANDLE) - Method in interface org.apache.nifi.processors.windows.event.log.jna.WEvtApi.EVT_SUBSCRIBE_CALLBACK

Callback method that will be invoked when new events come in

onEventDeserializationFailure(BinaryLogClient, Exception) - Method in class org.apache.nifi.cdc.mysql.event.BinlogLifecycleListener

onFailed - Variable in class org.apache.nifi.processor.util.pattern.Put

onFailed(PartialFunctions.OnFailed<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put

Specify an optional function which will be called if input FlowFiles failed being put to a target storage.

onFailure(ProcessContext, ProcessSession, FlowFile) - Method in class org.apache.nifi.processors.standard.PutTCP

Event handler method to perform the required actions when a failure has occurred.

onFailure(ProcessContext, ProcessSession, FlowFile) - Method in class org.apache.nifi.processors.standard.PutUDP

event handler method to perform the required actions when a failure has occurred.

onFinish() - Method in class org.apache.nifi.queryrecord.FlowFileEnumerator

onFinishRecordSet() - Method in class org.apache.nifi.avro.WriteAvroResultWithExternalSchema

onFinishRecordSet() - Method in class org.apache.nifi.csv.WriteCSVResult

onFinishRecordSet() - Method in class org.apache.nifi.json.WriteJsonResult

onFinishRecordSet() - Method in class org.apache.nifi.serialization.AbstractRecordSetWriter

Method that is called by AbstractRecordSetWriter.finishRecordSet() when a RecordSet is finished.

onFlowInitialized(boolean) - Method in class org.apache.nifi.controller.FlowController

Causes any processors that were added to the flow with a 'delayStart' flag of true to now start

onFunnelAdded(Funnel) - Method in class org.apache.nifi.controller.FlowController

onFunnelRemoved(Funnel) - Method in class org.apache.nifi.controller.FlowController

onGlobalSync() - Method in class org.apache.nifi.controller.repository.WriteAheadFlowFileRepository

onGlobalSync() - Method in interface org.wali.SyncListener

This method is called whenever the entire WriteAheadRepository is synched via the WriteAheadRepository#sync() method.

onIndexCommitted(File) - Method in class org.apache.nifi.provenance.index.lucene.IndexDirectoryManager

Notifies the Index Directory Manager that an Index Writer has been committed for the given index directory.

onInputPortAdded(Port) - Method in class org.apache.nifi.controller.FlowController

onInputPortRemoved(Port) - Method in class org.apache.nifi.controller.FlowController

onLeaderElection() - Method in interface org.apache.nifi.controller.leader.election.LeaderElectionStateChangeListener

This method is invoked whenever this node is elected leader

onLeaderRelinquish() - Method in interface org.apache.nifi.controller.leader.election.LeaderElectionStateChangeListener

This method is invoked whenever this node no longer is the elected leader.

onLogMessage(LogMessage) - Method in class org.apache.nifi.logging.ControllerServiceLogObserver

onLogMessage(LogMessage) - Method in interface org.apache.nifi.logging.LogObserver

onLogMessage(LogMessage) - Method in class org.apache.nifi.logging.ProcessorLogObserver

onLogMessage(LogMessage) - Method in class org.apache.nifi.logging.ReportingTaskLogObserver

ONLY_PHASE - Static variable in class org.apache.nifi.cluster.coordination.http.replication.StandardAsyncClusterResponse

onMatch(RelOptRuleCall) - Method in class org.apache.nifi.queryrecord.FlowFileProjectTableScanRule

onOutputPortAdded(Port) - Method in class org.apache.nifi.controller.FlowController

onOutputPortRemoved(Port) - Method in class org.apache.nifi.controller.FlowController

onPartitionsAssigned(Collection<TopicPartition>) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumerLease

This will be called by Kafka when the rebalance has completed.

onPartitionsRevoked(Collection<TopicPartition>) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumerLease

Kafka will call this method whenever it is about to rebalance the consumers for the given partitions.

onPrimaryNodeChange(PrimaryNodeState) - Method in class org.apache.nifi.hbase.GetHBase

onPrimaryNodeChange(PrimaryNodeState) - Method in class org.apache.nifi.processor.util.list.AbstractListProcessor

OnPrimaryNodeStateChange - Annotation Type in org.apache.nifi.annotation.notification

Marker annotation that a component can use to indicate that a method should be called whenever the state of the Primary Node in a cluster has changed.

onProcessGroupAdded(ProcessGroup) - Method in class org.apache.nifi.controller.FlowController

onProcessGroupRemoved(ProcessGroup) - Method in class org.apache.nifi.controller.FlowController

onProcessorAdded(ProcessorNode) - Method in class org.apache.nifi.controller.FlowController

onProcessorRemoved(ProcessorNode) - Method in class org.apache.nifi.controller.FlowController

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.cluster.integration.NopStateProvider

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.components.AbstractConfigurableComponent

Hook method allowing subclasses to eagerly react to a configuration change for the given property descriptor.

onPropertyModified(PropertyDescriptor, String, String) - Method in interface org.apache.nifi.components.ConfigurableComponent

Hook method allowing subclasses to eagerly react to a configuration change for the given property descriptor.

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.controller.AbstractConfiguredComponent

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.controller.service.util.TestControllerService

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.hbase.GetHBase

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.lookup.script.ScriptedLookupService

Handles changes to this processor's properties.

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processor.GhostProcessor

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processor.util.list.AbstractListProcessor

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.attributes.UpdateAttribute

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.hadoop.ListHDFS

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.hl7.RouteHL7

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.mqtt.ConsumeMQTT

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.script.InvokeScriptedProcessor

Handles changes to this processor's properties.

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.solr.GetSolr

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.splunk.GetSplunk

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.ControlRate

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.DistributeLoad

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.EvaluateJsonPath

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.ExecuteStreamCommand

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.GetHTTP

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.HashAttribute

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.InvokeHTTP

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.ListenSyslog

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.LookupRecord

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.QueryRecord

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.RouteOnAttribute

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.RouteOnContent

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.RouteText

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.ScanContent

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.SplitJson

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.standard.TailFile

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.processors.twitter.GetTwitter

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.reporting.GhostReportingTask

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.schemaregistry.services.AvroSchemaRegistry

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.script.AbstractScriptedControllerService

Handles changes to this processor's properties.

onPropertyModified(PropertyDescriptor, String, String) - Method in class org.apache.nifi.ssl.StandardSSLContextService

onRemove() - Method in interface org.apache.nifi.groups.RemoteProcessGroup

Called whenever RemoteProcessGroup is removed from the flow, so that any resources can be cleaned up appropriately.

onRemove() - Method in class org.apache.nifi.remote.StandardRemoteProcessGroup

OnRemoved - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a Processor, ControllerService, or ReportingTask implementation can use to indicate a method should be called whenever the component is removed from the flow.

onRemoved(ProcessContext) - Method in class org.apache.nifi.hbase.GetHBase

onRemoved() - Method in class org.apache.nifi.processors.solr.GetSolr

onRemoved(ProcessContext) - Method in class org.apache.nifi.processors.splunk.GetSplunk

onRemoved(ProcessContext) - Method in class org.apache.nifi.processors.standard.EvaluateJsonPath

Provides cleanup of the map for any JsonPath values that may have been created.

onRemoved(ProcessContext) - Method in class org.apache.nifi.processors.standard.GetJMSTopic

Deprecated.

onRemovedArgs(ProcessContext) - Method in class org.apache.nifi.documentation.example.DeprecatedProcessor

onRemovedArgs(ConfigurationContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedControllerService

onRemovedArgs(ProcessContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedProcessor

onRemovedArgs(ConfigurationContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedReportingTask

onRemovedNoArgs() - Method in class org.apache.nifi.documentation.example.DeprecatedProcessor

onRemovedNoArgs() - Method in class org.apache.nifi.documentation.example.FullyDocumentedControllerService

onRemovedNoArgs() - Method in class org.apache.nifi.documentation.example.FullyDocumentedProcessor

onRemovedNoArgs() - Method in class org.apache.nifi.documentation.example.FullyDocumentedReportingTask

onSchedule(ProcessContext) - Method in class org.apache.nifi.processors.hadoop.inotify.GetHDFSEvents

onSchedule(ProcessContext) - Method in class org.apache.nifi.processors.standard.SplitText

OnScheduled - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a Processor or ReportingTask implementation can use to indicate a method should be called whenever the component is scheduled to run.

onScheduled() - Method in class org.apache.nifi.controller.TestStandardProcessorNode.ProcessorThatThrowsExceptionOnScheduled

onScheduled(ProcessContext) - Method in class org.apache.nifi.hbase.AbstractPutHBase

onScheduled(ProcessContext) - Method in class org.apache.nifi.hbase.FetchHBaseRow

onScheduled(ProcessContext) - Method in class org.apache.nifi.processor.util.bin.BinFiles

onScheduled(ProcessContext) - Method in class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

onScheduled(ProcessContext) - Method in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

onScheduled(ProcessContext) - Method in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.AbstractEnrichIP

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.attributes.UpdateAttribute

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor

This method checks if {#link AbstractAWSCredentialsProviderProcessor.AWS_CREDENTIALS_PROVIDER_SERVICE is available and if it is, uses the credentials provider, otherwise it invokes the AbstractAWSProcessor.onScheduled(ProcessContext) which uses static AWSCredentials for the aws processors

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.aws.AbstractAWSProcessor

Deprecated.

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.azure.eventhub.GetAzureEventHub

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.beats.ListenBeats

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.cassandra.PutCassandraQL

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.cassandra.QueryCassandra

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.cybersecurity.FuzzyHashContent

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.enrich.QueryDNS

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.flume.ExecuteFlumeSink

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.flume.ExecuteFlumeSource

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.gcp.AbstractGCPProcessor

Assigns the cloud service client on scheduling.

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.gettcp.GetTCP

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.hadoop.GetHDFS

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.hadoop.GetHDFSSequenceFileTest.TestableGetHDFSSequenceFile

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumeKafka

OnScheduled(ProcessContext) - Method in class org.apache.nifi.processors.kudu.AbstractKudu

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.lumberjack.ListenLumberjack

Deprecated.

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.media.ExtractMediaMetadata

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.mqtt.ConsumeMQTT

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.mqtt.PublishMQTT

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.rethinkdb.GetRethinkDB

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.rethinkdb.PutRethinkDB

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.riemann.PutRiemann

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.solr.SolrProcessor

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.splunk.GetSplunk

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.AttributesToJSON

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ControlRate

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ConvertJSONToSQL

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.DebugFlow

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.EvaluateJsonPath

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ExtractGrok

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ExtractText

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.GenerateFlowFile

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.GetFile

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.GetFileTransfer

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.GetHTTP

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ListenRELP

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ListenSyslog

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ListenTCPRecord

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ListenUDPRecord

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ListFile

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.LookupAttribute

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.LookupRecord

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.MonitorActivity

OnScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ParseCEF

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.PostHTTP

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.PutDatabaseRecord

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.PutSyslog

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.RouteOnAttribute

When this processor is scheduled, update the dynamic properties into the map for quick access during each onTrigger call

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.RouteText

When this processor is scheduled, update the dynamic properties into the map for quick access during each onTrigger call

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.ScanAttribute

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.SplitJson

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.TransformXml

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.UnpackContent

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.twitter.GetTwitter

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.WriteResourceToStream

onScheduled(ProcessContext) - Method in class org.apache.nifi.processors.yandex.YandexTranslate

onScheduled(ConfigurationContext) - Method in class org.apache.nifi.reporting.SiteToSiteProvenanceReportingTask

onScheduledUsingControllerService(ProcessContext) - Method in class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor

Create aws client using credentials provider

onSchedulingStart() - Method in interface org.apache.nifi.connectable.Port

This method is called just before a Port is scheduled to run, giving the Port a chance to initialize any resources needed.

onSchedulingStart() - Method in class org.apache.nifi.controller.AbstractPort

onSchedulingStart() - Method in class org.apache.nifi.remote.StandardRemoteGroupPort

onSchedulingStart() - Method in class org.apache.nifi.remote.StandardRootGroupPort

OnShutdown - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a Processor, ControllerService, or ReportingTask implementation can use to indicate a method should be called whenever the flow is being shutdown.

onShutdown(ProcessContext) - Method in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL

onShutDown() - Method in class org.apache.nifi.processors.aws.AbstractAWSCredentialsProviderProcessor

onShutdown() - Method in class org.apache.nifi.processors.aws.AbstractAWSProcessor

Deprecated.

onShutdownArgs(ProcessContext) - Method in class org.apache.nifi.documentation.example.DeprecatedProcessor

onShutdownArgs(ConfigurationContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedControllerService

onShutdownArgs(ProcessContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedProcessor

onShutdownArgs(ConfigurationContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedReportingTask

onShutdownNoArgs() - Method in class org.apache.nifi.documentation.example.DeprecatedProcessor

onShutdownNoArgs() - Method in class org.apache.nifi.documentation.example.FullyDocumentedControllerService

onShutdownNoArgs() - Method in class org.apache.nifi.documentation.example.FullyDocumentedProcessor

onShutdownNoArgs() - Method in class org.apache.nifi.documentation.example.FullyDocumentedReportingTask

onStart() - Method in class org.apache.nifi.cluster.coordination.heartbeat.AbstractHeartbeatMonitor

This method does nothing in the abstract class but is meant for subclasses to override in order to provide functionality when the monitor is started.

onStart() - Method in class org.apache.nifi.cluster.coordination.heartbeat.ClusterProtocolHeartbeatMonitor

onStart() - Method in class org.apache.nifi.spark.NiFiReceiver

onStop() - Method in class org.apache.nifi.cluster.coordination.heartbeat.AbstractHeartbeatMonitor

This method does nothing in the abstract class but is meant for subclasses to override in order to provide functionality when the monitor is stopped.

onStop() - Method in class org.apache.nifi.cluster.coordination.heartbeat.ClusterProtocolHeartbeatMonitor

onStop(ProcessContext) - Method in class org.apache.nifi.processors.mqtt.PublishMQTT

onStop() - Method in class org.apache.nifi.spark.NiFiReceiver

OnStopped - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a Processor or ReportingTask implementation can use to indicate that a method should be called whenever the component is no longer scheduled to run.

onStopped(ProcessContext) - Method in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL

onStopped() - Method in class org.apache.nifi.controller.TestStandardProcessorNode.ProcessorThatThrowsExceptionOnScheduled

onStopped() - Method in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService

onStopped() - Method in class org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService

onStopped() - Method in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor

onStopped(ProcessContext) - Method in class org.apache.nifi.processors.mqtt.ConsumeMQTT

onStopped() - Method in class org.apache.nifi.processors.solr.GetSolr

onStopped() - Method in class org.apache.nifi.processors.splunk.GetSplunk

onStopped(ProcessContext) - Method in class org.apache.nifi.processors.standard.DebugFlow

onStopped() - Method in class org.apache.nifi.processors.standard.ExtractGrok

onStopped() - Method in class org.apache.nifi.processors.standard.ExtractText

onStopped() - Method in class org.apache.nifi.processors.standard.GetJMSTopic

Deprecated.

onStopped() - Method in class org.apache.nifi.processors.standard.ListenTCPRecord

onStopped(ProcessContext) - Method in class org.apache.nifi.processors.standard.MonitorActivity

onStopped() - Method in class org.apache.nifi.processors.standard.PostHTTP

onStopped() - Method in class org.apache.nifi.processors.standard.PutSyslog

onStopped() - Method in class org.apache.nifi.processors.standard.UnpackContent

onStopped(ProcessContext) - Method in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor

onSync(int) - Method in class org.apache.nifi.controller.repository.WriteAheadFlowFileRepository

onSync(int) - Method in interface org.wali.SyncListener

This method is called whenever a specific partition is synched via the WriteAheadRepository.update(java.util.Collection, boolean) method

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.amqp.processors.ConsumeAMQPTest.LocalConsumeAMQP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.amqp.processors.PublishAMQPTest.LocalPublishAMQP

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.connectable.LocalPort

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.controller.AbstractPort

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.controller.AbstractPort

onTrigger(ReportingContext) - Method in class org.apache.nifi.controller.ControllerStatusReportingTask

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.controller.DummyScheduledProcessor

onTrigger(ReportingContext) - Method in class org.apache.nifi.controller.DummyScheduledReportingTask

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.controller.DummySettingsProcessor

onTrigger(ReportingContext) - Method in class org.apache.nifi.controller.MonitorDiskUsage

onTrigger(ReportingContext) - Method in class org.apache.nifi.controller.MonitorMemory

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.controller.scheduling.TestProcessorLifecycle.TestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.controller.service.mock.DummyProcessor

onTrigger(ReportingContext) - Method in class org.apache.nifi.controller.service.mock.DummyReportingTask

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.controller.StandardFunnel

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.controller.StandardProcessorNode

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.controller.TestStandardProcessorNode.ProcessorThatThrowsExceptionOnScheduled

onTrigger(ProcessContext, ProcessSessionFactory) - Method in interface org.apache.nifi.controller.Triggerable

The method called when this processor is triggered to operate by the controller.

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.dbcp.TestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.documentation.example.DeprecatedProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.documentation.example.FullyDocumentedProcessor

onTrigger(ReportingContext) - Method in class org.apache.nifi.documentation.example.FullyDocumentedReportingTask

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.documentation.example.NakedProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.documentation.example.ProcessorWithLogger

onTrigger(ReportingContext) - Method in class org.apache.nifi.documentation.example.ReportingTaskWithLogger

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.GetHTMLElement

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.hbase.AbstractPutHBase

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.hbase.FetchHBaseRow

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.hbase.GetHBase

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.hbase.PutHBaseRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.hbase.TestProcessor

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.integration.util.RestrictedProcessor

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.integration.util.SourceTestProcessor

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.integration.util.TerminationTestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.lookup.TestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.ModifyHTMLElement

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.mongodb.TestControllerServiceProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.mongodb.TestLookupServiceProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.nar.NarThreadContextClassLoaderTest.WithDefaultConstructor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.nar.NarThreadContextClassLoaderTest.WithPropertiesConstructor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.prioritizer.NewestFirstPrioritizerTest.SimpleProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.prioritizer.OldestFirstPrioritizerTest.SimpleProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.prioritizer.PriorityAttributePrioritizerTest.SimpleProcessor

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processor.AbstractProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processor.AbstractProcessor

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processor.GhostProcessor

onTrigger(ProcessContext, ProcessSessionFactory) - Method in interface org.apache.nifi.processor.Processor

The method called when this processor is triggered to operate by the controller.

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processor.util.bin.BinFiles

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processor.util.list.AbstractListProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor

onTrigger(ProcessContext, ProcessSessionFactory, ComponentLog, PartialFunctions.OnTrigger) - Static method in class org.apache.nifi.processor.util.pattern.PartialFunctions

This method is identical to what AbstractProcessor.onTrigger(ProcessContext, ProcessSession) does.

onTrigger(ProcessContext, ProcessSessionFactory, ComponentLog, PartialFunctions.OnTrigger, PartialFunctions.RollbackSession) - Static method in class org.apache.nifi.processor.util.pattern.PartialFunctions

onTrigger(ProcessContext, ProcessSession, FC) - Method in class org.apache.nifi.processor.util.pattern.Put

Processor using this pattern is expected to call this method from its onTrigger.

onTrigger(ProcessContext, ProcessSessionFactory, FCT, ComponentLog, PartialFunctions.OnTrigger) - Static method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.attributes.UpdateAttribute

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.avro.ConvertAvroToJSON

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.avro.ExtractAvroMetadata

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.avro.SplitAvro

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.credentials.provider.factory.MockAWSProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDB

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.dynamodb.GetDynamoDB

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.dynamodb.PutDynamoDB

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.lambda.PutLambda

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.s3.DeleteS3Object

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.s3.FetchS3Object

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.s3.ListS3

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.s3.PutS3Object

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.sns.PutSNS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.sqs.DeleteSQS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.sqs.GetSQS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.aws.sqs.PutSQS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.azure.eventhub.GetAzureEventHub

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.azure.eventhub.PutAzureEventHub

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.azure.storage.FetchAzureBlobStorage

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.azure.storage.PutAzureBlobStorage

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.cassandra.AbstractCassandraProcessorTest.MockAbstractCassandraProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.cassandra.PutCassandraQL

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.cassandra.QueryCassandra

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.couchbase.GetCouchbaseKey

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.couchbase.PutCouchbaseKey

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.cybersecurity.FuzzyHashContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch5

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.PutElasticsearch

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.PutElasticsearch5

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.elasticsearch.ScrollElasticsearchHttp

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.email.ConsumeEWS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.email.ExtractEmailAttachments

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.email.ExtractEmailHeaders

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.email.ExtractTNEFAttachments

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.email.ListenSMTP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.enrich.QueryDNS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.enrich.QueryWhois

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.evtx.ParseEvtx

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.flume.AbstractFlumeProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.flume.AbstractFlumeProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.flume.ExecuteFlumeSink

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.flume.ExecuteFlumeSource

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.flume.ExecuteFlumeSource

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.gcp.credentials.factory.MockCredentialsFactoryProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.gcp.credentials.service.MockCredentialsServiceProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.gcp.storage.DeleteGCSObject

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.gcp.storage.FetchGCSObject

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.gcp.storage.ListGCSBucket

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.gcp.storage.PutGCSObject

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.GeoEnrichIP

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.gettcp.GetTCP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.grpc.InvokeGRPC

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.grpc.ListenGRPC

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.CreateHadoopSequenceFile

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.DeleteHDFS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.FetchHDFS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.GetHDFS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.inotify.GetHDFSEvents

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.ListHDFS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.PutHDFS

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.SimpleHadoopProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hive.ConvertAvroToORC

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.hive.PutHiveQL

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.hive.PutHiveStreaming

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.hive.SelectHiveQL

onTrigger() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hl7.ExtractHL7Attributes

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hl7.RouteHL7

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.ignite.cache.GetIgniteCache

Handle flow file and gets the entry from the cache based on the key attribute

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.ignite.cache.PutIgniteCache

Handle flow files

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.image.ExtractImageMetadata

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.image.ResizeImage

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.ISPEnrichIP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.GetKafka

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumeKafka

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_11

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_0_10

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_0_11

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.PublishKafka

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_11

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kite.ConvertAvroSchema

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kite.ConvertCSVToAvro

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kite.ConvertJSONToAvro

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kite.InferAvroSchema

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kite.StoreInKiteDataset

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kudu.AbstractKudu

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.media.ExtractMediaMetadata

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mongodb.AbstractMongoProcessorTest.MockAbstractMongoProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mongodb.GetMongo

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mongodb.PutMongo

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mongodb.PutMongoRecord

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mqtt.ConsumeMQTT

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.mqtt.PublishMQTT

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.poi.ConvertExcelToCSVProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.rethinkdb.GetRethinkDB

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.rethinkdb.PutRethinkDB

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.riemann.PutRiemann

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.script.ExecuteScript

Evaluates the given script body (or file) using the current session, context, and flowfile.

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.script.InvokeScriptedProcessor

Invokes the onTrigger() method of the scripted processor.

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.slack.PutSlack

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.solr.GetSolr

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.solr.PutSolrContentStream

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.splunk.GetSplunk

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.splunk.PutSplunk

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.AbstractRecordProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.AbstractRouteRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.AttributesToJSON

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.Base64EncodeContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.CompressContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ControlRate

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ConvertCharacterSet

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ConvertJSONToSQL

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.DebugFlow

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.DetectDuplicate

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.DistributeLoad

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.DuplicateFlowFile

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.EncodeContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.EncryptContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.EnforceOrder

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.EvaluateJsonPath

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.EvaluateXPath

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.EvaluateXQuery

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ExecuteProcess

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ExecuteSQL

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ExecuteStreamCommand

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ExtractGrok

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ExtractText

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.FetchDistributedMapCache

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.FetchFile

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.FetchFileTransfer

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.GenerateFlowFile

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.GenerateTableFetch

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.GetFile

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.GetFileTransfer

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.GetHTTP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.GetJMSQueue

Deprecated.

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.GetJMSTopic

Deprecated.

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.HandleHttpRequest

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.HandleHttpResponse

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.HashAttribute

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.HashContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.IdentifyMimeType

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.InvokeHTTP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.JoltTransformJSON

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ListDatabaseTables

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.ListenHTTP

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ListenSyslog

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ListenTCPRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ListenUDPRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.LogAttribute

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.LogMessage

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.LookupAttribute

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.MergeRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ModifyBytes

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.MonitorActivity

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.Notify

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ParseCEF

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ParseSyslog

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PartitionRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PostHTTP

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.PutDatabaseRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PutDistributedMapCache

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PutEmail

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PutFile

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PutFileTransfer

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PutJMS

Deprecated.

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.PutSQL

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.PutSyslog

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.PutTCP

event handler method to handle the FlowFile being forwarded to the Processor by the framework.

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.PutUDP

event handler method to handle the FlowFile being forwarded to the Processor by the framework.

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.standard.QueryDatabaseTable

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.QueryRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ReplaceText

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ReplaceTextWithMapping

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.RouteOnAttribute

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.RouteOnContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.RouteText

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ScanAttribute

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ScanContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.SegmentContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.SplitContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.SplitJson

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.SplitRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.SplitText

Will split the incoming stream releasing all splits as FlowFile at once.

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.SplitXml

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.TailFile

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.TransformXml

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.UnpackContent

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.UpdateCounter

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ValidateCsv

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ValidateRecord

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.ValidateXml

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.standard.Wait

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.twitter.GetTwitter

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.websocket.PutWebSocket

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.WriteResourceToStream

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.yandex.YandexTranslate

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.PutHTMLElement

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.redis.service.FakeRedisProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.remote.StandardRemoteGroupPort

onTrigger(ProcessContext, ProcessSessionFactory) - Method in class org.apache.nifi.remote.StandardRootGroupPort

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.remote.StandardRootGroupPort

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.ambari.AmbariReportingTask

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.datadog.DataDogReportingTask

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.ganglia.StandardGangliaReporter

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.GhostReportingTask

onTrigger(ReportingContext) - Method in interface org.apache.nifi.reporting.ReportingTask

This method is called on a scheduled interval to allow the Reporting Task to perform its tasks.

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.script.ScriptedReportingTask

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.SiteToSiteBulletinReportingTask

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.SiteToSiteProvenanceReportingTask

onTrigger(ReportingContext) - Method in class org.apache.nifi.reporting.SiteToSiteStatusReportingTask

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.spring.SpringContextProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.spring.SpringContextProcessorTest.TestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.ssl.TestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.test.processors.DataGeneratorTestProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.test.processors.ModifiesClasspathNoAnnotationProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.test.processors.ModifiesClasspathProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.test.processors.StubAttributeLoggerProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.test.processors.StubTerminationFileProcessor

onTrigger(ProcessContext, ProcessSession) - Method in class org.apache.nifi.util.TestMockProcessSession.PoorlyBehavedProcessor

onTriggerBadInput() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerBadInputRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerMultipleRecordsFailInMiddle() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerMultipleRecordsFailInMiddleRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerMultipleRecordsFailInMiddleRollbackOnFailureCommitted() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerMultipleRecordsMultipleTransaction() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerMultipleRecordsSingleTransaction() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerShouldOnlyProcessEventsWithSpecificPath() - Method in class org.apache.nifi.processors.hadoop.inotify.TestGetHDFSEvents

onTriggerShouldProperlyHandleAnEmptyEventBatch() - Method in class org.apache.nifi.processors.hadoop.inotify.TestGetHDFSEvents

onTriggerShouldProperlyHandleANullEventBatch() - Method in class org.apache.nifi.processors.hadoop.inotify.TestGetHDFSEvents

onTriggerSnmp(ProcessContext, ProcessSession) - Method in class org.apache.nifi.snmp.processors.GetSNMP

Delegate method to supplement AbstractSNMPProcessor.onTrigger(ProcessContext, ProcessSession).

onTriggerSnmp(ProcessContext, ProcessSession) - Method in class org.apache.nifi.snmp.processors.SetSNMP

onTriggerWithCommitFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithCommitFailureRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithConnectFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithConnectFailureRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithExceptionOnFlushAndClose() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithHeartbeat() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithInterruptedException() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithInterruptedExceptionRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithPartitionColumns() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithPartitionColumnsNotInRecord() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithPartitionColumnsNotInRecordRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithRetireWriters() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithSerializationError() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithSerializationErrorRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithTransactionFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithTransactionFailureRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithWriteFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

onTriggerWithWriteFailureRollbackOnFailure() - Method in class org.apache.nifi.processors.hive.TestPutHiveStreaming

OnUnscheduled - Annotation Type in org.apache.nifi.annotation.lifecycle

Marker annotation a Processor or ReportingTask should be called whenever the component is no longer scheduled to run.

onUnscheduled() - Method in class org.apache.nifi.controller.TestStandardProcessorNode.ProcessorThatThrowsExceptionOnScheduled

onUnscheduled() - Method in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor

onUnscheduled(ProcessContext) - Method in class org.apache.nifi.processors.mqtt.ConsumeMQTT

onUnscheduled(ProcessContext) - Method in class org.apache.nifi.processors.standard.DebugFlow

onUnscheduled() - Method in class org.apache.nifi.processors.standard.EvaluateJsonPath

onUnscheduled() - Method in class org.apache.nifi.processors.standard.ListenSyslog

onUnscheduled() - Method in class org.apache.nifi.reporting.SiteToSiteProvenanceReportingTask

onWebSocketBinary(byte[], int, int) - Method in class org.apache.nifi.websocket.jetty.RoutingWebSocketListener

onWebSocketBinary(String, byte[], int, int) - Method in class org.apache.nifi.websocket.WebSocketMessageRouter

onWebSocketClose(int, String) - Method in class org.apache.nifi.websocket.jetty.RoutingWebSocketListener

onWebSocketClose(String, int, String) - Method in class org.apache.nifi.websocket.WebSocketMessageRouter

onWebSocketConnect(Session) - Method in class org.apache.nifi.websocket.example.WebSocketServerExample.SocketListener

onWebSocketConnect(Session) - Method in class org.apache.nifi.websocket.jetty.RoutingWebSocketListener

onWebSocketServiceReady(WebSocketService) - Method in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor

onWebSocketText(String) - Method in class org.apache.nifi.websocket.example.WebSocketServerExample.SocketListener

onWebSocketText(String) - Method in class org.apache.nifi.websocket.jetty.RoutingWebSocketListener

onWebSocketText(String, String) - Method in class org.apache.nifi.websocket.WebSocketMessageRouter

onXmlElementFound(String) - Method in interface org.apache.nifi.processors.standard.util.XmlElementNotifier

open(InetAddress, int, int) - Method in interface org.apache.nifi.processor.util.listen.dispatcher.ChannelDispatcher

Opens the dispatcher listening on the given port and attempts to set the OS socket buffer to maxBufferSize.

open(InetAddress, int, int) - Method in class org.apache.nifi.processor.util.listen.dispatcher.DatagramChannelDispatcher

open(InetAddress, int, int) - Method in class org.apache.nifi.processor.util.listen.dispatcher.SocketChannelDispatcher

open() - Method in class org.apache.nifi.processor.util.put.sender.ChannelSender

Opens the connection to the destination.

open() - Method in class org.apache.nifi.processor.util.put.sender.DatagramChannelSender

open() - Method in class org.apache.nifi.processor.util.put.sender.SocketChannelSender

open() - Method in class org.apache.nifi.processor.util.put.sender.SSLSocketChannelSender

open(long, Map<String, String>) - Static method in class org.apache.nifi.processors.standard.relp.response.RELPResponse

Utility method to create a response to an open request.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.apache.nifi.storm.NiFiSpout

OPEN_FRAME - Static variable in class org.apache.nifi.processors.standard.relp.frame.TestRELPDecoder

OPEN_FRAME_DATA - Static variable in class org.apache.nifi.processors.standard.relp.frame.TestRELPDecoder

OPEN_FRAME_DATA - Static variable in class org.apache.nifi.processors.standard.relp.RELPFrameProducer

OPEN_FRAME_DATA - Static variable in class org.apache.nifi.processors.standard.TestListenRELP

OPEN_ID_CONNECT_SUPPORT_IS_NOT_CONFIGURED - Static variable in interface org.apache.nifi.web.security.oidc.OidcIdentityProvider

OPEN_START_ELEMENT_TOKEN - Static variable in class org.apache.nifi.processors.evtx.parser.bxml.BxmlNode

openBucket(String) - Method in interface org.apache.nifi.couchbase.CouchbaseClusterControllerService

Open a bucket connection.

openBucket(String) - Method in class org.apache.nifi.couchbase.CouchbaseClusterService

openBucket(ProcessContext) - Method in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor

Open a bucket connection using a CouchbaseClusterControllerService.

openConnectionForReceive(String, Peer) - Method in class org.apache.nifi.remote.util.SiteToSiteRestApiClient

openConnectionForSend(String, Peer) - Method in class org.apache.nifi.remote.util.SiteToSiteRestApiClient

OpenPGPKeyBasedEncryptor - Class in org.apache.nifi.security.util.crypto

OpenPGPKeyBasedEncryptor(String, String, String, String, char[], String) - Constructor for class org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptor

OpenPGPKeyBasedEncryptorTest - Class in org.apache.nifi.security.util.crypto

OpenPGPKeyBasedEncryptorTest() - Constructor for class org.apache.nifi.security.util.crypto.OpenPGPKeyBasedEncryptorTest

OpenPGPPasswordBasedEncryptor - Class in org.apache.nifi.security.util.crypto

OpenPGPPasswordBasedEncryptor(String, String, char[], String) - Constructor for class org.apache.nifi.security.util.crypto.OpenPGPPasswordBasedEncryptor

OpenPGPPasswordBasedEncryptorTest - Class in org.apache.nifi.security.util.crypto

OpenPGPPasswordBasedEncryptorTest() - Constructor for class org.apache.nifi.security.util.crypto.OpenPGPPasswordBasedEncryptorTest

OpenSSLPKCS5CipherProvider - Class in org.apache.nifi.security.util.crypto

OpenSSLPKCS5CipherProvider() - Constructor for class org.apache.nifi.security.util.crypto.OpenSSLPKCS5CipherProvider

OpenStartElementNode - Class in org.apache.nifi.processors.evtx.parser.bxml

Open tag in the template xml

OpenStartElementNode(BinaryReader, ChunkHeader, BxmlNode) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.OpenStartElementNode

OpenStartElementNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml

OpenStartElementNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.OpenStartElementNodeTest

Operation - Enum in org.apache.nifi.action

Defines possible operations for a given action.

operationType - Variable in class org.apache.nifi.processors.kudu.AbstractKudu

OperationType - Enum in org.apache.nifi.processors.kudu

OPT_SERVICE - Static variable in class org.apache.nifi.controller.service.mock.ServiceC

OPTIONAL_PROPERTY - Static variable in class org.apache.nifi.documentation.example.DeprecatedProcessor

OPTIONAL_PROPERTY - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedProcessor

options - Variable in class org.apache.nifi.processors.hive.PutHiveStreaming

OptionsHandler() - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.OptionsHandler

Oracle12DatabaseAdapter - Class in org.apache.nifi.processors.standard.db.impl

A database adapter that generates MS SQL Compatible SQL.

Oracle12DatabaseAdapter() - Constructor for class org.apache.nifi.processors.standard.db.impl.Oracle12DatabaseAdapter

OracleDatabaseAdapter - Class in org.apache.nifi.processors.standard.db.impl

A DatabaseAdapter that generates Oracle-compliant SQL.

OracleDatabaseAdapter() - Constructor for class org.apache.nifi.processors.standard.db.impl.OracleDatabaseAdapter

ORC_CONFIGURATION_RESOURCES - Static variable in class org.apache.nifi.processors.hive.ConvertAvroToORC

ORC_MIME_TYPE - Static variable in class org.apache.nifi.processors.hive.ConvertAvroToORC

OrcFlowFileWriter - Class in org.apache.hadoop.hive.ql.io.orc

An ORC file writer.

OrcFlowFileWriter(OutputStream, Path, Configuration, ObjectInspector, long, CompressionKind, int, int, MemoryManager, boolean, OrcFile.Version, OrcFile.WriterCallback, OrcFile.EncodingStrategy, OrcFile.CompressionStrategy, float, long, String, double) - Constructor for class org.apache.hadoop.hive.ql.io.orc.OrcFlowFileWriter

ORDER_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.EnforceOrder

OrEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions

OrEvaluator(Evaluator<Boolean>, Evaluator<Boolean>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.OrEvaluator

OrEvaluator - Class in org.apache.nifi.hl7.query.evaluator.logic

OrEvaluator(BooleanEvaluator, BooleanEvaluator) - Constructor for class org.apache.nifi.hl7.query.evaluator.logic.OrEvaluator

org.apache.hadoop.hive.ql.io.orc - package org.apache.hadoop.hive.ql.io.orc

org.apache.nifi - package org.apache.nifi

org.apache.nifi.action - package org.apache.nifi.action

org.apache.nifi.action.component.details - package org.apache.nifi.action.component.details

org.apache.nifi.action.details - package org.apache.nifi.action.details

org.apache.nifi.admin - package org.apache.nifi.admin

org.apache.nifi.admin.dao - package org.apache.nifi.admin.dao

org.apache.nifi.admin.dao.impl - package org.apache.nifi.admin.dao.impl

org.apache.nifi.admin.service - package org.apache.nifi.admin.service

org.apache.nifi.admin.service.action - package org.apache.nifi.admin.service.action

org.apache.nifi.admin.service.impl - package org.apache.nifi.admin.service.impl

org.apache.nifi.admin.service.transaction - package org.apache.nifi.admin.service.transaction

org.apache.nifi.admin.service.transaction.impl - package org.apache.nifi.admin.service.transaction.impl

org.apache.nifi.amqp.processors - package org.apache.nifi.amqp.processors

org.apache.nifi.annotation.behavior - package org.apache.nifi.annotation.behavior

org.apache.nifi.annotation.configuration - package org.apache.nifi.annotation.configuration

org.apache.nifi.annotation.documentation - package org.apache.nifi.annotation.documentation

org.apache.nifi.annotation.lifecycle - package org.apache.nifi.annotation.lifecycle

org.apache.nifi.annotation.notification - package org.apache.nifi.annotation.notification

org.apache.nifi.aop - package org.apache.nifi.aop

org.apache.nifi.attribute.expression.language - package org.apache.nifi.attribute.expression.language

org.apache.nifi.attribute.expression.language.compile - package org.apache.nifi.attribute.expression.language.compile

org.apache.nifi.attribute.expression.language.evaluation - package org.apache.nifi.attribute.expression.language.evaluation

org.apache.nifi.attribute.expression.language.evaluation.cast - package org.apache.nifi.attribute.expression.language.evaluation.cast

org.apache.nifi.attribute.expression.language.evaluation.functions - package org.apache.nifi.attribute.expression.language.evaluation.functions

org.apache.nifi.attribute.expression.language.evaluation.literals - package org.apache.nifi.attribute.expression.language.evaluation.literals

org.apache.nifi.attribute.expression.language.evaluation.reduce - package org.apache.nifi.attribute.expression.language.evaluation.reduce

org.apache.nifi.attribute.expression.language.evaluation.selection - package org.apache.nifi.attribute.expression.language.evaluation.selection

org.apache.nifi.attribute.expression.language.evaluation.util - package org.apache.nifi.attribute.expression.language.evaluation.util

org.apache.nifi.attribute.expression.language.exception - package org.apache.nifi.attribute.expression.language.exception

org.apache.nifi.audit - package org.apache.nifi.audit

org.apache.nifi.authentication - package org.apache.nifi.authentication

org.apache.nifi.authentication.annotation - package org.apache.nifi.authentication.annotation

org.apache.nifi.authentication.exception - package org.apache.nifi.authentication.exception

org.apache.nifi.authorization - package org.apache.nifi.authorization

org.apache.nifi.authorization.annotation - package org.apache.nifi.authorization.annotation

org.apache.nifi.authorization.exception - package org.apache.nifi.authorization.exception

org.apache.nifi.authorization.resource - package org.apache.nifi.authorization.resource

org.apache.nifi.authorization.user - package org.apache.nifi.authorization.user

org.apache.nifi.authorization.util - package org.apache.nifi.authorization.util

org.apache.nifi.avro - package org.apache.nifi.avro

org.apache.nifi.bootstrap - package org.apache.nifi.bootstrap

org.apache.nifi.bootstrap.exception - package org.apache.nifi.bootstrap.exception

org.apache.nifi.bootstrap.http - package org.apache.nifi.bootstrap.http

org.apache.nifi.bootstrap.notification - package org.apache.nifi.bootstrap.notification

org.apache.nifi.bootstrap.notification.email - package org.apache.nifi.bootstrap.notification.email

org.apache.nifi.bootstrap.notification.http - package org.apache.nifi.bootstrap.notification.http

org.apache.nifi.bootstrap.util - package org.apache.nifi.bootstrap.util

org.apache.nifi.bundle - package org.apache.nifi.bundle

org.apache.nifi.cdc - package org.apache.nifi.cdc

org.apache.nifi.cdc.event - package org.apache.nifi.cdc.event

org.apache.nifi.cdc.event.io - package org.apache.nifi.cdc.event.io

org.apache.nifi.cdc.mysql.event - package org.apache.nifi.cdc.mysql.event

org.apache.nifi.cdc.mysql.event.io - package org.apache.nifi.cdc.mysql.event.io

org.apache.nifi.cdc.mysql.processors - package org.apache.nifi.cdc.mysql.processors

org.apache.nifi.cluster - package org.apache.nifi.cluster

org.apache.nifi.cluster.coordination - package org.apache.nifi.cluster.coordination

org.apache.nifi.cluster.coordination.flow - package org.apache.nifi.cluster.coordination.flow

org.apache.nifi.cluster.coordination.heartbeat - package org.apache.nifi.cluster.coordination.heartbeat

org.apache.nifi.cluster.coordination.http - package org.apache.nifi.cluster.coordination.http

org.apache.nifi.cluster.coordination.http.endpoints - package org.apache.nifi.cluster.coordination.http.endpoints

org.apache.nifi.cluster.coordination.http.replication - package org.apache.nifi.cluster.coordination.http.replication

org.apache.nifi.cluster.coordination.node - package org.apache.nifi.cluster.coordination.node

org.apache.nifi.cluster.event - package org.apache.nifi.cluster.event

org.apache.nifi.cluster.exception - package org.apache.nifi.cluster.exception

org.apache.nifi.cluster.firewall - package org.apache.nifi.cluster.firewall

org.apache.nifi.cluster.firewall.impl - package org.apache.nifi.cluster.firewall.impl

org.apache.nifi.cluster.integration - package org.apache.nifi.cluster.integration

org.apache.nifi.cluster.manager - package org.apache.nifi.cluster.manager

org.apache.nifi.cluster.manager.exception - package org.apache.nifi.cluster.manager.exception

org.apache.nifi.cluster.manager.testutils - package org.apache.nifi.cluster.manager.testutils

org.apache.nifi.cluster.protocol - package org.apache.nifi.cluster.protocol

org.apache.nifi.cluster.protocol.impl - package org.apache.nifi.cluster.protocol.impl

org.apache.nifi.cluster.protocol.impl.testutils - package org.apache.nifi.cluster.protocol.impl.testutils

org.apache.nifi.cluster.protocol.jaxb - package org.apache.nifi.cluster.protocol.jaxb

org.apache.nifi.cluster.protocol.jaxb.message - package org.apache.nifi.cluster.protocol.jaxb.message

org.apache.nifi.cluster.protocol.message - package org.apache.nifi.cluster.protocol.message

org.apache.nifi.cluster.protocol.spring - package org.apache.nifi.cluster.protocol.spring

org.apache.nifi.cluster.spring - package org.apache.nifi.cluster.spring

org.apache.nifi.components - package org.apache.nifi.components

org.apache.nifi.components.state - package org.apache.nifi.components.state

org.apache.nifi.components.state.exception - package org.apache.nifi.components.state.exception

org.apache.nifi.confluent.schemaregistry - package org.apache.nifi.confluent.schemaregistry

org.apache.nifi.confluent.schemaregistry.client - package org.apache.nifi.confluent.schemaregistry.client

org.apache.nifi.connectable - package org.apache.nifi.connectable

org.apache.nifi.context - package org.apache.nifi.context

org.apache.nifi.controller - package org.apache.nifi.controller

org.apache.nifi.controller.cluster - package org.apache.nifi.controller.cluster

org.apache.nifi.controller.exception - package org.apache.nifi.controller.exception

org.apache.nifi.controller.label - package org.apache.nifi.controller.label

org.apache.nifi.controller.leader.election - package org.apache.nifi.controller.leader.election

org.apache.nifi.controller.queue - package org.apache.nifi.controller.queue

org.apache.nifi.controller.reporting - package org.apache.nifi.controller.reporting

org.apache.nifi.controller.repository - package org.apache.nifi.controller.repository

org.apache.nifi.controller.repository.claim - package org.apache.nifi.controller.repository.claim

org.apache.nifi.controller.repository.io - package org.apache.nifi.controller.repository.io

org.apache.nifi.controller.repository.metrics - package org.apache.nifi.controller.repository.metrics

org.apache.nifi.controller.repository.schema - package org.apache.nifi.controller.repository.schema

org.apache.nifi.controller.repository.util - package org.apache.nifi.controller.repository.util

org.apache.nifi.controller.scheduling - package org.apache.nifi.controller.scheduling

org.apache.nifi.controller.serialization - package org.apache.nifi.controller.serialization

org.apache.nifi.controller.service - package org.apache.nifi.controller.service

org.apache.nifi.controller.service.mock - package org.apache.nifi.controller.service.mock

org.apache.nifi.controller.service.util - package org.apache.nifi.controller.service.util

org.apache.nifi.controller.state - package org.apache.nifi.controller.state

org.apache.nifi.controller.state.config - package org.apache.nifi.controller.state.config

org.apache.nifi.controller.state.manager - package org.apache.nifi.controller.state.manager

org.apache.nifi.controller.state.providers - package org.apache.nifi.controller.state.providers

org.apache.nifi.controller.state.providers.local - package org.apache.nifi.controller.state.providers.local

org.apache.nifi.controller.state.providers.zookeeper - package org.apache.nifi.controller.state.providers.zookeeper

org.apache.nifi.controller.state.server - package org.apache.nifi.controller.state.server

org.apache.nifi.controller.status - package org.apache.nifi.controller.status

org.apache.nifi.controller.status.history - package org.apache.nifi.controller.status.history

org.apache.nifi.controller.swap - package org.apache.nifi.controller.swap

org.apache.nifi.controller.tasks - package org.apache.nifi.controller.tasks

org.apache.nifi.couchbase - package org.apache.nifi.couchbase

org.apache.nifi.csv - package org.apache.nifi.csv

org.apache.nifi.dbcp - package org.apache.nifi.dbcp

org.apache.nifi.dbcp.hive - package org.apache.nifi.dbcp.hive

org.apache.nifi.diagnostics - package org.apache.nifi.diagnostics

org.apache.nifi.distributed.cache.client - package org.apache.nifi.distributed.cache.client

org.apache.nifi.distributed.cache.client.exception - package org.apache.nifi.distributed.cache.client.exception

org.apache.nifi.distributed.cache.protocol - package org.apache.nifi.distributed.cache.protocol

org.apache.nifi.distributed.cache.protocol.exception - package org.apache.nifi.distributed.cache.protocol.exception

org.apache.nifi.distributed.cache.server - package org.apache.nifi.distributed.cache.server

org.apache.nifi.distributed.cache.server.map - package org.apache.nifi.distributed.cache.server.map

org.apache.nifi.distributed.cache.server.set - package org.apache.nifi.distributed.cache.server.set

org.apache.nifi.documentation - package org.apache.nifi.documentation

org.apache.nifi.documentation.example - package org.apache.nifi.documentation.example

org.apache.nifi.documentation.html - package org.apache.nifi.documentation.html

org.apache.nifi.encrypt - package org.apache.nifi.encrypt

org.apache.nifi.engine - package org.apache.nifi.engine

org.apache.nifi.events - package org.apache.nifi.events

org.apache.nifi.events.network - package org.apache.nifi.events.network

org.apache.nifi.expression - package org.apache.nifi.expression

org.apache.nifi.fingerprint - package org.apache.nifi.fingerprint

org.apache.nifi.flowfile - package org.apache.nifi.flowfile

org.apache.nifi.flowfile.attributes - package org.apache.nifi.flowfile.attributes

org.apache.nifi.framework.security.util - package org.apache.nifi.framework.security.util

org.apache.nifi.grok - package org.apache.nifi.grok

org.apache.nifi.groups - package org.apache.nifi.groups

org.apache.nifi.hadoop - package org.apache.nifi.hadoop

org.apache.nifi.hbase - package org.apache.nifi.hbase

org.apache.nifi.hbase.io - package org.apache.nifi.hbase.io

org.apache.nifi.hbase.put - package org.apache.nifi.hbase.put

org.apache.nifi.hbase.scan - package org.apache.nifi.hbase.scan

org.apache.nifi.hbase.util - package org.apache.nifi.hbase.util

org.apache.nifi.hbase.validate - package org.apache.nifi.hbase.validate

org.apache.nifi.history - package org.apache.nifi.history

org.apache.nifi.hl7.hapi - package org.apache.nifi.hl7.hapi

org.apache.nifi.hl7.io - package org.apache.nifi.hl7.io

org.apache.nifi.hl7.io.exception - package org.apache.nifi.hl7.io.exception

org.apache.nifi.hl7.model - package org.apache.nifi.hl7.model

org.apache.nifi.hl7.query - package org.apache.nifi.hl7.query

org.apache.nifi.hl7.query.evaluator - package org.apache.nifi.hl7.query.evaluator

org.apache.nifi.hl7.query.evaluator.comparison - package org.apache.nifi.hl7.query.evaluator.comparison

org.apache.nifi.hl7.query.evaluator.literal - package org.apache.nifi.hl7.query.evaluator.literal

org.apache.nifi.hl7.query.evaluator.logic - package org.apache.nifi.hl7.query.evaluator.logic

org.apache.nifi.hl7.query.evaluator.message - package org.apache.nifi.hl7.query.evaluator.message

org.apache.nifi.hl7.query.exception - package org.apache.nifi.hl7.query.exception

org.apache.nifi.hl7.query.result - package org.apache.nifi.hl7.query.result

org.apache.nifi.http - package org.apache.nifi.http

org.apache.nifi.init - package org.apache.nifi.init

org.apache.nifi.integration - package org.apache.nifi.integration

org.apache.nifi.integration.accesscontrol - package org.apache.nifi.integration.accesscontrol

org.apache.nifi.integration.util - package org.apache.nifi.integration.util

org.apache.nifi.io.nio - package org.apache.nifi.io.nio

org.apache.nifi.io.nio.consumer - package org.apache.nifi.io.nio.consumer

org.apache.nifi.io.nio.example - package org.apache.nifi.io.nio.example

org.apache.nifi.io.socket - package org.apache.nifi.io.socket

org.apache.nifi.io.socket.multicast - package org.apache.nifi.io.socket.multicast

org.apache.nifi.jaxb - package org.apache.nifi.jaxb

org.apache.nifi.jms.cf - package org.apache.nifi.jms.cf

org.apache.nifi.jms.processors - package org.apache.nifi.jms.processors

org.apache.nifi.json - package org.apache.nifi.json

org.apache.nifi.kerberos - package org.apache.nifi.kerberos

org.apache.nifi.key - package org.apache.nifi.key

org.apache.nifi.ldap - package org.apache.nifi.ldap

org.apache.nifi.ldap.tenants - package org.apache.nifi.ldap.tenants

org.apache.nifi.lifecycle - package org.apache.nifi.lifecycle

org.apache.nifi.loading - package org.apache.nifi.loading

org.apache.nifi.logging - package org.apache.nifi.logging

org.apache.nifi.logging.repository - package org.apache.nifi.logging.repository

org.apache.nifi.lookup - package org.apache.nifi.lookup

org.apache.nifi.lookup.configuration2 - package org.apache.nifi.lookup.configuration2

org.apache.nifi.lookup.maxmind - package org.apache.nifi.lookup.maxmind

org.apache.nifi.lookup.script - package org.apache.nifi.lookup.script

org.apache.nifi.mock - package org.apache.nifi.mock

org.apache.nifi.mongodb - package org.apache.nifi.mongodb

org.apache.nifi.nar - package org.apache.nifi.nar

org.apache.nifi.persistence - package org.apache.nifi.persistence

org.apache.nifi.prioritizer - package org.apache.nifi.prioritizer

org.apache.nifi.processor - package org.apache.nifi.processor

org.apache.nifi.processor.exception - package org.apache.nifi.processor.exception

org.apache.nifi.processor.io - package org.apache.nifi.processor.io

org.apache.nifi.processor.util - package org.apache.nifi.processor.util

org.apache.nifi.processor.util.bin - package org.apache.nifi.processor.util.bin

org.apache.nifi.processor.util.list - package org.apache.nifi.processor.util.list

org.apache.nifi.processor.util.listen - package org.apache.nifi.processor.util.listen

org.apache.nifi.processor.util.listen.dispatcher - package org.apache.nifi.processor.util.listen.dispatcher

org.apache.nifi.processor.util.listen.event - package org.apache.nifi.processor.util.listen.event

org.apache.nifi.processor.util.listen.handler - package org.apache.nifi.processor.util.listen.handler

org.apache.nifi.processor.util.listen.handler.socket - package org.apache.nifi.processor.util.listen.handler.socket

org.apache.nifi.processor.util.listen.response - package org.apache.nifi.processor.util.listen.response

org.apache.nifi.processor.util.listen.response.socket - package org.apache.nifi.processor.util.listen.response.socket

org.apache.nifi.processor.util.pattern - package org.apache.nifi.processor.util.pattern

org.apache.nifi.processor.util.put - package org.apache.nifi.processor.util.put

org.apache.nifi.processor.util.put.sender - package org.apache.nifi.processor.util.put.sender

org.apache.nifi.processors - package org.apache.nifi.processors

org.apache.nifi.processors.attributes - package org.apache.nifi.processors.attributes

org.apache.nifi.processors.avro - package org.apache.nifi.processors.avro

org.apache.nifi.processors.aws - package org.apache.nifi.processors.aws

org.apache.nifi.processors.aws.cloudwatch - package org.apache.nifi.processors.aws.cloudwatch

org.apache.nifi.processors.aws.credentials.provider.factory - package org.apache.nifi.processors.aws.credentials.provider.factory

org.apache.nifi.processors.aws.credentials.provider.factory.strategies - package org.apache.nifi.processors.aws.credentials.provider.factory.strategies

org.apache.nifi.processors.aws.credentials.provider.service - package org.apache.nifi.processors.aws.credentials.provider.service

org.apache.nifi.processors.aws.dynamodb - package org.apache.nifi.processors.aws.dynamodb

org.apache.nifi.processors.aws.kinesis - package org.apache.nifi.processors.aws.kinesis

org.apache.nifi.processors.aws.kinesis.firehose - package org.apache.nifi.processors.aws.kinesis.firehose

org.apache.nifi.processors.aws.kinesis.stream - package org.apache.nifi.processors.aws.kinesis.stream

org.apache.nifi.processors.aws.lambda - package org.apache.nifi.processors.aws.lambda

org.apache.nifi.processors.aws.s3 - package org.apache.nifi.processors.aws.s3

org.apache.nifi.processors.aws.sns - package org.apache.nifi.processors.aws.sns

org.apache.nifi.processors.aws.sqs - package org.apache.nifi.processors.aws.sqs

org.apache.nifi.processors.azure - package org.apache.nifi.processors.azure

org.apache.nifi.processors.azure.eventhub - package org.apache.nifi.processors.azure.eventhub

org.apache.nifi.processors.azure.storage - package org.apache.nifi.processors.azure.storage

org.apache.nifi.processors.azure.storage.utils - package org.apache.nifi.processors.azure.storage.utils

org.apache.nifi.processors.beats - package org.apache.nifi.processors.beats

org.apache.nifi.processors.beats.event - package org.apache.nifi.processors.beats.event

org.apache.nifi.processors.beats.frame - package org.apache.nifi.processors.beats.frame

org.apache.nifi.processors.beats.handler - package org.apache.nifi.processors.beats.handler

org.apache.nifi.processors.beats.response - package org.apache.nifi.processors.beats.response

org.apache.nifi.processors.cassandra - package org.apache.nifi.processors.cassandra

org.apache.nifi.processors.ccda - package org.apache.nifi.processors.ccda

org.apache.nifi.processors.couchbase - package org.apache.nifi.processors.couchbase

org.apache.nifi.processors.cybersecurity - package org.apache.nifi.processors.cybersecurity

org.apache.nifi.processors.cybersecurity.matchers - package org.apache.nifi.processors.cybersecurity.matchers

org.apache.nifi.processors.elasticsearch - package org.apache.nifi.processors.elasticsearch

org.apache.nifi.processors.email - package org.apache.nifi.processors.email

org.apache.nifi.processors.email.smtp - package org.apache.nifi.processors.email.smtp

org.apache.nifi.processors.enrich - package org.apache.nifi.processors.enrich

org.apache.nifi.processors.evtx - package org.apache.nifi.processors.evtx

org.apache.nifi.processors.evtx.parser - package org.apache.nifi.processors.evtx.parser

org.apache.nifi.processors.evtx.parser.bxml - package org.apache.nifi.processors.evtx.parser.bxml

org.apache.nifi.processors.evtx.parser.bxml.value - package org.apache.nifi.processors.evtx.parser.bxml.value

org.apache.nifi.processors.flume - package org.apache.nifi.processors.flume

org.apache.nifi.processors.flume.util - package org.apache.nifi.processors.flume.util

org.apache.nifi.processors.gcp - package org.apache.nifi.processors.gcp

org.apache.nifi.processors.gcp.credentials.factory - package org.apache.nifi.processors.gcp.credentials.factory

org.apache.nifi.processors.gcp.credentials.factory.strategies - package org.apache.nifi.processors.gcp.credentials.factory.strategies

org.apache.nifi.processors.gcp.credentials.service - package org.apache.nifi.processors.gcp.credentials.service

org.apache.nifi.processors.gcp.storage - package org.apache.nifi.processors.gcp.storage

org.apache.nifi.processors.gettcp - package org.apache.nifi.processors.gettcp

org.apache.nifi.processors.grpc - package org.apache.nifi.processors.grpc

org.apache.nifi.processors.hadoop - package org.apache.nifi.processors.hadoop

org.apache.nifi.processors.hadoop.exception - package org.apache.nifi.processors.hadoop.exception

org.apache.nifi.processors.hadoop.inotify - package org.apache.nifi.processors.hadoop.inotify

org.apache.nifi.processors.hadoop.inotify.util - package org.apache.nifi.processors.hadoop.inotify.util

org.apache.nifi.processors.hadoop.record - package org.apache.nifi.processors.hadoop.record

org.apache.nifi.processors.hadoop.util - package org.apache.nifi.processors.hadoop.util

org.apache.nifi.processors.hive - package org.apache.nifi.processors.hive

org.apache.nifi.processors.hl7 - package org.apache.nifi.processors.hl7

org.apache.nifi.processors.ignite - package org.apache.nifi.processors.ignite

org.apache.nifi.processors.ignite.cache - package org.apache.nifi.processors.ignite.cache

org.apache.nifi.processors.image - package org.apache.nifi.processors.image

org.apache.nifi.processors.kafka - package org.apache.nifi.processors.kafka

org.apache.nifi.processors.kafka.pubsub - package org.apache.nifi.processors.kafka.pubsub

org.apache.nifi.processors.kafka.pubsub.util - package org.apache.nifi.processors.kafka.pubsub.util

org.apache.nifi.processors.kafka.test - package org.apache.nifi.processors.kafka.test

org.apache.nifi.processors.kite - package org.apache.nifi.processors.kite

org.apache.nifi.processors.kudu - package org.apache.nifi.processors.kudu

org.apache.nifi.processors.lumberjack - package org.apache.nifi.processors.lumberjack

org.apache.nifi.processors.lumberjack.event - package org.apache.nifi.processors.lumberjack.event

org.apache.nifi.processors.lumberjack.frame - package org.apache.nifi.processors.lumberjack.frame

org.apache.nifi.processors.lumberjack.handler - package org.apache.nifi.processors.lumberjack.handler

org.apache.nifi.processors.lumberjack.response - package org.apache.nifi.processors.lumberjack.response

org.apache.nifi.processors.maxmind - package org.apache.nifi.processors.maxmind

org.apache.nifi.processors.media - package org.apache.nifi.processors.media

org.apache.nifi.processors.mongodb - package org.apache.nifi.processors.mongodb

org.apache.nifi.processors.mqtt - package org.apache.nifi.processors.mqtt

org.apache.nifi.processors.mqtt.common - package org.apache.nifi.processors.mqtt.common

org.apache.nifi.processors.mqtt.integration - package org.apache.nifi.processors.mqtt.integration

org.apache.nifi.processors.parquet - package org.apache.nifi.processors.parquet

org.apache.nifi.processors.parquet.record - package org.apache.nifi.processors.parquet.record

org.apache.nifi.processors.poi - package org.apache.nifi.processors.poi

org.apache.nifi.processors.rethinkdb - package org.apache.nifi.processors.rethinkdb

org.apache.nifi.processors.riemann - package org.apache.nifi.processors.riemann

org.apache.nifi.processors.script - package org.apache.nifi.processors.script

org.apache.nifi.processors.script.engine - package org.apache.nifi.processors.script.engine

org.apache.nifi.processors.slack - package org.apache.nifi.processors.slack

org.apache.nifi.processors.solr - package org.apache.nifi.processors.solr

org.apache.nifi.processors.splunk - package org.apache.nifi.processors.splunk

org.apache.nifi.processors.splunk.util - package org.apache.nifi.processors.splunk.util

org.apache.nifi.processors.standard - package org.apache.nifi.processors.standard

org.apache.nifi.processors.standard.db - package org.apache.nifi.processors.standard.db

org.apache.nifi.processors.standard.db.impl - package org.apache.nifi.processors.standard.db.impl

org.apache.nifi.processors.standard.merge - package org.apache.nifi.processors.standard.merge

org.apache.nifi.processors.standard.relp - package org.apache.nifi.processors.standard.relp

org.apache.nifi.processors.standard.relp.event - package org.apache.nifi.processors.standard.relp.event

org.apache.nifi.processors.standard.relp.frame - package org.apache.nifi.processors.standard.relp.frame

org.apache.nifi.processors.standard.relp.handler - package org.apache.nifi.processors.standard.relp.handler

org.apache.nifi.processors.standard.relp.response - package org.apache.nifi.processors.standard.relp.response

org.apache.nifi.processors.standard.servlets - package org.apache.nifi.processors.standard.servlets

org.apache.nifi.processors.standard.syslog - package org.apache.nifi.processors.standard.syslog

org.apache.nifi.processors.standard.util - package org.apache.nifi.processors.standard.util

org.apache.nifi.processors.standard.util.jolt - package org.apache.nifi.processors.standard.util.jolt

org.apache.nifi.processors.stateful.analysis - package org.apache.nifi.processors.stateful.analysis

org.apache.nifi.processors.twitter - package org.apache.nifi.processors.twitter

org.apache.nifi.processors.websocket - package org.apache.nifi.processors.websocket

org.apache.nifi.processors.windows.event.log - package org.apache.nifi.processors.windows.event.log

org.apache.nifi.processors.windows.event.log.jna - package org.apache.nifi.processors.windows.event.log.jna

org.apache.nifi.processors.yandex - package org.apache.nifi.processors.yandex

org.apache.nifi.processors.yandex.model - package org.apache.nifi.processors.yandex.model

org.apache.nifi.processors.yandex.util - package org.apache.nifi.processors.yandex.util

org.apache.nifi.properties - package org.apache.nifi.properties

org.apache.nifi.provenance - package org.apache.nifi.provenance

org.apache.nifi.provenance.authorization - package org.apache.nifi.provenance.authorization

org.apache.nifi.provenance.expiration - package org.apache.nifi.provenance.expiration

org.apache.nifi.provenance.index - package org.apache.nifi.provenance.index

org.apache.nifi.provenance.index.lucene - package org.apache.nifi.provenance.index.lucene

org.apache.nifi.provenance.lineage - package org.apache.nifi.provenance.lineage

org.apache.nifi.provenance.lucene - package org.apache.nifi.provenance.lucene

org.apache.nifi.provenance.schema - package org.apache.nifi.provenance.schema

org.apache.nifi.provenance.search - package org.apache.nifi.provenance.search

org.apache.nifi.provenance.serialization - package org.apache.nifi.provenance.serialization

org.apache.nifi.provenance.store - package org.apache.nifi.provenance.store

org.apache.nifi.provenance.store.iterator - package org.apache.nifi.provenance.store.iterator

org.apache.nifi.provenance.toc - package org.apache.nifi.provenance.toc

org.apache.nifi.provenance.util - package org.apache.nifi.provenance.util

org.apache.nifi.queryrecord - package org.apache.nifi.queryrecord

org.apache.nifi.ranger.authorization - package org.apache.nifi.ranger.authorization

org.apache.nifi.record.listen - package org.apache.nifi.record.listen

org.apache.nifi.record.path - package org.apache.nifi.record.path

org.apache.nifi.record.path.exception - package org.apache.nifi.record.path.exception

org.apache.nifi.record.path.filter - package org.apache.nifi.record.path.filter

org.apache.nifi.record.path.functions - package org.apache.nifi.record.path.functions

org.apache.nifi.record.path.paths - package org.apache.nifi.record.path.paths

org.apache.nifi.record.path.util - package org.apache.nifi.record.path.util

org.apache.nifi.record.path.validation - package org.apache.nifi.record.path.validation

org.apache.nifi.record.script - package org.apache.nifi.record.script

org.apache.nifi.redis - package org.apache.nifi.redis

org.apache.nifi.redis.service - package org.apache.nifi.redis.service

org.apache.nifi.redis.state - package org.apache.nifi.redis.state

org.apache.nifi.redis.util - package org.apache.nifi.redis.util

org.apache.nifi.registry - package org.apache.nifi.registry

org.apache.nifi.registry.variable - package org.apache.nifi.registry.variable

org.apache.nifi.remote - package org.apache.nifi.remote

org.apache.nifi.remote.client - package org.apache.nifi.remote.client

org.apache.nifi.remote.client.http - package org.apache.nifi.remote.client.http

org.apache.nifi.remote.client.socket - package org.apache.nifi.remote.client.socket

org.apache.nifi.remote.cluster - package org.apache.nifi.remote.cluster

org.apache.nifi.remote.codec - package org.apache.nifi.remote.codec

org.apache.nifi.remote.exception - package org.apache.nifi.remote.exception

org.apache.nifi.remote.io - package org.apache.nifi.remote.io

org.apache.nifi.remote.io.http - package org.apache.nifi.remote.io.http

org.apache.nifi.remote.io.socket - package org.apache.nifi.remote.io.socket

org.apache.nifi.remote.io.socket.ssl - package org.apache.nifi.remote.io.socket.ssl

org.apache.nifi.remote.protocol - package org.apache.nifi.remote.protocol

org.apache.nifi.remote.protocol.http - package org.apache.nifi.remote.protocol.http

org.apache.nifi.remote.protocol.socket - package org.apache.nifi.remote.protocol.socket

org.apache.nifi.remote.util - package org.apache.nifi.remote.util

org.apache.nifi.reporting - package org.apache.nifi.reporting

org.apache.nifi.reporting.ambari - package org.apache.nifi.reporting.ambari

org.apache.nifi.reporting.ambari.api - package org.apache.nifi.reporting.ambari.api

org.apache.nifi.reporting.ambari.metrics - package org.apache.nifi.reporting.ambari.metrics

org.apache.nifi.reporting.datadog - package org.apache.nifi.reporting.datadog

org.apache.nifi.reporting.datadog.api - package org.apache.nifi.reporting.datadog.api

org.apache.nifi.reporting.datadog.metrics - package org.apache.nifi.reporting.datadog.metrics

org.apache.nifi.reporting.ganglia - package org.apache.nifi.reporting.ganglia

org.apache.nifi.reporting.script - package org.apache.nifi.reporting.script

org.apache.nifi.repository.schema - package org.apache.nifi.repository.schema

org.apache.nifi.scheduling - package org.apache.nifi.scheduling

org.apache.nifi.schema.access - package org.apache.nifi.schema.access

org.apache.nifi.schema.validation - package org.apache.nifi.schema.validation

org.apache.nifi.schemaregistry.hortonworks - package org.apache.nifi.schemaregistry.hortonworks

org.apache.nifi.schemaregistry.services - package org.apache.nifi.schemaregistry.services

org.apache.nifi.script - package org.apache.nifi.script

org.apache.nifi.script.impl - package org.apache.nifi.script.impl

org.apache.nifi.search - package org.apache.nifi.search

org.apache.nifi.security.kms - package org.apache.nifi.security.kms

org.apache.nifi.security.util - package org.apache.nifi.security.util

org.apache.nifi.security.util.crypto - package org.apache.nifi.security.util.crypto

org.apache.nifi.security.util.crypto.bcrypt - package org.apache.nifi.security.util.crypto.bcrypt

org.apache.nifi.security.util.crypto.scrypt - package org.apache.nifi.security.util.crypto.scrypt

org.apache.nifi.security.xml - package org.apache.nifi.security.xml

org.apache.nifi.serialization - package org.apache.nifi.serialization

org.apache.nifi.serialization.record - package org.apache.nifi.serialization.record

org.apache.nifi.serialization.record.type - package org.apache.nifi.serialization.record.type

org.apache.nifi.serialization.record.util - package org.apache.nifi.serialization.record.util

org.apache.nifi.serialization.record.validation - package org.apache.nifi.serialization.record.validation

org.apache.nifi.services - package org.apache.nifi.services

org.apache.nifi.snmp.processors - package org.apache.nifi.snmp.processors

org.apache.nifi.spark - package org.apache.nifi.spark

org.apache.nifi.spring - package org.apache.nifi.spring

org.apache.nifi.spring.bootstrap - package org.apache.nifi.spring.bootstrap

org.apache.nifi.ssl - package org.apache.nifi.ssl

org.apache.nifi.state - package org.apache.nifi.state

org.apache.nifi.storm - package org.apache.nifi.storm

org.apache.nifi.stream.io - package org.apache.nifi.stream.io

org.apache.nifi.stream.io.exception - package org.apache.nifi.stream.io.exception

org.apache.nifi.stream.io.util - package org.apache.nifi.stream.io.util

org.apache.nifi.test.processors - package org.apache.nifi.test.processors

org.apache.nifi.text - package org.apache.nifi.text

org.apache.nifi.toolkit - package org.apache.nifi.toolkit

org.apache.nifi.toolkit.flowanalyzer - package org.apache.nifi.toolkit.flowanalyzer

org.apache.nifi.toolkit.repos.flowfile - package org.apache.nifi.toolkit.repos.flowfile

org.apache.nifi.toolkit.s2s - package org.apache.nifi.toolkit.s2s

org.apache.nifi.toolkit.tls - package org.apache.nifi.toolkit.tls

org.apache.nifi.toolkit.tls.commandLine - package org.apache.nifi.toolkit.tls.commandLine

org.apache.nifi.toolkit.tls.configuration - package org.apache.nifi.toolkit.tls.configuration

org.apache.nifi.toolkit.tls.manager - package org.apache.nifi.toolkit.tls.manager

org.apache.nifi.toolkit.tls.manager.writer - package org.apache.nifi.toolkit.tls.manager.writer

org.apache.nifi.toolkit.tls.properties - package org.apache.nifi.toolkit.tls.properties

org.apache.nifi.toolkit.tls.service - package org.apache.nifi.toolkit.tls.service

org.apache.nifi.toolkit.tls.service.client - package org.apache.nifi.toolkit.tls.service.client

org.apache.nifi.toolkit.tls.service.dto - package org.apache.nifi.toolkit.tls.service.dto

org.apache.nifi.toolkit.tls.service.server - package org.apache.nifi.toolkit.tls.service.server

org.apache.nifi.toolkit.tls.standalone - package org.apache.nifi.toolkit.tls.standalone

org.apache.nifi.toolkit.tls.util - package org.apache.nifi.toolkit.tls.util

org.apache.nifi.toolkit.zkmigrator - package org.apache.nifi.toolkit.zkmigrator

org.apache.nifi.ui.extension - package org.apache.nifi.ui.extension

org.apache.nifi.update.attributes - package org.apache.nifi.update.attributes

org.apache.nifi.update.attributes.api - package org.apache.nifi.update.attributes.api

org.apache.nifi.update.attributes.dto - package org.apache.nifi.update.attributes.dto

org.apache.nifi.update.attributes.entity - package org.apache.nifi.update.attributes.entity

org.apache.nifi.update.attributes.serde - package org.apache.nifi.update.attributes.serde

org.apache.nifi.user - package org.apache.nifi.user

org.apache.nifi.util - package org.apache.nifi.util

org.apache.nifi.util.concurrency - package org.apache.nifi.util.concurrency

org.apache.nifi.util.console - package org.apache.nifi.util.console

org.apache.nifi.util.file - package org.apache.nifi.util.file

org.apache.nifi.util.file.classloader - package org.apache.nifi.util.file.classloader

org.apache.nifi.util.file.monitor - package org.apache.nifi.util.file.monitor

org.apache.nifi.util.hive - package org.apache.nifi.util.hive

org.apache.nifi.util.orc - package org.apache.nifi.util.orc

org.apache.nifi.util.search - package org.apache.nifi.util.search

org.apache.nifi.util.search.ahocorasick - package org.apache.nifi.util.search.ahocorasick

org.apache.nifi.util.timebuffer - package org.apache.nifi.util.timebuffer

org.apache.nifi.util.validator - package org.apache.nifi.util.validator

org.apache.nifi.web - package org.apache.nifi.web

org.apache.nifi.web.api - package org.apache.nifi.web.api

org.apache.nifi.web.api.config - package org.apache.nifi.web.api.config

org.apache.nifi.web.api.dto - package org.apache.nifi.web.api.dto

org.apache.nifi.web.api.dto.action - package org.apache.nifi.web.api.dto.action

org.apache.nifi.web.api.dto.action.component.details - package org.apache.nifi.web.api.dto.action.component.details

org.apache.nifi.web.api.dto.action.details - package org.apache.nifi.web.api.dto.action.details

org.apache.nifi.web.api.dto.flow - package org.apache.nifi.web.api.dto.flow

org.apache.nifi.web.api.dto.provenance - package org.apache.nifi.web.api.dto.provenance

org.apache.nifi.web.api.dto.provenance.lineage - package org.apache.nifi.web.api.dto.provenance.lineage

org.apache.nifi.web.api.dto.remote - package org.apache.nifi.web.api.dto.remote

org.apache.nifi.web.api.dto.search - package org.apache.nifi.web.api.dto.search

org.apache.nifi.web.api.dto.status - package org.apache.nifi.web.api.dto.status

org.apache.nifi.web.api.dto.util - package org.apache.nifi.web.api.dto.util

org.apache.nifi.web.api.entity - package org.apache.nifi.web.api.entity

org.apache.nifi.web.api.filter - package org.apache.nifi.web.api.filter

org.apache.nifi.web.api.request - package org.apache.nifi.web.api.request

org.apache.nifi.web.contextlistener - package org.apache.nifi.web.contextlistener

org.apache.nifi.web.controller - package org.apache.nifi.web.controller

org.apache.nifi.web.dao - package org.apache.nifi.web.dao

org.apache.nifi.web.dao.impl - package org.apache.nifi.web.dao.impl

org.apache.nifi.web.docs - package org.apache.nifi.web.docs

org.apache.nifi.web.filter - package org.apache.nifi.web.filter

org.apache.nifi.web.revision - package org.apache.nifi.web.revision

org.apache.nifi.web.security - package org.apache.nifi.web.security

org.apache.nifi.web.security.anonymous - package org.apache.nifi.web.security.anonymous

org.apache.nifi.web.security.jwt - package org.apache.nifi.web.security.jwt

org.apache.nifi.web.security.kerberos - package org.apache.nifi.web.security.kerberos

org.apache.nifi.web.security.knox - package org.apache.nifi.web.security.knox

org.apache.nifi.web.security.oidc - package org.apache.nifi.web.security.oidc

org.apache.nifi.web.security.otp - package org.apache.nifi.web.security.otp

org.apache.nifi.web.security.spring - package org.apache.nifi.web.security.spring

org.apache.nifi.web.security.token - package org.apache.nifi.web.security.token

org.apache.nifi.web.security.util - package org.apache.nifi.web.security.util

org.apache.nifi.web.security.x509 - package org.apache.nifi.web.security.x509

org.apache.nifi.web.security.x509.ocsp - package org.apache.nifi.web.security.x509.ocsp

org.apache.nifi.web.server - package org.apache.nifi.web.server

org.apache.nifi.web.spring - package org.apache.nifi.web.spring

org.apache.nifi.web.standard.api - package org.apache.nifi.web.standard.api

org.apache.nifi.web.standard.api.processor - package org.apache.nifi.web.standard.api.processor

org.apache.nifi.web.standard.api.transformjson - package org.apache.nifi.web.standard.api.transformjson

org.apache.nifi.web.standard.api.transformjson.dto - package org.apache.nifi.web.standard.api.transformjson.dto

org.apache.nifi.web.util - package org.apache.nifi.web.util

org.apache.nifi.websocket - package org.apache.nifi.websocket

org.apache.nifi.websocket.example - package org.apache.nifi.websocket.example

org.apache.nifi.websocket.jetty - package org.apache.nifi.websocket.jetty

org.wali - package org.wali

ORIGINAL - Static variable in class org.apache.nifi.processors.poi.ConvertExcelToCSVProcessor

ORIGINAL_DESCRIPTION_ATTRIBUTE_NAME - Static variable in class org.apache.nifi.processors.standard.DetectDuplicate

ORIGINAL_RELATIONSHIP - Static variable in class org.apache.nifi.processors.standard.ExecuteStreamCommand

OSUtils - Class in org.apache.nifi.bootstrap.util

OS specific utilities with generic method interfaces

OSUtils() - Constructor for class org.apache.nifi.bootstrap.util.OSUtils

OTHER_SERVICE - Static variable in class org.apache.nifi.controller.service.mock.ServiceA

OTHER_SERVICE_2 - Static variable in class org.apache.nifi.controller.service.mock.ServiceA

OtpAuthenticationException - Exception in org.apache.nifi.web.security.otp

Thrown if a one time use token fails authentication.

OtpAuthenticationException(String) - Constructor for exception org.apache.nifi.web.security.otp.OtpAuthenticationException

OtpAuthenticationException(String, Throwable) - Constructor for exception org.apache.nifi.web.security.otp.OtpAuthenticationException

OtpAuthenticationFilter - Class in org.apache.nifi.web.security.otp

OtpAuthenticationFilter() - Constructor for class org.apache.nifi.web.security.otp.OtpAuthenticationFilter

OtpAuthenticationFilterTest - Class in org.apache.nifi.web.security.otp

OtpAuthenticationFilterTest() - Constructor for class org.apache.nifi.web.security.otp.OtpAuthenticationFilterTest

OtpAuthenticationProvider - Class in org.apache.nifi.web.security.otp

OtpAuthenticationProvider(OtpService, NiFiProperties, Authorizer) - Constructor for class org.apache.nifi.web.security.otp.OtpAuthenticationProvider

OtpAuthenticationProviderTest - Class in org.apache.nifi.web.security.otp

OtpAuthenticationProviderTest() - Constructor for class org.apache.nifi.web.security.otp.OtpAuthenticationProviderTest

OtpAuthenticationRequestToken - Class in org.apache.nifi.web.security.otp

This is an authentication request with a given OTP token.

OtpAuthenticationRequestToken(String, boolean, String) - Constructor for class org.apache.nifi.web.security.otp.OtpAuthenticationRequestToken

Creates a representation of the otp authentication request for a user.

OtpAuthenticationToken - Class in org.apache.nifi.web.security.token

This is an Authentication Token for logging in.

OtpAuthenticationToken(String) - Constructor for class org.apache.nifi.web.security.token.OtpAuthenticationToken

Creates a representation of the otp authentication token for a user.

otpFilterBean() - Method in class org.apache.nifi.web.NiFiWebApiSecurityConfiguration

OtpService - Class in org.apache.nifi.web.security.otp

OtpService is a service for generating and verifying one time password tokens.

OtpService() - Constructor for class org.apache.nifi.web.security.otp.OtpService

Creates a new OtpService with an expiration of 5 minutes.

OtpService(int, TimeUnit) - Constructor for class org.apache.nifi.web.security.otp.OtpService

Creates a new OtpService.

OtpServiceTest - Class in org.apache.nifi.web.security.otp

OtpServiceTest() - Constructor for class org.apache.nifi.web.security.otp.OtpServiceTest

outcome - Variable in class org.apache.nifi.processors.aws.dynamodb.GetDynamoDBTest

OUTGOING_MESSAGE_DELIMITER - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor

output - Variable in class org.apache.nifi.remote.io.http.HttpCommunicationsSession

OUTPUT_BYTES - Static variable in interface org.apache.nifi.reporting.datadog.metrics.MetricNames

OUTPUT_CHARSET - Static variable in class org.apache.nifi.processors.standard.ConvertCharacterSet

OUTPUT_COUNT - Static variable in interface org.apache.nifi.reporting.datadog.metrics.MetricNames

OUTPUT_DIRECTORY_ARG - Static variable in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine

OUTPUT_FORMAT - Static variable in class org.apache.nifi.processors.cassandra.QueryCassandra

OUTPUT_METHOD_HTML - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery

OUTPUT_METHOD_TEXT - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery

OUTPUT_METHOD_XML - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery

OUTPUT_MODE - Static variable in class org.apache.nifi.processors.splunk.GetSplunk

OUTPUT_PORT_STATUS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.PortStatusEndpointMerger

OUTPUT_PORT_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.PortEndpointMerger

OUTPUT_PORTS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.OutputPortsEndpointMerger

OUTPUT_PORTS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.PortEndpointMerger

OUTPUT_SCHEMA - Static variable in class org.apache.nifi.processors.kite.TestConvertAvroSchema

OUTPUT_SIZE - Static variable in class org.apache.nifi.processors.avro.SplitAvro

OUTPUT_STRATEGY - Static variable in class org.apache.nifi.processors.avro.SplitAvro

OUTPUT_STREAM_RELATIONSHIP - Static variable in class org.apache.nifi.processors.standard.ExecuteStreamCommand

OUTPUT_TYPE - Static variable in class org.apache.nifi.GetHTMLElement

OUTPUT_TYPE - Static variable in class org.apache.nifi.ModifyHTMLElement

outputEvents(ProcessSession, StateManager, ComponentLog) - Method in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL

OutputPortResource - Class in org.apache.nifi.web.api

RESTful endpoint for managing an Output Port.

OutputPortResource() - Constructor for class org.apache.nifi.web.api.OutputPortResource

OutputPortsEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints

OutputPortsEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.OutputPortsEndpointMerger

OutputPortsEntity - 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.

OutputPortsEntity() - Constructor for class org.apache.nifi.web.api.entity.OutputPortsEntity

OutputPortTransactionServlet() - Constructor for class org.apache.nifi.remote.client.http.TestHttpClient.OutputPortTransactionServlet

OutputStreamCallback - Interface in org.apache.nifi.processor.io

OutputStreamFactory - Interface in org.apache.nifi.toolkit.tls.util

OutputStreamWritable - Class in org.apache.nifi.processors.hadoop.util

This class will write to an output stream, rather than an in-memory buffer, the fields being read.

OutputStreamWritable(OutputStream, boolean) - Constructor for class org.apache.nifi.processors.hadoop.util.OutputStreamWritable

OVERLAY_PROPERTIES - Static variable in class org.apache.nifi.toolkit.tls.manager.writer.NifiPropertiesTlsClientConfigWriter

OVERWRITE - Static variable in class org.apache.nifi.processors.gcp.storage.PutGCSObject

OVERWRITE - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord

OVERWRITE_ARG - Static variable in class org.apache.nifi.toolkit.tls.standalone.TlsToolkitStandaloneCommandLine

overwriteFlow(InputStream) - Method in class org.apache.nifi.controller.StandardFlowService

overwriteFlow(InputStream) - Method in interface org.apache.nifi.services.FlowService

Saves the given stream to the flow.xml file on disk.

OWNER - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3Processor

OWNER - Static variable in class org.apache.nifi.processors.splunk.GetSplunk

owner(String) - Method in class org.apache.nifi.processors.standard.util.FileInfo.Builder

OWNER_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

OWNER_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

OWNER_TYPE_ATTR - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

OWNER_TYPE_DESC - Static variable in class org.apache.nifi.processors.gcp.storage.StorageAttributes

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