P-Index

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

P

packageFlowFile(InputStream, OutputStream, Map<String, String>, long) - Method in interface org.apache.nifi.util.FlowFilePackager
packageFlowFile(InputStream, OutputStream, Map<String, String>, long) - Method in class org.apache.nifi.util.FlowFilePackagerV1
packageFlowFile(InputStream, OutputStream, Map<String, String>, long) - Method in class org.apache.nifi.util.FlowFilePackagerV2
packageFlowFile(InputStream, OutputStream, Map<String, String>, long) - Method in class org.apache.nifi.util.FlowFilePackagerV3
PACKAGING_FORMAT - Static variable in class org.apache.nifi.processors.standard.UnpackContent
padLeft(String, int, char) - Static method in class org.apache.nifi.util.StringUtils
padRight(String, int, char) - Static method in class org.apache.nifi.util.StringUtils
PAGE - Static variable in class org.apache.nifi.processors.azure.AzureConstants
PAGE_SIZE - Static variable in class org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp
PAGE_SIZE - Static variable in class org.apache.nifi.processors.elasticsearch.ScrollElasticsearchHttp
PAGE_SIZE - Static variable in class org.apache.nifi.processors.parquet.PutParquet
parent - Variable in class org.apache.nifi.processors.evtx.parser.bxml.BxmlNodeTestBase
PARENT_UUIDS - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
PARENT_UUIDS - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
PARENT_UUIDS - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
ParentPath - Class in org.apache.nifi.record.path.paths
parse(String) - Static method in class org.apache.nifi.attribute.expression.language.evaluation.util.NumberParsing
parse(File) - Method in class org.apache.nifi.authorization.FlowParser: Extracts the root group id from the flow configuration file provided in nifi.properties, and extracts the root group input ports and output ports, and their access controls.
parse(Element) - Static method in class org.apache.nifi.controller.serialization.FlowEncodingVersion: Parses the 'encoding-version' attribute of the given XML Element as FlowEncodingVersion.
parse(String) - Static method in class org.apache.nifi.controller.serialization.FlowEncodingVersion: Parses the given String as FlowEncodingVersion.
parse(File) - Static method in class org.apache.nifi.controller.state.config.StateManagerConfiguration
parse(String...) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine: Parses the command line arguments
parse(String) - Static method in class org.apache.nifi.web.api.request.DateTimeParameter
PARSE_MESSAGES - Static variable in class org.apache.nifi.processors.standard.ListenSyslog
PARSE_SEGMENT_FIELDS - Static variable in class org.apache.nifi.processors.hl7.ExtractHL7Attributes
parseBatchResponse(String, String, String, int, String) - Method in class org.apache.nifi.processors.enrich.AbstractEnrichProcessor: This method returns the parsed record string in the form of a map of two strings, consisting of a iteration aware attribute names and its values
parseBytes(byte[]) - Static method in class org.apache.nifi.controller.SnippetManager
ParseCEF - Class in org.apache.nifi.processors.standard
ParseCEF() - Constructor for class org.apache.nifi.processors.standard.ParseCEF
ParseCEF.ValidateLocale - Class in org.apache.nifi.processors.standard
parseCertificate(Reader) - Static method in class org.apache.nifi.toolkit.tls.util.TlsHelper
parseCipherFromAlgorithm(String) - Static method in class org.apache.nifi.security.util.crypto.CipherUtility: Returns the cipher algorithm from the full algorithm name.
parseCli(Options, String[]) - Static method in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain: Parses command line options into a CliParse object
parseClusterUrls(String) - Static method in class org.apache.nifi.remote.util.SiteToSiteRestApiClient: Parse the comma-separated URLs string for the remote NiFi instances.
parseColumns(ProcessContext) - Method in class org.apache.nifi.hbase.GetHBase
parseCsr(String) - Static method in class org.apache.nifi.toolkit.tls.util.TlsHelper
parseDataSize(String, DataUnit) - Static method in enum org.apache.nifi.processor.DataUnit
parseDto(Element) - Static method in class org.apache.nifi.controller.TemplateUtils
parseDto(byte[]) - Static method in class org.apache.nifi.controller.TemplateUtils
parseEvent(ByteBuffer) - Method in class org.apache.nifi.processors.standard.syslog.SyslogParser: Parses a SyslogEvent from a byte buffer.
parseEvent(ByteBuffer, String) - Method in class org.apache.nifi.processors.standard.syslog.SyslogParser: Parses a SyslogEvent from a byte buffer.
parseEvent(byte[], String) - Method in class org.apache.nifi.processors.standard.syslog.SyslogParser: Parses a SyslogEvent from a byte array.
ParseEvtx - Class in org.apache.nifi.processors.evtx
ParseEvtx() - Constructor for class org.apache.nifi.processors.evtx.ParseEvtx
ParseEvtx(FileHeaderFactory, MalformedChunkHandler, RootNodeHandlerFactory, ResultProcessor) - Constructor for class org.apache.nifi.processors.evtx.ParseEvtx
ParseEvtxTest - Class in org.apache.nifi.processors.evtx
ParseEvtxTest() - Constructor for class org.apache.nifi.processors.evtx.ParseEvtxTest
parseFlowFiles(List<MockFlowFile>) - Method in class org.apache.nifi.processors.standard.TestSplitXml
parseHTMLDocumentFromFlowfile(FlowFile, ProcessContext, ProcessSession) - Method in class org.apache.nifi.AbstractHTMLProcessor: Parses the Jsoup HTML document from the FlowFile input content.
parseJsonResponse(InputStream) - Method in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchHttpProcessor
parseKeyLengthFromAlgorithm(String) - Static method in class org.apache.nifi.security.util.crypto.CipherUtility: Returns the cipher key length from the full algorithm name.
parseKeyPair(Reader) - Static method in class org.apache.nifi.toolkit.tls.util.TlsHelper
parseLocation(String) - Static method in class org.apache.nifi.processors.twitter.LocationUtil
parseLocations(String) - Static method in class org.apache.nifi.processors.twitter.LocationUtil
parseMessage(EmailMessage, List<String>, List<String>) - Method in class org.apache.nifi.processors.email.ConsumeEWS
parseOffers(byte[], Charset) - Static method in class org.apache.nifi.processors.standard.relp.response.RELPResponse: Parses the provided data into a Map of offers.
parseParameters(String) - Static method in class org.apache.nifi.security.util.crypto.scrypt.Scrypt: Parses the individual values from the encoded params value in the modified-mcrypt format for the salt & hash.
parsePem(Class<T>, Reader) - Static method in class org.apache.nifi.toolkit.tls.util.TlsHelper
parseResponse(String, String, String, String, String) - Method in class org.apache.nifi.processors.enrich.AbstractEnrichProcessor: This method returns the parsed record string in the form of a map of two strings, consisting of a iteration aware attribute names and its values
parseSchema(ProcessContext) - Method in class org.apache.nifi.processors.standard.ValidateXml
parseStateValue(String) - Static method in class org.apache.nifi.processors.standard.GetHTTP
ParseSyslog - Class in org.apache.nifi.processors.standard
ParseSyslog() - Constructor for class org.apache.nifi.processors.standard.ParseSyslog
PartialFunctions - Class in org.apache.nifi.processor.util.pattern: This class contains various partial functions those are reusable among process patterns.
PartialFunctions() - Constructor for class org.apache.nifi.processor.util.pattern.PartialFunctions
PartialFunctions.AdjustRoute<FC> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.Cleanup<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.FetchFlowFiles<FC> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.FlowFileGroup - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.InitConnection<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.OnCompleted<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.OnFailed<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.OnTrigger - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.RollbackSession - Interface in org.apache.nifi.processor.util.pattern
PartialFunctions.TransferFlowFiles<FC> - Interface in org.apache.nifi.processor.util.pattern
partition(Object, int) - Method in class org.apache.nifi.processors.kafka.Partitioners.HashPartitioner
partition(Object, int) - Method in class org.apache.nifi.processors.kafka.Partitioners.RandomPartitioner
partition(Object, int) - Method in class org.apache.nifi.processors.kafka.Partitioners.RoundRobinPartitioner
partition(String, Object, byte[], Object, byte[], Cluster) - Method in class org.apache.nifi.processors.kafka.pubsub.Partitioners.RoundRobinPartitioner
PARTITION - Static variable in class org.apache.nifi.processors.kafka.PutKafka
PARTITION_COLUMNS - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
PARTITION_SIZE - Static variable in class org.apache.nifi.processors.standard.GenerateTableFetch
PartitionedEventStore - Class in org.apache.nifi.provenance.store
PartitionedEventStore(RepositoryConfiguration, EventReporter) - Constructor for class org.apache.nifi.provenance.store.PartitionedEventStore
PartitionedWriteAheadEventStore - Class in org.apache.nifi.provenance.store
PartitionedWriteAheadEventStore(RepositoryConfiguration, RecordWriterFactory, RecordReaderFactory, EventReporter, EventFileManager) - Constructor for class org.apache.nifi.provenance.store.PartitionedWriteAheadEventStore
Partitioners - Class in org.apache.nifi.processors.kafka: Collection of implementation of common Kafka Partitioners.
Partitioners - Class in org.apache.nifi.processors.kafka.pubsub: Collection of implementation of common Kafka Partitioners.
Partitioners.HashPartitioner - Class in org.apache.nifi.processors.kafka: Partitioner that implements 'key hash' mechanism which distributes the load between all available partitions based on hashing the value of the key.
Partitioners.RandomPartitioner - Class in org.apache.nifi.processors.kafka: Partitioner that implements 'random' mechanism which randomly distributes the load between all available partitions.
Partitioners.RoundRobinPartitioner - Class in org.apache.nifi.processors.kafka: Partitioner that implements 'round-robin' mechanism which evenly distributes load between all available partitions.
Partitioners.RoundRobinPartitioner - Class in org.apache.nifi.processors.kafka.pubsub: Partitioner that implements 'round-robin' mechanism which evenly distributes load between all available partitions.
PartitionRecord - Class in org.apache.nifi.processors.standard
PartitionRecord() - Constructor for class org.apache.nifi.processors.standard.PartitionRecord
PASSIVE_LOCAL_CONNECTION_MODE - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
PASSWORD - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
PASSWORD - Static variable in class org.apache.nifi.processors.cassandra.AbstractCassandraProcessor
PASSWORD - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchProcessor
PASSWORD - Static variable in class org.apache.nifi.processors.email.ConsumeEWS
password - Variable in class org.apache.nifi.processors.rethinkdb.ITAbstractRethinkDBTest
PASSWORD - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
PASSWORD - Static variable in class org.apache.nifi.processors.standard.EncryptContent
PASSWORD - Static variable in class org.apache.nifi.processors.standard.GetHTTP
PASSWORD - Static variable in class org.apache.nifi.processors.standard.PostHTTP
PASSWORD - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
PASSWORD - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
PASSWORD - Static variable in class org.apache.nifi.redis.util.RedisUtils
PasswordBasedEncryptor - Class in org.apache.nifi.security.util.crypto
PasswordBasedEncryptor(EncryptionMethod, char[], KeyDerivationFunction) - Constructor for class org.apache.nifi.security.util.crypto.PasswordBasedEncryptor
passwordLengthIsValidForAlgorithmOnLimitedStrengthCrypto(int, EncryptionMethod) - Static method in class org.apache.nifi.security.util.crypto.CipherUtility
PasswordsExhaustedException - Exception in org.apache.nifi.toolkit.tls.util
PasswordsExhaustedException(String) - Constructor for exception org.apache.nifi.toolkit.tls.util.PasswordsExhaustedException
passwordSupplier() - Method in class org.apache.nifi.toolkit.tls.util.PasswordUtil
passwordSupplier(String) - Static method in class org.apache.nifi.toolkit.tls.util.PasswordUtil
passwordSupplier(String, String[]) - Static method in class org.apache.nifi.toolkit.tls.util.PasswordUtil
PasswordUtil - Class in org.apache.nifi.toolkit.tls.util
PasswordUtil() - Constructor for class org.apache.nifi.toolkit.tls.util.PasswordUtil
PasswordUtil(SecureRandom) - Constructor for class org.apache.nifi.toolkit.tls.util.PasswordUtil
PasswordUtilTest - Class in org.apache.nifi.toolkit.tls.util
PasswordUtilTest() - Constructor for class org.apache.nifi.toolkit.tls.util.PasswordUtilTest
PATH_FILTER - Static variable in class org.apache.nifi.processors.standard.GetFile
PATH_FILTER - Static variable in class org.apache.nifi.processors.standard.ListFile
PATH_FILTER_REGEX - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
PATH_NOT_FOUND - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
PATH_NOT_FOUND_IGNORE - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
PATH_NOT_FOUND_WARN - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
PATH_PREFIX - Static variable in class org.apache.nifi.processors.hadoop.util.HDFSListing.StateKeys
PATH_REGEX - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
Pause - Interface in org.apache.nifi.web.util
pause() - Method in interface org.apache.nifi.web.util.Pause: Waits up to given amount of time, and returns true if the action being performed should continue, false if the action being performed has been cancelled
payload(byte[]) - Method in class org.apache.nifi.processors.beats.frame.BeatsFrame.Builder
payload(byte[]) - Method in class org.apache.nifi.processors.lumberjack.frame.LumberjackFrame.Builder: Deprecated.
PBECipherProvider - Interface in org.apache.nifi.security.util.crypto
PBKDF2CipherProvider - Class in org.apache.nifi.security.util.crypto
PBKDF2CipherProvider() - Constructor for class org.apache.nifi.security.util.crypto.PBKDF2CipherProvider: Instantiates a PBKDF2 cipher provider with the default number of iterations and the default PRF.
PBKDF2CipherProvider(String, int) - Constructor for class org.apache.nifi.security.util.crypto.PBKDF2CipherProvider: Instantiates a PBKDF2 cipher provider with the specified number of iterations and the specified PRF.
peek(String, FlowFileQueue) - Method in class org.apache.nifi.controller.FileSystemSwapManager
peek(String, FlowFileQueue) - Method in interface org.apache.nifi.controller.repository.FlowFileSwapManager: Recovers the FlowFiles from the swap file that lives at the given location.
peek() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Returns the byte that would be read without changing the position
peekBytes(int) - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Returns the next length bytes without changing the position
peer - Variable in class org.apache.nifi.remote.AbstractTransaction
Peer - Class in org.apache.nifi.remote
Peer(PeerDescription, CommunicationsSession, String, String) - Constructor for class org.apache.nifi.remote.Peer
PEER_PERSISTENCE_FILE_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PeerDescription - Class in org.apache.nifi.remote
PeerDescription(String, int, boolean) - Constructor for class org.apache.nifi.remote.PeerDescription
PeerDTO - Class in org.apache.nifi.web.api.dto.remote: Details of a Site-to-Site peer within this NiFi.
PeerDTO() - Constructor for class org.apache.nifi.web.api.dto.remote.PeerDTO
peerPersistenceFile(File) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder: Specifies a file that the client can write to in order to persist the list of nodes in the remote cluster and recover the list of nodes upon restart.
PeerSelector - Class in org.apache.nifi.remote.client
PeerSelector(PeerStatusProvider, File) - Constructor for class org.apache.nifi.remote.client.PeerSelector
PeersEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
PeersEntity() - Constructor for class org.apache.nifi.web.api.entity.PeersEntity
PeersServlet() - Constructor for class org.apache.nifi.remote.client.http.TestHttpClient.PeersServlet
PeerStatus - Class in org.apache.nifi.remote
PeerStatus(PeerDescription, int, boolean) - Constructor for class org.apache.nifi.remote.PeerStatus
PeerStatusCache - Class in org.apache.nifi.remote.util
PeerStatusCache(Set<PeerStatus>) - Constructor for class org.apache.nifi.remote.util.PeerStatusCache
PeerStatusCache(Set<PeerStatus>, long) - Constructor for class org.apache.nifi.remote.util.PeerStatusCache
PeerStatusProvider - Interface in org.apache.nifi.remote.client: This interface defines methods used from PeerSelector.
pemEncodeJcaObject(Object) - Static method in class org.apache.nifi.toolkit.tls.util.TlsHelper
PENALIZATION_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
penalize(FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
penalize(FlowFile) - Method in interface org.apache.nifi.processor.ProcessSession: Sets a penalty for the given FlowFile which will make it unavailable to be operated on any further during the penalty period.
penalize(Peer, long) - Method in class org.apache.nifi.remote.client.PeerSelector: Updates internal state map to penalize a PeerStatus that points to the specified peer
penalize(PeerDescription, long) - Method in class org.apache.nifi.remote.client.PeerSelector
penalize(String, long) - Method in class org.apache.nifi.remote.Peer: Penalizes this peer for the given destination only for the provided number of milliseconds
penalize(FlowFile) - Method in class org.apache.nifi.util.MockProcessSession
penalty() - Method in enum org.apache.nifi.processor.util.pattern.ErrorTypes
penalty() - Method in class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
penalty() - Method in enum org.apache.nifi.processors.couchbase.ErrorHandlingStrategy
penaltyExpirationTime(long) - Method in class org.apache.nifi.controller.repository.StandardFlowFileRecord.Builder
PERCENTAGE_PATTERN - Static variable in class org.apache.nifi.controller.MonitorMemory
perform(KeyPair) - Method in class org.apache.nifi.toolkit.tls.service.client.TlsCertificateSigningRequestPerformer: Submits a CSR to the Certificate authority, checks the resulting hmac, and returns the chain if everything succeeds
performListing(ProcessContext, Long) - Method in class org.apache.nifi.processor.util.list.AbstractListProcessor: Performs a listing of the remote entities that can be pulled.
performListing(ProcessContext, Long) - Method in class org.apache.nifi.processors.azure.storage.ListAzureBlobStorage
performListing(ProcessContext) - Method in class org.apache.nifi.processors.hadoop.GetHDFS: Do a listing of HDFS if the POLLING_INTERVAL has lapsed.
performListing(ProcessContext, Long) - Method in class org.apache.nifi.processors.standard.ListFile
performListing(ProcessContext, Long) - Method in class org.apache.nifi.processors.standard.ListFileTransfer
performTask() - Method in interface org.apache.nifi.web.revision.DeleteRevisionTask
Permissible<DtoType> - Interface in org.apache.nifi.web.api.entity: Provides access to a component given an PermissionsDTO.
PermissionDeniedException - Exception in org.apache.nifi.processors.standard.util
PermissionDeniedException(String) - Constructor for exception org.apache.nifi.processors.standard.util.PermissionDeniedException
PermissionDeniedException(String, Throwable) - Constructor for exception org.apache.nifi.processors.standard.util.PermissionDeniedException
permissions(String) - Method in class org.apache.nifi.processors.standard.util.FileInfo.Builder
PERMISSIONS - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
PermissionsDTO - Class in org.apache.nifi.web.api.dto: Details for the access configuration.
PermissionsDTO() - Constructor for class org.apache.nifi.web.api.dto.PermissionsDTO
PermissionsDtoMerger - Class in org.apache.nifi.cluster.manager
PermissionsDtoMerger() - Constructor for class org.apache.nifi.cluster.manager.PermissionsDtoMerger
PERSIST_TO - Static variable in class org.apache.nifi.processors.couchbase.PutCouchbaseKey
persistence - Variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PERSISTENCE_PATH - Static variable in class org.apache.nifi.distributed.cache.server.DistributedCacheServer
PERSISTENCE_ROOT - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object
PERSISTENT_STATE_DIRECTORY - Static variable in class org.apache.nifi.util.NiFiProperties
PersistentMapCache - Class in org.apache.nifi.distributed.cache.server.map
PersistentMapCache(String, File, MapCache) - Constructor for class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
PersistentProvenanceRepository - Class in org.apache.nifi.provenance
PersistentProvenanceRepository() - Constructor for class org.apache.nifi.provenance.PersistentProvenanceRepository: default no args constructor for service loading only.
PersistentProvenanceRepository(NiFiProperties) - Constructor for class org.apache.nifi.provenance.PersistentProvenanceRepository
PersistentProvenanceRepository(RepositoryConfiguration, int) - Constructor for class org.apache.nifi.provenance.PersistentProvenanceRepository
PersistentSetCache - Class in org.apache.nifi.distributed.cache.server.set
PersistentSetCache(String, File, SetCache) - Constructor for class org.apache.nifi.distributed.cache.server.set.PersistentSetCache
persistLocalState(String, PutS3Object.MultipartState) - Method in class org.apache.nifi.processors.aws.s3.PutS3Object
PGPUtil - Class in org.apache.nifi.processors.standard.util: This class contains static utility methods to assist with common PGP operations.
PGPUtil() - Constructor for class org.apache.nifi.processors.standard.util.PGPUtil
PHOENIX_CLIENT_JAR_LOCATION - Static variable in interface org.apache.nifi.hbase.HBaseClientService
PID_KEY - Static variable in class org.apache.nifi.bootstrap.RunNiFi
PING_CMD - Static variable in class org.apache.nifi.bootstrap.RunNiFi
PING_TIMEOUT - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchTransportClientProcessor
PingMessage - Class in org.apache.nifi.cluster.protocol.message
PingMessage() - Constructor for class org.apache.nifi.cluster.protocol.message.PingMessage
PLACEHOLDER_TRANSFORMER - Static variable in interface org.apache.nifi.provenance.authorization.EventTransformer: An EventTransformer that transforms any event into a Placeholder event
PlaceholderProvenanceEvent - Class in org.apache.nifi.provenance: A Provenance Event that is used to replace another Provenance Event when authorizations are not granted for the original Provenance Event
PlaceholderProvenanceEvent(ProvenanceEventRecord) - Constructor for class org.apache.nifi.provenance.PlaceholderProvenanceEvent
PlusEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
PlusEvaluator(Evaluator<Number>, Evaluator<Number>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.PlusEvaluator
poison() - Method in class org.apache.nifi.processors.kafka.pubsub.PublisherLease
poll(FlowFileFilter, Set<FlowFileRecord>) - Method in interface org.apache.nifi.connectable.Connection
poll(Set<FlowFileRecord>) - Method in interface org.apache.nifi.connectable.Connection
poll(FlowFileFilter, Set<FlowFileRecord>) - Method in class org.apache.nifi.connectable.StandardConnection
poll(Set<FlowFileRecord>) - Method in class org.apache.nifi.connectable.StandardConnection
poll(long, TimeUnit) - Method in class org.apache.nifi.controller.EventDrivenWorkerQueue
poll(Set<FlowFileRecord>) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
poll(int, Set<FlowFileRecord>) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
poll(FlowFileFilter, Set<FlowFileRecord>) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue
poll(Set<FlowFileRecord>) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
poll(int, Set<FlowFileRecord>) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
poll(FlowFileFilter, Set<FlowFileRecord>) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
poll(long, TimeUnit) - Method in interface org.apache.nifi.controller.WorkerQueue
poll() - Method in class org.apache.nifi.io.nio.BufferPool
poll() - Method in class org.apache.nifi.util.MockFlowFileQueue
POLL_TIMEOUT - Static variable in class org.apache.nifi.processors.standard.ListenUDPRecord
POLL_TIMEOUT_MS - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
POLLING_INTERVAL - Static variable in class org.apache.nifi.documentation.example.DeprecatedProcessor
POLLING_INTERVAL - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedProcessor
POLLING_INTERVAL - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS
POLLING_INTERVAL - Static variable in class org.apache.nifi.processors.standard.GetFile
POLLING_INTERVAL - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
POOL_BLOCK_WHEN_EXHAUSTED - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_MAX_IDLE - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_MAX_TOTAL - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_MAX_WAIT_TIME - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_MIN_EVICTABLE_IDLE_TIME - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_MIN_IDLE - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_NUM_TESTS_PER_EVICTION_RUN - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_TEST_ON_BORROW - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_TEST_ON_CREATE - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_TEST_ON_RETURN - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_TEST_WHILE_IDLE - Static variable in class org.apache.nifi.redis.util.RedisUtils
POOL_TIME_BETWEEN_EVICTION_RUNS - Static variable in class org.apache.nifi.redis.util.RedisUtils
PoorlyBehavedProcessor() - Constructor for class org.apache.nifi.util.TestMockProcessSession.PoorlyBehavedProcessor
PopularVoteFlowElection - Class in org.apache.nifi.cluster.coordination.flow: An implementation of FlowElection that waits until either a maximum amount of time has elapsed or a maximum number of Data Flows have entered the running to be elected, and then elects the 'winner' based on the number of 'votes' that a particular DataFlow has received.
PopularVoteFlowElection(long, TimeUnit, Integer, FingerprintFactory) - Constructor for class org.apache.nifi.cluster.coordination.flow.PopularVoteFlowElection
PopularVoteFlowElectionFactoryBean - Class in org.apache.nifi.cluster.coordination.flow
PopularVoteFlowElectionFactoryBean() - Constructor for class org.apache.nifi.cluster.coordination.flow.PopularVoteFlowElectionFactoryBean
populateAffectedComponents(VariableRegistryDTO, ProcessGroup, RevisionManager) - Method in class org.apache.nifi.web.api.dto.DtoFactory
populateAffectedComponents(VariableRegistryDTO) - Method in interface org.apache.nifi.web.NiFiServiceFacade: Returns a Variable Registry that includes the variables in the given DTO but has the affected components populated
populateAffectedComponents(VariableRegistryDTO) - Method in class org.apache.nifi.web.StandardNiFiServiceFacade
populateAnonymousUser(NiFiUser, String) - Static method in class org.apache.nifi.authorization.user.StandardNiFiUser: This static builder allows the chain and clientAddress to be populated without allowing calling code to provide a non-anonymous identity of the anonymous user.
populateFlow(Client, String, NiFiTestUser, String) - Static method in class org.apache.nifi.integration.NiFiWebApiTest
populateFlowSnippet(Snippet, boolean, boolean, boolean) - Method in class org.apache.nifi.web.util.SnippetUtils: Populates the specified snippet and returns the details.
populateJsonPaths() - Method in class org.apache.nifi.json.TestJsonPathRowRecordReader
populateLock(ProceedingJoinPoint) - Method in class org.apache.nifi.web.NiFiServiceFacadeLock
populateRemainingAccessPolicyEntityContent(AccessPolicyEntity) - Method in class org.apache.nifi.web.api.AccessPolicyResource: Populates the uri for the specified access policy.
populateRemainingConnectionEntitiesContent(Set<ConnectionEntity>) - Method in class org.apache.nifi.web.api.ConnectionResource: Populate the URIs for the specified connections.
populateRemainingConnectionEntityContent(ConnectionEntity) - Method in class org.apache.nifi.web.api.ConnectionResource: Populate the URIs for the specified connection.
populateRemainingControllerServiceContent(ControllerServiceDTO) - Method in class org.apache.nifi.web.api.ControllerServiceResource: Populates the uri for the specified controller service.
populateRemainingControllerServiceEntitiesContent(Set<ControllerServiceEntity>) - Method in class org.apache.nifi.web.api.ControllerServiceResource: Populate the uri's for the specified controller services.
populateRemainingControllerServiceEntityContent(ControllerServiceEntity) - Method in class org.apache.nifi.web.api.ControllerServiceResource: Populate the uri's for the specified controller service.
populateRemainingFlowFileContent(String, FlowFileSummaryDTO) - Method in class org.apache.nifi.web.api.FlowFileQueueResource: Populate the URIs for the specified flowfile.
populateRemainingFlowFileListingContent(String, ListingRequestDTO) - Method in class org.apache.nifi.web.api.FlowFileQueueResource: Populate the URIs for the specified flowfile listing.
populateRemainingFunnelEntitiesContent(Set<FunnelEntity>) - Method in class org.apache.nifi.web.api.FunnelResource: Populates the uri for the specified funnels.
populateRemainingFunnelEntityContent(FunnelEntity) - Method in class org.apache.nifi.web.api.FunnelResource: Populates the uri for the specified funnel.
populateRemainingInputPortEntitiesContent(Set<PortEntity>) - Method in class org.apache.nifi.web.api.InputPortResource: Populates the uri for the specified input ports.
populateRemainingInputPortEntityContent(PortEntity) - Method in class org.apache.nifi.web.api.InputPortResource: Populates the uri for the specified input port.
populateRemainingLabelEntitiesContent(Set<LabelEntity>) - Method in class org.apache.nifi.web.api.LabelResource: Populates the uri for the specified labels.
populateRemainingLabelEntityContent(LabelEntity) - Method in class org.apache.nifi.web.api.LabelResource: Populates the uri for the specified labels.
populateRemainingOutputPortEntitiesContent(Set<PortEntity>) - Method in class org.apache.nifi.web.api.OutputPortResource: Populates the uri for the specified output ports.
populateRemainingOutputPortEntityContent(PortEntity) - Method in class org.apache.nifi.web.api.OutputPortResource: Populates the uri for the specified output ports.
populateRemainingProcessGroupEntitiesContent(Set<ProcessGroupEntity>) - Method in class org.apache.nifi.web.api.ProcessGroupResource: Populates the remaining fields in the specified process groups.
populateRemainingProcessGroupEntityContent(ProcessGroupEntity) - Method in class org.apache.nifi.web.api.ProcessGroupResource: Populates the remaining fields in the specified process group.
populateRemainingProcessorContent(ProcessorDTO) - Method in class org.apache.nifi.web.api.ProcessorResource: Populate the uri's for the specified processor and its relationships.
populateRemainingProcessorEntitiesContent(Set<ProcessorEntity>) - Method in class org.apache.nifi.web.api.ProcessorResource: Populate the uri's for the specified processors and their relationships.
populateRemainingProcessorEntityContent(ProcessorEntity) - Method in class org.apache.nifi.web.api.ProcessorResource: Populate the uri's for the specified processors and their relationships.
populateRemainingRemoteProcessGroupEntitiesContent(Set<RemoteProcessGroupEntity>) - Method in class org.apache.nifi.web.api.RemoteProcessGroupResource: Populates the remaining content for each remote process group.
populateRemainingRemoteProcessGroupEntityContent(RemoteProcessGroupEntity) - Method in class org.apache.nifi.web.api.RemoteProcessGroupResource: Populates the remaining content for each remote process group.
populateRemainingReportingTaskContent(ReportingTaskDTO) - Method in class org.apache.nifi.web.api.ReportingTaskResource: Populates the uri for the specified reporting task.
populateRemainingReportingTaskEntitiesContent(Set<ReportingTaskEntity>) - Method in class org.apache.nifi.web.api.ReportingTaskResource: Populate the uri's for the specified reporting tasks.
populateRemainingReportingTaskEntityContent(ReportingTaskEntity) - Method in class org.apache.nifi.web.api.ReportingTaskResource: Populate the uri's for the specified reporting task.
populateRemainingTemplateContent(TemplateDTO) - Method in class org.apache.nifi.web.api.TemplateResource: Populates the uri for the specified template.
populateRemainingTemplateEntitiesContent(Set<TemplateEntity>) - Method in class org.apache.nifi.web.api.TemplateResource: Populate the uri's for the specified templates.
populateRemainingUserEntitiesContent(Set<UserEntity>) - Method in class org.apache.nifi.web.api.TenantsResource: Populates the uri for the specified users.
populateRemainingUserEntityContent(UserEntity) - Method in class org.apache.nifi.web.api.TenantsResource: Populates the uri for the specified user.
populateRemainingUserGroupEntitiesContent(Set<UserGroupEntity>) - Method in class org.apache.nifi.web.api.TenantsResource: Populates the uri for the specified user groups.
populateRemainingUserGroupEntityContent(UserGroupEntity) - Method in class org.apache.nifi.web.api.TenantsResource: Populates the uri for the specified user group.
Port - Interface in org.apache.nifi.connectable
PORT - Static variable in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
PORT - Static variable in class org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService
PORT - Static variable in class org.apache.nifi.distributed.cache.server.DistributedCacheServer
PORT - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
port - Variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
PORT - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
port - Variable in class org.apache.nifi.processor.util.put.sender.ChannelSender
PORT - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
PORT - Static variable in class org.apache.nifi.processors.standard.AbstractSyslogProcessor
PORT - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
PORT - Static variable in class org.apache.nifi.processors.standard.ListenHTTP
PORT - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PORT - Static variable in class org.apache.nifi.processors.standard.util.SFTPTransfer
port - Variable in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
PORT - Static variable in class org.apache.nifi.reporting.ganglia.StandardGangliaReporter
PORT_ARG - Static variable in class org.apache.nifi.toolkit.tls.service.BaseCertificateAuthorityCommandLine
PORT_GROUP_ID - Static variable in interface org.apache.nifi.reporting.datadog.metrics.MetricNames
PORT_ID - Static variable in interface org.apache.nifi.reporting.datadog.metrics.MetricNames
PORT_IDENTIFIER_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PORT_NAME - Static variable in interface org.apache.nifi.reporting.datadog.metrics.MetricNames
PORT_NAME_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PORT_RELATIONSHIP - Static variable in class org.apache.nifi.controller.AbstractPort
PORT_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
PortAuditor - Class in org.apache.nifi.audit
PortAuditor() - Constructor for class org.apache.nifi.audit.PortAuditor
PortAuthorizationResult - Interface in org.apache.nifi.remote
PortDAO - Interface in org.apache.nifi.web.dao
PortDTO - Class in org.apache.nifi.web.api.dto: The details for a port within this NiFi flow.
PortDTO() - Constructor for class org.apache.nifi.web.api.dto.PortDTO
PortEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
PortEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.PortEndpointMerger
PortEntity - 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.
PortEntity() - Constructor for class org.apache.nifi.web.api.entity.PortEntity
PortEntityMerger - Class in org.apache.nifi.cluster.manager
PortEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.PortEntityMerger
portIdentifier(String) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder: Specifies the unique identifier of the port to communicate with.
portName(String) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder: Specifies the name of the port to communicate with.
PortNotRunningException - Exception in org.apache.nifi.remote.exception: PortNotRunningException occurs when the remote NiFi instance reports that the Port that the client is attempting to communicate with is not currently running and therefore communications with that Port are not allowed.
PortNotRunningException(String) - Constructor for exception org.apache.nifi.remote.exception.PortNotRunningException
PortsEntityMerger - Class in org.apache.nifi.cluster.manager
PortsEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.PortsEntityMerger
PortStatus - Class in org.apache.nifi.controller.status: The status of a port.
PortStatus() - Constructor for class org.apache.nifi.controller.status.PortStatus
PortStatusDTO - Class in org.apache.nifi.web.api.dto.status
PortStatusDTO() - Constructor for class org.apache.nifi.web.api.dto.status.PortStatusDTO
PortStatusEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
PortStatusEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.PortStatusEndpointMerger
PortStatusEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
PortStatusEntity() - Constructor for class org.apache.nifi.web.api.entity.PortStatusEntity
PortStatusSnapshotDTO - Class in org.apache.nifi.web.api.dto.status: The status for a port in this NiFi.
PortStatusSnapshotDTO() - Constructor for class org.apache.nifi.web.api.dto.status.PortStatusSnapshotDTO
PortStatusSnapshotEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
PortStatusSnapshotEntity() - Constructor for class org.apache.nifi.web.api.entity.PortStatusSnapshotEntity
PortTransactionsAccessDeniedServlet() - Constructor for class org.apache.nifi.remote.client.http.TestHttpClient.PortTransactionsAccessDeniedServlet
PortTransactionsServlet() - Constructor for class org.apache.nifi.remote.client.http.TestHttpClient.PortTransactionsServlet
Position - Class in org.apache.nifi.connectable
Position(double, double) - Constructor for class org.apache.nifi.connectable.Position
Positionable - Interface in org.apache.nifi.connectable: Represents a component that can be positioned with X,Y coordinates on the canvas.
PositionDTO - Class in org.apache.nifi.web.api.dto: A position on the canvas.
PositionDTO() - Constructor for class org.apache.nifi.web.api.dto.PositionDTO
PositionDTO(Double, Double) - Constructor for class org.apache.nifi.web.api.dto.PositionDTO
POSITIVE_INTEGER_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
POSITIVE_LONG_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
POSITIVE_SHORT_VALIDATOR - Static variable in interface org.apache.nifi.processors.hadoop.HadoopValidators
post(URI, Object) - Method in class org.apache.nifi.web.util.ClientUtils: Performs a POST using the specified url and entity body.
post(URI, Map<String, String>) - Method in class org.apache.nifi.web.util.ClientUtils: Performs a POST using the specified url and form data.
PostHTTP - Class in org.apache.nifi.processors.standard
PostHTTP() - Constructor for class org.apache.nifi.processors.standard.PostHTTP
postMonitor() - Method in interface org.apache.nifi.controller.SchedulingAgentCallback
postProcess(ProcessContext, ProcessSession, List<E>) - Method in class org.apache.nifi.processor.util.listen.AbstractListenEventBatchingProcessor: Called at the end of onTrigger to allow sub-classes to take post processing action on the events
postProcess(ProcessContext, ProcessSession, List<BeatsEvent>) - Method in class org.apache.nifi.processors.beats.ListenBeats
postProcess(ProcessContext, ProcessSession, FlowFile, Path) - Method in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord: This method will be called after successfully writing to the destination file and renaming the file to it's final name in order to give sub-classes a chance to take action before transferring to success.
postProcess(ProcessContext, ProcessSession, FlowFile, Path) - Method in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord: This method will be called after successfully writing to the destination file and renaming the file to it's final name in order to give sub-classes a chance to take action before transferring to success.
postProcess(ProcessContext, ProcessSession, List<LumberjackEvent>) - Method in class org.apache.nifi.processors.lumberjack.ListenLumberjack: Deprecated.
postProcess(ProcessContext, ProcessSession, FlowFile, Path) - Method in class org.apache.nifi.processors.parquet.PutParquet
postProcess(ProcessContext, ProcessSession, List<RELPEvent>) - Method in class org.apache.nifi.processors.standard.ListenRELP
POWERS - Static variable in enum org.apache.nifi.processor.DataUnit
PRECISION_AUTO_DETECT - Static variable in class org.apache.nifi.processor.util.list.AbstractListProcessor
PRECISION_MILLIS - Static variable in class org.apache.nifi.processor.util.list.AbstractListProcessor
PRECISION_MINUTES - Static variable in class org.apache.nifi.processor.util.list.AbstractListProcessor
PRECISION_SECONDS - Static variable in class org.apache.nifi.processor.util.list.AbstractListProcessor
preCompile(ConfigurationContext) - Method in class org.apache.nifi.grok.GrokReader
preDestruction() - Method in interface org.apache.nifi.authentication.LoginIdentityProvider: Called immediately before instance destruction for implementers to release resources.
preDestruction() - Method in interface org.apache.nifi.authorization.AccessPolicyProvider: Called immediately before instance destruction for implementers to release resources.
preDestruction() - Method in interface org.apache.nifi.authorization.Authorizer: Called immediately before instance destruction for implementers to release resources.
preDestruction() - Method in class org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider
preDestruction() - Method in class org.apache.nifi.authorization.CompositeUserGroupProvider
preDestruction() - Method in class org.apache.nifi.authorization.FileAccessPolicyProvider
preDestruction() - Method in class org.apache.nifi.authorization.FileAuthorizer
preDestruction() - Method in class org.apache.nifi.authorization.FileUserGroupProvider
preDestruction() - Method in class org.apache.nifi.authorization.MockPolicyBasedAuthorizer
preDestruction() - Method in class org.apache.nifi.authorization.SimpleUserGroupProvider
preDestruction() - Method in class org.apache.nifi.authorization.StandardManagedAuthorizer
preDestruction() - Method in interface org.apache.nifi.authorization.UserGroupProvider: Called immediately before instance destruction for implementers to release resources.
preDestruction() - Method in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer
preDestruction() - Method in class org.apache.nifi.integration.util.NiFiTestAuthorizer
preDestruction() - Method in class org.apache.nifi.integration.util.NiFiTestLoginIdentityProvider
preDestruction() - Method in class org.apache.nifi.kerberos.KerberosProvider
preDestruction() - Method in class org.apache.nifi.ldap.LdapProvider
preDestruction() - Method in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
preDestruction() - Method in class org.apache.nifi.ranger.authorization.RangerNiFiAuthorizer
PredicatePath - Class in org.apache.nifi.record.path.paths
PredicatePath(RecordPathSegment, RecordPathFilter, boolean) - Constructor for class org.apache.nifi.record.path.paths.PredicatePath
PREFIX - Static variable in class org.apache.nifi.processors.aws.s3.ListS3
PREFIX - Static variable in class org.apache.nifi.processors.gcp.storage.ListGCSBucket
preload(Configuration) - Method in class org.apache.nifi.util.hive.HiveConfigurator
prepare(String) - Static method in class org.apache.nifi.attribute.expression.language.Query
prepare(Map, TopologyContext, OutputCollector) - Method in class org.apache.nifi.storm.NiFiBolt
prepareDeleteRequest(String, String, String) - Method in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
PreparedQuery - Interface in org.apache.nifi.attribute.expression.language
prepareForRead(int) - Method in class org.apache.nifi.remote.io.socket.BufferStateManager
prepareForWrite(int) - Method in class org.apache.nifi.remote.io.socket.BufferStateManager
prepareResource(String, List<String>, String, String) - Method in class org.apache.nifi.processors.yandex.YandexTranslate
prepareUser(Snmp, String, int, String, OID, OID, String, String) - Static method in class org.apache.nifi.snmp.processors.SNMPUtilsTest: Method to prepare user target and to add id in the User Based Security Model of the given SNMP instance
prepDestDirectory() - Method in class org.apache.nifi.processors.standard.TestFetchFile
PREPEND_ELEMENT - Static variable in class org.apache.nifi.PutHTMLElement
PREPEND_ELEMENT_VALUE - Static variable in class org.apache.nifi.GetHTMLElement
PrependEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
PrependEvaluator(Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.PrependEvaluator
prependValue - Static variable in class org.apache.nifi.processors.standard.ReplaceText
preProcessConfiguration(Configuration, ProcessContext) - Method in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor: This method will be called after the Configuration has been created, but before the FileSystem is created, allowing sub-classes to take further action on the Configuration before creating the FileSystem.
preProcessConfiguration(Configuration, ProcessContext) - Method in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
preProcessConfiguration(Configuration, ProcessContext) - Method in class org.apache.nifi.processors.hadoop.PutHDFS
preprocessFlowFile(ProcessContext, ProcessSession, FlowFile) - Method in class org.apache.nifi.processor.util.bin.BinFiles: Allows general pre-processing of a flow file before it is offered to a bin.
preprocessFlowFile(ProcessContext, ProcessSession, FlowFile) - Method in class org.apache.nifi.processors.standard.MergeContent
presentValues(Stream<Optional<T>>) - Static method in class org.apache.nifi.record.path.util.Filters
PRETTY_AVRO_OUTPUT - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
prettyPrint(Integer, Long) - Static method in class org.apache.nifi.cluster.manager.StatusMerger
PREVIOUS_ATTRIBUTES - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
PREVIOUS_ATTRIBUTES - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
PREVIOUS_ATTRIBUTES - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
PREVIOUS_CONTENT_CLAIM - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
PREVIOUS_CONTENT_CLAIM - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
PREVIOUS_CONTENT_CLAIM - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
PreviousValue - Class in org.apache.nifi.history
PreviousValue() - Constructor for class org.apache.nifi.history.PreviousValue
previousValue(String) - Method in class org.apache.nifi.web.ConfigurationAction.Builder
PreviousValueDTO - Class in org.apache.nifi.web.api.dto: The previous value for a processor property.
PreviousValueDTO() - Constructor for class org.apache.nifi.web.api.dto.PreviousValueDTO
PRIMARY_NODE - Static variable in class org.apache.nifi.cluster.coordination.node.ClusterRoles
PrimaryNodeState - Enum in org.apache.nifi.annotation.notification: Represents a state change that occurred for the Primary Node of a NiFi cluster.
primaryUri(String) - Method in class org.apache.nifi.processors.azure.storage.utils.BlobInfo.Builder
printf(String, Object...) - Method in class org.apache.nifi.util.console.TextDevice
printTestName() - Method in class org.apache.nifi.provenance.TestPersistentProvenanceRepository
printUsage(String, Options) - Static method in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain: Prints the usage to System.out
printUsage(String) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
printUsageAndThrow(String, ExitCode) - Method in class org.apache.nifi.toolkit.tls.commandLine.BaseCommandLine
PRIORITIZER_TYPES_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.PrioritizerTypesEndpointMerger
PrioritizerTypesEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
PrioritizerTypesEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.PrioritizerTypesEndpointMerger
PrioritizerTypesEntity - 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.
PrioritizerTypesEntity() - Constructor for class org.apache.nifi.web.api.entity.PrioritizerTypesEntity
priority(String) - Method in class org.apache.nifi.processors.standard.syslog.SyslogEvent.Builder
PriorityAttributePrioritizer - Class in org.apache.nifi.prioritizer: This prioritizer checks each FlowFile for a "priority" attribute and lets that attribute determine the priority.
PriorityAttributePrioritizer() - Constructor for class org.apache.nifi.prioritizer.PriorityAttributePrioritizer
PriorityAttributePrioritizerTest - Class in org.apache.nifi.prioritizer
PriorityAttributePrioritizerTest() - Constructor for class org.apache.nifi.prioritizer.PriorityAttributePrioritizerTest
PriorityAttributePrioritizerTest.SimpleProcessor - Class in org.apache.nifi.prioritizer
PRIVATE_KEY_PASSPHRASE - Static variable in class org.apache.nifi.processors.standard.util.SFTPTransfer
PRIVATE_KEY_PATH - Static variable in class org.apache.nifi.processors.standard.util.SFTPTransfer
PRIVATE_KEYRING - Static variable in class org.apache.nifi.processors.standard.EncryptContent
PRIVATE_KEYRING_PASSPHRASE - Static variable in class org.apache.nifi.processors.standard.EncryptContent
PRIVILEGED_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiTestAuthorizer
proceed() - Method in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
process() - Method in class org.apache.nifi.io.nio.consumer.AbstractStreamConsumer
process() - Method in interface org.apache.nifi.io.nio.consumer.StreamConsumer: Will be called by the thread that executes the consumption of data.
process(InputStream) - Method in interface org.apache.nifi.processor.io.InputStreamCallback: Provides a managed input stream for use.
process(OutputStream) - Method in interface org.apache.nifi.processor.io.OutputStreamCallback: Provides a managed output stream for use.
process(InputStream, OutputStream) - Method in interface org.apache.nifi.processor.io.StreamCallback: Provides a managed output stream for use.
process(byte) - Method in class org.apache.nifi.processors.beats.frame.BeatsDecoder: Process the next byte from the channel, updating the builder and state accordingly.
process(ProcessSession, ComponentLog, FlowFile, Exception, String) - Method in class org.apache.nifi.processors.evtx.ResultProcessor
process(byte) - Method in class org.apache.nifi.processors.lumberjack.frame.LumberjackDecoder: Deprecated.

Process the next byte from the channel, updating the builder and state accordingly.
process(Record, RecordSchema, FlowFile, ProcessContext) - Method in class org.apache.nifi.processors.standard.AbstractRecordProcessor
process(Record, RecordSchema, FlowFile, ProcessContext) - Method in class org.apache.nifi.processors.standard.ConvertRecord
process(InputStream) - Method in class org.apache.nifi.processors.standard.LogAttribute.FlowFilePayloadCallback
process(byte) - Method in class org.apache.nifi.processors.standard.relp.frame.RELPDecoder: Process the next byte from the channel, updating the builder and state accordingly.
process(Record, RecordSchema, FlowFile, ProcessContext) - Method in class org.apache.nifi.processors.standard.UpdateRecord
process(InputStream) - Method in class org.apache.nifi.processors.standard.util.DocumentReaderCallback
process() - Method in class org.apache.nifi.processors.standard.util.UDPStreamConsumer
process(OutputStream) - Method in class org.apache.nifi.processors.standard.util.UDPStreamConsumer.UDPConsumerCallback
PROCESS_GROUP_STATUS_HISTORY_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.StatusHistoryEndpointMerger
PROCESS_GROUP_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessGroupEndpointMerger
PROCESS_GROUPS_CONTROLLER_SERVICES_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerServiceEndpointMerger
PROCESS_GROUPS_CONTROLLER_SERVICES_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ControllerServicesEndpointMerger
PROCESS_GROUPS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessGroupsEndpointMerger
processBatchOfFiles(List<Path>, ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.GetHDFS
processBatchOfFiles(List<Path>, ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.hadoop.GetHDFSSequenceFile
processBin(Bin, ProcessContext) - Method in class org.apache.nifi.processor.util.bin.BinFiles: Processes a single bin.
processBin(Bin, ProcessContext) - Method in class org.apache.nifi.processors.standard.MergeContent
processBuffer(ByteBuffer) - Method in class org.apache.nifi.io.nio.consumer.AbstractStreamConsumer
processBuffer(ByteBuffer) - Method in class org.apache.nifi.io.nio.example.UselessStreamConsumer
processBuffer(SSLSocketChannel, SocketChannel, int, byte[]) - Method in class org.apache.nifi.processor.util.listen.handler.socket.SSLSocketChannelHandler: Process the contents of the buffer.
processBuffer(SocketChannel, ByteBuffer) - Method in class org.apache.nifi.processor.util.listen.handler.socket.StandardSocketChannelHandler: Process the contents that have been read into the buffer.
processBuffer(SocketChannel, ByteBuffer) - Method in class org.apache.nifi.processors.beats.handler.BeatsSocketChannelHandler
processBuffer(SSLSocketChannel, SocketChannel, int, byte[]) - Method in class org.apache.nifi.processors.beats.handler.BeatsSSLSocketChannelHandler
processBuffer(SocketChannel, ByteBuffer) - Method in class org.apache.nifi.processors.lumberjack.handler.LumberjackSocketChannelHandler: Deprecated.
processBuffer(SSLSocketChannel, SocketChannel, int, byte[]) - Method in class org.apache.nifi.processors.lumberjack.handler.LumberjackSSLSocketChannelHandler: Deprecated.
processBuffer(SocketChannel, ByteBuffer) - Method in class org.apache.nifi.processors.standard.relp.handler.RELPSocketChannelHandler
processBuffer(SSLSocketChannel, SocketChannel, int, byte[]) - Method in class org.apache.nifi.processors.standard.relp.handler.RELPSSLSocketChannelHandler
processChunkGranularity(ProcessSession, ComponentLog, FlowFile, String, InputStream) - Method in class org.apache.nifi.processors.evtx.ParseEvtx
processClientException(ProcessSession, List<FlowFile>, AmazonClientException) - Method in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
ProcessContext - Class in org.apache.nifi.controller.repository
ProcessContext(Connectable, AtomicLong, ContentRepository, FlowFileRepository, FlowFileEventRepository, CounterRepository, ProvenanceEventRepository) - Constructor for class org.apache.nifi.controller.repository.ProcessContext
ProcessContext - Interface in org.apache.nifi.processor: Provides a bridge between a Processor and the NiFi Framework
ProcessContextFactory - Class in org.apache.nifi.controller.scheduling
ProcessContextFactory(ContentRepository, FlowFileRepository, FlowFileEventRepository, CounterRepository, ProvenanceEventRepository) - Constructor for class org.apache.nifi.controller.scheduling.ProcessContextFactory
processElement(String, Object, Map<String, String>) - Method in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes: Process elements children based on the parser mapping.
ProcessException - Exception in org.apache.nifi.processor.exception: Indicates an issue occurred in user code while processing a FlowFile.
ProcessException() - Constructor for exception org.apache.nifi.processor.exception.ProcessException
ProcessException(String) - Constructor for exception org.apache.nifi.processor.exception.ProcessException
ProcessException(String, Throwable) - Constructor for exception org.apache.nifi.processor.exception.ProcessException
ProcessException(Throwable) - Constructor for exception org.apache.nifi.processor.exception.ProcessException
processException(ProcessSession, List<FlowFile>, Exception) - Method in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
processFileGranularity(ProcessSession, ComponentLog, FlowFile, String, AtomicReference<Exception>, InputStream, OutputStream) - Method in class org.apache.nifi.processors.evtx.ParseEvtx
processFlowFile(ComponentLog, LogAttribute.DebugLevels, FlowFile, ProcessSession, ProcessContext) - Method in class org.apache.nifi.processors.standard.LogAttribute
processGroup(ProcessGroup) - Method in class org.apache.nifi.connectable.StandardConnection.Builder
ProcessGroup - Interface in org.apache.nifi.groups: ProcessGroup objects are containers for processing entities, such as Processors, Ports, and other ProcessGroups.
ProcessGroupAuditor - Class in org.apache.nifi.audit: Audits process group creation/removal and configuration changes.
ProcessGroupAuditor() - Constructor for class org.apache.nifi.audit.ProcessGroupAuditor
ProcessGroupAuthorizable - Interface in org.apache.nifi.authorization: Authorizable for a ProcessGroup and its encapsulated components.
ProcessGroupCounts - Class in org.apache.nifi.groups
ProcessGroupCounts(int, int, int, int, int, int, int, int) - Constructor for class org.apache.nifi.groups.ProcessGroupCounts
ProcessGroupDAO - Interface in org.apache.nifi.web.dao
ProcessGroupDTO - Class in org.apache.nifi.web.api.dto: The details for a process group within this NiFi flow.
ProcessGroupDTO() - Constructor for class org.apache.nifi.web.api.dto.ProcessGroupDTO
ProcessGroupEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProcessGroupEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProcessGroupEndpointMerger
ProcessGroupEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessGroupEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessGroupEntity
ProcessGroupEntityMerger - Class in org.apache.nifi.cluster.manager
ProcessGroupEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.ProcessGroupEntityMerger
ProcessGroupFlowDTO - Class in org.apache.nifi.web.api.dto.flow: The NiFi flow starting at a given Process Group.
ProcessGroupFlowDTO() - Constructor for class org.apache.nifi.web.api.dto.flow.ProcessGroupFlowDTO
ProcessGroupFlowEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessGroupFlowEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessGroupFlowEntity
ProcessGroupResource - Class in org.apache.nifi.web.api: RESTful endpoint for managing a Group.
ProcessGroupResource() - Constructor for class org.apache.nifi.web.api.ProcessGroupResource
ProcessGroupsEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProcessGroupsEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProcessGroupsEndpointMerger
ProcessGroupsEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessGroupsEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessGroupsEntity
ProcessGroupsEntityMerger - Class in org.apache.nifi.cluster.manager
ProcessGroupsEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.ProcessGroupsEntityMerger
ProcessGroupStatus - Class in org.apache.nifi.controller.status
ProcessGroupStatus() - Constructor for class org.apache.nifi.controller.status.ProcessGroupStatus
ProcessGroupStatusDescriptor - Enum in org.apache.nifi.controller.status.history
ProcessGroupStatusDTO - Class in org.apache.nifi.web.api.dto.status
ProcessGroupStatusDTO() - Constructor for class org.apache.nifi.web.api.dto.status.ProcessGroupStatusDTO
ProcessGroupStatusEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessGroupStatusEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessGroupStatusEntity
ProcessGroupStatusSnapshotDTO - Class in org.apache.nifi.web.api.dto.status: The status for a process group in this NiFi.
ProcessGroupStatusSnapshotDTO() - Constructor for class org.apache.nifi.web.api.dto.status.ProcessGroupStatusSnapshotDTO
ProcessGroupStatusSnapshotEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessGroupStatusSnapshotEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessGroupStatusSnapshotEntity
PROCESSING_INSTRUCTION_DATA_TOKEN - Static variable in class org.apache.nifi.processors.evtx.parser.bxml.BxmlNode
PROCESSING_INSTRUCTION_TARGET_TOKEN - Static variable in class org.apache.nifi.processors.evtx.parser.bxml.BxmlNode
ProcessingInstructionDataNode - Class in org.apache.nifi.processors.evtx.parser.bxml
ProcessingInstructionDataNode(BinaryReader, ChunkHeader, BxmlNode) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.ProcessingInstructionDataNode
ProcessingInstructionDataNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml
ProcessingInstructionDataNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.ProcessingInstructionDataNodeTest
ProcessingInstructionTargetNode - Class in org.apache.nifi.processors.evtx.parser.bxml
ProcessingInstructionTargetNode(BinaryReader, ChunkHeader, BxmlNode) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.ProcessingInstructionTargetNode
ProcessingInstructionTargetNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml
ProcessingInstructionTargetNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.ProcessingInstructionTargetNodeTest
processInputStream(InputStream, FlowFile, SequenceFile.Writer) - Method in class org.apache.nifi.processors.hadoop.FlowFileStreamUnpackerSequenceFileWriter
processInputStream(InputStream, FlowFile, SequenceFile.Writer) - Method in class org.apache.nifi.processors.hadoop.SequenceFileWriterImpl
processInputStream(InputStream, FlowFile, SequenceFile.Writer) - Method in class org.apache.nifi.processors.hadoop.TarUnpackerSequenceFileWriter
processInputStream(InputStream, FlowFile, SequenceFile.Writer) - Method in class org.apache.nifi.processors.hadoop.ZipUnpackerSequenceFileWriter
processList(String, List, Map<String, String>) - Method in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes: Iterate through the list and calls processElement to process each element
Processor - Interface in org.apache.nifi.processor: Processor objects operate on FlowFile objects where the processors are linked together via relationships forming a directed graph structure.
PROCESSOR_ALREADY_SUBSCRIBED - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
PROCESSOR_SCHEDULING_TIMEOUT - Static variable in class org.apache.nifi.util.NiFiProperties
PROCESSOR_STATE_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ComponentStateEndpointMerger
PROCESSOR_STATUS_HISTORY_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.StatusHistoryEndpointMerger
PROCESSOR_STATUS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorStatusEndpointMerger
PROCESSOR_TYPES_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorTypesEndpointMerger
PROCESSOR_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorEndpointMerger
ProcessorAuditor - Class in org.apache.nifi.audit: Audits processor creation/removal and configuration changes.
ProcessorAuditor() - Constructor for class org.apache.nifi.audit.ProcessorAuditor
processorConfig - Variable in class org.apache.nifi.processors.hadoop.GetHDFS
ProcessorConfigDTO - Class in org.apache.nifi.web.api.dto: Configuration details for a processor in this NiFi.
ProcessorConfigDTO() - Constructor for class org.apache.nifi.web.api.dto.ProcessorConfigDTO
ProcessorDAO - Interface in org.apache.nifi.web.dao
ProcessorDetails - Class in org.apache.nifi.controller: Holder for StandardProcessorNode to atomically swap out the component.
ProcessorDetails(LoggableComponent<Processor>) - Constructor for class org.apache.nifi.controller.ProcessorDetails
ProcessorDocumentationWriterTest - Class in org.apache.nifi.documentation.html
ProcessorDocumentationWriterTest() - Constructor for class org.apache.nifi.documentation.html.ProcessorDocumentationWriterTest
ProcessorDTO - Class in org.apache.nifi.web.api.dto: Details for a processor within this NiFi.
ProcessorDTO() - Constructor for class org.apache.nifi.web.api.dto.ProcessorDTO
ProcessorEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProcessorEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorEndpointMerger
ProcessorEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessorEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessorEntity
ProcessorEntityMerger - Class in org.apache.nifi.cluster.manager
ProcessorEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.ProcessorEntityMerger
ProcessorInitializationContext - Interface in org.apache.nifi.processor: The ProcessorInitializationContext provides Processors access to objects that may be of use throughout the life of the Processor.
ProcessorInitializer - Class in org.apache.nifi.init: Initializes a Processor using a MockProcessorInitializationContext
ProcessorInitializer() - Constructor for class org.apache.nifi.init.ProcessorInitializer
ProcessorInstantiationException - Exception in org.apache.nifi.controller.exception
ProcessorInstantiationException(String, Throwable) - Constructor for exception org.apache.nifi.controller.exception.ProcessorInstantiationException
ProcessorInstantiationException(String) - Constructor for exception org.apache.nifi.controller.exception.ProcessorInstantiationException
ProcessorLogObserver - Class in org.apache.nifi.logging: Observes processor log messages and converts them into Bulletins.
ProcessorLogObserver(BulletinRepository, ProcessorNode) - Constructor for class org.apache.nifi.logging.ProcessorLogObserver
ProcessorNode - Class in org.apache.nifi.controller
ProcessorNode(String, ValidationContextFactory, ControllerServiceProvider, String, String, ComponentVariableRegistry, ReloadComponent, boolean) - Constructor for class org.apache.nifi.controller.ProcessorNode
ProcessorResource - Class in org.apache.nifi.web.api: RESTful endpoint for managing a Processor.
ProcessorResource() - Constructor for class org.apache.nifi.web.api.ProcessorResource
ProcessorResource - Class in org.apache.nifi.web.standard.api.processor
ProcessorResource() - Constructor for class org.apache.nifi.web.standard.api.processor.ProcessorResource
PROCESSORS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorEndpointMerger
PROCESSORS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorsEndpointMerger
ProcessorsEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProcessorsEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorsEndpointMerger
ProcessorsEntity - 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.
ProcessorsEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessorsEntity
ProcessorsEntityMerger - Class in org.apache.nifi.cluster.manager
ProcessorsEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.ProcessorsEntityMerger
ProcessorStatus - Class in org.apache.nifi.controller.status
ProcessorStatus() - Constructor for class org.apache.nifi.controller.status.ProcessorStatus
ProcessorStatusDescriptor - Enum in org.apache.nifi.controller.status.history
ProcessorStatusDTO - Class in org.apache.nifi.web.api.dto.status: DTO for serializing the status of a processor.
ProcessorStatusDTO() - Constructor for class org.apache.nifi.web.api.dto.status.ProcessorStatusDTO
ProcessorStatusEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProcessorStatusEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorStatusEndpointMerger
ProcessorStatusEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessorStatusEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessorStatusEntity
ProcessorStatusSnapshotDTO - Class in org.apache.nifi.web.api.dto.status: DTO for serializing the status of a processor.
ProcessorStatusSnapshotDTO() - Constructor for class org.apache.nifi.web.api.dto.status.ProcessorStatusSnapshotDTO
ProcessorStatusSnapshotEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProcessorStatusSnapshotEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessorStatusSnapshotEntity
ProcessorThatThrowsExceptionOnScheduled() - Constructor for class org.apache.nifi.controller.TestStandardProcessorNode.ProcessorThatThrowsExceptionOnScheduled
ProcessorTypesEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProcessorTypesEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProcessorTypesEndpointMerger
ProcessorTypesEntity - 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.
ProcessorTypesEntity() - Constructor for class org.apache.nifi.web.api.entity.ProcessorTypesEntity
ProcessorWithLogger - Class in org.apache.nifi.documentation.example
ProcessorWithLogger() - Constructor for class org.apache.nifi.documentation.example.ProcessorWithLogger
processRecordGranularity(ProcessSession, ComponentLog, FlowFile, String, InputStream) - Method in class org.apache.nifi.processors.evtx.ParseEvtx
processRow(ResultSet) - Method in class org.apache.nifi.processors.standard.QueryDatabaseTable.MaxValueResultSetRowCollector
processRow(ResultSet) - Method in interface org.apache.nifi.processors.standard.util.JdbcCommon.ResultSetRowCallback
processRow(ResultSet) - Method in interface org.apache.nifi.util.hive.HiveJdbcCommon.ResultSetRowCallback
ProcessScheduler - Interface in org.apache.nifi.controller
processServiceException(ProcessSession, List<FlowFile>, AmazonServiceException) - Method in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
ProcessSession - Interface in org.apache.nifi.processor: A process session encompasses all the behaviors a processor can perform to obtain, clone, read, modify remove FlowFiles in an atomic unit.
processSession - Variable in class org.apache.nifi.processors.email.ConsumeEWS
ProcessSessionFactory - Interface in org.apache.nifi.processor: Factory for creating a ProcessSession
processSessionFactory - Variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
processSessionFactory - Variable in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
processStreams(Cipher, InputStream, OutputStream) - Static method in class org.apache.nifi.security.util.crypto.CipherUtility
PROFILE_NAME - Static variable in class org.apache.nifi.processors.aws.credentials.provider.factory.CredentialPropertyDescriptors: Specifies use of a named profile credential.
profileMethod(ProceedingJoinPoint) - Method in class org.apache.nifi.aop.MethodProfiler
ProgressiveResult - Interface in org.apache.nifi.provenance: A Provenance query result that is capable of being updated
project(int[]) - Method in class org.apache.nifi.queryrecord.FlowFileTable: Returns an enumerable over a given projection of the fields.
PROJECT_ID - Static variable in class org.apache.nifi.processors.gcp.AbstractGCPProcessor
PROP_ADD_HEADERS_TO_REQUEST - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_ATTRIBUTES_TO_SEND - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_AUTHENTICATION_STRATEGY - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_AUTHORIZED_DN_PATTERN - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
PROP_BASIC_AUTH_PASSWORD - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_BASIC_AUTH_USERNAME - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_BROKER_URI - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_CACHE_ENTRY_IDENTIFIER - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
PROP_CHARACTER_SET - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
PROP_CLEAN_SESSION - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_CLIENTID - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_CONN_TIMEOUT - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_CONNECT_TIMEOUT - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_CONNECT_TIMEOUT - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_CONNECTION_TIMEOUT - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_CONTENT_TYPE - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_DATE_HEADER - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_DIGEST_AUTH - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_DISTRIBUTED_CACHE_SERVICE - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
PROP_FLOW_CONTROL_WINDOW - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
PROP_FOLLOW_REDIRECTS - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_FOO - Static variable in class org.apache.nifi.controller.service.mock.DummyReportingTask
PROP_FOO1 - Static variable in class org.apache.nifi.controller.service.mock.ServiceD
PROP_FOO2 - Static variable in class org.apache.nifi.controller.service.mock.ServiceD
PROP_GROUP_MEMBER_ATTRIBUTE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_GROUP_NAME_ATTRIBUTE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_GROUP_OBJECT_CLASS - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_GROUP_SEARCH_BASE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_GROUP_SEARCH_FILTER - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_GROUP_SEARCH_SCOPE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_KEEP_ALIVE_INTERVAL - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_KEY_PASSWORD - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_KEYSTORE - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_KEYSTORE_PASSWORD - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_KEYSTORE_TYPE - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_LAST_WILL_MESSAGE - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_LAST_WILL_QOS - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_LAST_WILL_RETAIN - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_LAST_WILL_TOPIC - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_MANAGER_DN - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_MANAGER_PASSWORD - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_MAX_MESSAGE_SIZE - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_MAX_MESSAGE_SIZE - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
PROP_MAX_QUEUE_SIZE - Static variable in class org.apache.nifi.processors.mqtt.ConsumeMQTT
PROP_METHOD - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_MQTT_VERSION - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_OUTPUT_RESPONSE_REGARDLESS - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_OUTPUT_RESPONSE_REGARDLESS - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PAGE_SIZE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_PASSWORD - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_PENALIZE_NO_RETRY - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_PENALIZE_NO_RETRY - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PROXY_HOST - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PROXY_PASSWORD - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PROXY_PORT - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PROXY_USER - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PUT_ATTRIBUTE_MAX_LENGTH - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
PROP_PUT_ATTRIBUTE_MAX_LENGTH - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
PROP_PUT_OUTPUT_IN_ATTRIBUTE - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_QOS - Static variable in class org.apache.nifi.processors.mqtt.ConsumeMQTT
PROP_QOS - Static variable in class org.apache.nifi.processors.mqtt.PublishMQTT
PROP_READ_TIMEOUT - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_READ_TIMEOUT - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_REFERRAL_STRATEGY - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_RETAIN - Static variable in class org.apache.nifi.processors.mqtt.PublishMQTT
PROP_SEND_BODY - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_SEND_CONTENT - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_SERVER_URL_PATH - Static variable in class org.apache.nifi.processors.websocket.ListenWebSocket
PROP_SERVICE_HOST - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_SERVICE_PORT - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_SERVICE_PORT - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
PROP_SHIELD_LOCATION - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchTransportClientProcessor
PROP_SSL_CONTEXT_SERVICE - Static variable in class org.apache.nifi.processors.cassandra.AbstractCassandraProcessor
PROP_SSL_CONTEXT_SERVICE - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchProcessor
PROP_SSL_CONTEXT_SERVICE - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_SSL_CONTEXT_SERVICE - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
PROP_SSL_CONTEXT_SERVICE - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_SSL_CONTEXT_SERVICE - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_SYNC_INTERVAL - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_TOPIC - Static variable in class org.apache.nifi.processors.mqtt.PublishMQTT
PROP_TOPIC_FILTER - Static variable in class org.apache.nifi.processors.mqtt.ConsumeMQTT
PROP_TRUSTED_HOSTNAME - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_TRUSTSTORE - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_TRUSTSTORE_PASSWORD - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_TRUSTSTORE_TYPE - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_TYPE_BOOLEAN - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_BYTE - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_DOUBLE - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_FLOAT - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_INTEGER - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_LONG - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_OBJECT - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_SHORT - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_TYPE_STRING - Static variable in class org.apache.nifi.processors.standard.util.JmsFactory
PROP_URL - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_URL - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_URL - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_USE_CHUNKED_ENCODING - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
PROP_USE_SECURE - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROP_USE_SECURE - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
PROP_USER_GROUP_ATTRIBUTE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_USER_IDENTITY_ATTRIBUTE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_USER_OBJECT_CLASS - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_USER_SEARCH_BASE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_USER_SEARCH_FILTER - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_USER_SEARCH_SCOPE - Static variable in class org.apache.nifi.ldap.tenants.LdapUserGroupProvider
PROP_USERNAME - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
PROP_WEBSOCKET_CLIENT_ID - Static variable in class org.apache.nifi.processors.websocket.ConnectWebSocket
PROP_WEBSOCKET_CLIENT_SERVICE - Static variable in class org.apache.nifi.processors.websocket.ConnectWebSocket
PROP_WEBSOCKET_SERVER_SERVICE - Static variable in class org.apache.nifi.processors.websocket.ListenWebSocket
PROP_WRITE_TIMEOUT - Static variable in class org.apache.nifi.bootstrap.notification.http.HttpNotificationService
PROP_WS_CONTROLLER_SERVICE_ENDPOINT - Static variable in class org.apache.nifi.processors.websocket.PutWebSocket
PROP_WS_CONTROLLER_SERVICE_ID - Static variable in class org.apache.nifi.processors.websocket.PutWebSocket
PROP_WS_MESSAGE_TYPE - Static variable in class org.apache.nifi.processors.websocket.PutWebSocket
PROP_WS_SESSION_ID - Static variable in class org.apache.nifi.processors.websocket.PutWebSocket
propDescriptors - Variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
propDescriptors - Static variable in class org.apache.nifi.processors.standard.PutDatabaseRecord
properties - Static variable in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric
properties - Variable in class org.apache.nifi.processors.aws.credentials.provider.factory.MockAWSProcessor
properties - Static variable in class org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDB
properties - Static variable in class org.apache.nifi.processors.aws.dynamodb.GetDynamoDB
properties - Static variable in class org.apache.nifi.processors.aws.dynamodb.PutDynamoDB
properties - Static variable in class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose
properties - Static variable in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream
properties - Static variable in class org.apache.nifi.processors.aws.lambda.PutLambda
properties - Static variable in class org.apache.nifi.processors.aws.s3.DeleteS3Object
properties - Static variable in class org.apache.nifi.processors.aws.s3.FetchS3Object
properties - Static variable in class org.apache.nifi.processors.aws.s3.ListS3
properties - Static variable in class org.apache.nifi.processors.aws.s3.PutS3Object
properties - Static variable in class org.apache.nifi.processors.aws.sns.PutSNS
properties - Static variable in class org.apache.nifi.processors.aws.sqs.DeleteSQS
properties - Static variable in class org.apache.nifi.processors.aws.sqs.GetSQS
properties - Static variable in class org.apache.nifi.processors.aws.sqs.PutSQS
properties - Variable in class org.apache.nifi.processors.gcp.credentials.factory.MockCredentialsFactoryProcessor
properties - Variable in class org.apache.nifi.processors.gcp.credentials.service.MockCredentialsServiceProcessor
PROPERTIES - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
PROPERTIES - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
properties - Variable in class org.apache.nifi.processors.hadoop.AbstractHadoopProcessor
PROPERTIES - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
properties - Variable in class org.apache.nifi.web.api.ApplicationResource
properties(Map<String, String>) - Method in class org.apache.nifi.web.ComponentDetails.Builder
PROPERTIES_FILE_PATH - Static variable in class org.apache.nifi.util.NiFiProperties
PropertiesFileLookupService - Class in org.apache.nifi.lookup
PropertiesFileLookupService() - Constructor for class org.apache.nifi.lookup.PropertiesFileLookupService
PROPERTY_DESCRIPTORS - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
PropertyContext - Interface in org.apache.nifi.context: A context for retrieving a PropertyValue from a PropertyDescriptor.
PropertyDescriptor - Class in org.apache.nifi.components: An immutable object for holding information about a type of component property.
PropertyDescriptor(PropertyDescriptor.Builder) - Constructor for class org.apache.nifi.components.PropertyDescriptor
PropertyDescriptor.Builder - Class in org.apache.nifi.components
PropertyDescriptorDTO - Class in org.apache.nifi.web.api.dto: A description of a property.
PropertyDescriptorDTO() - Constructor for class org.apache.nifi.web.api.dto.PropertyDescriptorDTO
PropertyDescriptorDtoMerger - Class in org.apache.nifi.cluster.manager
PropertyDescriptorDtoMerger() - Constructor for class org.apache.nifi.cluster.manager.PropertyDescriptorDtoMerger
PropertyDescriptorEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
PropertyDescriptorEntity() - Constructor for class org.apache.nifi.web.api.entity.PropertyDescriptorEntity
PropertyHistoryDTO - Class in org.apache.nifi.web.api.dto: History of a processor property.
PropertyHistoryDTO() - Constructor for class org.apache.nifi.web.api.dto.PropertyHistoryDTO
PropertyValue - Interface in org.apache.nifi.components: A PropertyValue provides a mechanism whereby the currently configured value of a processor property can be obtained in different forms.
protect(String) - Method in class org.apache.nifi.properties.AESSensitivePropertyProvider: Returns the encrypted cipher text.
protect(String) - Method in interface org.apache.nifi.properties.SensitivePropertyProvider: Returns the "protected" form of this value.
PROTOCOL - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
PROTOCOL - Static variable in class org.apache.nifi.processors.standard.AbstractSyslogProcessor
PROTOCOL_VERSION - Static variable in class org.apache.nifi.processors.standard.PostHTTP
PROTOCOL_VERSION - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
PROTOCOL_VERSION - Static variable in class org.apache.nifi.remote.protocol.http.HttpHeaders
PROTOCOL_VERSION_HEADER - Static variable in class org.apache.nifi.processors.standard.PostHTTP
PROTOCOL_VERSION_HEADER - Static variable in class org.apache.nifi.processors.standard.servlets.ListenHTTPServlet
protocolCommandSent(ProtocolCommandEvent) - Method in class org.apache.nifi.processors.standard.util.FTPUtils.FTPCommandMonitor
ProtocolContext<T> - Interface in org.apache.nifi.cluster.protocol: The context for communicating using the internal cluster protocol.
ProtocolException - Exception in org.apache.nifi.cluster.protocol: The base exception for problems encountered while communicating within the cluster.
ProtocolException() - Constructor for exception org.apache.nifi.cluster.protocol.ProtocolException
ProtocolException(String) - Constructor for exception org.apache.nifi.cluster.protocol.ProtocolException
ProtocolException(Throwable) - Constructor for exception org.apache.nifi.cluster.protocol.ProtocolException
ProtocolException(String, Throwable) - Constructor for exception org.apache.nifi.cluster.protocol.ProtocolException
ProtocolException - Exception in org.apache.nifi.remote.exception: A ProtocolException occurs when unexpected data is received, for example an invalid Response Code.
ProtocolException(String, Throwable) - Constructor for exception org.apache.nifi.remote.exception.ProtocolException
ProtocolException(String) - Constructor for exception org.apache.nifi.remote.exception.ProtocolException
ProtocolException(Throwable) - Constructor for exception org.apache.nifi.remote.exception.ProtocolException
ProtocolHandler - Interface in org.apache.nifi.cluster.protocol: A handler for processing protocol messages.
ProtocolHandshake - Class in org.apache.nifi.distributed.cache.protocol
ProtocolHandshake() - Constructor for class org.apache.nifi.distributed.cache.protocol.ProtocolHandshake
ProtocolListener - Interface in org.apache.nifi.cluster.protocol: Defines the interface for a listener to process protocol messages.
ProtocolMessage - Class in org.apache.nifi.cluster.protocol.message
ProtocolMessage() - Constructor for class org.apache.nifi.cluster.protocol.message.ProtocolMessage
ProtocolMessage.MessageType - Enum in org.apache.nifi.cluster.protocol.message
ProtocolMessageMarshaller<T> - Interface in org.apache.nifi.cluster.protocol: Defines a marshaller for serializing protocol messages.
ProtocolMessageUnmarshaller<T> - Interface in org.apache.nifi.cluster.protocol: Defines an unmarshaller for deserializing protocol messages.
protocolReplyReceived(ProtocolCommandEvent) - Method in class org.apache.nifi.processors.standard.util.FTPUtils.FTPCommandMonitor
protocolVersion - Variable in class org.apache.nifi.remote.AbstractTransaction
PROVENANCE_COMPRESS_ON_ROLLOVER - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_EVENT_SCHEMA_V1 - Static variable in class org.apache.nifi.provenance.schema.ProvenanceEventSchema
PROVENANCE_EVENT_SCHEMA_V1_WITHOUT_EVENT_ID - Static variable in class org.apache.nifi.provenance.schema.ProvenanceEventSchema
PROVENANCE_EVENT_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceEventEndpointMerger
PROVENANCE_INDEX_SHARD_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_INDEX_THREAD_POOL_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_INDEXED_ATTRIBUTES - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_INDEXED_FIELDS - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_JOURNAL_COUNT - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_MAX_STORAGE_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_MAX_STORAGE_TIME - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_QUERY_THREAD_POOL_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_QUERY_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceQueryEndpointMerger
PROVENANCE_REPO_DEBUG_FREQUENCY - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_REPO_DIRECTORY_PREFIX - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_REPO_ENCRYPTION_KEY - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_REPO_ENCRYPTION_KEY_ID - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_REPO_ENCRYPTION_KEY_PROVIDER_IMPLEMENTATION_CLASS - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_REPO_ENCRYPTION_KEY_PROVIDER_LOCATION - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_REPO_IMPLEMENTATION_CLASS - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_ROLLOVER_SIZE - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_ROLLOVER_TIME - Static variable in class org.apache.nifi.util.NiFiProperties
PROVENANCE_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceQueryEndpointMerger
ProvenanceAuthorizableFactory - Interface in org.apache.nifi.provenance
ProvenanceDTO - Class in org.apache.nifi.web.api.dto.provenance: A provenance submission.
ProvenanceDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.ProvenanceDTO
ProvenanceEntity - Class in org.apache.nifi.web.api.entity
ProvenanceEntity() - Constructor for class org.apache.nifi.web.api.entity.ProvenanceEntity
ProvenanceEventBuilder - Interface in org.apache.nifi.provenance
ProvenanceEventDTO - Class in org.apache.nifi.web.api.dto.provenance: A provenance event.
ProvenanceEventDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.ProvenanceEventDTO
ProvenanceEventEncryptor - Interface in org.apache.nifi.provenance
ProvenanceEventEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProvenanceEventEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceEventEndpointMerger
ProvenanceEventEnricher - Interface in org.apache.nifi.controller.repository
ProvenanceEventEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProvenanceEventEntity() - Constructor for class org.apache.nifi.web.api.entity.ProvenanceEventEntity
ProvenanceEventLineageNode - Interface in org.apache.nifi.provenance.lineage
ProvenanceEventRecord - Interface in org.apache.nifi.provenance: Describes an event that happened to a FlowFile.
ProvenanceEventRepository - Interface in org.apache.nifi.provenance: This Repository houses Provenance Events.
ProvenanceEventResource - Class in org.apache.nifi.web.api: RESTful endpoint for querying data provenance.
ProvenanceEventResource() - Constructor for class org.apache.nifi.web.api.ProvenanceEventResource
ProvenanceEventSchema - Class in org.apache.nifi.provenance.schema
ProvenanceEventSchema() - Constructor for class org.apache.nifi.provenance.schema.ProvenanceEventSchema
ProvenanceEventType - Enum in org.apache.nifi.provenance
ProvenanceLinkDTO - Class in org.apache.nifi.web.api.dto.provenance.lineage: A link between an event or flowfile within a provenance lineage.
ProvenanceLinkDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.lineage.ProvenanceLinkDTO
ProvenanceNodeDTO - Class in org.apache.nifi.web.api.dto.provenance.lineage: A node within a provenance lineage.
ProvenanceNodeDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.lineage.ProvenanceNodeDTO
ProvenanceOptionsDTO - Class in org.apache.nifi.web.api.dto.provenance: A provenance search options.
ProvenanceOptionsDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.ProvenanceOptionsDTO
ProvenanceOptionsEntity - Class in org.apache.nifi.web.api.entity: A serialized representation of this class can be placed in the entity body of a request or response to or from the API.
ProvenanceOptionsEntity() - Constructor for class org.apache.nifi.web.api.entity.ProvenanceOptionsEntity
ProvenanceQueryEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ProvenanceQueryEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ProvenanceQueryEndpointMerger
ProvenanceReporter - Interface in org.apache.nifi.provenance: ProvenanceReporter generates and records Provenance-related events.
provenanceRepository(ProvenanceEventRepository) - Method in class org.apache.nifi.connectable.StandardConnection.Builder
ProvenanceRepository - Interface in org.apache.nifi.provenance
ProvenanceRequestDTO - Class in org.apache.nifi.web.api.dto.provenance: A request for provenance.
ProvenanceRequestDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.ProvenanceRequestDTO
ProvenanceResource - Class in org.apache.nifi.web.api: RESTful endpoint for querying data provenance.
ProvenanceResource() - Constructor for class org.apache.nifi.web.api.ProvenanceResource
ProvenanceResultsDTO - Class in org.apache.nifi.web.api.dto.provenance: Results of a provenance request.
ProvenanceResultsDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.ProvenanceResultsDTO
ProvenanceSearchableFieldDTO - Class in org.apache.nifi.web.api.dto.provenance: A searchable field for provenance queries.
ProvenanceSearchableFieldDTO() - Constructor for class org.apache.nifi.web.api.dto.provenance.ProvenanceSearchableFieldDTO
provide() - Method in interface org.apache.nifi.processor.util.list.ListProcessorTestWatcher.Provider
PROVIDED_VALUE - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
ProviderCreationException - Exception in org.apache.nifi.authentication.exception: Represents the exceptional case when an AuthorityProvider fails instantiated.
ProviderCreationException() - Constructor for exception org.apache.nifi.authentication.exception.ProviderCreationException
ProviderCreationException(String) - Constructor for exception org.apache.nifi.authentication.exception.ProviderCreationException
ProviderCreationException(Throwable) - Constructor for exception org.apache.nifi.authentication.exception.ProviderCreationException
ProviderCreationException(String, Throwable) - Constructor for exception org.apache.nifi.authentication.exception.ProviderCreationException
ProviderDestructionException - Exception in org.apache.nifi.authentication.exception: Represents the exceptional case when an AuthorityProvider fails destruction.
ProviderDestructionException() - Constructor for exception org.apache.nifi.authentication.exception.ProviderDestructionException
ProviderDestructionException(String) - Constructor for exception org.apache.nifi.authentication.exception.ProviderDestructionException
ProviderDestructionException(Throwable) - Constructor for exception org.apache.nifi.authentication.exception.ProviderDestructionException
ProviderDestructionException(String, Throwable) - Constructor for exception org.apache.nifi.authentication.exception.ProviderDestructionException
providerIsValid(String) - Static method in class org.apache.nifi.encrypt.StringEncryptor
ProxiedEntitiesUtils - Class in org.apache.nifi.web.security
ProxiedEntitiesUtils() - Constructor for class org.apache.nifi.web.security.ProxiedEntitiesUtils
proxy - Variable in class org.apache.nifi.remote.util.SiteToSiteRestApiClient
PROXY_CONTEXT_PATH_HTTP_HEADER - Static variable in class org.apache.nifi.web.api.ApplicationResource
PROXY_DN - Static variable in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer
PROXY_DN - Static variable in class org.apache.nifi.integration.util.NiFiTestAuthorizer
PROXY_ENTITIES_ACCEPTED - Static variable in class org.apache.nifi.web.security.ProxiedEntitiesUtils
PROXY_ENTITIES_CHAIN - Static variable in class org.apache.nifi.web.security.ProxiedEntitiesUtils
PROXY_ENTITIES_DETAILS - Static variable in class org.apache.nifi.web.security.ProxiedEntitiesUtils
PROXY_HOST - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
PROXY_HOST - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchHttpProcessor
PROXY_HOST - Static variable in class org.apache.nifi.processors.standard.GetHTTP
PROXY_HOST - Static variable in class org.apache.nifi.processors.standard.PostHTTP
PROXY_HOST - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PROXY_HOST_HTTP_HEADER - Static variable in class org.apache.nifi.web.api.ApplicationResource
PROXY_HOST_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PROXY_HOST_PORT - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
PROXY_PASSWORD_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PROXY_PORT - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchHttpProcessor
PROXY_PORT - Static variable in class org.apache.nifi.processors.standard.GetHTTP
PROXY_PORT - Static variable in class org.apache.nifi.processors.standard.PostHTTP
PROXY_PORT - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PROXY_PORT_HTTP_HEADER - Static variable in class org.apache.nifi.web.api.ApplicationResource
PROXY_PORT_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PROXY_PORT_OPTION_DEFAULT - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
PROXY_SCHEME_HTTP_HEADER - Static variable in class org.apache.nifi.web.api.ApplicationResource
PROXY_TYPE - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PROXY_TYPE_DIRECT - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PROXY_TYPE_HTTP - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PROXY_TYPE_SOCKS - Static variable in class org.apache.nifi.processors.standard.util.FTPTransfer
PROXY_USERNAME_OPTION - Static variable in class org.apache.nifi.toolkit.s2s.SiteToSiteCliMain
ProxyAuthenticator - Class in org.apache.nifi.processors.standard.util
ProxyAuthenticator() - Constructor for class org.apache.nifi.processors.standard.util.ProxyAuthenticator
ProxyAuthenticator(String, String) - Constructor for class org.apache.nifi.processors.standard.util.ProxyAuthenticator
proxyVariablesValidForAssumeRole(Map<PropertyDescriptor, String>) - Method in class org.apache.nifi.processors.aws.credentials.provider.factory.strategies.AssumeRoleCredentialsStrategy
pruneIdleSenders(long) - Method in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor: Close any senders that haven't been active with in the given threshold
PUBLIC_KEY_USERID - Static variable in class org.apache.nifi.processors.standard.EncryptContent
PUBLIC_KEYRING - Static variable in class org.apache.nifi.processors.standard.EncryptContent
publish(String, byte[], int, boolean) - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
publish(String, MqttMessage) - Method in class org.apache.nifi.processors.mqtt.common.MqttTestClient
PUBLISH_WAIT_MS - Variable in class org.apache.nifi.processors.mqtt.common.TestConsumeMqttCommon
PublishAMQP - Class in org.apache.nifi.amqp.processors: Publishing AMQP processor which upon each invocation of AbstractAMQPProcessor.onTrigger(ProcessContext, ProcessSession) method will construct an AMQP message sending it to an exchange identified during construction of this class while transferring the incoming FlowFile to 'success' Relationship.
PublishAMQP() - Constructor for class org.apache.nifi.amqp.processors.PublishAMQP
PublishAMQPTest - Class in org.apache.nifi.amqp.processors
PublishAMQPTest() - Constructor for class org.apache.nifi.amqp.processors.PublishAMQPTest
PublishAMQPTest.LocalPublishAMQP - Class in org.apache.nifi.amqp.processors
publishedMessage - Variable in class org.apache.nifi.processors.mqtt.common.MqttTestClient
PublisherLease - Class in org.apache.nifi.processors.kafka.pubsub
PublisherLease(Producer<byte[], byte[]>, int, long, ComponentLog) - Constructor for class org.apache.nifi.processors.kafka.pubsub.PublisherLease
PublisherPool - Class in org.apache.nifi.processors.kafka.pubsub
PublishJMS - Class in org.apache.nifi.jms.processors: An implementation of JMS Message publishing Processor which upon each invocation of AbstractJMSProcessor.onTrigger(ProcessContext, ProcessSession) method will construct a Message from the contents of the FlowFile sending it to the Destination identified by the AbstractJMSProcessor.DESTINATION property while transferring the incoming FlowFile to 'success' Relationship.
PublishJMS() - Constructor for class org.apache.nifi.jms.processors.PublishJMS
PublishJMSTest - Class in org.apache.nifi.jms.processors
PublishJMSTest() - Constructor for class org.apache.nifi.jms.processors.PublishJMSTest
PublishKafka - Class in org.apache.nifi.processors.kafka.pubsub
PublishKafka() - Constructor for class org.apache.nifi.processors.kafka.pubsub.PublishKafka
PublishKafka_0_10 - Class in org.apache.nifi.processors.kafka.pubsub
PublishKafka_0_10() - Constructor for class org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10
PublishKafka_0_11 - Class in org.apache.nifi.processors.kafka.pubsub
PublishKafka_0_11() - Constructor for class org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11
PublishKafkaRecord_0_10 - Class in org.apache.nifi.processors.kafka.pubsub
PublishKafkaRecord_0_10() - Constructor for class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10
PublishKafkaRecord_0_11 - Class in org.apache.nifi.processors.kafka.pubsub
PublishKafkaRecord_0_11() - Constructor for class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_11
PublishMQTT - Class in org.apache.nifi.processors.mqtt
PublishMQTT() - Constructor for class org.apache.nifi.processors.mqtt.PublishMQTT
PublishResult - Interface in org.apache.nifi.processors.kafka.pubsub
purge() - Method in class org.apache.nifi.controller.FileSystemSwapManager
purge() - Method in interface org.apache.nifi.controller.repository.claim.ResourceClaimManager: Clears the manager's memory of any and all ResourceClaims that it knows about
purge() - Method in class org.apache.nifi.controller.repository.claim.StandardResourceClaimManager
purge() - Method in interface org.apache.nifi.controller.repository.ContentRepository: Purges the contents of the repository, as if the repository were newly created.
purge() - Method in class org.apache.nifi.controller.repository.FileSystemRepository
purge() - Method in interface org.apache.nifi.controller.repository.FlowFileSwapManager: Purge all known Swap Files without updating FlowFileRepository or Provenance Repository
purge() - Method in class org.apache.nifi.controller.repository.VolatileContentRepository
purge() - Method in class org.apache.nifi.controller.TestFileSystemSwapManager.NopResourceClaimManager
purge() - Method in class org.apache.nifi.processor.util.bin.BinManager
purge() - Method in class org.apache.nifi.processors.standard.merge.RecordBinManager: Must be called only when there are no active threads modifying the bins.
purgeActions(Date, Action) - Method in interface org.apache.nifi.admin.service.AuditService: Purges all action's that occurred before the specified end date.
purgeActions(Date, Action) - Method in class org.apache.nifi.admin.service.impl.StandardAuditService
PurgeActionsAction - Class in org.apache.nifi.admin.service.action: Purges actions up to a specified end date.
PurgeActionsAction(Date, Action) - Constructor for class org.apache.nifi.admin.service.action.PurgeActionsAction
PurgeDetails - Interface in org.apache.nifi.action.details: Provides details about a purge action.
PurgeDetailsDTO - Class in org.apache.nifi.web.api.dto.action.details: Details of a purge operation.
PurgeDetailsDTO() - Constructor for class org.apache.nifi.web.api.dto.action.details.PurgeDetailsDTO
purgeEvents(long) - Method in interface org.apache.nifi.controller.repository.metrics.EventContainer
purgeEvents(long) - Method in class org.apache.nifi.controller.repository.metrics.SecondPrecisionEventContainer
purgeHeartbeats() - Method in class org.apache.nifi.cluster.coordination.heartbeat.ClusterProtocolHeartbeatMonitor
purgeHeartbeats() - Method in interface org.apache.nifi.cluster.coordination.heartbeat.HeartbeatMonitor: Clears all heartbeats that have been received
purgeOldestEvents() - Method in interface org.apache.nifi.provenance.store.EventStorePartition: Purges some number of events from the partition.
purgeOldestEvents() - Method in class org.apache.nifi.provenance.store.WriteAheadStorePartition
purgeOldEvents(long, TimeUnit) - Method in interface org.apache.nifi.provenance.store.EventStorePartition: Purges any events from the partition that are older than the given amount of time
purgeOldEvents(long, TimeUnit) - Method in class org.apache.nifi.provenance.store.WriteAheadStorePartition
purgeSwapFiles() - Method in interface org.apache.nifi.controller.queue.FlowFileQueue: Destroys any Swap Files that exist for this queue without updating the FlowFile Repository or Provenance Repository.
purgeSwapFiles() - Method in class org.apache.nifi.controller.StandardFlowFileQueue
purgeTransferEvents(long) - Method in interface org.apache.nifi.controller.repository.FlowFileEventRepository: Causes any flow file events of the given entry age in epoch milliseconds or older to be purged from the repository
purgeTransferEvents(long) - Method in class org.apache.nifi.controller.repository.metrics.RingBufferEventRepository
pushback(Record) - Method in class org.apache.nifi.serialization.record.PushBackRecordSet
PushBackRecordSet - Class in org.apache.nifi.serialization.record
PushBackRecordSet(RecordSet) - Constructor for class org.apache.nifi.serialization.record.PushBackRecordSet
put(String, String) - Method in class org.apache.nifi.attribute.expression.language.AttributesAndState
put(FlowFileRecord) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue: places the given file into the queue
put(FlowFileRecord) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
put(K, V, Serializer<K>, Serializer<V>) - Method in interface org.apache.nifi.distributed.cache.client.DistributedMapCacheClient: Adds the specified key and value to the cache, overwriting any value that is currently set.
put(K, V, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
put(ByteBuffer, ByteBuffer) - Method in interface org.apache.nifi.distributed.cache.server.map.MapCache
put(ByteBuffer, ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
put(ByteBuffer, ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.map.SimpleMapCache
put(K, V, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientMapCacheService
put(String, Collection<PutFlowFile>) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientService
put(String, byte[], Collection<PutColumn>) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientService
put(String, Collection<PutFlowFile>) - Method in interface org.apache.nifi.hbase.HBaseClientService: Puts a batch of mutations to the given table.
put(String, byte[], Collection<PutColumn>) - Method in interface org.apache.nifi.hbase.HBaseClientService: Puts the given row to HBase with the provided columns.
put(String, byte[], Collection<PutColumn>) - Method in class org.apache.nifi.hbase.MockHBaseClientService
Put<FC,C extends java.lang.AutoCloseable> - Class in org.apache.nifi.processor.util.pattern: Abstract Put pattern class with a generic onTrigger method structure, composed with various partial functions.
Put() - Constructor for class org.apache.nifi.processor.util.pattern.Put
put(byte) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
put(byte[]) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
put(FlowFile, String, String, InputStream) - Method in interface org.apache.nifi.processors.standard.util.FileTransfer
put(FlowFile, String, String, InputStream) - Method in class org.apache.nifi.processors.standard.util.FTPTransfer
put(FlowFile, String, String, InputStream) - Method in class org.apache.nifi.processors.standard.util.SFTPTransfer
put(K, V, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
Put.PutFlowFile<FC,C> - Interface in org.apache.nifi.processor.util.pattern
PUT_LOCATION_TYPE - Static variable in class org.apache.nifi.PutHTMLElement
PUT_VALUE - Static variable in class org.apache.nifi.PutHTMLElement
putAll(Map<? extends String, ? extends String>) - Method in class org.apache.nifi.attribute.expression.language.AttributesAndState
putAll(Collection<FlowFileRecord>) - Method in interface org.apache.nifi.controller.queue.FlowFileQueue: places the given files into the queue
putAll(Collection<FlowFileRecord>) - Method in class org.apache.nifi.controller.StandardFlowFileQueue
putAllAttributes(FlowFile, Map<String, String>) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
putAllAttributes(FlowFile, Map<String, String>) - Method in interface org.apache.nifi.processor.ProcessSession: Updates the given FlowFiles attributes with the given key/value pairs.
putAllAttributes(FlowFile, Map<String, String>) - Method in class org.apache.nifi.util.MockProcessSession
putAttribute(FlowFile, String, String) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
putAttribute(FlowFile, String, String) - Method in interface org.apache.nifi.processor.ProcessSession: Updates the given FlowFiles attributes with the given key/value pair.
putAttribute(String, String) - Method in class org.apache.nifi.toolkit.s2s.DataPacketDto
putAttribute(FlowFile, String, String) - Method in class org.apache.nifi.util.MockProcessSession
putAttributes(Map<String, String>) - Method in class org.apache.nifi.util.MockFlowFile
PutAzureBlobStorage - Class in org.apache.nifi.processors.azure.storage
PutAzureBlobStorage() - Constructor for class org.apache.nifi.processors.azure.storage.PutAzureBlobStorage
PutAzureEventHub - Class in org.apache.nifi.processors.azure.eventhub
PutAzureEventHub() - Constructor for class org.apache.nifi.processors.azure.eventhub.PutAzureEventHub
putBase64EncodedBinary(String) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
PutCassandraQL - Class in org.apache.nifi.processors.cassandra
PutCassandraQL() - Constructor for class org.apache.nifi.processors.cassandra.PutCassandraQL
PutCassandraQLTest - Class in org.apache.nifi.processors.cassandra: Unit tests for the PutCassandraQL processor
PutCassandraQLTest() - Constructor for class org.apache.nifi.processors.cassandra.PutCassandraQLTest
PutCloudWatchMetric - Class in org.apache.nifi.processors.aws.cloudwatch
PutCloudWatchMetric() - Constructor for class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric
PutColumn - Class in org.apache.nifi.hbase.put: Encapsulates the information for one column of a put operation.
PutColumn(byte[], byte[], byte[]) - Constructor for class org.apache.nifi.hbase.put.PutColumn
PutColumn(byte[], byte[], byte[], Long) - Constructor for class org.apache.nifi.hbase.put.PutColumn
PutCouchbaseKey - Class in org.apache.nifi.processors.couchbase
PutCouchbaseKey() - Constructor for class org.apache.nifi.processors.couchbase.PutCouchbaseKey
PutDatabaseRecord - Class in org.apache.nifi.processors.standard
PutDatabaseRecord() - Constructor for class org.apache.nifi.processors.standard.PutDatabaseRecord
PutDatabaseRecord.ColumnDescription - Class in org.apache.nifi.processors.standard
PutDistributedMapCache - Class in org.apache.nifi.processors.standard
PutDistributedMapCache() - Constructor for class org.apache.nifi.processors.standard.PutDistributedMapCache
PutDistributedMapCache.CacheValueDeserializer - Class in org.apache.nifi.processors.standard
PutDistributedMapCache.CacheValueSerializer - Class in org.apache.nifi.processors.standard
PutDistributedMapCache.StringSerializer - Class in org.apache.nifi.processors.standard: Simple string serializer, used for serializing the cache key
putDWord(int) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putDWord(UnsignedInteger) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putDWordAt(int, int) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putDWordBE(int) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putDWordBE(UnsignedInteger) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
PutDynamoDB - Class in org.apache.nifi.processors.aws.dynamodb
PutDynamoDB() - Constructor for class org.apache.nifi.processors.aws.dynamodb.PutDynamoDB
putDynamoDB - Variable in class org.apache.nifi.processors.aws.dynamodb.PutDynamoDBTest
PutDynamoDBTest - Class in org.apache.nifi.processors.aws.dynamodb
PutDynamoDBTest() - Constructor for class org.apache.nifi.processors.aws.dynamodb.PutDynamoDBTest
PutElasticsearch - Class in org.apache.nifi.processors.elasticsearch
PutElasticsearch() - Constructor for class org.apache.nifi.processors.elasticsearch.PutElasticsearch
PutElasticsearch5 - Class in org.apache.nifi.processors.elasticsearch
PutElasticsearch5() - Constructor for class org.apache.nifi.processors.elasticsearch.PutElasticsearch5
PutElasticsearchHttp - Class in org.apache.nifi.processors.elasticsearch
PutElasticsearchHttp() - Constructor for class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp
PutElasticsearchHttpRecord - Class in org.apache.nifi.processors.elasticsearch
PutElasticsearchHttpRecord() - Constructor for class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord
PutEmail - Class in org.apache.nifi.processors.standard
PutEmail() - Constructor for class org.apache.nifi.processors.standard.PutEmail
PutFile - Class in org.apache.nifi.processors.standard
PutFile() - Constructor for class org.apache.nifi.processors.standard.PutFile
putFileTime(Date) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
PutFileTransfer<T extends FileTransfer> - Class in org.apache.nifi.processors.standard: Base class for PutFTP & PutSFTP
PutFileTransfer() - Constructor for class org.apache.nifi.processors.standard.PutFileTransfer
PutFlowFile - Class in org.apache.nifi.hbase.put: Wrapper to encapsulate all of the information for the Put along with the FlowFile.
PutFlowFile(String, byte[], Collection<PutColumn>, FlowFile) - Constructor for class org.apache.nifi.hbase.put.PutFlowFile
putFlowFile - Variable in class org.apache.nifi.processor.util.pattern.Put
putFlowFile(Put.PutFlowFile<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.Put: Specify a function that puts an incoming FlowFile to target data storage.
putFlowFile(Put.PutFlowFile<FC, C>) - Method in class org.apache.nifi.processor.util.pattern.PutGroup: PutGroup does not support PutFileFile function for single FlowFile.
putFlowFiles(ProcessContext, ProcessSession, FC, C, List<FlowFile>, RoutingResult) - Method in class org.apache.nifi.processor.util.pattern.Put: Put fetched FlowFiles to a data storage.
putFlowFiles(PutGroup.PutFlowFiles<FC, C, FFG>) - Method in class org.apache.nifi.processor.util.pattern.PutGroup: Specify a function that puts an input FlowFile group to a target storage using a given connection.
putFlowFiles(ProcessContext, ProcessSession, FC, C, List<FlowFile>, RoutingResult) - Method in class org.apache.nifi.processor.util.pattern.PutGroup
PutFTP - Class in org.apache.nifi.processors.standard
PutFTP() - Constructor for class org.apache.nifi.processors.standard.PutFTP
PutGCSObject - Class in org.apache.nifi.processors.gcp.storage
PutGCSObject() - Constructor for class org.apache.nifi.processors.gcp.storage.PutGCSObject
PutGCSObjectIT - Class in org.apache.nifi.processors.gcp.storage: Integration tests for PutGCSObject which actually use Google Cloud resources.
PutGCSObjectIT() - Constructor for class org.apache.nifi.processors.gcp.storage.PutGCSObjectIT
PutGCSObjectTest - Class in org.apache.nifi.processors.gcp.storage: Unit tests for PutGCSObject which do not use Google Cloud resources.
PutGCSObjectTest() - Constructor for class org.apache.nifi.processors.gcp.storage.PutGCSObjectTest
PutGroup<FC,C extends java.lang.AutoCloseable,FFG extends PartialFunctions.FlowFileGroup> - Class in org.apache.nifi.processor.util.pattern: Extended Put pattern capable of handling FlowFile groups.
PutGroup() - Constructor for class org.apache.nifi.processor.util.pattern.PutGroup
PutGroup.GroupFlowFiles<FC,C,FFG> - Interface in org.apache.nifi.processor.util.pattern
PutGroup.PutFlowFiles<FC,C,FFG> - Interface in org.apache.nifi.processor.util.pattern
putGuid(String) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putHandshakeParam(HandshakeProperty, String) - Method in class org.apache.nifi.remote.io.http.HttpServerCommunicationsSession
PutHBaseCell - Class in org.apache.nifi.hbase
PutHBaseCell() - Constructor for class org.apache.nifi.hbase.PutHBaseCell
PutHBaseJSON - Class in org.apache.nifi.hbase
PutHBaseJSON() - Constructor for class org.apache.nifi.hbase.PutHBaseJSON
PutHBaseRecord - Class in org.apache.nifi.hbase
PutHBaseRecord() - Constructor for class org.apache.nifi.hbase.PutHBaseRecord
PutHDFS - Class in org.apache.nifi.processors.hadoop: This processor copies FlowFiles to HDFS.
PutHDFS() - Constructor for class org.apache.nifi.processors.hadoop.PutHDFS
PutHDFSTest - Class in org.apache.nifi.processors.hadoop
PutHDFSTest() - Constructor for class org.apache.nifi.processors.hadoop.PutHDFSTest
PutHiveQL - Class in org.apache.nifi.processors.hive
PutHiveQL() - Constructor for class org.apache.nifi.processors.hive.PutHiveQL
PutHiveStreaming - Class in org.apache.nifi.processors.hive: This processor utilizes the Hive Streaming capability to insert data from the flow into a Hive database table.
PutHiveStreaming() - Constructor for class org.apache.nifi.processors.hive.PutHiveStreaming
PutHiveStreaming.HiveStreamingRecord - Class in org.apache.nifi.processors.hive
PutHTMLElement - Class in org.apache.nifi
PutHTMLElement() - Constructor for class org.apache.nifi.PutHTMLElement
putIfAbsent(K, V, Serializer<K>, Serializer<V>) - Method in interface org.apache.nifi.distributed.cache.client.DistributedMapCacheClient: Adds the specified key and value to the cache, if they are not already present, serializing the key and value with the given Serializers.
putIfAbsent(K, V, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
putIfAbsent(ByteBuffer, ByteBuffer) - Method in interface org.apache.nifi.distributed.cache.server.map.MapCache
putIfAbsent(ByteBuffer, ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
putIfAbsent(ByteBuffer, ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.map.SimpleMapCache
putIfAbsent(K, V, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientMapCacheService
putIfAbsent(K, V, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
PutIgniteCache - Class in org.apache.nifi.processors.ignite.cache: Put cache processors which pushes the flow file content into Ignite Cache using DataStreamer interface
PutIgniteCache() - Constructor for class org.apache.nifi.processors.ignite.cache.PutIgniteCache
PutJMS - Class in org.apache.nifi.processors.standard: Deprecated.
PutJMS() - Constructor for class org.apache.nifi.processors.standard.PutJMS: Deprecated.
PutKafka - Class in org.apache.nifi.processors.kafka
PutKafka() - Constructor for class org.apache.nifi.processors.kafka.PutKafka
PutKafkaTest - Class in org.apache.nifi.processors.kafka
PutKafkaTest() - Constructor for class org.apache.nifi.processors.kafka.PutKafkaTest
PutKinesisFirehose - Class in org.apache.nifi.processors.aws.kinesis.firehose
PutKinesisFirehose() - Constructor for class org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose
PutKinesisStream - Class in org.apache.nifi.processors.aws.kinesis.stream
PutKinesisStream() - Constructor for class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream
PutKudu - Class in org.apache.nifi.processors.kudu
PutKudu() - Constructor for class org.apache.nifi.processors.kudu.PutKudu
PutLambda - Class in org.apache.nifi.processors.aws.lambda
PutLambda() - Constructor for class org.apache.nifi.processors.aws.lambda.PutLambda
putMetricData(PutMetricDataRequest) - Method in class org.apache.nifi.processors.aws.cloudwatch.MockPutCloudWatchMetric
putMetricData(PutMetricDataRequest) - Method in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric
putMetricDataCallCount - Variable in class org.apache.nifi.processors.aws.cloudwatch.MockPutCloudWatchMetric
PutMongo - Class in org.apache.nifi.processors.mongodb
PutMongo() - Constructor for class org.apache.nifi.processors.mongodb.PutMongo
PutMongoRecord - Class in org.apache.nifi.processors.mongodb
PutMongoRecord() - Constructor for class org.apache.nifi.processors.mongodb.PutMongoRecord
PutMongoTest - Class in org.apache.nifi.processors.mongodb
PutMongoTest() - Constructor for class org.apache.nifi.processors.mongodb.PutMongoTest
putNode(TestBinaryReaderBuilder, int, int, String) - Static method in class org.apache.nifi.processors.evtx.parser.bxml.NameStringNodeTest
putNode(TestBinaryReaderBuilder, int, String, int) - Static method in class org.apache.nifi.processors.evtx.parser.bxml.TemplateNodeTest
putNode(TestBinaryReaderBuilder, int, Date) - Static method in class org.apache.nifi.processors.evtx.parser.RecordTest
PutParquet - Class in org.apache.nifi.processors.parquet
PutParquet() - Constructor for class org.apache.nifi.processors.parquet.PutParquet
PutParquetTest - Class in org.apache.nifi.processors.parquet
PutParquetTest() - Constructor for class org.apache.nifi.processors.parquet.PutParquetTest
putQWord(long) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putQWord(UnsignedLong) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
PutRethinkDB - Class in org.apache.nifi.processors.rethinkdb
PutRethinkDB() - Constructor for class org.apache.nifi.processors.rethinkdb.PutRethinkDB
PutRiemann - Class in org.apache.nifi.processors.riemann
PutRiemann() - Constructor for class org.apache.nifi.processors.riemann.PutRiemann
PutRiemann.Transport - Enum in org.apache.nifi.processors.riemann
PutS3Object - Class in org.apache.nifi.processors.aws.s3
PutS3Object() - Constructor for class org.apache.nifi.processors.aws.s3.PutS3Object
PutS3Object.MultipartState - Class in org.apache.nifi.processors.aws.s3
PutSFTP - Class in org.apache.nifi.processors.standard
PutSFTP() - Constructor for class org.apache.nifi.processors.standard.PutSFTP
PutSlack - Class in org.apache.nifi.processors.slack
PutSlack() - Constructor for class org.apache.nifi.processors.slack.PutSlack
PutSlackTest - Class in org.apache.nifi.processors.slack
PutSlackTest() - Constructor for class org.apache.nifi.processors.slack.PutSlackTest
PutSNS - Class in org.apache.nifi.processors.aws.sns
PutSNS() - Constructor for class org.apache.nifi.processors.aws.sns.PutSNS
PutSolrContentStream - Class in org.apache.nifi.processors.solr
PutSolrContentStream() - Constructor for class org.apache.nifi.processors.solr.PutSolrContentStream
PutSplunk - Class in org.apache.nifi.processors.splunk
PutSplunk() - Constructor for class org.apache.nifi.processors.splunk.PutSplunk
PutSQL - Class in org.apache.nifi.processors.standard
PutSQL() - Constructor for class org.apache.nifi.processors.standard.PutSQL
PutSQS - Class in org.apache.nifi.processors.aws.sqs
PutSQS() - Constructor for class org.apache.nifi.processors.aws.sqs.PutSQS
putString(String) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
PutSyslog - Class in org.apache.nifi.processors.standard
PutSyslog() - Constructor for class org.apache.nifi.processors.standard.PutSyslog
putSystemtime(Calendar) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
PutTCP - Class in org.apache.nifi.processors.standard: The PutTCP processor receives a FlowFile and transmits the FlowFile content over a TCP connection to the configured TCP server.
PutTCP() - Constructor for class org.apache.nifi.processors.standard.PutTCP
putTestFile(String, File) - Method in class org.apache.nifi.processors.aws.s3.AbstractS3IT
putTestFile(String, byte[]) - Method in class org.apache.nifi.processors.gcp.storage.AbstractGCSIT: Puts a test file onto Google Cloud Storage in bucket AbstractGCSIT.BUCKET.
putTestFileEncrypted(String, File) - Method in class org.apache.nifi.processors.aws.s3.AbstractS3IT
putTestFileEncrypted(String, byte[]) - Method in class org.apache.nifi.processors.gcp.storage.AbstractGCSIT: Puts a test file onto Google Cloud Storage in bucket AbstractGCSIT.BUCKET.
PutUDP - Class in org.apache.nifi.processors.standard: The PutUDP processor receives a FlowFile and packages the FlowFile content into a single UDP datagram packet which is then transmitted to the configured UDP server.
PutUDP() - Constructor for class org.apache.nifi.processors.standard.PutUDP
PutWebSocket - Class in org.apache.nifi.processors.websocket
PutWebSocket() - Constructor for class org.apache.nifi.processors.websocket.PutWebSocket
putWord(int) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putWordBE(int) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder
putWriteAheadLog(ByteBuffer, ByteBuffer, MapPutResult) - Method in class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
putWString(String) - Method in class org.apache.nifi.processors.evtx.parser.TestBinaryReaderBuilder

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