R-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

R

RandomIVPBECipherProvider - Class in org.apache.nifi.security.util.crypto
RandomIVPBECipherProvider() - Constructor for class org.apache.nifi.security.util.crypto.RandomIVPBECipherProvider
RandomNumberGeneratorEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
RandomNumberGeneratorEvaluator() - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.RandomNumberGeneratorEvaluator
randomParitionKeyGenerator - Variable in class org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream: A random number generator for cases where partition key is not available
RandomPartitioner() - Constructor for class org.apache.nifi.processors.kafka.Partitioners.RandomPartitioner
randomPort() - Static method in class org.apache.nifi.processors.grpc.TestGRPCClient: Can be used by clients to grab a random port in a range of ports
randomPort() - Static method in class org.apache.nifi.processors.grpc.TestGRPCServer: Can be used by clients to grab a random port in a range of ports
RandomShortDelayEnablingService() - Constructor for class org.apache.nifi.controller.scheduling.TestStandardProcessScheduler.RandomShortDelayEnablingService
Range(int, int) - Constructor for class org.apache.nifi.attribute.expression.language.Query.Range
Range(long, long) - Constructor for class org.apache.nifi.processor.util.put.AbstractPutEventProcessor.Range
RANGE_KEY_NAME - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
RANGE_KEY_VALUE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
RANGE_KEY_VALUE_TYPE - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
RangerBasePluginWithPolicies - Class in org.apache.nifi.ranger.authorization: Extends the base plugin to convert service policies into NiFi policy domain model.
RangerBasePluginWithPolicies(String, String) - Constructor for class org.apache.nifi.ranger.authorization.RangerBasePluginWithPolicies
RangerBasePluginWithPolicies(String, String, UserGroupProvider) - Constructor for class org.apache.nifi.ranger.authorization.RangerBasePluginWithPolicies
RangerNiFiAuthorizer - Class in org.apache.nifi.ranger.authorization: Authorizer implementation that uses Apache Ranger to make authorization decisions.
RangerNiFiAuthorizer() - Constructor for class org.apache.nifi.ranger.authorization.RangerNiFiAuthorizer
RATE_CONTROL_ATTRIBUTE_NAME - Static variable in class org.apache.nifi.processors.standard.ControlRate
RATE_CONTROL_CRITERIA - Static variable in class org.apache.nifi.processors.standard.ControlRate
RAW_KEY_HEX - Static variable in class org.apache.nifi.processors.standard.EncryptContent
RAW_VALUE - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
RawBinlogEvent - Class in org.apache.nifi.cdc.mysql.event: An object holder for raw binlog events
RawBinlogEvent(Event, String) - Constructor for class org.apache.nifi.cdc.mysql.event.RawBinlogEvent
rawMessage(byte[]) - Method in class org.apache.nifi.processors.standard.syslog.SyslogEvent.Builder
RawRecordWriter - Interface in org.apache.nifi.serialization.record
read() - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream
read(byte[]) - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream
read(byte[], int, int) - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream
read() - Method in class org.apache.nifi.cluster.protocol.impl.CopyingInputStream
read(byte[]) - Method in class org.apache.nifi.cluster.protocol.impl.CopyingInputStream
read(byte[], int, int) - Method in class org.apache.nifi.cluster.protocol.impl.CopyingInputStream
read(ContentClaim) - Method in interface org.apache.nifi.controller.repository.ContentRepository: Provides access to the input stream for the given claim
read(ContentClaim) - Method in class org.apache.nifi.controller.repository.FileSystemRepository
read() - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream
read(byte[]) - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream
read(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream
read() - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream
read(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream
read(byte[]) - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream
read() - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream
read(byte[]) - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream
read(byte[], int, int) - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream
read(FlowFile, InputStreamCallback) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
read(FlowFile, boolean, InputStreamCallback) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
read(FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
read(ContentClaim) - Method in class org.apache.nifi.controller.repository.VolatileContentRepository
read(FlowFile, InputStreamCallback) - Method in interface org.apache.nifi.processor.ProcessSession: Executes the given callback against the contents corresponding to the given FlowFile.
read(FlowFile) - Method in interface org.apache.nifi.processor.ProcessSession: Provides an InputStream that can be used to read the contents of the given FlowFile.
read(FlowFile, boolean, InputStreamCallback) - Method in interface org.apache.nifi.processor.ProcessSession: Executes the given callback against the contents corresponding to the given FlowFile.
read() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads a single byte
read(byte[], int, int) - Method in class org.apache.nifi.processors.standard.util.ValidatingBase32InputStream
read(byte[]) - Method in class org.apache.nifi.processors.standard.util.ValidatingBase32InputStream
read() - Method in class org.apache.nifi.processors.standard.util.ValidatingBase32InputStream
read(byte[], int, int) - Method in class org.apache.nifi.processors.standard.util.ValidatingBase64InputStream
read(byte[]) - Method in class org.apache.nifi.processors.standard.util.ValidatingBase64InputStream
read() - Method in class org.apache.nifi.processors.standard.util.ValidatingBase64InputStream
read(byte[]) - Method in class org.apache.nifi.provenance.LoopingInputStream
read() - Method in class org.apache.nifi.provenance.LoopingInputStream
read(byte[], int, int) - Method in class org.apache.nifi.provenance.LoopingInputStream
read(TopDocs, EventAuthorizer, IndexReader, Collection<Path>, AtomicInteger, int, int) - Method in class org.apache.nifi.provenance.lucene.DocsReader
read(List<Document>, EventAuthorizer, Collection<Path>, AtomicInteger, int, int) - Method in class org.apache.nifi.provenance.lucene.DocsReader
read() - Method in class org.apache.nifi.remote.io.CompressionInputStream
read(byte[]) - Method in class org.apache.nifi.remote.io.CompressionInputStream
read(byte[], int, int) - Method in class org.apache.nifi.remote.io.CompressionInputStream
read() - Method in class org.apache.nifi.remote.io.InterruptableInputStream
read(byte[]) - Method in class org.apache.nifi.remote.io.InterruptableInputStream
read(byte[], int, int) - Method in class org.apache.nifi.remote.io.InterruptableInputStream
read() - Method in class org.apache.nifi.remote.io.socket.SocketChannelInputStream
read(byte[]) - Method in class org.apache.nifi.remote.io.socket.SocketChannelInputStream
read(byte[], int, int) - Method in class org.apache.nifi.remote.io.socket.SocketChannelInputStream
read() - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
read(byte[]) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
read(byte[], int, int) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannel
read() - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelInputStream
read(byte[]) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelInputStream
read(byte[], int, int) - Method in class org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelInputStream
read(DataInputStream) - Static method in class org.apache.nifi.remote.protocol.Response
read() - Method in class org.apache.nifi.stream.io.ByteCountingInputStream
read(byte[], int, int) - Method in class org.apache.nifi.stream.io.ByteCountingInputStream
read(byte[]) - Method in class org.apache.nifi.stream.io.ByteCountingInputStream
read() - Method in class org.apache.nifi.stream.io.LimitingInputStream
read(byte[]) - Method in class org.apache.nifi.stream.io.LimitingInputStream
read(byte[], int, int) - Method in class org.apache.nifi.stream.io.LimitingInputStream
read() - Method in class org.apache.nifi.stream.io.MinimumLengthInputStream
read(byte[]) - Method in class org.apache.nifi.stream.io.MinimumLengthInputStream
read(byte[], int, int) - Method in class org.apache.nifi.stream.io.MinimumLengthInputStream
read() - Method in class org.apache.nifi.stream.io.NonCloseableInputStream
read(byte[]) - Method in class org.apache.nifi.stream.io.NonCloseableInputStream
read(byte[], int, int) - Method in class org.apache.nifi.stream.io.NonCloseableInputStream
read() - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream
read(byte[], int, int) - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream
read(byte[]) - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream
read() - Method in class org.apache.nifi.util.LimitingInputStream
read(byte[]) - Method in class org.apache.nifi.util.LimitingInputStream
read(byte[], int, int) - Method in class org.apache.nifi.util.LimitingInputStream
read(FlowFile, InputStreamCallback) - Method in class org.apache.nifi.util.MockProcessSession
read(FlowFile, boolean, InputStreamCallback) - Method in class org.apache.nifi.util.MockProcessSession
read(FlowFile) - Method in class org.apache.nifi.util.MockProcessSession
READ_ACL_LIST - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3Processor
READ_CLIENT_ID - Static variable in class org.apache.nifi.integration.accesscontrol.AccessControlHelper
READ_CONFIG_JSON_ARG - Static variable in class org.apache.nifi.toolkit.tls.service.BaseCertificateAuthorityCommandLine
READ_MODE - Static variable in class org.apache.nifi.processors.rethinkdb.GetRethinkDB
READ_MODE_KEY - Variable in class org.apache.nifi.processors.rethinkdb.GetRethinkDB
READ_MODE_MAJORITY - Static variable in class org.apache.nifi.processors.rethinkdb.GetRethinkDB
READ_MODE_OUTDATED - Static variable in class org.apache.nifi.processors.rethinkdb.GetRethinkDB
READ_MODE_SINGLE - Static variable in class org.apache.nifi.processors.rethinkdb.GetRethinkDB
READ_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer
READ_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiTestAuthorizer
READ_USER_LIST - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3Processor
READ_WRITE_CLIENT_ID - Static variable in class org.apache.nifi.integration.accesscontrol.AccessControlHelper
READ_WRITE_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiFlowTestAuthorizer
READ_WRITE_USER_DN - Static variable in class org.apache.nifi.integration.util.NiFiTestAuthorizer
ReadablePermission - Interface in org.apache.nifi.web.api.dto
readAndBase64EncodeBinary(int) - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads length bytes and Bas64 encodes them
readAttributes(InputStream) - Method in class org.apache.nifi.util.FlowFileUnpackagerV2
readAttributes(InputStream) - Method in class org.apache.nifi.util.FlowFileUnpackagerV3
readBytes(int) - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads the next length bytes
readBytes(byte[], int, int) - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads the next length bytes into the buf buffer at a given offset
readBytesFromInputStream(InputStream, String, int, byte[]) - Static method in class org.apache.nifi.security.util.crypto.CipherUtility
readChunkHeader() - Method in class org.apache.nifi.remote.io.CompressionInputStream
readContent(ProcessSession, FlowFile) - Method in class org.apache.nifi.processors.standard.PutUDP: Helper method to read the FlowFile content stream into a byte array.
readContents(DataPacket) - Static method in class org.apache.nifi.remote.protocol.SiteToSiteTestUtils
readDWord() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads 4 bytes in little endian order and returns the UnsignedInteger value
readDWordBE() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads 4 bytes in big endian order and returns the UnsignedInteger value
reader() - Method in class org.apache.nifi.util.console.TextDevice
readFields(DataInput) - Method in class org.apache.nifi.processors.hadoop.util.InputStreamWritable
readFields(DataInput) - Method in class org.apache.nifi.processors.hadoop.util.OutputStreamWritable
readFileTime() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads a timestamp that is the number of hundreds of nanoseconds since Jan 1 1601 (see http://integriography.wordpress.com/2010/01/16/using-phython-to-parse-and-present-windows-64-bit-timestamps/)
readFrom(InputStream) - Static method in class org.apache.nifi.repository.schema.RecordSchema
readGuid() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads an Evtx formatted guid (16 bytes arranged into the grouping described by INDEX_ARRAYS)
readHeader(DataInputStream) - Method in class org.apache.nifi.controller.repository.SchemaRepositoryRecordSerde
readHeader(DataInputStream, int) - Method in class org.apache.nifi.provenance.ByteArraySchemaRecordReader
readHeader(DataInputStream, int) - Method in class org.apache.nifi.provenance.EventIdFirstSchemaRecordReader
readHeader(DataInputStream, int) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordReader
readHeader(DataInputStream) - Method in interface org.wali.SerDe: Provides the SerDe the opportunity to read header information before deserializing any records
readIV(InputStream) - Method in class org.apache.nifi.security.util.crypto.KeyedCipherProvider
readIV(InputStream) - Method in class org.apache.nifi.security.util.crypto.RandomIVPBECipherProvider
readKeys(String, SecretKey) - Static method in class org.apache.nifi.security.kms.CryptoUtils: Returns a map containing the key IDs and the parsed key from a key provider definition file.
readLine() - Method in class org.apache.nifi.processors.standard.util.NLKBufferedReader: Reads a line of text.
readLine() - Method in class org.apache.nifi.util.console.TextDevice
readLong(InputStream) - Method in class org.apache.nifi.util.FlowFileUnpackagerV2
readLong(InputStream) - Method in class org.apache.nifi.util.FlowFileUnpackagerV3
ReadOnlyRevisionCallback<T> - Interface in org.apache.nifi.web.revision
readPassword() - Method in class org.apache.nifi.util.console.TextDevice
readQWord() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads 8 bytes in litte endian order and returns the UnsignedLong value
readRecord(InputStream, Schema) - Method in class org.apache.nifi.avro.TestWriteAvroResult
readRecord(InputStream, Schema) - Method in class org.apache.nifi.avro.TestWriteAvroResultWithoutSchema
readRecord(InputStream, Schema) - Method in class org.apache.nifi.avro.TestWriteAvroResultWithSchema
readRecord(InputStream) - Method in class org.apache.nifi.repository.schema.SchemaRecordReader
readRequestType(DataInputStream) - Static method in enum org.apache.nifi.remote.protocol.RequestType
readSalt(InputStream) - Method in class org.apache.nifi.security.util.crypto.NiFiLegacyCipherProvider: Deprecated.
readSalt(EncryptionMethod, InputStream) - Method in class org.apache.nifi.security.util.crypto.NiFiLegacyCipherProvider: Deprecated.

Returns the salt provided as part of the cipher stream, or throws an exception if one cannot be detected.
readSalt(InputStream) - Method in class org.apache.nifi.security.util.crypto.OpenSSLPKCS5CipherProvider: Returns the salt provided as part of the cipher stream, or throws an exception if one cannot be detected.
readSalt(InputStream) - Method in interface org.apache.nifi.security.util.crypto.PBECipherProvider: Returns the salt provided as part of the cipher stream, or throws an exception if one cannot be detected.
readSalt(InputStream) - Method in class org.apache.nifi.security.util.crypto.RandomIVPBECipherProvider
ReadsAttribute - Annotation Type in org.apache.nifi.annotation.behavior: Annotation that may be placed on a Processor indicating that this processor reads a specific FlowFile attribute.
ReadsAttributes - Annotation Type in org.apache.nifi.annotation.behavior: Annotation that may be placed on a Processor indicating that this processor reads specific FlowFile attributes.
readSend2StreamHuge_FileBased() - Method in class org.apache.nifi.processors.standard.util.TestJdbcHugeStream
readSequenceFile(Path, Configuration, FileSystem) - Method in class org.apache.nifi.processors.hadoop.KeyValueReader
readSequenceFile(Path, Configuration, FileSystem) - Method in interface org.apache.nifi.processors.hadoop.util.SequenceFileReader
readSequenceFile(Path, Configuration, FileSystem) - Method in class org.apache.nifi.processors.hadoop.ValueReader
readString(int) - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads a string made up of single byte characters
readString(InputStream) - Method in class org.apache.nifi.util.FlowFileUnpackagerV2
readString(InputStream) - Method in class org.apache.nifi.util.FlowFileUnpackagerV3
ReadTimeoutHandler() - Constructor for class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon.ReadTimeoutHandler
readToEvent(long, DataInputStream, int) - Method in class org.apache.nifi.provenance.EncryptedSchemaRecordReader
readToEvent(long, DataInputStream, int) - Method in class org.apache.nifi.provenance.EventIdFirstSchemaRecordReader
readToEvent(long, DataInputStream, int) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordReader
readTransactionResponse() - Method in class org.apache.nifi.remote.AbstractTransaction
readTransactionResponse(boolean, CommunicationsSession) - Method in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
readTransactionResponse() - Method in class org.apache.nifi.remote.protocol.http.HttpClientTransaction
readTransactionResponse(boolean, CommunicationsSession) - Method in class org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol
readTransactionResponse() - Method in class org.apache.nifi.remote.protocol.socket.SocketClientTransaction
readWord() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads 2 bytes in little endian order and returns the int value
readWordBE() - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads 2 bytes in big endian order and returns the int value
readWString(int) - Method in class org.apache.nifi.processors.evtx.parser.BinaryReader: Reads a string encoded with UTF_16LE of a given length
RECEIPT_HANDLE - Static variable in class org.apache.nifi.processors.aws.sqs.DeleteSQS
receive(FlowFile, String) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
receive(FlowFile, String, String) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
receive(FlowFile, String, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
receive(FlowFile, String, String, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
receive(FlowFile, String, String, String, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
receive(FlowFile, String) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type RECEIVE that indicates that the given FlowFile was created from data received from an external source.
receive(FlowFile, String, String) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type RECEIVE that indicates that the given FlowFile was created from data received from the specified URI and that the source system used the specified identifier (a URI with namespace) to refer to the data.
receive(FlowFile, String, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type RECEIVE that indicates that the given FlowFile was created from data received from an external source.
receive(FlowFile, String, String, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type RECEIVE that indicates that the given FlowFile was created from data received from an external source and provides additional details about the receipt of the FlowFile, such as a remote system's Distinguished Name.
receive(FlowFile, String, String, String, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type RECEIVE that indicates that the given FlowFile was created from data received from an external source and provides additional details about the receipt of the FlowFile, such as a remote system's Distinguished Name.
receive() - Method in class org.apache.nifi.remote.AbstractTransaction
receive() - Method in interface org.apache.nifi.remote.Transaction: Retrieves information from the remote NiFi instance, if any is available.
receive(long) - Method in interface org.apache.nifi.spring.SpringDataExchanger: Receives data from Spring
receive(FlowFile, String) - Method in class org.apache.nifi.util.MockProvenanceReporter
receive(FlowFile, String, String) - Method in class org.apache.nifi.util.MockProvenanceReporter
receive(FlowFile, String, long) - Method in class org.apache.nifi.util.MockProvenanceReporter
receive(FlowFile, String, String, long) - Method in class org.apache.nifi.util.MockProvenanceReporter
receive(FlowFile, String, String, String, long) - Method in class org.apache.nifi.util.MockProvenanceReporter
RECEIVE_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.gettcp.GetTCP
RECEIVE_MSG_WAIT_TIME - Static variable in class org.apache.nifi.processors.aws.sqs.GetSQS
RECEIVE_TIMEOUT - Static variable in class org.apache.nifi.spring.SpringContextProcessor
receiveClientProtocolNegotiation(DataInputStream, DataOutputStream) - Static method in class org.apache.nifi.remote.RemoteResourceFactory
receiveCodecNegotiation(DataInputStream, DataOutputStream) - Static method in class org.apache.nifi.remote.RemoteResourceFactory
RECEIVED_RESPONSE_CODE - Static variable in class org.apache.nifi.toolkit.tls.service.client.TlsCertificateSigningRequestPerformer
RECEIVED_THE_FOLLOWING_WIN32_ERROR - Static variable in class org.apache.nifi.processors.windows.event.log.jna.EventSubscribeXmlRenderingCallback
receiveEvents(ProcessContext, String) - Method in class org.apache.nifi.processors.azure.eventhub.GetAzureEventHub: This method is here to try and isolate the Azure related code as the PartitionReceiver cannot be mocked with PowerMock due to it being final.
receiveFiles() - Method in class org.apache.nifi.toolkit.s2s.SiteToSiteReceiver
receiveFlowFiles(Peer, ProcessContext, ProcessSession, FlowFileCodec) - Method in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
receiveFlowFiles(Peer, ProcessContext, ProcessSession, FlowFileCodec) - Method in interface org.apache.nifi.remote.protocol.ServerProtocol: Receives FlowFiles from the specified peer
receiveFlowFiles(Peer, ServerProtocol) - Method in interface org.apache.nifi.remote.RootGroupPort: Receives data from the given stream
receiveFlowFiles(Peer, ServerProtocol) - Method in class org.apache.nifi.remote.StandardRootGroupPort
receiveFlowFiles(String, String, HttpServletRequest, ServletContext, InputStream) - Method in class org.apache.nifi.web.api.DataTransferResource
receiveHandshake(InputStream, OutputStream, VersionNegotiator) - Static method in class org.apache.nifi.distributed.cache.protocol.ProtocolHandshake
receiveMessage(ProcessContext) - Method in class org.apache.nifi.processors.email.ConsumeEWS: Receives message from the internal queue filling up the queue if necessary.
receiveResourceNegotiation(Class<T>, DataInputStream, DataOutputStream, Class<?>[], Object[]) - Static method in class org.apache.nifi.remote.RemoteResourceFactory
receiveServerProtocolNegotiation(DataInputStream, DataOutputStream) - Static method in class org.apache.nifi.remote.RemoteResourceFactory
ReceivingClientTest - Class in org.apache.nifi.processors.gettcp
ReceivingClientTest() - Constructor for class org.apache.nifi.processors.gettcp.ReceivingClientTest
recipient(String) - Method in class org.apache.nifi.processors.email.smtp.SmtpConsumer
reconnect(ConsumeMQTT) - Static method in class org.apache.nifi.processors.mqtt.common.TestConsumeMqttCommon
RECONNECT_INTERVAL - Static variable in class org.apache.nifi.processors.gettcp.GetTCP
ReconnectionRequestMessage - Class in org.apache.nifi.cluster.protocol.message
ReconnectionRequestMessage() - Constructor for class org.apache.nifi.cluster.protocol.message.ReconnectionRequestMessage
ReconnectionResponseMessage - Class in org.apache.nifi.cluster.protocol.message: This message is used an "ACK" for a ReconnectionRequestMessage
ReconnectionResponseMessage() - Constructor for class org.apache.nifi.cluster.protocol.message.ReconnectionResponseMessage
RECORD - Static variable in class org.apache.nifi.processors.evtx.ParseEvtx
Record - Class in org.apache.nifi.processors.evtx.parser: Individual event, pretty much a wrapper for the RootNode
Record(BinaryReader, ChunkHeader) - Constructor for class org.apache.nifi.processors.evtx.parser.Record
Record - Interface in org.apache.nifi.repository.schema
Record - Interface in org.apache.nifi.serialization.record
RECORD_COUNT_ATTR - Static variable in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord
RECORD_COUNT_ATTR - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
RECORD_COUNT_ATTR - Static variable in class org.apache.nifi.processors.kudu.AbstractKudu
RECORD_COUNT_ATTR - Static variable in class org.apache.nifi.processors.standard.ListenUDPRecord
RECORD_COUNT_ATTRIBUTE - Static variable in class org.apache.nifi.processors.hive.ConvertAvroToORC
RECORD_ID - Static variable in class org.apache.nifi.controller.repository.schema.FlowFileSchema
RECORD_ID - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
RECORD_ID_FIELD - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
RECORD_IDENTIFIER - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
RECORD_IDENTIFIER_OFFSET - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
RECORD_NAME - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
RECORD_READER - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
RECORD_READER - Static variable in class org.apache.nifi.processors.kudu.AbstractKudu
RECORD_READER - Static variable in class org.apache.nifi.processors.standard.ListenUDPRecord
RECORD_READER - Static variable in class org.apache.nifi.processors.standard.MergeRecord
RECORD_SPLIT - Static variable in class org.apache.nifi.processors.avro.SplitAvro
RECORD_SPLIT_VALUE - Static variable in class org.apache.nifi.processors.avro.SplitAvro
RECORD_WRITER - Static variable in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord
RECORD_WRITER - Static variable in class org.apache.nifi.processors.standard.ListenUDPRecord
RECORD_WRITER - Static variable in class org.apache.nifi.processors.standard.MergeRecord
RecordBin - Class in org.apache.nifi.processors.standard.merge
RecordBin(ProcessContext, ProcessSession, ComponentLog, RecordBinThresholds) - Constructor for class org.apache.nifi.processors.standard.merge.RecordBin
RecordBinManager - Class in org.apache.nifi.processors.standard.merge
RecordBinManager(ProcessContext, ProcessSessionFactory, ComponentLog) - Constructor for class org.apache.nifi.processors.standard.merge.RecordBinManager
RecordBinThresholds - Class in org.apache.nifi.processors.standard.merge
RecordBinThresholds(int, int, long, long, long, String, String) - Constructor for class org.apache.nifi.processors.standard.merge.RecordBinThresholds
RecordDataType - Class in org.apache.nifi.serialization.record.type
RecordDataType(RecordSchema) - Constructor for class org.apache.nifi.serialization.record.type.RecordDataType
recordFactory - Variable in class org.apache.nifi.record.script.AbstractScriptedRecordFactory
RecordField - Interface in org.apache.nifi.repository.schema
RecordField - Class in org.apache.nifi.serialization.record
RecordField(String, DataType) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, boolean) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, Object) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, Object, boolean) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, Set<String>) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, Set<String>, boolean) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, Object, Set<String>) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordField(String, DataType, Object, Set<String>, boolean) - Constructor for class org.apache.nifi.serialization.record.RecordField
RecordFieldType - Enum in org.apache.nifi.serialization.record
recordGranularityLifecycleTest() - Method in class org.apache.nifi.processors.evtx.ParseEvtxTest
RecordLookupService - Interface in org.apache.nifi.lookup
recordName(String) - Method in class org.apache.nifi.processors.standard.util.JdbcCommon.AvroConversionOptions.Builder: Specify a priori record name to use if it cannot be determined from the result set.
RecordPath - Interface in org.apache.nifi.record.path
RecordPathCache - Class in org.apache.nifi.record.path.util
RecordPathCache(int) - Constructor for class org.apache.nifi.record.path.util.RecordPathCache
RecordPathCompiler - Class in org.apache.nifi.record.path.paths
RecordPathCompiler() - Constructor for class org.apache.nifi.record.path.paths.RecordPathCompiler
RecordPathEvaluationContext - Interface in org.apache.nifi.record.path
RecordPathException - Exception in org.apache.nifi.record.path.exception
RecordPathException(String) - Constructor for exception org.apache.nifi.record.path.exception.RecordPathException
RecordPathException(String, Throwable) - Constructor for exception org.apache.nifi.record.path.exception.RecordPathException
RecordPathException(Throwable) - Constructor for exception org.apache.nifi.record.path.exception.RecordPathException
RecordPathFilter - Interface in org.apache.nifi.record.path.filter
RecordPathPropertyNameValidator - Class in org.apache.nifi.record.path.validation
RecordPathPropertyNameValidator() - Constructor for class org.apache.nifi.record.path.validation.RecordPathPropertyNameValidator
RecordPathResult - Interface in org.apache.nifi.record.path
RecordPathSegment - Class in org.apache.nifi.record.path.paths
RecordPathSegment(String, RecordPathSegment, boolean) - Constructor for class org.apache.nifi.record.path.paths.RecordPathSegment
RecordPathUtils - Class in org.apache.nifi.record.path.util
RecordPathUtils() - Constructor for class org.apache.nifi.record.path.util.RecordPathUtils
RecordPathValidator - Class in org.apache.nifi.record.path.validation
RecordPathValidator() - Constructor for class org.apache.nifi.record.path.validation.RecordPathValidator
RecordReader - Interface in org.apache.nifi.provenance.serialization
RecordReader - Interface in org.apache.nifi.serialization: A RowRecordReader is responsible for parsing data and returning a record at a time in order to allow the caller to iterate over the records individually.
RecordReaderFactory - Interface in org.apache.nifi.provenance.store
RecordReaderFactory - Interface in org.apache.nifi.serialization: A Controller Service that is responsible for creating a RecordReader.
RecordReaderFactoryException - Exception in org.apache.nifi.processors.hadoop.exception: Thrown when an error is occurs while using the record reader factory to create a record reader.
RecordReaderFactoryException(String) - Constructor for exception org.apache.nifi.processors.hadoop.exception.RecordReaderFactoryException
RecordReaderFactoryException(String, Throwable) - Constructor for exception org.apache.nifi.processors.hadoop.exception.RecordReaderFactoryException
RecordReaders - Class in org.apache.nifi.provenance.serialization
RecordReaders() - Constructor for class org.apache.nifi.provenance.serialization.RecordReaders
RECORDS_PER_TXN - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
RecordSchema - Class in org.apache.nifi.repository.schema
RecordSchema(List<RecordField>) - Constructor for class org.apache.nifi.repository.schema.RecordSchema
RecordSchema(RecordField...) - Constructor for class org.apache.nifi.repository.schema.RecordSchema
RecordSchema - Interface in org.apache.nifi.serialization.record
RecordSchemaValidator - Interface in org.apache.nifi.serialization.record.validation
RecordSet - Interface in org.apache.nifi.serialization.record
RecordSetWriter - Interface in org.apache.nifi.serialization: A ResultSetWriter is responsible for writing a ResultSet to a given OutputStream.
RecordSetWriterFactory - Interface in org.apache.nifi.serialization: A Controller Service that is responsible for creating a RecordSetWriter.
RecordTest - Class in org.apache.nifi.processors.evtx.parser
RecordTest() - Constructor for class org.apache.nifi.processors.evtx.parser.RecordTest
RecordWriter - Interface in org.apache.nifi.provenance.serialization
RecordWriter - Interface in org.apache.nifi.serialization
RecordWriterFactory - Interface in org.apache.nifi.provenance.store
RecordWriterLease - Class in org.apache.nifi.provenance.store
RecordWriterLease(RecordWriter, long) - Constructor for class org.apache.nifi.provenance.store.RecordWriterLease
RecordWriterLease(RecordWriter, long, int) - Constructor for class org.apache.nifi.provenance.store.RecordWriterLease
RecordWriters - Class in org.apache.nifi.provenance.serialization
RecordWriters() - Constructor for class org.apache.nifi.provenance.serialization.RecordWriters
recoverJournalFiles() - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
recoverRecords() - Method in class org.wali.MinimalLockingWriteAheadLog
recoverRecords() - Method in interface org.wali.WriteAheadRepository: Recovers all records from the persisted state.
recoverState(ProcessContext) - Method in class org.apache.nifi.processors.standard.TailFile
recoverSwapLocations(FlowFileQueue) - Method in class org.apache.nifi.controller.FileSystemSwapManager
recoverSwapLocations(FlowFileQueue) - Method in interface org.apache.nifi.controller.repository.FlowFileSwapManager: Determines swap files that exist for the given FlowFileQueue
recoverSwappedFlowFiles() - Method in interface org.apache.nifi.controller.queue.FlowFileQueue: Reads any Swap Files that belong to this queue and returns a summary of what is swapped out.
recoverSwappedFlowFiles() - Method in class org.apache.nifi.controller.StandardFlowFileQueue
RECURSE - Static variable in class org.apache.nifi.documentation.example.DeprecatedProcessor
RECURSE - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedProcessor
RECURSE - Static variable in class org.apache.nifi.processors.standard.GetFile
RECURSE - Static variable in class org.apache.nifi.processors.standard.ListFile
RECURSE_SUBDIRS - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS
RECURSE_SUBDIRS - Static variable in class org.apache.nifi.processors.hadoop.ListHDFS
RECURSIVE - Static variable in class org.apache.nifi.processors.hadoop.DeleteHDFS
RECURSIVE_SEARCH - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
RECV_BUFFER_SIZE - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
RECV_BUFFER_SIZE - Static variable in class org.apache.nifi.processors.standard.ListenSyslog
REDIRECT_COOKIE_POLICY - Static variable in class org.apache.nifi.processors.standard.GetHTTP
REDIRECT_ERROR_STREAM - Static variable in class org.apache.nifi.processors.standard.ExecuteProcess
RedirectResourceFilter - Class in org.apache.nifi.web.api.filter: This filter provides backward compatibility for Resource URI changes.
RedirectResourceFilter() - Constructor for class org.apache.nifi.web.api.filter.RedirectResourceFilter
REDIS_CONNECTION_POOL - Static variable in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
REDIS_CONNECTION_PROPERTY_DESCRIPTORS - Static variable in class org.apache.nifi.redis.util.RedisUtils
REDIS_MODE - Static variable in class org.apache.nifi.redis.util.RedisUtils
REDIS_MODE_CLUSTER - Static variable in class org.apache.nifi.redis.util.RedisUtils
REDIS_MODE_SENTINEL - Static variable in class org.apache.nifi.redis.util.RedisUtils
REDIS_MODE_STANDALONE - Static variable in class org.apache.nifi.redis.util.RedisUtils
REDIS_SERVICE - Static variable in class org.apache.nifi.redis.service.FakeRedisProcessor
RedisAction<T> - Interface in org.apache.nifi.redis.util: An action to be executed with a RedisConnection.
RedisConnectionPool - Interface in org.apache.nifi.redis: A service that provides connections to Redis using spring-data-redis.
RedisConnectionPoolService - Class in org.apache.nifi.redis.service
RedisConnectionPoolService() - Constructor for class org.apache.nifi.redis.service.RedisConnectionPoolService
RedisDistributedMapCacheClientService - Class in org.apache.nifi.redis.service
RedisDistributedMapCacheClientService() - Constructor for class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
RedisStateMap - Class in org.apache.nifi.redis.state: A StateMap implementation for RedisStateProvider.
RedisStateMap.Builder - Class in org.apache.nifi.redis.state
RedisStateMapJsonSerDe - Class in org.apache.nifi.redis.state: A RedisStateMapSerDe that uses JSON as the underlying representation.
RedisStateMapJsonSerDe() - Constructor for class org.apache.nifi.redis.state.RedisStateMapJsonSerDe
RedisStateMapSerDe - Interface in org.apache.nifi.redis.state: Provides serialization/deserialization of a RedisStateMap.
RedisStateProvider - Class in org.apache.nifi.redis.state: A StateProvider backed by Redis.
RedisStateProvider() - Constructor for class org.apache.nifi.redis.state.RedisStateProvider
RedisType - Enum in org.apache.nifi.redis: Possible types of Redis instances.
RedisUtils - Class in org.apache.nifi.redis.util
RedisUtils() - Constructor for class org.apache.nifi.redis.util.RedisUtils
reduce(List<T>) - Method in interface org.apache.nifi.controller.status.history.ValueReducer
ReduceEvaluator<T> - Interface in org.apache.nifi.attribute.expression.language.evaluation.reduce
ReferralStrategy - Enum in org.apache.nifi.ldap
ReflectionUtils - Class in org.apache.nifi.init: This class is a copy of org.apache.nifi.util.ReflectionUtils.
ReflectionUtils() - Constructor for class org.apache.nifi.init.ReflectionUtils
ReflectionUtils - Class in org.apache.nifi.util
ReflectionUtils() - Constructor for class org.apache.nifi.util.ReflectionUtils
ReflectionUtilsTest - Class in org.apache.nifi.util
ReflectionUtilsTest() - Constructor for class org.apache.nifi.util.ReflectionUtilsTest
ReflectionUtilsTest.A<T> - Class in org.apache.nifi.util
ReflectionUtilsTest.B - Class in org.apache.nifi.util
ReflectionUtilsTest.C - Class in org.apache.nifi.util
ReflectionUtilsTest.D - Class in org.apache.nifi.util
ReflectionUtilsTest.E - Class in org.apache.nifi.util
ReflectionUtilsTest.F - Class in org.apache.nifi.util
ReflexiveProtocolHandler - Class in org.apache.nifi.cluster.protocol.impl.testutils
ReflexiveProtocolHandler() - Constructor for class org.apache.nifi.cluster.protocol.impl.testutils.ReflexiveProtocolHandler
REFRESH_INTERVAL - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
refreshFlowContents() - Method in interface org.apache.nifi.groups.RemoteProcessGroup
refreshFlowContents() - Method in class org.apache.nifi.remote.StandardRemoteProcessGroup
refreshPeers() - Method in class org.apache.nifi.remote.client.PeerSelector
refreshProperties() - Method in class org.apache.nifi.controller.AbstractConfiguredComponent
refreshProperties() - Method in interface org.apache.nifi.controller.ConfiguredComponent
REGEX - Static variable in class org.apache.nifi.processors.enrich.AbstractEnrichProcessor
REGEX - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping
regexReplaceValue - Static variable in class org.apache.nifi.processors.standard.ReplaceText
REGION - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
region - Variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
REGION - Static variable in class org.apache.nifi.processors.aws.dynamodb.ITAbstractDynamoDBTest
REGION - Static variable in class org.apache.nifi.processors.aws.s3.AbstractS3IT
register(String, LeaderElectionStateChangeListener) - Method in class org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager
register(String, LeaderElectionStateChangeListener, String) - Method in class org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager
register(String, LeaderElectionStateChangeListener) - Method in interface org.apache.nifi.controller.leader.election.LeaderElectionManager: Adds a new role for which a leader is required, without participating in the leader election.
register(String, LeaderElectionStateChangeListener, String) - Method in interface org.apache.nifi.controller.leader.election.LeaderElectionManager: Adds a new role for which a leader is required, providing the given value for this node as the Participant ID.
register(String, LeaderElectionStateChangeListener) - Method in class org.apache.nifi.controller.leader.election.StandaloneLeaderElectionManager
register(String, LeaderElectionStateChangeListener, String) - Method in class org.apache.nifi.controller.leader.election.StandaloneLeaderElectionManager
register(String, HttpServletRequest, HttpServletResponse, AsyncContext) - Method in interface org.apache.nifi.http.HttpContextMap: Registers an HttpServletRequest, HttpServletResponse, and the AsyncContext for a given identifier
register(String, HttpServletRequest, HttpServletResponse, AsyncContext) - Method in class org.apache.nifi.http.StandardHttpContextMap
register(RelOptPlanner) - Method in class org.apache.nifi.queryrecord.FlowFileTableScan
registerEvent(Connectable) - Method in interface org.apache.nifi.controller.ProcessScheduler: Registers a relevant event for an Event-Driven worker
registerEvent(Connectable) - Method in class org.apache.nifi.controller.scheduling.StandardProcessScheduler
registerEvent(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.MockProvenanceRepository
registerEvent(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
registerEvent(ProvenanceEventRecord) - Method in interface org.apache.nifi.provenance.ProvenanceEventRepository: Adds the given event to the repository and returns a new event for which the event id has been populated.
registerEvent(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.VolatileProvenanceRepository
registerEvent(ProvenanceEventRecord) - Method in class org.apache.nifi.provenance.WriteAheadProvenanceRepository
registerEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.MockProvenanceRepository
registerEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
registerEvents(Iterable<ProvenanceEventRecord>) - Method in interface org.apache.nifi.provenance.ProvenanceEventRepository: Adds the given events to the repository.
registerEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.VolatileProvenanceRepository
registerEvents(Iterable<ProvenanceEventRecord>) - Method in class org.apache.nifi.provenance.WriteAheadProvenanceRepository
registerNotificationService(NotificationType, String) - Method in class org.apache.nifi.bootstrap.NotificationServiceManager: Registers the service that has the given identifier to respond to notifications of the given type
registerProcessor(String, Processor) - Method in class org.apache.nifi.websocket.AbstractWebSocketService
registerProcessor(Processor) - Method in class org.apache.nifi.websocket.WebSocketMessageRouter
registerProcessor(String, Processor) - Method in class org.apache.nifi.websocket.WebSocketMessageRouters
registerProcessor(String, Processor) - Method in interface org.apache.nifi.websocket.WebSocketService
registerProcessorToService(ProcessContext, AbstractWebSocketGatewayProcessor.WebSocketFunction) - Method in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
REGULAR_EXPRESSION_VALIDATOR - Static variable in class org.apache.nifi.processor.util.StandardValidators
reindexEvents(Map<ProvenanceEventRecord, StorageSummary>) - Method in interface org.apache.nifi.provenance.index.EventIndex: Replaces the entries in the appropriate index with the given events
reindexEvents(Map<ProvenanceEventRecord, StorageSummary>) - Method in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex
reindexLatestEvents(EventIndex) - Method in class org.apache.nifi.provenance.store.ArrayListEventStore
reindexLatestEvents(EventIndex) - Method in interface org.apache.nifi.provenance.store.EventStore: Causes the latest events in this store to be re-indexed by the given Event Index
reindexLatestEvents(EventIndex) - Method in class org.apache.nifi.provenance.store.PartitionedWriteAheadEventStore
reinitialize(boolean) - Method in interface org.apache.nifi.groups.RemoteProcessGroup: Initiates a task in the remote process group to re-initialize, as a result of clustering changes
reinitialize(boolean) - Method in class org.apache.nifi.remote.StandardRemoteProcessGroup
REJECT_ZERO_BYTE - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
rejectCodecNegotiation(DataInputStream, DataOutputStream, String) - Static method in class org.apache.nifi.remote.RemoteResourceFactory
REL_ACTIVITY_RESTORED - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
REL_ATTACHMENTS - Static variable in class org.apache.nifi.processors.email.ExtractEmailAttachments
REL_ATTACHMENTS - Static variable in class org.apache.nifi.processors.email.ExtractTNEFAttachments
REL_COMMS_FAILURE - Static variable in class org.apache.nifi.processors.yandex.YandexTranslate
REL_CONNECTED - Static variable in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
REL_CONNECTION_FAILURE - Static variable in class org.apache.nifi.processors.solr.PutSolrContentStream
REL_DUPLICATE - Static variable in class org.apache.nifi.processors.standard.DetectDuplicate
REL_EXPIRED - Static variable in class org.apache.nifi.processors.standard.Wait
REL_FAILED_SET_STATE - Static variable in class org.apache.nifi.processors.attributes.UpdateAttribute
REL_FAILED_SET_STATE - Static variable in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
REL_FAILURE - Static variable in class org.apache.nifi.amqp.processors.PublishAMQP
REL_FAILURE - Static variable in class org.apache.nifi.documentation.example.DeprecatedProcessor
REL_FAILURE - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedProcessor
REL_FAILURE - Static variable in class org.apache.nifi.hbase.AbstractPutHBase
REL_FAILURE - Static variable in class org.apache.nifi.jms.processors.PublishJMS
REL_FAILURE - Static variable in class org.apache.nifi.processor.util.bin.BinFiles
REL_FAILURE - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
REL_FAILURE - Static variable in class org.apache.nifi.processors.avro.SplitAvro
REL_FAILURE - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
REL_FAILURE - Static variable in class org.apache.nifi.processors.azure.AbstractAzureProcessor
REL_FAILURE - Static variable in class org.apache.nifi.processors.cassandra.PutCassandraQL
REL_FAILURE - Static variable in class org.apache.nifi.processors.cassandra.QueryCassandra
REL_FAILURE - Static variable in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes: REL_FAILURE - Value to be returned in case the processor fails
REL_FAILURE - Static variable in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
REL_FAILURE - Static variable in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash
REL_FAILURE - Static variable in class org.apache.nifi.processors.cybersecurity.FuzzyHashContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch5
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp
REL_FAILURE - Static variable in class org.apache.nifi.processors.elasticsearch.ScrollElasticsearchHttp
REL_FAILURE - Static variable in class org.apache.nifi.processors.email.ExtractEmailAttachments
REL_FAILURE - Static variable in class org.apache.nifi.processors.email.ExtractEmailHeaders
REL_FAILURE - Static variable in class org.apache.nifi.processors.email.ExtractTNEFAttachments
REL_FAILURE - Static variable in class org.apache.nifi.processors.gcp.storage.AbstractGCSProcessor
REL_FAILURE - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
REL_FAILURE - Static variable in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord
REL_FAILURE - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
REL_FAILURE - Static variable in class org.apache.nifi.processors.hadoop.DeleteHDFS
REL_FAILURE - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
REL_FAILURE - Static variable in class org.apache.nifi.processors.hive.PutHiveQL
REL_FAILURE - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
REL_FAILURE - Static variable in class org.apache.nifi.processors.hive.SelectHiveQL
REL_FAILURE - Static variable in class org.apache.nifi.processors.hl7.ExtractHL7Attributes
REL_FAILURE - Static variable in class org.apache.nifi.processors.ignite.AbstractIgniteProcessor: Failure relation
REL_FAILURE - Static variable in class org.apache.nifi.processors.kafka.PutKafka
REL_FAILURE - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
REL_FAILURE - Static variable in class org.apache.nifi.processors.kudu.AbstractKudu
REL_FAILURE - Static variable in class org.apache.nifi.processors.mqtt.PublishMQTT
REL_FAILURE - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
REL_FAILURE - Static variable in class org.apache.nifi.processors.script.ExecuteScript
REL_FAILURE - Static variable in class org.apache.nifi.processors.slack.PutSlack
REL_FAILURE - Static variable in class org.apache.nifi.processors.solr.PutSolrContentStream
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.Base64EncodeContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.CompressContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.ControlRate
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.DetectDuplicate
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.EncodeContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.EncryptContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.ExecuteSQL
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.GenerateTableFetch
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.HandleHttpResponse
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.HashAttribute
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.HashContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.LookupAttribute
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.MergeRecord
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.Notify
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PostHTTP
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PutDistributedMapCache
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PutEmail
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PutFile
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PutFileTransfer
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PutJMS: Deprecated.
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.PutSyslog
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.QueryRecord
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.ReplaceText
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.SplitJson
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.SplitText
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.SplitXml
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.TransformXml
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.UnpackContent
REL_FAILURE - Static variable in class org.apache.nifi.processors.standard.Wait
REL_FAILURE - Static variable in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
REL_FAILURE - Static variable in class org.apache.nifi.processors.websocket.PutWebSocket
REL_FAILURE - Static variable in class org.apache.nifi.processors.WriteResourceToStream
REL_FAILURE - Static variable in class org.apache.nifi.script.ScriptingComponentUtils: A relationship indicating an error while processing flow files
REL_FAILURE - Static variable in class org.apache.nifi.snmp.processors.GetSNMP: relationship for failure
REL_FAILURE - Static variable in class org.apache.nifi.snmp.processors.SetSNMP: relationship for failure
REL_FAILURE - Static variable in class org.apache.nifi.spring.SpringContextProcessor
REL_FOUND - Static variable in class org.apache.nifi.processors.AbstractEnrichIP
REL_FOUND - Static variable in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash
REL_FOUND - Static variable in class org.apache.nifi.processors.enrich.AbstractEnrichProcessor
REL_INACTIVE - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
REL_INVALID - Static variable in class org.apache.nifi.processors.standard.ListenSyslog
REL_INVALID - Static variable in class org.apache.nifi.processors.standard.PutSyslog
REL_INVALID - Static variable in class org.apache.nifi.processors.standard.ValidateCsv
REL_INVALID - Static variable in class org.apache.nifi.processors.standard.ValidateXml
REL_INVALID_HTML - Static variable in class org.apache.nifi.AbstractHTMLProcessor
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.ExtractGrok
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.ExtractText
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteText
REL_MATCH - Static variable in class org.apache.nifi.processors.standard.ScanContent
REL_MATCHED - Static variable in class org.apache.nifi.processors.standard.LookupAttribute
REL_MATCHED - Static variable in class org.apache.nifi.processors.standard.ScanAttribute
REL_MERGED - Static variable in class org.apache.nifi.processors.standard.MergeContent
REL_MERGED - Static variable in class org.apache.nifi.processors.standard.MergeRecord
REL_MESSAGE - Static variable in class org.apache.nifi.processors.mqtt.ConsumeMQTT
REL_MESSAGE_BINARY - Static variable in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
REL_MESSAGE_TEXT - Static variable in class org.apache.nifi.processors.websocket.AbstractWebSocketGatewayProcessor
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.EvaluateXQuery
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.ExtractGrok
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.ExtractText
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteOnContent
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteText
REL_NO_MATCH - Static variable in class org.apache.nifi.processors.standard.ScanContent
REL_NO_RETRY - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
REL_NO_RETRY - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REL_NON_DUPLICATE - Static variable in class org.apache.nifi.processors.standard.DetectDuplicate
REL_NOT_FOUND - Static variable in class org.apache.nifi.AbstractHTMLProcessor
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.AbstractEnrichIP
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.aws.dynamodb.GetDynamoDB
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.cybersecurity.CompareFuzzyHash
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch5
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.enrich.AbstractEnrichProcessor
REL_NOT_FOUND - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
REL_ORIGINAL - Static variable in class org.apache.nifi.AbstractHTMLProcessor
REL_ORIGINAL - Static variable in class org.apache.nifi.processor.util.bin.BinFiles
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.avro.SplitAvro
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.email.ExtractEmailAttachments
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.email.ExtractTNEFAttachments
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.MergeRecord
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.QueryRecord
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.RouteText
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.SegmentContent
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.SplitContent
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.SplitJson
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.SplitText
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.SplitXml
REL_ORIGINAL - Static variable in class org.apache.nifi.processors.standard.UnpackContent
REL_OVERTOOK - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
REL_PARSE_FAILURE - Static variable in class org.apache.nifi.processors.standard.ListenUDPRecord
REL_PARTIAL - Static variable in class org.apache.nifi.processors.gettcp.GetTCP
REL_REJECT - Static variable in class org.apache.nifi.processors.standard.PutFileTransfer
REL_RESPONSE - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
REL_RESPONSE - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REL_RETRY - Static variable in class org.apache.nifi.processors.cassandra.PutCassandraQL
REL_RETRY - Static variable in class org.apache.nifi.processors.cassandra.QueryCassandra
REL_RETRY - Static variable in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch5
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord
REL_RETRY - Static variable in class org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp
REL_RETRY - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
REL_RETRY - Static variable in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord
REL_RETRY - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
REL_RETRY - Static variable in class org.apache.nifi.processors.hive.PutHiveQL
REL_RETRY - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
REL_RETRY - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REL_SEGMENTS - Static variable in class org.apache.nifi.processors.standard.SegmentContent
REL_SKIPPED - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
REL_SPLIT - Static variable in class org.apache.nifi.processors.avro.SplitAvro
REL_SPLIT - Static variable in class org.apache.nifi.processors.standard.SplitJson
REL_SPLIT - Static variable in class org.apache.nifi.processors.standard.SplitXml
REL_SPLITS - Static variable in class org.apache.nifi.processors.standard.SplitContent
REL_SPLITS - Static variable in class org.apache.nifi.processors.standard.SplitText
REL_SUCCESS - Static variable in class org.apache.nifi.AbstractHTMLProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.amqp.processors.ConsumeAMQP
REL_SUCCESS - Static variable in class org.apache.nifi.amqp.processors.PublishAMQP
REL_SUCCESS - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
REL_SUCCESS - Static variable in class org.apache.nifi.documentation.example.DeprecatedProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.documentation.example.FullyDocumentedProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.hbase.AbstractPutHBase
REL_SUCCESS - Static variable in class org.apache.nifi.jms.processors.ConsumeJMS
REL_SUCCESS - Static variable in class org.apache.nifi.jms.processors.PublishJMS
REL_SUCCESS - Static variable in class org.apache.nifi.processor.util.list.AbstractListProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processors.attributes.UpdateAttribute
REL_SUCCESS - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
REL_SUCCESS - Static variable in class org.apache.nifi.processors.azure.AbstractAzureProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processors.cassandra.PutCassandraQL
REL_SUCCESS - Static variable in class org.apache.nifi.processors.cassandra.QueryCassandra
REL_SUCCESS - Static variable in class org.apache.nifi.processors.ccda.ExtractCCDAAttributes: REL_SUCCESS - Value to be returned in case the processor succeeds
REL_SUCCESS - Static variable in class org.apache.nifi.processors.couchbase.AbstractCouchbaseProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processors.cybersecurity.FuzzyHashContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearch5
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp
REL_SUCCESS - Static variable in class org.apache.nifi.processors.elasticsearch.ScrollElasticsearchHttp
REL_SUCCESS - Static variable in class org.apache.nifi.processors.email.ExtractEmailHeaders
REL_SUCCESS - Static variable in class org.apache.nifi.processors.email.ListenSMTP
REL_SUCCESS - Static variable in class org.apache.nifi.processors.gcp.storage.AbstractGCSProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processors.gettcp.GetTCP
REL_SUCCESS - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.AbstractFetchHDFSRecord
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.DeleteHDFS
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.GetHDFS
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.ListHDFS
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hive.PutHiveQL
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hive.SelectHiveQL
REL_SUCCESS - Static variable in class org.apache.nifi.processors.hl7.ExtractHL7Attributes
REL_SUCCESS - Static variable in class org.apache.nifi.processors.ignite.AbstractIgniteProcessor: Success relation
REL_SUCCESS - Static variable in class org.apache.nifi.processors.kafka.GetKafka
REL_SUCCESS - Static variable in class org.apache.nifi.processors.kafka.PutKafka
REL_SUCCESS - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
REL_SUCCESS - Static variable in class org.apache.nifi.processors.kudu.AbstractKudu
REL_SUCCESS - Static variable in class org.apache.nifi.processors.mqtt.PublishMQTT
REL_SUCCESS - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
REL_SUCCESS - Static variable in class org.apache.nifi.processors.script.ExecuteScript
REL_SUCCESS - Static variable in class org.apache.nifi.processors.slack.PutSlack
REL_SUCCESS - Static variable in class org.apache.nifi.processors.solr.GetSolr
REL_SUCCESS - Static variable in class org.apache.nifi.processors.solr.PutSolrContentStream
REL_SUCCESS - Static variable in class org.apache.nifi.processors.splunk.GetSplunk
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.AttributesToJSON
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.Base64EncodeContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.CompressContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ControlRate
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ConvertCharacterSet
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.EncodeContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.EncryptContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ExecuteProcess
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ExecuteSQL
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.FetchDistributedMapCache
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.FetchFileTransfer
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.GetFile
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.GetFileTransfer
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.GetHTTP
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.HandleHttpRequest
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.HandleHttpResponse
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.HashAttribute
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.HashContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.IdentifyMimeType
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.JmsConsumer
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ListDatabaseTables
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ListenSyslog
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.LogAttribute
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.LogMessage
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ModifyBytes
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.Notify
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PostHTTP
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutDatabaseRecord
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutDistributedMapCache
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutEmail
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutFile
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutFileTransfer
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutJMS: Deprecated.
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.PutSyslog
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ReplaceText
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ReplaceTextWithMapping
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.TransformXml
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.UnpackContent
REL_SUCCESS - Static variable in class org.apache.nifi.processors.standard.Wait
REL_SUCCESS - Static variable in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
REL_SUCCESS - Static variable in class org.apache.nifi.processors.twitter.GetTwitter
REL_SUCCESS - Static variable in class org.apache.nifi.processors.websocket.PutWebSocket
REL_SUCCESS - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
REL_SUCCESS - Static variable in class org.apache.nifi.processors.WriteResourceToStream
REL_SUCCESS - Static variable in class org.apache.nifi.processors.yandex.YandexTranslate
REL_SUCCESS - Static variable in class org.apache.nifi.script.ScriptingComponentUtils: A relationship indicating flow files were processed successfully
REL_SUCCESS - Static variable in class org.apache.nifi.snmp.processors.GetSNMP: relationship for success
REL_SUCCESS - Static variable in class org.apache.nifi.snmp.processors.SetSNMP: relationship for success
REL_SUCCESS - Static variable in class org.apache.nifi.spring.SpringContextProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.test.processors.DataGeneratorTestProcessor
REL_SUCCESS - Static variable in class org.apache.nifi.test.processors.StubAttributeLoggerProcessor
REL_SUCCESS_REQ - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
REL_SUCCESS_REQ - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REL_TRANSLATION_FAILED - Static variable in class org.apache.nifi.processors.yandex.YandexTranslate
REL_UNMATCHED - Static variable in class org.apache.nifi.processors.standard.LookupAttribute
REL_UNMATCHED - Static variable in class org.apache.nifi.processors.standard.ScanAttribute
REL_UNPROCESSED - Static variable in class org.apache.nifi.processors.aws.dynamodb.AbstractDynamoDBProcessor
REL_UNSUPPORTED_CONTENT - Static variable in class org.apache.nifi.processors.kite.InferAvroSchema
REL_VALID - Static variable in class org.apache.nifi.processors.standard.ValidateCsv
REL_VALID - Static variable in class org.apache.nifi.processors.standard.ValidateXml
REL_WAIT - Static variable in class org.apache.nifi.processors.standard.EnforceOrder
REL_WAIT - Static variable in class org.apache.nifi.processors.standard.Wait
Relationship - Class in org.apache.nifi.processor: An immutable object for holding information about a type of relationship.
Relationship(Relationship.Builder) - Constructor for class org.apache.nifi.processor.Relationship
RELATIONSHIP - Static variable in class org.apache.nifi.provenance.schema.EventFieldNames
RELATIONSHIP - Static variable in class org.apache.nifi.provenance.schema.EventRecordFields
RELATIONSHIP - Static variable in class org.apache.nifi.provenance.schema.LookupTableEventRecordFields
Relationship - Static variable in class org.apache.nifi.provenance.SearchableFields
Relationship.Builder - Class in org.apache.nifi.processor
RELATIONSHIP_FAILURE - Static variable in class org.apache.nifi.processors.hadoop.CreateHadoopSequenceFile
RELATIONSHIP_SUCCESS - Static variable in class org.apache.nifi.processors.hadoop.CreateHadoopSequenceFile
RELATIONSHIP_SUCCESS - Static variable in class org.apache.nifi.processors.standard.ListenHTTP
RelationshipAuditor - Class in org.apache.nifi.audit: Audits relationship creation/removal.
RelationshipAuditor() - Constructor for class org.apache.nifi.audit.RelationshipAuditor
RelationshipDTO - Class in org.apache.nifi.web.api.dto: Details of a relationship.
RelationshipDTO() - Constructor for class org.apache.nifi.web.api.dto.RelationshipDTO
relationships - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
relationships(Collection<Relationship>) - Method in class org.apache.nifi.connectable.StandardConnection.Builder
relationships - Variable in class org.apache.nifi.processor.util.listen.AbstractListenEventProcessor
relationships - Static variable in class org.apache.nifi.processors.aws.AbstractAWSProcessor: Deprecated.
relationships - Static variable in class org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric
relationships - Static variable in class org.apache.nifi.processors.aws.s3.ListS3
RELATIONSHIPS - Variable in class org.apache.nifi.processors.email.ConsumeEWS
relationships - Static variable in class org.apache.nifi.processors.gcp.storage.AbstractGCSProcessor
relationships - Static variable in class org.apache.nifi.processors.gcp.storage.ListGCSBucket
RELATIONSHIPS - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
RELATIONSHIPS - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
relationships - Static variable in class org.apache.nifi.processors.ignite.cache.AbstractIgniteCacheProcessor: Relations
relationships - Static variable in class org.apache.nifi.processors.slack.PutSlack
relationships - Variable in class org.apache.nifi.processors.standard.AbstractDatabaseFetchProcessor
RELATIONSHIPS - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
relationships - Static variable in class org.apache.nifi.processors.standard.PutDatabaseRecord
RELATIONSHIPS - Static variable in class org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog
RELEASABLE_FLOWFILE_COUNT - Static variable in class org.apache.nifi.processors.standard.Wait
RELEASE_SIGNAL_IDENTIFIER - Static variable in class org.apache.nifi.processors.standard.Notify
RELEASE_SIGNAL_IDENTIFIER - Static variable in class org.apache.nifi.processors.standard.Wait
releaseCandidates(String, long, int, List<E>, Consumer<List<E>>, Consumer<List<E>>) - Method in class org.apache.nifi.processors.standard.WaitNotifyProtocol.Signal: Consume accumulated notification signals to let some waiting candidates get released.
releaseQuietly(FileLock) - Static method in class org.apache.nifi.util.file.FileUtils: Releases the given lock quietly no logging, no exception
releaseReadLock(File) - Method in class org.apache.nifi.provenance.store.EventFileManager
releaseWriteLock(File) - Method in class org.apache.nifi.provenance.store.EventFileManager
relinquishClaim() - Method in class org.apache.nifi.provenance.store.RecordWriterLease
relinquishSender(ChannelSender) - Method in class org.apache.nifi.processor.util.put.AbstractPutEventProcessor: Helper method to relinquish the ChannelSender back to the pool.
reload(Set<URL>) - Method in interface org.apache.nifi.controller.ConfiguredComponent
reload(ProcessorNode, String, BundleCoordinate, Set<URL>) - Method in class org.apache.nifi.controller.FlowController
reload(ReportingTaskNode, String, BundleCoordinate, Set<URL>) - Method in class org.apache.nifi.controller.FlowController
reload(ControllerServiceNode, String, BundleCoordinate, Set<URL>) - Method in class org.apache.nifi.controller.FlowController
reload(ProcessorNode, String, BundleCoordinate, Set<URL>) - Method in interface org.apache.nifi.controller.ReloadComponent: Changes the underlying Processor held by the node to an instance of the new type.
reload(ControllerServiceNode, String, BundleCoordinate, Set<URL>) - Method in interface org.apache.nifi.controller.ReloadComponent: Changes the underlying ControllerService held by the node to an instance of the new type.
reload(ReportingTaskNode, String, BundleCoordinate, Set<URL>) - Method in interface org.apache.nifi.controller.ReloadComponent: Changes the underlying ReportingTask held by the node to an instance of the new type.
reload(Set<URL>) - Method in class org.apache.nifi.controller.reporting.AbstractReportingTaskNode
reload(Set<URL>) - Method in class org.apache.nifi.controller.service.StandardControllerServiceNode
reload(Set<URL>) - Method in class org.apache.nifi.controller.StandardProcessorNode
ReloadComponent - Interface in org.apache.nifi.controller: A service used to change the type of an underlying component.
reloadScript(String) - Method in class org.apache.nifi.lookup.script.ScriptedLookupService: Reloads the script RecordReaderFactory.
reloadScript(String) - Method in class org.apache.nifi.record.script.ScriptedReader: Reloads the script RecordReaderFactory.
reloadScript(String) - Method in class org.apache.nifi.record.script.ScriptedRecordSetWriter: Reloads the script RecordSetWriterFactory.
reloadScript(String) - Method in class org.apache.nifi.script.AbstractScriptedControllerService
reloadScriptBody(String) - Method in class org.apache.nifi.script.AbstractScriptedControllerService: Reloads the script defined by the given string
reloadScriptFile(String) - Method in class org.apache.nifi.script.AbstractScriptedControllerService: Reloads the script located at the given path
RELPChannelResponse - Class in org.apache.nifi.processors.standard.relp.response: Creates a RELPFrame for the provided response and returns the encoded frame.
RELPChannelResponse(RELPEncoder, RELPResponse) - Constructor for class org.apache.nifi.processors.standard.relp.response.RELPChannelResponse
RELPDecoder - Class in org.apache.nifi.processors.standard.relp.frame: Decodes a RELP frame by maintaining a state based on each byte that has been processed.
RELPDecoder(Charset) - Constructor for class org.apache.nifi.processors.standard.relp.frame.RELPDecoder
RELPDecoder(Charset, ByteArrayOutputStream) - Constructor for class org.apache.nifi.processors.standard.relp.frame.RELPDecoder
RELPEncoder - Class in org.apache.nifi.processors.standard.relp.frame: Encodes a RELPFrame into raw bytes using the given charset.
RELPEncoder(Charset) - Constructor for class org.apache.nifi.processors.standard.relp.frame.RELPEncoder
RELPEvent - Class in org.apache.nifi.processors.standard.relp.event: A RELP event which adds the transaction number and command to the StandardEvent.
RELPEvent(String, byte[], ChannelResponder<SocketChannel>, long, String) - Constructor for class org.apache.nifi.processors.standard.relp.event.RELPEvent
RELPEventFactory - Class in org.apache.nifi.processors.standard.relp.event: An EventFactory implementation to create RELPEvents.
RELPEventFactory() - Constructor for class org.apache.nifi.processors.standard.relp.event.RELPEventFactory
RELPFrame - Class in org.apache.nifi.processors.standard.relp.frame: A RELP frame received from a channel.
RELPFrame.Builder - Class in org.apache.nifi.processors.standard.relp.frame: Builder for a RELPFrame.
RELPFrameException - Exception in org.apache.nifi.processors.standard.relp.frame: Represents an error encountered when decoding RELP frames.
RELPFrameException(String) - Constructor for exception org.apache.nifi.processors.standard.relp.frame.RELPFrameException
RELPFrameException(String, Throwable) - Constructor for exception org.apache.nifi.processors.standard.relp.frame.RELPFrameException
RELPFrameHandler<E extends Event<java.nio.channels.SocketChannel>> - Class in org.apache.nifi.processors.standard.relp.handler: Encapsulates the logic to handle a RELPFrame once it has been read from the channel.
RELPFrameHandler(SelectionKey, Charset, EventFactory<E>, BlockingQueue<E>, AsyncChannelDispatcher, ComponentLog) - Constructor for class org.apache.nifi.processors.standard.relp.handler.RELPFrameHandler
RELPFrameProducer - Class in org.apache.nifi.processors.standard.relp
RELPFrameProducer() - Constructor for class org.apache.nifi.processors.standard.relp.RELPFrameProducer
RELPMetadata - Interface in org.apache.nifi.processors.standard.relp.event: Metadata keys for RELP.
RELPResponse - Class in org.apache.nifi.processors.standard.relp.response: The data portion of a RELPFrame for a response: RSP-CODE [SP HUMANMSG] LF [CMDDATA]
RELPResponse(long, int) - Constructor for class org.apache.nifi.processors.standard.relp.response.RELPResponse
RELPResponse(long, int, String, String) - Constructor for class org.apache.nifi.processors.standard.relp.response.RELPResponse
RELPSocketChannelHandler<E extends Event<java.nio.channels.SocketChannel>> - Class in org.apache.nifi.processors.standard.relp.handler: Extends the StandardSocketChannelHandler to decode bytes into RELP frames.
RELPSocketChannelHandler(SelectionKey, AsyncChannelDispatcher, Charset, EventFactory<E>, BlockingQueue<E>, ComponentLog) - Constructor for class org.apache.nifi.processors.standard.relp.handler.RELPSocketChannelHandler
RELPSocketChannelHandlerFactory<E extends Event<java.nio.channels.SocketChannel>> - Class in org.apache.nifi.processors.standard.relp.handler: Default factory for creating RELP socket channel handlers.
RELPSocketChannelHandlerFactory() - Constructor for class org.apache.nifi.processors.standard.relp.handler.RELPSocketChannelHandlerFactory
RELPSSLSocketChannelHandler<E extends Event<java.nio.channels.SocketChannel>> - Class in org.apache.nifi.processors.standard.relp.handler: A RELP implementation of SSLSocketChannelHandler.
RELPSSLSocketChannelHandler(SelectionKey, AsyncChannelDispatcher, Charset, EventFactory<E>, BlockingQueue<E>, ComponentLog) - Constructor for class org.apache.nifi.processors.standard.relp.handler.RELPSSLSocketChannelHandler
RELPState - Enum in org.apache.nifi.processors.standard.relp.frame: The parts of a RELP frame.
REMOTE_DN - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REMOTE_DN_KEY - Static variable in class org.apache.nifi.processors.grpc.FlowFileIngestServiceInterceptor
REMOTE_FILENAME - Static variable in class org.apache.nifi.processors.standard.FetchFileTransfer
REMOTE_GROUP - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
REMOTE_GROUP - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
REMOTE_GROUP - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
REMOTE_HOST - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
REMOTE_HOST_KEY - Static variable in class org.apache.nifi.processors.grpc.FlowFileIngestServiceInterceptor
REMOTE_HOST_KEY - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
REMOTE_HOSTNAME - Static variable in class org.apache.nifi.processors.standard.util.SFTPUtils
REMOTE_INPUT_HOST - Static variable in class org.apache.nifi.util.NiFiProperties
REMOTE_INPUT_PORT - Static variable in class org.apache.nifi.util.NiFiProperties
REMOTE_INPUT_PORT_TYPE - Static variable in interface org.apache.nifi.provenance.ProvenanceEventRecord
REMOTE_OUTPUT_PORT_TYPE - Static variable in interface org.apache.nifi.provenance.ProvenanceEventRecord
REMOTE_OWNER - Static variable in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord
REMOTE_OWNER - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
REMOTE_OWNER - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
REMOTE_PASSWORD - Static variable in class org.apache.nifi.processors.standard.util.SFTPUtils
REMOTE_PASSWORD_KEY - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
REMOTE_PATH - Static variable in class org.apache.nifi.processors.standard.ListFileTransfer
REMOTE_PATH - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
REMOTE_POLL_BATCH_SIZE - Static variable in interface org.apache.nifi.processors.standard.util.FileTransfer
REMOTE_PORT_KEY - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
REMOTE_PROCESS_GROUP_STATUS_HISTORY_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.StatusHistoryEndpointMerger
REMOTE_PROCESS_GROUP_STATUS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupStatusEndpointMerger
REMOTE_PROCESS_GROUP_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupEndpointMerger
REMOTE_PROCESS_GROUPS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupEndpointMerger
REMOTE_PROCESS_GROUPS_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupsEndpointMerger
REMOTE_USER_DN - Static variable in class org.apache.nifi.processors.grpc.ListenGRPC
REMOTE_USER_KEY - Static variable in class org.apache.nifi.processors.standard.util.FTPUtils
REMOTE_USERNAME - Static variable in class org.apache.nifi.processors.standard.util.SFTPUtils
RemoteAuthorizationState - Enum in org.apache.nifi.remote
RemoteDestination - Interface in org.apache.nifi.remote: A model object for referring to a remote destination (i.e., a Port) for site-to-site communications
RemoteGroupPort - Class in org.apache.nifi.remote
RemoteGroupPort(String, String, ProcessGroup, ConnectableType, ProcessScheduler) - Constructor for class org.apache.nifi.remote.RemoteGroupPort
RemoteNiFiUtils - Class in org.apache.nifi.remote
RemoteNiFiUtils(SSLContext) - Constructor for class org.apache.nifi.remote.RemoteNiFiUtils
RemoteProcessGroup - Interface in org.apache.nifi.groups
RemoteProcessGroupAuditor - Class in org.apache.nifi.audit: Audits remote process group creation/removal and configuration changes.
RemoteProcessGroupAuditor() - Constructor for class org.apache.nifi.audit.RemoteProcessGroupAuditor
RemoteProcessGroupContentsDTO - Class in org.apache.nifi.web.api.dto: Contents of a remote process group.
RemoteProcessGroupContentsDTO() - Constructor for class org.apache.nifi.web.api.dto.RemoteProcessGroupContentsDTO
RemoteProcessGroupDAO - Interface in org.apache.nifi.web.dao
RemoteProcessGroupDetails - Interface in org.apache.nifi.action.component.details: Provides details of a remote process group to an Action.
RemoteProcessGroupDetailsDTO - Class in org.apache.nifi.web.api.dto.action.component.details: Remote process group details for an action.
RemoteProcessGroupDetailsDTO() - Constructor for class org.apache.nifi.web.api.dto.action.component.details.RemoteProcessGroupDetailsDTO
RemoteProcessGroupDTO - Class in org.apache.nifi.web.api.dto: Details of a remote process group in this NiFi.
RemoteProcessGroupDTO() - Constructor for class org.apache.nifi.web.api.dto.RemoteProcessGroupDTO
RemoteProcessGroupDTO(RemoteProcessGroupDTO) - Constructor for class org.apache.nifi.web.api.dto.RemoteProcessGroupDTO
RemoteProcessGroupEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
RemoteProcessGroupEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupEndpointMerger
RemoteProcessGroupEntity - 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.
RemoteProcessGroupEntity() - Constructor for class org.apache.nifi.web.api.entity.RemoteProcessGroupEntity
RemoteProcessGroupEntityMerger - Class in org.apache.nifi.cluster.manager
RemoteProcessGroupEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.RemoteProcessGroupEntityMerger
RemoteProcessGroupPortDescriptor - Interface in org.apache.nifi.groups
RemoteProcessGroupPortDTO - Class in org.apache.nifi.web.api.dto: Details of a port in a remote process group.
RemoteProcessGroupPortDTO() - Constructor for class org.apache.nifi.web.api.dto.RemoteProcessGroupPortDTO
RemoteProcessGroupPortEntity - 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.
RemoteProcessGroupPortEntity() - Constructor for class org.apache.nifi.web.api.entity.RemoteProcessGroupPortEntity
RemoteProcessGroupResource - Class in org.apache.nifi.web.api: RESTful endpoint for managing a Remote group.
RemoteProcessGroupResource() - Constructor for class org.apache.nifi.web.api.RemoteProcessGroupResource
RemoteProcessGroupsEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
RemoteProcessGroupsEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupsEndpointMerger
RemoteProcessGroupsEntity - 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.
RemoteProcessGroupsEntity() - Constructor for class org.apache.nifi.web.api.entity.RemoteProcessGroupsEntity
RemoteProcessGroupsEntityMerger - Class in org.apache.nifi.cluster.manager
RemoteProcessGroupsEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.RemoteProcessGroupsEntityMerger
RemoteProcessGroupStatus - Class in org.apache.nifi.controller.status
RemoteProcessGroupStatus() - Constructor for class org.apache.nifi.controller.status.RemoteProcessGroupStatus
RemoteProcessGroupStatusDescriptor - Enum in org.apache.nifi.controller.status.history
RemoteProcessGroupStatusDTO - Class in org.apache.nifi.web.api.dto.status
RemoteProcessGroupStatusDTO() - Constructor for class org.apache.nifi.web.api.dto.status.RemoteProcessGroupStatusDTO
RemoteProcessGroupStatusEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
RemoteProcessGroupStatusEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.RemoteProcessGroupStatusEndpointMerger
RemoteProcessGroupStatusEntity - 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.
RemoteProcessGroupStatusEntity() - Constructor for class org.apache.nifi.web.api.entity.RemoteProcessGroupStatusEntity
RemoteProcessGroupStatusSnapshotDTO - Class in org.apache.nifi.web.api.dto.status: The status of a remote process group in this NiFi.
RemoteProcessGroupStatusSnapshotDTO() - Constructor for class org.apache.nifi.web.api.dto.status.RemoteProcessGroupStatusSnapshotDTO
RemoteProcessGroupStatusSnapshotEntity - 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.
RemoteProcessGroupStatusSnapshotEntity() - Constructor for class org.apache.nifi.web.api.entity.RemoteProcessGroupStatusSnapshotEntity
RemoteResourceFactory - Class in org.apache.nifi.remote
RemoteResourceFactory() - Constructor for class org.apache.nifi.remote.RemoteResourceFactory
RemoteResourceInitiator - Class in org.apache.nifi.remote
RemoteResourceInitiator() - Constructor for class org.apache.nifi.remote.RemoteResourceInitiator
RemoteResourceManager - Class in org.apache.nifi.remote
RemoteResourceManager() - Constructor for class org.apache.nifi.remote.RemoteResourceManager
RemoteSiteListener - Interface in org.apache.nifi.remote
remove(Object) - Method in class org.apache.nifi.attribute.expression.language.AttributesAndState
remove(ContentClaim) - Method in interface org.apache.nifi.controller.repository.ContentRepository: Removes the content indicated by the given claim
remove(ContentClaim) - Method in class org.apache.nifi.controller.repository.FileSystemRepository
remove(FlowFile) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
remove(Collection<FlowFile>) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
remove(ContentClaim) - Method in class org.apache.nifi.controller.repository.VolatileContentRepository
remove(Snippet) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
remove(K, Serializer<K>) - Method in interface org.apache.nifi.distributed.cache.client.DistributedMapCacheClient: Removes the entry with the given key from the cache, if it is present.
remove(K, Serializer<K>) - Method in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
remove(T, Serializer<T>) - Method in interface org.apache.nifi.distributed.cache.client.DistributedSetCacheClient: Removes the given value from the cache, if it is present.
remove(T, Serializer<T>) - Method in class org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService
remove(ByteBuffer) - Method in interface org.apache.nifi.distributed.cache.server.map.MapCache
remove(ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
remove(ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.map.SimpleMapCache
remove(ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.set.PersistentSetCache
remove(ByteBuffer) - Method in interface org.apache.nifi.distributed.cache.server.set.SetCache
remove(ByteBuffer) - Method in class org.apache.nifi.distributed.cache.server.set.SimpleSetCache
remove(Snippet) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes all of the components whose ID's are specified within the given Snippet from this ProcessGroup.
remove(Snippet) - Method in class org.apache.nifi.groups.StandardProcessGroup
remove(K, Serializer<K>) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientMapCacheService
remove(FlowFile) - Method in interface org.apache.nifi.processor.ProcessSession: Ends the managed persistence for the given FlowFile.
remove(Collection<FlowFile>) - Method in interface org.apache.nifi.processor.ProcessSession: Ends the managed persistence for the given FlowFiles.
remove(K, Serializer<K>) - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
remove(FlowFile) - Method in class org.apache.nifi.util.MockProcessSession
remove(Collection<FlowFile>) - Method in class org.apache.nifi.util.MockProcessSession
REMOVE_ALL - Static variable in class org.apache.nifi.processors.standard.ModifyBytes
REMOVE_CRC_FILES - Static variable in class org.apache.nifi.processors.parquet.PutParquet
REMOVE_TRAILING_NEWLINES - Static variable in class org.apache.nifi.processors.standard.SplitText
removeAccessPolicy(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.AccessPolicyResource: Removes the specified access policy.
removeAllAttributes(FlowFile, Set<String>) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
removeAllAttributes(FlowFile, Pattern) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
removeAllAttributes(FlowFile, Set<String>) - Method in interface org.apache.nifi.processor.ProcessSession: Removes the attributes with the given keys from the given FlowFile.
removeAllAttributes(FlowFile, Pattern) - Method in interface org.apache.nifi.processor.ProcessSession: Remove all attributes from the given FlowFile that have keys which match the given pattern.
removeAllAttributes(FlowFile, Set<String>) - Method in class org.apache.nifi.util.MockProcessSession
removeAllAttributes(FlowFile, Pattern) - Method in class org.apache.nifi.util.MockProcessSession
removeAllNonExistentPorts() - Method in interface org.apache.nifi.groups.RemoteProcessGroup: Removes all non existent ports from this RemoteProcessGroup.
removeAllNonExistentPorts() - Method in class org.apache.nifi.remote.StandardRemoteProcessGroup
removeAllObservers() - Method in interface org.apache.nifi.logging.LogRepository: Removes all LogObservers from this Repository
removeAllObservers() - Method in class org.apache.nifi.logging.repository.StandardLogRepository
removeAttribute(FlowFile, String) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
removeAttribute(FlowFile, String) - Method in interface org.apache.nifi.processor.ProcessSession: Removes the given FlowFile attribute with the given key.
removeAttribute(FlowFile, String) - Method in class org.apache.nifi.util.MockProcessSession
removeAttributes(String...) - Method in class org.apache.nifi.controller.repository.StandardFlowFileRecord.Builder
removeAttributes(Set<String>) - Method in class org.apache.nifi.controller.repository.StandardFlowFileRecord.Builder
removeAttributes(Pattern) - Method in class org.apache.nifi.controller.repository.StandardFlowFileRecord.Builder
removeAttributes(Set<String>) - Method in class org.apache.nifi.util.MockFlowFile
removeByPattern(String) - Method in interface org.apache.nifi.distributed.cache.client.DistributedMapCacheClient: Removes entries whose keys match the specified pattern
removeByPattern(String) - Method in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
removeByPattern(String) - Method in interface org.apache.nifi.distributed.cache.server.map.MapCache
removeByPattern(String) - Method in class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
removeByPattern(String) - Method in class org.apache.nifi.distributed.cache.server.map.SimpleMapCache
removeByPattern(String) - Method in class org.apache.nifi.hbase.HBase_1_1_2_ClientMapCacheService
removeByPattern(String) - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
removeChildFlowFile(FlowFile) - Method in interface org.apache.nifi.provenance.ProvenanceEventBuilder: Removes the given FlowFile as a child for Events of type ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE This is valid only for ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE events and will be ignored for any other event types.
removeChildFlowFile(FlowFile) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
removeClaimantCount(ResourceClaim) - Method in class org.apache.nifi.controller.repository.claim.StandardResourceClaimManager
removeConnection(Connection) - Method in interface org.apache.nifi.connectable.Connectable
removeConnection(Connection) - Method in class org.apache.nifi.connectable.LocalPort
removeConnection(Connection) - Method in class org.apache.nifi.controller.AbstractPort
removeConnection(Connection) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeConnection(Connection) - Method in class org.apache.nifi.controller.StandardFunnel
removeConnection(Connection) - Method in class org.apache.nifi.controller.StandardProcessorNode
removeConnection(Connection) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the connection from this ProcessGroup.
removeConnection(Connection) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeConnection(Connection) - Method in class org.apache.nifi.remote.StandardRemoteGroupPort
removeConnection(Relationship) - Method in class org.apache.nifi.util.MockProcessContext
removeConnection(Relationship) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
removeConnection(String) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
removeConnection(Relationship) - Method in interface org.apache.nifi.util.TestRunner: Removes the connection for the given Relationship from the configured processor.
removeConnection(String) - Method in interface org.apache.nifi.util.TestRunner: Removes the connection for the relationship with the given name from the configured processor.
removeConnectionAdvice(ProceedingJoinPoint, String, ConnectionDAO) - Method in class org.apache.nifi.audit.RelationshipAuditor: Audits the removal of relationships via deleteConnection().
removeControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.FlowController
removeControllerService(ControllerServiceNode) - Method in interface org.apache.nifi.controller.service.ControllerServiceProvider: Removes the given Controller Service from the flow.
removeControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.service.StandardControllerServiceProvider
removeControllerService(ControllerServiceNode) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the given Controller Service from this group
removeControllerService(ControllerServiceNode) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeControllerService(ControllerService) - Method in class org.apache.nifi.util.MockControllerServiceLookup
removeControllerService(ControllerService) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
removeControllerService(ControllerService) - Method in interface org.apache.nifi.util.TestRunner: Removes the Controller Service from the TestRunner.
removeControllerService(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.ControllerServiceResource: Removes the specified controller service.
removeControllerServiceAdvice(ProceedingJoinPoint, String, ControllerServiceDAO) - Method in class org.apache.nifi.audit.ControllerServiceAuditor: Audits the removal of a controller service via deleteControllerService().
removeDelimiter(List<Byte>) - Method in class org.apache.nifi.processors.standard.util.TCPTestServer
removeDropRequest(HttpServletRequest, String, String) - Method in class org.apache.nifi.web.api.FlowFileQueueResource: Deletes the specified drop request.
removeFunnel(Funnel) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeFunnel(Funnel) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the given funnel from this ProcessGroup
removeFunnel(Funnel) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeFunnel(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.FunnelResource: Removes the specified funnel.
removeFunnelAdvice(ProceedingJoinPoint, String, FunnelDAO) - Method in class org.apache.nifi.audit.FunnelAuditor: Audits the removal of a funnel.
removeGroup(String) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder: Removes the provided groups from the builder's set of groups.
removeGroups(Set<String>) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder: Removes all groups in the provided set from the builder's set of groups.
removeHandler(ProtocolHandler) - Method in class org.apache.nifi.cluster.protocol.impl.ClusterCoordinationProtocolSenderListener
removeHandler(ProtocolHandler) - Method in class org.apache.nifi.cluster.protocol.impl.NodeProtocolSenderListener
removeHandler(ProtocolHandler) - Method in class org.apache.nifi.cluster.protocol.impl.SocketProtocolListener
removeHandler(ProtocolHandler) - Method in interface org.apache.nifi.cluster.protocol.ProtocolListener: Unregisters the handler with the listener.
removeHeartbeat(NodeIdentifier) - Method in class org.apache.nifi.cluster.coordination.heartbeat.ClusterProtocolHeartbeatMonitor
removeHeartbeat(NodeIdentifier) - Method in interface org.apache.nifi.cluster.coordination.heartbeat.HeartbeatMonitor: Removes the heartbeat for the given node from the monitor and the remote location where heartbeats are sent
removeIndex(File) - Method in class org.apache.nifi.provenance.lucene.CachingIndexManager
removeIndex(File) - Method in interface org.apache.nifi.provenance.lucene.IndexManager
removeIndex(File) - Method in class org.apache.nifi.provenance.lucene.SimpleIndexManager
removeIndexDirectory(File) - Method in class org.apache.nifi.provenance.IndexConfiguration
removeInputPort(Port) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeInputPort(Port) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes a Port from this ProcessGroup's list of Input Ports.
removeInputPort(Port) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeInputPort(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.InputPortResource: Removes the specified input port.
removeInstanceClassLoader(String) - Static method in class org.apache.nifi.nar.ExtensionManager: Removes the InstanceClassLoader for a given component.
removeLabel(Label) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeLabel(Label) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the given Label from this ProcessGroup
removeLabel(Label) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeLabel(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.LabelResource: Removes the specified label.
removeLocalState(String) - Method in class org.apache.nifi.processors.aws.s3.PutS3Object
removeLock(ProceedingJoinPoint) - Method in class org.apache.nifi.web.NiFiServiceFacadeLock
removeNode(NodeIdentifier, String) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator: Removes the given disconnected node from the cluster
removeNode(NodeIdentifier, String) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
removeNonExistentPort(RemoteGroupPort) - Method in interface org.apache.nifi.groups.RemoteProcessGroup: Removes a port that no longer exists on the remote instance from this RemoteProcessGroup
removeNonExistentPort(RemoteGroupPort) - Method in class org.apache.nifi.remote.StandardRemoteProcessGroup: Shuts down and removes the given port
removeObserver(String) - Method in interface org.apache.nifi.logging.LogRepository: Removes the given LogObserver from this Repository.
removeObserver(String) - Method in class org.apache.nifi.logging.repository.StandardLogRepository
removeOldestBin() - Method in class org.apache.nifi.processor.util.bin.BinManager
removeOutputPort(Port) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeOutputPort(Port) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes a Port from this ProcessGroup's list of Output Ports.
removeOutputPort(Port) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeOutputPort(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.OutputPortResource: Removes the specified output port.
removeParentFlowFile(FlowFile) - Method in interface org.apache.nifi.provenance.ProvenanceEventBuilder: Removes the given FlowFile as a parent for Events of type, ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE This is valid only for ProvenanceEventType.FORK, ProvenanceEventType.JOIN, and ProvenanceEventType.CLONE events and will be ignored for any other event types.
removeParentFlowFile(FlowFile) - Method in class org.apache.nifi.provenance.StandardProvenanceEventRecord.Builder
removePolicyAdvice(ProceedingJoinPoint, String, AccessPolicyDAO) - Method in class org.apache.nifi.audit.AccessPolicyAuditor: Audits the removal of a policy via deleteAccessPolicy().
removePortAdvice(ProceedingJoinPoint, String, PortDAO) - Method in class org.apache.nifi.audit.PortAuditor: Audits the removal of a processor via deleteProcessor().
removeProcessGroup(ProcessGroup) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeProcessGroup(ProcessGroup) - Method in interface org.apache.nifi.groups.ProcessGroup
removeProcessGroup(ProcessGroup) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeProcessGroup(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.ProcessGroupResource: Removes the specified process group reference.
removeProcessGroupAdvice(ProceedingJoinPoint, String) - Method in class org.apache.nifi.audit.ProcessGroupAuditor: Audits the removal of a process group via deleteProcessGroup().
removeProcessor(ProcessorNode) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeProcessor(ProcessorNode) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the given processor from this group, destroying the Processor.
removeProcessor(ProcessorNode) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeProcessorAdvice(ProceedingJoinPoint, String, ProcessorDAO) - Method in class org.apache.nifi.audit.ProcessorAuditor: Audits the removal of a processor via deleteProcessor().
removeProperty(PropertyDescriptor) - Method in class org.apache.nifi.util.MockProcessContext
removeProperty(PropertyDescriptor) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
removeProperty(PropertyDescriptor) - Method in interface org.apache.nifi.util.TestRunner: Removes the PropertyDescriptor from the ProcessContext, effectively setting its value to null, or the property's default value, if it has one.
removeReadyBins(boolean) - Method in class org.apache.nifi.processor.util.bin.BinManager: Finds all bins that are considered full and removes them from the manager.
removeReference(ConfiguredComponent) - Method in interface org.apache.nifi.controller.service.ControllerServiceNode: Indicates that the given component is no longer referencing this Controller Service
removeReference(ConfiguredComponent) - Method in class org.apache.nifi.controller.service.StandardControllerServiceNode
removeRemoteProcessGroup(RemoteProcessGroup) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeRemoteProcessGroup(RemoteProcessGroup) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the given RemoteProcessGroup from this ProcessGroup
removeRemoteProcessGroup(RemoteProcessGroup) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeRemoteProcessGroup(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.RemoteProcessGroupResource: Removes the specified remote process group.
removeRemoteProcessGroupAdvice(ProceedingJoinPoint, String, RemoteProcessGroupDAO) - Method in class org.apache.nifi.audit.RemoteProcessGroupAuditor: Audits the removal of a process group via deleteProcessGroup().
removeReportingTask(ReportingTaskNode) - Method in class org.apache.nifi.controller.FlowController
removeReportingTask(ReportingTaskNode) - Method in interface org.apache.nifi.controller.reporting.ReportingTaskProvider: Removes the given reporting task from the flow
removeReportingTask(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.ReportingTaskResource: Removes the specified reporting task.
removeReportingTaskAdvice(ProceedingJoinPoint, String, ReportingTaskDAO) - Method in class org.apache.nifi.audit.ReportingTaskAuditor: Audits the removal of a reporting task via deleteReportingTask().
removeRootControllerService(ControllerServiceNode) - Method in class org.apache.nifi.controller.FlowController
removeSelectedElements(RingBuffer.Filter<T>) - Method in class org.apache.nifi.util.RingBuffer: Removes all elements from the RingBuffer that match the given filter
removeService(String) - Method in interface org.apache.nifi.io.socket.multicast.ServicesBroadcaster: Removes the service with the given service name from the set.
removeSnippet(StandardSnippet) - Method in class org.apache.nifi.controller.SnippetManager
removeSnippetAdvice(ProceedingJoinPoint, String, SnippetDAO) - Method in class org.apache.nifi.audit.SnippetAuditor: Audits bulk delete.
removeTemplate(Template) - Method in class org.apache.nifi.controller.service.mock.MockProcessGroup
removeTemplate(Template) - Method in interface org.apache.nifi.groups.ProcessGroup: Removes the given template from the Process Group
removeTemplate(Template) - Method in class org.apache.nifi.groups.StandardProcessGroup
removeTemplate(HttpServletRequest, String) - Method in class org.apache.nifi.web.api.TemplateResource: Removes the specified template.
removeUser(String) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder: Removes the provided user from the builder's set of users.
removeUser(String) - Method in class org.apache.nifi.authorization.Group.Builder: Removes the given user from the builder's set of users.
removeUser(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.TenantsResource: Removes the specified user.
removeUserAdvice(ProceedingJoinPoint, String, UserDAO) - Method in class org.apache.nifi.audit.UserAuditor: Audits the removal of a user via deleteUser().
removeUserAdvice(ProceedingJoinPoint, String, UserGroupDAO) - Method in class org.apache.nifi.audit.UserGroupAuditor: Audits the removal of a user via deleteUser().
removeUserGroup(HttpServletRequest, LongParameter, ClientIdParameter, String) - Method in class org.apache.nifi.web.api.TenantsResource: Removes the specified user group.
removeUsers(Set<String>) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder: Removes all users in the provided set from the builder's set of users.
removeUsers(Set<String>) - Method in class org.apache.nifi.authorization.Group.Builder: Removes all users from the provided set from the builder's set of users.
removeVariable(VariableDescriptor) - Method in class org.apache.nifi.util.MockVariableRegistry
removeVariable(String) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
removeVariable(String) - Method in interface org.apache.nifi.util.TestRunner: Removes the variable with the given name from this Test Runner, if it is set.
REMOVR - Static variable in class org.apache.nifi.processors.standard.JoltTransformJSON
rename(FileSystem, Path, Path) - Method in class org.apache.nifi.processors.hadoop.AbstractPutHDFSRecord: Attempts to rename srcFile to destFile up to 10 times, with a 200ms sleep in between each attempt.
rename(FlowFile, String, String) - Method in interface org.apache.nifi.processors.standard.util.FileTransfer
rename(FlowFile, String, String) - Method in class org.apache.nifi.processors.standard.util.FTPTransfer
rename(FlowFile, String, String) - Method in class org.apache.nifi.processors.standard.util.SFTPTransfer
renameFile(File, File, int) - Static method in class org.apache.nifi.util.file.FileUtils: Renames the given file from the source path to the destination path.
renameFile(File, File, int, boolean) - Static method in class org.apache.nifi.util.file.FileUtils: Renames the given file from the source path to the destination path.
rendezvousWithAmqp(ProcessContext, ProcessSession) - Method in class org.apache.nifi.amqp.processors.AbstractAMQPProcessorTest.MockAbstractAMQPProcessor
rendezvousWithAmqp(ProcessContext, ProcessSession) - Method in class org.apache.nifi.amqp.processors.ConsumeAMQP: Will construct a FlowFile containing the body of the consumed AMQP message (if GetResponse returned by AMQPConsumer is not null) and AMQP properties that came with message which are added to a FlowFile as attributes, transferring FlowFile to 'success' Relationship.
rendezvousWithAmqp(ProcessContext, ProcessSession) - Method in class org.apache.nifi.amqp.processors.PublishAMQP: Will construct AMQP message by extracting its body from the incoming FlowFile.
rendezvousWithJms(ProcessContext, ProcessSession) - Method in class org.apache.nifi.jms.processors.ConsumeJMS: Will construct a FlowFile containing the body of the consumed JMS message (if GetResponse returned by JMSConsumer is not null) and JMS properties that came with message which are added to a FlowFile as attributes, transferring FlowFile to 'success' Relationship.
rendezvousWithJms(ProcessContext, ProcessSession) - Method in class org.apache.nifi.jms.processors.PublishJMS: Will construct JMS Message by extracting its body from the incoming FlowFile.
rendezvousWithKafka(ProcessContext, ProcessSession) - Method in class org.apache.nifi.processors.kafka.PutKafka: Will rendezvous with Kafka if ProcessSession contains FlowFile producing a result FlowFile.
reorder(List<String>) - Method in class org.apache.nifi.update.attributes.Criteria: Reorders the rule collection.
reorderDn(String) - Static method in class org.apache.nifi.security.util.CertificateUtils: Reorders DN to the order the elements appear in the RFC 2253 table https://www.ietf.org/rfc/rfc2253.txt String X.500 AttributeType ------------------------------ CN commonName L localityName ST stateOrProvinceName O organizationName OU organizationalUnitName C countryName STREET streetAddress DC domainComponent UID userid
RepairCorruptedFileEndings - Class in org.apache.nifi.toolkit.repos.flowfile
RepairCorruptedFileEndings() - Constructor for class org.apache.nifi.toolkit.repos.flowfile.RepairCorruptedFileEndings
REPEATING_PARAM_PATTERN - Static variable in class org.apache.nifi.processors.solr.PutSolrContentStream
Repetition - Enum in org.apache.nifi.repository.schema
replace(StateMap, Map<String, String>, String) - Method in class org.apache.nifi.cluster.integration.NopStateProvider
replace(StateMap, Map<String, String>, Scope) - Method in interface org.apache.nifi.components.state.StateManager: Updates the value of the component's state to the new value if and only if the value currently is the same as the given oldValue.
replace(StateMap, Map<String, String>, String) - Method in interface org.apache.nifi.components.state.StateProvider: Updates the value of the component's state to the new value if and only if the value currently is the same as the given oldValue.
replace(StateMap, Map<String, String>, String) - Method in class org.apache.nifi.controller.state.providers.local.WriteAheadLocalStateProvider
replace(StateMap, Map<String, String>, String) - Method in class org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider
replace(StateMap, Map<String, String>, Scope) - Method in class org.apache.nifi.controller.state.StandardStateManager
replace(AtomicCacheEntry<K, V, R>, Serializer<K>, Serializer<V>) - Method in interface org.apache.nifi.distributed.cache.client.AtomicDistributedMapCacheClient: Replace an existing key with new value.
replace(AtomicCacheEntry<K, V, Long>, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService
replace(MapCacheRecord) - Method in interface org.apache.nifi.distributed.cache.server.map.MapCache
replace(MapCacheRecord) - Method in class org.apache.nifi.distributed.cache.server.map.PersistentMapCache
replace(MapCacheRecord) - Method in class org.apache.nifi.distributed.cache.server.map.SimpleMapCache
replace(WaitNotifyProtocol.Signal) - Method in class org.apache.nifi.processors.standard.WaitNotifyProtocol
Replace - Class in org.apache.nifi.record.path.functions
Replace(RecordPathSegment, RecordPathSegment, RecordPathSegment, boolean) - Constructor for class org.apache.nifi.record.path.functions.Replace
replace(AtomicCacheEntry<K, V, byte[]>, Serializer<K>, Serializer<V>) - Method in class org.apache.nifi.redis.service.RedisDistributedMapCacheClientService
replace(StateMap, Map<String, String>, String) - Method in class org.apache.nifi.redis.state.RedisStateProvider
replace(StateMap, Map<String, String>, Scope) - Method in class org.apache.nifi.state.MockStateManager
REPLACE_RESOLUTION - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
REPLACE_RESOLUTION - Static variable in class org.apache.nifi.processors.standard.PutFile
REPLACE_RESOLUTION_AV - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
ReplaceAllEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
ReplaceAllEvaluator(Evaluator<String>, Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.ReplaceAllEvaluator
ReplaceEmptyEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
ReplaceEmptyEvaluator(Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.ReplaceEmptyEvaluator
ReplaceEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
ReplaceEvaluator(Evaluator<String>, Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.ReplaceEvaluator
ReplaceFirstEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
ReplaceFirstEvaluator(Evaluator<String>, Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.ReplaceFirstEvaluator
replaceFuture(ScheduledFuture<?>, ScheduledFuture<?>) - Method in class org.apache.nifi.controller.scheduling.ScheduleState
REPLACEMENT_STRATEGY - Static variable in class org.apache.nifi.processors.standard.ReplaceText
REPLACEMENT_VALUE - Static variable in class org.apache.nifi.processors.standard.ReplaceText
ReplaceNull - Class in org.apache.nifi.record.path.functions
ReplaceNull(RecordPathSegment, RecordPathSegment, boolean) - Constructor for class org.apache.nifi.record.path.functions.ReplaceNull
ReplaceNullEvaluator - Class in org.apache.nifi.attribute.expression.language.evaluation.functions
ReplaceNullEvaluator(Evaluator<String>, Evaluator<String>) - Constructor for class org.apache.nifi.attribute.expression.language.evaluation.functions.ReplaceNullEvaluator
ReplaceRegex - Class in org.apache.nifi.record.path.functions
ReplaceRegex(RecordPathSegment, RecordPathSegment, RecordPathSegment, boolean) - Constructor for class org.apache.nifi.record.path.functions.ReplaceRegex
ReplaceText - Class in org.apache.nifi.processors.standard
ReplaceText() - Constructor for class org.apache.nifi.processors.standard.ReplaceText
ReplaceTextWithMapping - Class in org.apache.nifi.processors.standard
ReplaceTextWithMapping() - Constructor for class org.apache.nifi.processors.standard.ReplaceTextWithMapping
ReplaceTextWithMapping.ConfigurationState - Class in org.apache.nifi.processors.standard
replaceUnauthorizedWithPlaceholders(Set<ProvenanceEventRecord>) - Method in interface org.apache.nifi.provenance.authorization.EventAuthorizer: Returns a Set of provenance events for which any of the given events that the user does not have access to has been replaced by a placeholder event
replaceUnauthorizedWithPlaceholders(Set<ProvenanceEventRecord>, NiFiUser) - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
replayFlowFile(long, NiFiUser) - Method in class org.apache.nifi.controller.FlowController
replayFlowFile(ProvenanceEventRecord, NiFiUser) - Method in class org.apache.nifi.controller.FlowController
replicate(String, URI, Object, Map<String, String>) - Method in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: Replicates a request to each node in the cluster.
replicate(Set<NodeIdentifier>, String, URI, Object, Map<String, String>, boolean, boolean) - Method in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: Requests are sent to each node in the given set of Node Identifiers.
replicate(String, URI, Object, Map<String, String>) - Method in class org.apache.nifi.cluster.coordination.http.replication.ThreadPoolRequestReplicator
replicate(Set<NodeIdentifier>, String, URI, Object, Map<String, String>, boolean, boolean) - Method in class org.apache.nifi.cluster.coordination.http.replication.ThreadPoolRequestReplicator
replicate(String, String) - Method in class org.apache.nifi.web.api.ApplicationResource: Replicates the request to the given node
replicate(String, Object, String, Map<String, String>) - Method in class org.apache.nifi.web.api.ApplicationResource
replicate(String, Object, String) - Method in class org.apache.nifi.web.api.ApplicationResource: Replicates the request to the given node
replicate(URI, String, Object, String, Map<String, String>) - Method in class org.apache.nifi.web.api.ApplicationResource: Replicates the request to the given node
replicate(String, NodeIdentifier) - Method in class org.apache.nifi.web.api.ApplicationResource
replicate(String, NodeIdentifier, Object) - Method in class org.apache.nifi.web.api.ApplicationResource
replicate(String) - Method in class org.apache.nifi.web.api.ApplicationResource: Convenience method for calling ApplicationResource.replicate(String, Object) with an entity of getRequestParameters(true)
replicate(String, Object) - Method in class org.apache.nifi.web.api.ApplicationResource: Replicates the request to all nodes in the cluster using the provided method and entity.
replicate(String, Object, Map<String, String>) - Method in class org.apache.nifi.web.api.ApplicationResource: Replicates the request to all nodes in the cluster using the provided method and entity.
REPLICATE_TO - Static variable in class org.apache.nifi.processors.couchbase.PutCouchbaseKey
replicateNodeResponse(String) - Method in class org.apache.nifi.web.api.ApplicationResource: Convenience method for calling ApplicationResource.replicateNodeResponse(String, Object, Map) with an entity of getRequestParameters(true) and overriding no headers
replicateNodeResponse(String, Object, Map<String, String>) - Method in class org.apache.nifi.web.api.ApplicationResource
replicateNodeResponse(URI, String, Object, Map<String, String>) - Method in class org.apache.nifi.web.api.ApplicationResource: Replicates the request to all nodes in the cluster using the provided method and entity.
replicateRequest(WebResource.Builder, NodeIdentifier, String, URI, String, Map<String, String>, StandardAsyncClusterResponse) - Method in class org.apache.nifi.cluster.coordination.http.replication.ThreadPoolRequestReplicator
replicateToCoordinator(String, Object) - Method in class org.apache.nifi.web.api.ApplicationResource
REPLICATION_FACTOR - Static variable in class org.apache.nifi.processors.hadoop.PutHDFS
REPLICATION_INDICATOR_HEADER - Static variable in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: When we replicate a request across the cluster, we replicate it only from the cluster coordinator.
REPLICATION_TARGET_NODE_UUID_HEADER - Static variable in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: When replicating a request to the cluster coordinator, it may be useful to denote that the request should be replicated only to a single node.
REPLY_TO_QUEUE - Static variable in class org.apache.nifi.processors.standard.util.JmsProperties
REPORT_NODE_ALL - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
REPORT_NODE_PRIMARY - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
ReportedEvent - Class in org.apache.nifi.cluster
ReportedEvent(NodeIdentifier, Severity, String) - Constructor for class org.apache.nifi.cluster.ReportedEvent
reportEvent(NodeIdentifier, Severity, String) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator: Reports that some event occurred that is relevant to the cluster
reportEvent(NodeIdentifier, Severity, String) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
reportEvent(Severity, String, String) - Method in interface org.apache.nifi.events.EventReporter
reportEvent(Severity, String, String) - Method in class org.apache.nifi.events.StandardEventReporter
REPORTING_INTERVAL - Static variable in class org.apache.nifi.controller.MonitorMemory
REPORTING_NODE - Static variable in class org.apache.nifi.processors.standard.MonitorActivity
REPORTING_TASK_STATE_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ComponentStateEndpointMerger
REPORTING_TASK_TYPES_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskTypesEndpointMerger
REPORTING_TASK_URI_PATTERN - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskEndpointMerger
REPORTING_TASKS_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskEndpointMerger
REPORTING_TASKS_URI - Static variable in class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTasksEndpointMerger
ReportingContext - Interface in org.apache.nifi.reporting: This interface provides a bridge between the NiFi Framework and a ReportingTask.
ReportingInitializationContext - Interface in org.apache.nifi.reporting: A ReportingConfiguration provides configuration information to a ReportingTask at the time of initialization
ReportingTask - Interface in org.apache.nifi.reporting: Defines a task that is responsible for reporting status information to external destinations.
ReportingTaskAuditor - Class in org.apache.nifi.audit: Audits reporting creation/removal and configuration changes.
ReportingTaskAuditor() - Constructor for class org.apache.nifi.audit.ReportingTaskAuditor
ReportingTaskDAO - Interface in org.apache.nifi.web.dao
ReportingTaskDTO - Class in org.apache.nifi.web.api.dto: Component that is capable of reporting internal NiFi state to an external service
ReportingTaskDTO() - Constructor for class org.apache.nifi.web.api.dto.ReportingTaskDTO
ReportingTaskEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ReportingTaskEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskEndpointMerger
ReportingTaskEntity - 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.
ReportingTaskEntity() - Constructor for class org.apache.nifi.web.api.entity.ReportingTaskEntity
ReportingTaskEntityMerger - Class in org.apache.nifi.cluster.manager
ReportingTaskEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.ReportingTaskEntityMerger
ReportingTaskingInitializer - Class in org.apache.nifi.init: Initializes a ReportingTask using a MockReportingInitializationContext;
ReportingTaskingInitializer() - Constructor for class org.apache.nifi.init.ReportingTaskingInitializer
ReportingTaskInstantiationException - Exception in org.apache.nifi.controller.exception
ReportingTaskInstantiationException(String, Throwable) - Constructor for exception org.apache.nifi.controller.exception.ReportingTaskInstantiationException
ReportingTaskInstantiationException(String) - Constructor for exception org.apache.nifi.controller.exception.ReportingTaskInstantiationException
ReportingTaskInstantiationException - Exception in org.apache.nifi.controller.reporting
ReportingTaskInstantiationException(String, Throwable) - Constructor for exception org.apache.nifi.controller.reporting.ReportingTaskInstantiationException
ReportingTaskInstantiationException(String) - Constructor for exception org.apache.nifi.controller.reporting.ReportingTaskInstantiationException
ReportingTaskLogObserver - Class in org.apache.nifi.logging
ReportingTaskLogObserver(BulletinRepository, ReportingTaskNode) - Constructor for class org.apache.nifi.logging.ReportingTaskLogObserver
ReportingTaskNode - Interface in org.apache.nifi.controller
ReportingTaskProvider - Interface in org.apache.nifi.controller.reporting: A ReportingTaskProvider is responsible for providing management of, and access to, Reporting Tasks
ReportingTaskProviderFactoryBean - Class in org.apache.nifi.web.spring
ReportingTaskProviderFactoryBean() - Constructor for class org.apache.nifi.web.spring.ReportingTaskProviderFactoryBean
ReportingTaskResource - Class in org.apache.nifi.web.api: RESTful endpoint for managing a Reporting Task.
ReportingTaskResource() - Constructor for class org.apache.nifi.web.api.ReportingTaskResource
ReportingTasksEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ReportingTasksEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTasksEndpointMerger
ReportingTasksEntity - 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.
ReportingTasksEntity() - Constructor for class org.apache.nifi.web.api.entity.ReportingTasksEntity
ReportingTasksEntityMerger - Class in org.apache.nifi.cluster.manager
ReportingTasksEntityMerger() - Constructor for class org.apache.nifi.cluster.manager.ReportingTasksEntityMerger
ReportingTaskTypesEndpointMerger - Class in org.apache.nifi.cluster.coordination.http.endpoints
ReportingTaskTypesEndpointMerger() - Constructor for class org.apache.nifi.cluster.coordination.http.endpoints.ReportingTaskTypesEndpointMerger
ReportingTaskTypesEntity - 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.
ReportingTaskTypesEntity() - Constructor for class org.apache.nifi.web.api.entity.ReportingTaskTypesEntity
ReportingTaskWithLogger - Class in org.apache.nifi.documentation.example
ReportingTaskWithLogger() - Constructor for class org.apache.nifi.documentation.example.ReportingTaskWithLogger
ReportingTaskWrapper - Class in org.apache.nifi.controller.tasks
ReportingTaskWrapper(ReportingTaskNode, ScheduleState) - Constructor for class org.apache.nifi.controller.tasks.ReportingTaskWrapper
reportTransferEvents(long) - Method in interface org.apache.nifi.controller.repository.FlowFileEventRepository
reportTransferEvents(long) - Method in class org.apache.nifi.controller.repository.metrics.RingBufferEventRepository
REPOSITORY_CONTENT_PREFIX - Static variable in class org.apache.nifi.util.NiFiProperties
REPOSITORY_DATABASE_DIRECTORY - Static variable in class org.apache.nifi.util.NiFiProperties
REPOSITORY_RECORD_SCHEMA_V1 - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
REPOSITORY_RECORD_SCHEMA_V2 - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
REPOSITORY_RECORD_UPDATE_V1 - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
REPOSITORY_RECORD_UPDATE_V2 - Static variable in class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
RepositoryConfiguration - Class in org.apache.nifi.provenance
RepositoryConfiguration() - Constructor for class org.apache.nifi.provenance.RepositoryConfiguration
RepositoryPurgeException - Exception in org.apache.nifi.controller.repository: This exception is thrown when a flow file repository was unable to be properly purged.
RepositoryPurgeException() - Constructor for exception org.apache.nifi.controller.repository.RepositoryPurgeException
RepositoryPurgeException(String) - Constructor for exception org.apache.nifi.controller.repository.RepositoryPurgeException
RepositoryPurgeException(Throwable) - Constructor for exception org.apache.nifi.controller.repository.RepositoryPurgeException
RepositoryPurgeException(String, Throwable) - Constructor for exception org.apache.nifi.controller.repository.RepositoryPurgeException
RepositoryRecord - Interface in org.apache.nifi.controller.repository: Represents an abstraction of a FlowFile that can be used to track changing state of a FlowFile so that transactionality with repositories can exist
RepositoryRecordFieldMap - Class in org.apache.nifi.controller.repository.schema
RepositoryRecordFieldMap(RepositoryRecord, RecordSchema, RecordSchema) - Constructor for class org.apache.nifi.controller.repository.schema.RepositoryRecordFieldMap
RepositoryRecordSchema - Class in org.apache.nifi.controller.repository.schema
RepositoryRecordSchema() - Constructor for class org.apache.nifi.controller.repository.schema.RepositoryRecordSchema
RepositoryRecordSerde - Class in org.apache.nifi.controller.repository
RepositoryRecordSerde() - Constructor for class org.apache.nifi.controller.repository.RepositoryRecordSerde
RepositoryRecordSerdeFactory - Class in org.apache.nifi.controller.repository
RepositoryRecordSerdeFactory(ResourceClaimManager) - Constructor for class org.apache.nifi.controller.repository.RepositoryRecordSerdeFactory
RepositoryRecordType - Enum in org.apache.nifi.controller.repository
RepositoryRecordUpdate - Class in org.apache.nifi.controller.repository.schema
RepositoryRecordUpdate(RepositoryRecordFieldMap, RecordSchema) - Constructor for class org.apache.nifi.controller.repository.schema.RepositoryRecordUpdate
RepositoryStatusReport - Interface in org.apache.nifi.controller.repository
RepositoryUtils - Class in org.apache.nifi.admin: A utility class for useful methods dealing with the repository
RepositoryUtils() - Constructor for class org.apache.nifi.admin.RepositoryUtils
REQ_SERVICE_1 - Static variable in class org.apache.nifi.controller.service.mock.ServiceC
REQ_SERVICE_2 - Static variable in class org.apache.nifi.controller.service.mock.ServiceC
request - Variable in class org.apache.nifi.web.standard.api.AbstractStandardResource
REQUEST_EXECUTION_HTTP_HEADER - Static variable in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: Indicates that this is the second phase of the two phase commit and the execution of the action should proceed.
REQUEST_EXPIRATION - Static variable in class org.apache.nifi.http.StandardHttpContextMap
REQUEST_TRANSACTION_CANCELATION_HTTP_HEADER - Static variable in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: Indicates that the request is intended to cancel a transaction that was previously created without performing the action
REQUEST_TRANSACTION_ID_HEADER - Static variable in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator
REQUEST_URL - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
REQUEST_VALIDATION_HTTP_HEADER - Static variable in interface org.apache.nifi.cluster.coordination.http.replication.RequestReplicator: The HTTP header that the requestor specifies to ask a node if they are able to process a given request.
RequestAction - Enum in org.apache.nifi.authorization: Actions a user/entity can take on a resource.
requestBatchCount(int) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder: When pulling data from a NiFi instance, the sender chooses how large a Transaction is.
requestBatchDuration(long, TimeUnit) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder: When pulling data from a NiFi instance, the sender chooses how large a Transaction is.
requestBatchSize(long) - Method in class org.apache.nifi.remote.client.SiteToSiteClient.Builder: When pulling data from a NiFi instance, the sender chooses how large a Transaction is.
requestBuffer(int) - Method in class org.apache.nifi.cluster.coordination.http.replication.StandardAsyncClusterResponse
RequestCompletionCallback - Interface in org.apache.nifi.cluster.coordination.http.replication: A callback that can be registered to be called after an HTTP Request is replicated and all nodes' responses have been accounted for (either successfully or not)
requestConnection(ConnectionRequestMessage) - Method in class org.apache.nifi.cluster.protocol.AbstractNodeProtocolSender
requestConnection(ConnectionRequestMessage) - Method in class org.apache.nifi.cluster.protocol.impl.NodeProtocolSenderListener
requestConnection(ConnectionRequestMessage) - Method in interface org.apache.nifi.cluster.protocol.NodeProtocolSender: Sends a "connection request" message to the cluster manager.
requestContext - Static variable in class org.apache.nifi.web.standard.api.processor.TestProcessorResource
requestContext - Static variable in class org.apache.nifi.web.standard.api.transformjson.TestTransformJSONResource
requestedResource(Resource) - Method in class org.apache.nifi.authorization.AuthorizationRequest.Builder
RequestExpiredException - Exception in org.apache.nifi.remote.exception: Used to indicate that by the time the request was serviced, it had already expired
RequestExpiredException() - Constructor for exception org.apache.nifi.remote.exception.RequestExpiredException
RequestLogger - Class in org.apache.nifi.web.filter: A filter to log requests.
RequestLogger() - Constructor for class org.apache.nifi.web.filter.RequestLogger
requestNodeConnect(NodeIdentifier, String) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator: Sends a request to the node to connect to the cluster.
requestNodeConnect(NodeIdentifier, String) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
requestNodeConnectionStatus(String, int) - Method in interface org.apache.nifi.cluster.protocol.ClusterCoordinationProtocolSender: Sends a request to the given hostname and port to request its connection status
requestNodeConnectionStatus(String, int) - Method in class org.apache.nifi.cluster.protocol.impl.ClusterCoordinationProtocolSenderListener
requestNodeConnectionStatus(String, int) - Method in class org.apache.nifi.cluster.protocol.impl.StandardClusterCoordinationProtocolSender
requestNodeDisconnect(NodeIdentifier, DisconnectionCode, String) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator: Sends a request to the node to disconnect from the cluster.
requestNodeDisconnect(NodeIdentifier, DisconnectionCode, String) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
requestReconnection(ReconnectionRequestMessage) - Method in interface org.apache.nifi.cluster.protocol.ClusterCoordinationProtocolSender: Sends a "reconnection request" message to a node.
requestReconnection(ReconnectionRequestMessage) - Method in class org.apache.nifi.cluster.protocol.impl.ClusterCoordinationProtocolSenderListener
requestReconnection(ReconnectionRequestMessage) - Method in class org.apache.nifi.cluster.protocol.impl.StandardClusterCoordinationProtocolSender: Requests a node to reconnect to the cluster.
RequestReplicator - Interface in org.apache.nifi.cluster.coordination.http.replication
RequestType - Enum in org.apache.nifi.remote.protocol
required(boolean) - Method in class org.apache.nifi.components.PropertyDescriptor.Builder
RequiresInstanceClassLoading - Annotation Type in org.apache.nifi.annotation.behavior: Marker annotation a component can use to indicate that the framework should create a new ClassLoader for each instance of the component, copying all resources from the component's NARClassLoader to a new ClassLoader which will only be used by a given instance of the component.
requiresMasterKey(String) - Static method in class org.apache.nifi.security.kms.KeyProviderFactory
reset() - Method in class org.apache.nifi.bootstrap.util.LimitingInputStream
reset() - Method in interface org.apache.nifi.controller.Counter
reset() - Method in class org.apache.nifi.controller.repository.claim.ContentClaimWriteCache
reset() - Method in class org.apache.nifi.controller.repository.io.ArrayManagedOutputStream
reset() - Method in class org.apache.nifi.controller.repository.io.DisableOnCloseInputStream
reset() - Method in class org.apache.nifi.controller.repository.io.FlowFileAccessInputStream
reset() - Method in class org.apache.nifi.controller.repository.io.LimitedInputStream
reset() - Method in class org.apache.nifi.controller.StandardCounter
reset() - Method in class org.apache.nifi.processors.beats.frame.BeatsDecoder: Resets this decoder back to its initial state.
reset() - Method in class org.apache.nifi.processors.beats.frame.BeatsFrame.Builder
reset() - Method in class org.apache.nifi.processors.kafka.pubsub.InFlightMessageTracker
reset() - Method in class org.apache.nifi.processors.lumberjack.frame.LumberjackDecoder: Deprecated.

Resets this decoder back to its initial state.
reset() - Method in class org.apache.nifi.processors.lumberjack.frame.LumberjackFrame.Builder: Deprecated.
reset() - Method in class org.apache.nifi.processors.standard.relp.frame.RELPDecoder: Resets this decoder back to it's initial state.
reset() - Method in class org.apache.nifi.processors.standard.relp.frame.RELPFrame.Builder
reset() - Method in class org.apache.nifi.processors.standard.syslog.SyslogEvent.Builder
reset(int) - Method in class org.apache.nifi.processors.standard.util.SoftLimitBoundedByteArrayOutputStream
reset() - Method in class org.apache.nifi.processors.standard.util.SoftLimitBoundedByteArrayOutputStream
reset() - Method in class org.apache.nifi.queryrecord.FlowFileEnumerator
reset() - Method in class org.apache.nifi.remote.io.InterruptableInputStream
reset() - Method in class org.apache.nifi.stream.io.ByteCountingInputStream
reset() - Method in class org.apache.nifi.stream.io.LimitingInputStream
reset() - Method in class org.apache.nifi.util.FlowFileUnpackagerV1.NonCloseableInputStream
reset() - Method in class org.apache.nifi.util.LimitingInputStream
reset() - Method in class org.apache.nifi.util.ReflectionUtilsTest
reset(Collection<Revision>) - Method in class org.apache.nifi.web.revision.NaiveRevisionManager
reset(Collection<Revision>) - Method in interface org.apache.nifi.web.revision.RevisionManager: Clears any revisions that are currently held and resets the Revision Manager so that the revisions present are those provided in the given collection
resetCounter(String) - Method in class org.apache.nifi.controller.FlowController
resetCounter(String) - Method in interface org.apache.nifi.controller.repository.CounterRepository
resetCounter(String) - Method in class org.apache.nifi.controller.repository.StandardCounterRepository
resetCounter(String) - Method in class org.apache.nifi.web.controller.ControllerFacade: Resets the counter with the specified id.
resetDirtyFlag() - Method in class org.apache.nifi.provenance.AbstractRecordWriter
resetIdGenerator() - Static method in class org.apache.nifi.controller.swap.MockFlowFile
resetIds() - Method in class org.apache.nifi.provenance.store.TestPartitionedWriteAheadEventStore
resetIds() - Method in class org.apache.nifi.provenance.TestStandardRecordReaderWriter
resetLastSuccessfulTransfer() - Method in class org.apache.nifi.processors.standard.MonitorActivity
resetNodeStatus(NodeConnectionStatus, long) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator: Resets the status of the node to be in accordance with the given NodeConnectionStatus if and only if the currently held status for this node has an Update ID equal to the given qualifyingUpdateId
resetNodeStatus(NodeConnectionStatus, long) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
resetNodeStatuses(Map<NodeIdentifier, NodeConnectionStatus>) - Method in interface org.apache.nifi.cluster.coordination.ClusterCoordinator: Clears the current state of all nodes and replaces them with the values provided in the given map
resetNodeStatuses(Map<NodeIdentifier, NodeConnectionStatus>) - Method in class org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator
resetState() - Method in class org.apache.nifi.processor.util.bin.BinFiles
resetState() - Method in class org.apache.nifi.processors.standard.MergeRecord
resetWriteStream(Long) - Method in class org.apache.nifi.provenance.serialization.CompressableRecordWriter: Resets the streams to prepare for a new block
ResizeImage - Class in org.apache.nifi.processors.image
ResizeImage() - Constructor for class org.apache.nifi.processors.image.ResizeImage
resolvePath(String) - Method in class org.apache.nifi.controller.cluster.ZooKeeperClientConfig
resource(String) - Method in class org.apache.nifi.authorization.AccessPolicy.Builder: Sets the resource of the builder.
resource(Resource) - Method in class org.apache.nifi.authorization.AuthorizationRequest.Builder
Resource - Interface in org.apache.nifi.authorization: Resource in an authorization request.
RESOURCE_CLAIM - Static variable in class org.apache.nifi.controller.repository.schema.ContentClaimSchema
RESOURCE_CLAIM - Static variable in class org.apache.nifi.controller.swap.SwapSchema
RESOURCE_CLAIM_COUNT - Static variable in class org.apache.nifi.controller.swap.SwapSchema
RESOURCE_CLAIM_OFFSET - Static variable in class org.apache.nifi.controller.repository.schema.ContentClaimSchema
RESOURCE_CLAIM_SCHEMA_V1 - Static variable in class org.apache.nifi.controller.repository.schema.ContentClaimSchema
RESOURCE_CLAIMS - Static variable in class org.apache.nifi.controller.swap.SwapSchema
RESOURCE_NAME - Static variable in class org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol
RESOURCE_NAME - Static variable in class org.apache.nifi.remote.protocol.socket.SocketFlowFileServerProtocol
RESOURCE_OK - Static variable in class org.apache.nifi.distributed.cache.protocol.ProtocolHandshake
RESOURCE_OK - Static variable in class org.apache.nifi.remote.RemoteResourceInitiator
ResourceClaim - Interface in org.apache.nifi.controller.repository.claim: Represents a resource that can be provided by a ContentRepository
ResourceClaimFieldMap - Class in org.apache.nifi.controller.repository.schema
ResourceClaimFieldMap(ResourceClaim, RecordSchema) - Constructor for class org.apache.nifi.controller.repository.schema.ResourceClaimFieldMap
resourceClaimManager(ResourceClaimManager) - Method in class org.apache.nifi.connectable.StandardConnection.Builder
ResourceClaimManager - Interface in org.apache.nifi.controller.repository.claim: Responsible for managing all ResourceClaims that are used in the application
resourceContext(Map<String, String>) - Method in class org.apache.nifi.authorization.AuthorizationRequest.Builder
ResourceDTO - Class in org.apache.nifi.web.api.dto: Resource that supports access/authorization policies.
ResourceDTO() - Constructor for class org.apache.nifi.web.api.dto.ResourceDTO
ResourceFactory - Class in org.apache.nifi.authorization.resource
resourceNotFound() - Static method in class org.apache.nifi.authorization.AuthorizationResult: Resource not found will indicate that there are no specific authorization rules for this resource.
ResourceNotFoundException - Exception in org.apache.nifi.web: Exception indicating that the desired resource was not found.
ResourceNotFoundException(String) - Constructor for exception org.apache.nifi.web.ResourceNotFoundException
ResourceNotFoundException(String, Throwable) - Constructor for exception org.apache.nifi.web.ResourceNotFoundException
ResourceNotFoundExceptionMapper - Class in org.apache.nifi.web.api.config: Maps resource not found exceptions into client responses.
ResourceNotFoundExceptionMapper() - Constructor for class org.apache.nifi.web.api.config.ResourceNotFoundExceptionMapper
ResourceResource - Class in org.apache.nifi.web.api: RESTful endpoint for retrieving system diagnostics.
ResourceResource() - Constructor for class org.apache.nifi.web.api.ResourceResource
ResourcesEntity - 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.
ResourcesEntity() - Constructor for class org.apache.nifi.web.api.entity.ResourcesEntity
ResourceType - Enum in org.apache.nifi.authorization.resource
respond() - Method in interface org.apache.nifi.processor.util.listen.response.ChannelResponder: Writes the responses to the underlying channel.
respond() - Method in class org.apache.nifi.processor.util.listen.response.socket.SocketChannelResponder
respond() - Method in class org.apache.nifi.processor.util.listen.response.socket.SSLSocketChannelResponder
respond(BeatsEvent, BeatsResponse) - Method in class org.apache.nifi.processors.beats.ListenBeats
respond(LumberjackEvent, LumberjackResponse) - Method in class org.apache.nifi.processors.lumberjack.ListenLumberjack: Deprecated.
respond(RELPEvent, RELPResponse) - Method in class org.apache.nifi.processors.standard.ListenRELP
Response - Class in org.apache.nifi.remote.protocol
RESPONSE_BODY - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
RESPONSE_BODY - Static variable in class org.apache.nifi.processors.standard.InvokeHTTP
RESPONSE_CODE - Static variable in class org.apache.nifi.processors.grpc.InvokeGRPC
RESPONSE_CODE - Static variable in class org.apache.nifi.web.api.DataTransferResource
RESPONSE_TIMEOUT - Static variable in class org.apache.nifi.processors.elasticsearch.AbstractElasticsearchHttpProcessor
ResponseCode - Enum in org.apache.nifi.remote.protocol
ResponseCreator() - Constructor for class org.apache.nifi.web.api.ApplicationResource.ResponseCreator
responses - Variable in class org.apache.nifi.processor.util.listen.response.socket.SocketChannelResponder
ResponseUtils - Class in org.apache.nifi.cluster.coordination.http.replication
ResponseUtils() - Constructor for class org.apache.nifi.cluster.coordination.http.replication.ResponseUtils
restore() - Method in class org.apache.nifi.distributed.cache.server.set.PersistentSetCache
RESTORE_DIRECTORY - Static variable in class org.apache.nifi.util.NiFiProperties
Restricted - Annotation Type in org.apache.nifi.annotation.behavior: Marks the usage of a component as restricted to users with elevated privileges.
RESTRICTED_SSL_ALGORITHM - Static variable in class org.apache.nifi.ssl.StandardRestrictedSSLContextService
RestrictedComponentsAuthorizable - Class in org.apache.nifi.authorization.resource
RestrictedComponentsAuthorizable() - Constructor for class org.apache.nifi.authorization.resource.RestrictedComponentsAuthorizable
RestrictedProcessor - Class in org.apache.nifi.integration.util
RestrictedProcessor() - Constructor for class org.apache.nifi.integration.util.RestrictedProcessor
RestrictedSSLContextService - Interface in org.apache.nifi.ssl: Simple extension of the regular SSLContextService to allow for restricted implementations of that interface.
RestrictedSSLContextServiceTest - Class in org.apache.nifi.ssl
RestrictedSSLContextServiceTest() - Constructor for class org.apache.nifi.ssl.RestrictedSSLContextServiceTest
RestSchemaRegistryClient - Class in org.apache.nifi.confluent.schemaregistry.client: A Client for interacting with Confluent Schema Registry.
RestSchemaRegistryClient(List<String>, int, SSLContext) - Constructor for class org.apache.nifi.confluent.schemaregistry.client.RestSchemaRegistryClient
RESTServiceContentModified - Class in org.apache.nifi.processors.standard
RESTServiceContentModified() - Constructor for class org.apache.nifi.processors.standard.RESTServiceContentModified
restStatus - Variable in class org.apache.nifi.processors.elasticsearch.ITDeleteElasticsearch5Test
restStatus - Variable in class org.apache.nifi.processors.elasticsearch.TestDeleteElasticsearch5
result() - Method in enum org.apache.nifi.processor.util.pattern.ErrorTypes
Result(ErrorTypes.Destination, ErrorTypes.Penalty) - Constructor for class org.apache.nifi.processor.util.pattern.ErrorTypes.Result
result - Variable in class org.apache.nifi.processors.aws.cloudwatch.MockPutCloudWatchMetric
result - Variable in class org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDBTest
result - Variable in class org.apache.nifi.processors.aws.dynamodb.GetDynamoDBTest
result - Variable in class org.apache.nifi.processors.aws.dynamodb.PutDynamoDBTest
result() - Method in enum org.apache.nifi.processors.couchbase.ErrorHandlingStrategy
result - Variable in class org.apache.nifi.processors.rethinkdb.TestPutRethinkDB
RESULT_CHANGES_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RESULT_QUERY_DURATION - Static variable in class org.apache.nifi.processors.standard.ExecuteSQL
RESULT_ROW_COUNT - Static variable in class org.apache.nifi.processors.cassandra.QueryCassandra
RESULT_ROW_COUNT - Static variable in class org.apache.nifi.processors.hive.SelectHiveQL
RESULT_ROW_COUNT - Static variable in class org.apache.nifi.processors.standard.ExecuteSQL
RESULT_ROW_COUNT - Static variable in class org.apache.nifi.processors.standard.QueryDatabaseTable
RESULT_TABLENAME - Static variable in class org.apache.nifi.processors.standard.QueryDatabaseTable
ResultCell - Class in org.apache.nifi.hbase.scan
ResultCell() - Constructor for class org.apache.nifi.hbase.scan.ResultCell
ResultHandler - Interface in org.apache.nifi.hbase.scan: Handles a single row from an HBase scan.
ResultHit - Interface in org.apache.nifi.hl7.query
ResultProcessor - Class in org.apache.nifi.processors.evtx
ResultProcessor(Relationship, Relationship) - Constructor for class org.apache.nifi.processors.evtx.ResultProcessor
ResultProcessorTest - Class in org.apache.nifi.processors.evtx
ResultProcessorTest() - Constructor for class org.apache.nifi.processors.evtx.ResultProcessorTest
ResultSetRecordSet - Class in org.apache.nifi.serialization.record
ResultSetRecordSet(ResultSet) - Constructor for class org.apache.nifi.serialization.record.ResultSetRecordSet
resumeHeartbeating() - Method in class org.apache.nifi.cluster.integration.Node
resumeHeartbeats() - Method in class org.apache.nifi.controller.FlowController: Notifies controller that the sending of heartbeats should be re-enabled.
resumeWork(Connectable) - Method in class org.apache.nifi.controller.EventDrivenWorkerQueue
resumeWork(Connectable) - Method in interface org.apache.nifi.controller.WorkerQueue
RETAIN_VALIDATOR - Static variable in class org.apache.nifi.processors.mqtt.common.AbstractMQTTProcessor
retainConsumers() - Method in class org.apache.nifi.processors.kafka.pubsub.ConsumerPool
RETHINKDB_DELETE_RESULT_DELETED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETHINKDB_DELETE_RESULT_ERROR_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETHINKDB_DELETE_RESULT_INSERTED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETHINKDB_DELETE_RESULT_REPLACED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETHINKDB_DELETE_RESULT_SKIPPED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETHINKDB_DELETE_RESULT_UNCHANGED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETHINKDB_INSERT_RESULT - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_DELETED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_ERROR_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_FIRST_ERROR_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_GENERATED_KEYS_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_INSERTED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_REPLACED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_SKIPPED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_UNCHANGED_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETHINKDB_INSERT_RESULT_WARNINGS_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
RETRIES - Static variable in class org.apache.nifi.processors.gcp.storage.AbstractGCSIT
RETRIEVE_ALL_RECORDS - Static variable in class org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL
retrieveLineageSubmission(String, NiFiUser) - Method in interface org.apache.nifi.provenance.index.EventIndex: Retrieves the ComputeLineageSubmission that was returned by the 'submitLineageComputation' methods
retrieveLineageSubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex
retrieveLineageSubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.MockProvenanceRepository
retrieveLineageSubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
retrieveLineageSubmission(String, NiFiUser) - Method in interface org.apache.nifi.provenance.ProvenanceRepository
retrieveLineageSubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.VolatileProvenanceRepository
retrieveLineageSubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.WriteAheadProvenanceRepository
retrieveQuerySubmission(String, NiFiUser) - Method in interface org.apache.nifi.provenance.index.EventIndex: Retrieves the QuerySubmission that was returned by the 'submitQuery' method
retrieveQuerySubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.index.lucene.LuceneEventIndex
retrieveQuerySubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.MockProvenanceRepository
retrieveQuerySubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.PersistentProvenanceRepository
retrieveQuerySubmission(String, NiFiUser) - Method in interface org.apache.nifi.provenance.ProvenanceRepository
retrieveQuerySubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.VolatileProvenanceRepository
retrieveQuerySubmission(String, NiFiUser) - Method in class org.apache.nifi.provenance.WriteAheadProvenanceRepository
retrieveSchema(String) - Method in class org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry
retrieveSchema(long, int) - Method in class org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry
retrieveSchema(String) - Method in class org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry
retrieveSchema(long, int) - Method in class org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry
retrieveSchema(String) - Method in class org.apache.nifi.schemaregistry.services.AvroSchemaRegistry
retrieveSchema(long, int) - Method in class org.apache.nifi.schemaregistry.services.AvroSchemaRegistry
retrieveSchema(String) - Method in interface org.apache.nifi.schemaregistry.services.SchemaRegistry: Retrieves and returns the RecordSchema based on the provided name of the schema available in Schema Registry.
retrieveSchema(long, int) - Method in interface org.apache.nifi.schemaregistry.services.SchemaRegistry: Retrieves the schema with the given ID and version.
retrieveSchema(String) - Method in class org.apache.nifi.serialization.record.MockSchemaRegistry
retrieveSchema(long, int) - Method in class org.apache.nifi.serialization.record.MockSchemaRegistry
retrieveSchemaText(String) - Method in class org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry
retrieveSchemaText(long, int) - Method in class org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry
retrieveSchemaText(String) - Method in class org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry
retrieveSchemaText(long, int) - Method in class org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry
retrieveSchemaText(String) - Method in class org.apache.nifi.schemaregistry.services.AvroSchemaRegistry
retrieveSchemaText(long, int) - Method in class org.apache.nifi.schemaregistry.services.AvroSchemaRegistry
retrieveSchemaText(String) - Method in interface org.apache.nifi.schemaregistry.services.SchemaRegistry: Retrieves and returns the textual representation of the schema based on the provided name of the schema available in Schema Registry.
retrieveSchemaText(long, int) - Method in interface org.apache.nifi.schemaregistry.services.SchemaRegistry: Retrieves the textual representation of the schema with the given ID and version
retrieveSchemaText(String) - Method in class org.apache.nifi.serialization.record.MockSchemaRegistry
retrieveSchemaText(long, int) - Method in class org.apache.nifi.serialization.record.MockSchemaRegistry
RETRY_COUNT - Static variable in class org.apache.nifi.processors.gcp.AbstractGCPProcessor
RetryableException - Exception in org.apache.nifi.processors.elasticsearch: Represents a retryable exception from ElasticSearch.
RetryableException() - Constructor for exception org.apache.nifi.processors.elasticsearch.RetryableException
RetryableException(String, Throwable) - Constructor for exception org.apache.nifi.processors.elasticsearch.RetryableException
RetryableException(String) - Constructor for exception org.apache.nifi.processors.elasticsearch.RetryableException
RetryableException(Throwable) - Constructor for exception org.apache.nifi.processors.elasticsearch.RetryableException
RETURN_CHANGES - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETURN_CHANGES_FALSE - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETURN_CHANGES_OPTION_KEY - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETURN_CHANGES_TRUE - Static variable in class org.apache.nifi.processors.rethinkdb.DeleteRethinkDB
RETURN_FIELDS - Static variable in class org.apache.nifi.processors.solr.GetSolr
RETURN_TYPE - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
RETURN_TYPE - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
RETURN_TYPE_AUTO - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
RETURN_TYPE_AUTO - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
RETURN_TYPE_JSON - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
RETURN_TYPE_NODESET - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
RETURN_TYPE_SCALAR - Static variable in class org.apache.nifi.processors.standard.EvaluateJsonPath
RETURN_TYPE_STRING - Static variable in class org.apache.nifi.processors.standard.EvaluateXPath
returnBuffer(ByteBuffer, int) - Method in class org.apache.nifi.io.nio.BufferPool: Returns the given buffer to the pool - and clears it.
returnIndexSearcher(EventIndexSearcher) - Method in class org.apache.nifi.provenance.lucene.CachingIndexManager
returnIndexSearcher(EventIndexSearcher) - Method in interface org.apache.nifi.provenance.lucene.IndexManager
returnIndexSearcher(EventIndexSearcher) - Method in class org.apache.nifi.provenance.lucene.SimpleIndexManager
returnIndexWriter(EventIndexWriter) - Method in class org.apache.nifi.provenance.lucene.CachingIndexManager
returnIndexWriter(EventIndexWriter, boolean, boolean) - Method in class org.apache.nifi.provenance.lucene.CachingIndexManager
returnIndexWriter(EventIndexWriter, boolean, boolean) - Method in interface org.apache.nifi.provenance.lucene.IndexManager
returnIndexWriter(EventIndexWriter) - Method in interface org.apache.nifi.provenance.lucene.IndexManager
returnIndexWriter(EventIndexWriter) - Method in class org.apache.nifi.provenance.lucene.SimpleIndexManager
returnIndexWriter(EventIndexWriter, boolean, boolean) - Method in class org.apache.nifi.provenance.lucene.SimpleIndexManager
Revision - Class in org.apache.nifi.web: A model object representing a revision.
Revision(Long, String, String) - Constructor for class org.apache.nifi.web.Revision
RevisionClaim - Interface in org.apache.nifi.web.revision
RevisionComparator - Class in org.apache.nifi.web.revision
RevisionComparator() - Constructor for class org.apache.nifi.web.revision.RevisionComparator
RevisionDTO - Class in org.apache.nifi.web.api.dto: Current revision for this NiFi.
RevisionDTO() - Constructor for class org.apache.nifi.web.api.dto.RevisionDTO
RevisionLockResult - Enum in org.apache.nifi.web.revision
RevisionManager - Interface in org.apache.nifi.web.revision: A Revision Manager provides the ability to prevent clients of the Web API from stepping on one another.
RevisionUpdate<T> - Interface in org.apache.nifi.web.revision: A packaging of a Component's DTO and the corresponding Revision for that component
RIEMANN_HOST - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
RIEMANN_PORT - Static variable in class org.apache.nifi.processors.riemann.PutRiemann
riemannClient - Variable in class org.apache.nifi.processors.riemann.PutRiemann
RingBuffer<T> - Class in org.apache.nifi.util: Thread-safe implementation of a RingBuffer
RingBuffer(int) - Constructor for class org.apache.nifi.util.RingBuffer
RingBuffer.Filter<S> - Interface in org.apache.nifi.util
RingBuffer.ForEachEvaluator<S> - Interface in org.apache.nifi.util: Defines an interface that can be used to iterate over all of the elements in the RingBuffer via the RingBuffer.forEach(org.apache.nifi.util.RingBuffer.ForEachEvaluator<T>) method
RingBuffer.IterationDirection - Enum in org.apache.nifi.util
RingBufferEventRepository - Class in org.apache.nifi.controller.repository.metrics
RingBufferEventRepository(int) - Constructor for class org.apache.nifi.controller.repository.metrics.RingBufferEventRepository
RingBufferEventRepositoryBean - Class in org.apache.nifi.spring
RingBufferEventRepositoryBean() - Constructor for class org.apache.nifi.spring.RingBufferEventRepositoryBean
Role - Enum in org.apache.nifi.authorization: Legacy Roles prior to the new authorization model.
RoleAccessPolicy - Class in org.apache.nifi.authorization: Defines the mapping from legacy roles to access policies.
rollback(Connection, Logger) - Static method in class org.apache.nifi.admin.RepositoryUtils
rollback() - Method in class org.apache.nifi.admin.service.transaction.impl.StandardTransaction
rollback() - Method in interface org.apache.nifi.admin.service.transaction.Transaction: Rolls back the current transaction.
rollback() - Method in class org.apache.nifi.controller.repository.StandardProcessSession
rollback(boolean) - Method in class org.apache.nifi.controller.repository.StandardProcessSession
rollback() - Method in interface org.apache.nifi.processor.ProcessSession: Reverts any changes made during this session.
rollback(boolean) - Method in interface org.apache.nifi.processor.ProcessSession: Reverts any changes made during this session.
rollback(ProcessSession, Throwable) - Method in interface org.apache.nifi.processor.util.pattern.PartialFunctions.RollbackSession
rollback() - Method in class org.apache.nifi.processors.standard.merge.RecordBin
rollback() - Method in class org.apache.nifi.util.MockProcessSession
rollback(boolean) - Method in class org.apache.nifi.util.MockProcessSession
ROLLBACK_ON_FAILURE - Static variable in class org.apache.nifi.processor.util.pattern.RollbackOnFailure
ROLLBACK_ON_FAILURE - Static variable in class org.apache.nifi.processors.hive.PutHiveStreaming
rollbackClonedPolicies(FlowSnippetDTO) - Method in class org.apache.nifi.web.util.SnippetUtils: Attempts to roll back and in the specified snippet.
RollbackOnFailure - Class in org.apache.nifi.processor.util.pattern: RollbackOnFailure can be used as a function context for process patterns such as Put to provide a configurable error handling.
RollbackOnFailure(boolean, boolean) - Constructor for class org.apache.nifi.processor.util.pattern.RollbackOnFailure: Constructor.
ROLLING_WINDOW_COUNT_KEY - Static variable in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
ROLLING_WINDOW_MEAN_KEY - Static variable in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
ROLLING_WINDOW_VALUE_KEY - Static variable in class org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow
ROOT_GROUP_ID_ALIAS - Static variable in class org.apache.nifi.controller.FlowController
rootGroup - Variable in class org.apache.nifi.remote.protocol.AbstractFlowFileServerProtocol
RootGroupPort - Interface in org.apache.nifi.remote
RootGroupPortAuthorizable - Interface in org.apache.nifi.authorization: Authorizable for a RootGroupPort.
RootNode - Class in org.apache.nifi.processors.evtx.parser.bxml: Node that contains children and substitutions
RootNode(BinaryReader, ChunkHeader, BxmlNode) - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.RootNode
RootNode.VariantTypeSizeAndFactory - Class in org.apache.nifi.processors.evtx.parser.bxml
RootNodeHandler - Interface in org.apache.nifi.processors.evtx
RootNodeHandlerFactory - Interface in org.apache.nifi.processors.evtx
RootNodeTest - Class in org.apache.nifi.processors.evtx.parser.bxml
RootNodeTest() - Constructor for class org.apache.nifi.processors.evtx.parser.bxml.RootNodeTest
RootPath - Class in org.apache.nifi.record.path.paths
RootPath() - Constructor for class org.apache.nifi.record.path.paths.RootPath
RoundRobinPartitioner() - Constructor for class org.apache.nifi.processors.kafka.Partitioners.RoundRobinPartitioner
RoundRobinPartitioner() - Constructor for class org.apache.nifi.processors.kafka.pubsub.Partitioners.RoundRobinPartitioner
route(FlowFile, Relationship) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
route(FlowFile, Relationship, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
route(FlowFile, Relationship, String) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
route(FlowFile, Relationship, String, long) - Method in class org.apache.nifi.controller.repository.StandardProvenanceReporter
route(Record, RecordSchema, FlowFile, ProcessContext, T) - Method in class org.apache.nifi.processors.standard.AbstractRouteRecord
route(Record, RecordSchema, FlowFile, ProcessContext, Tuple<Map<String, RecordPath>, RecordPath>) - Method in class org.apache.nifi.processors.standard.LookupRecord
route(FlowFile, Relationship) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type ROUTE that indicates that the given FlowFile was routed to the given Relationship.
route(FlowFile, Relationship, String) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type ROUTE that indicates that the given FlowFile was routed to the given Relationship.
route(FlowFile, Relationship, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type ROUTE that indicates that the given FlowFile was routed to the given Relationship.
route(FlowFile, Relationship, String, long) - Method in interface org.apache.nifi.provenance.ProvenanceReporter: Emits a Provenance Event of type ROUTE that indicates that the given FlowFile was routed to the given Relationship.
route(FlowFile, Relationship) - Method in class org.apache.nifi.util.MockProvenanceReporter
route(FlowFile, Relationship, long) - Method in class org.apache.nifi.util.MockProvenanceReporter
route(FlowFile, Relationship, String) - Method in class org.apache.nifi.util.MockProvenanceReporter
route(FlowFile, Relationship, String, long) - Method in class org.apache.nifi.util.MockProvenanceReporter
ROUTE_ALL_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
ROUTE_ANY_MATCHES - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
ROUTE_ATTRIBUTE_KEY - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
ROUTE_ATTRIBUTE_KEY - Static variable in class org.apache.nifi.processors.standard.RouteOnContent
ROUTE_ATTRIBUTE_KEY - Static variable in class org.apache.nifi.processors.standard.RouteText
ROUTE_PROPERTY_NAME - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
ROUTE_STRATEGY - Static variable in class org.apache.nifi.processors.standard.RouteOnAttribute
ROUTE_STRATEGY - Static variable in class org.apache.nifi.processors.standard.RouteText
ROUTE_TO_MATCHED_WHEN_ALL_PROPERTIES_MATCH - Static variable in class org.apache.nifi.processors.standard.RouteText
ROUTE_TO_MATCHED_WHEN_ANY_PROPERTY_MATCHES - Static variable in class org.apache.nifi.processors.standard.RouteText
ROUTE_TO_MATCHING_PROPERTY_NAME - Static variable in class org.apache.nifi.processors.standard.RouteText
RouteHL7 - Class in org.apache.nifi.processors.hl7
RouteHL7() - Constructor for class org.apache.nifi.processors.hl7.RouteHL7
RouteOnAttribute - Class in org.apache.nifi.processors.standard: This processor routes a FlowFile based on its flow file attributes by using the Attribute Expression Language.
RouteOnAttribute() - Constructor for class org.apache.nifi.processors.standard.RouteOnAttribute
RouteOnContent - Class in org.apache.nifi.processors.standard
RouteOnContent() - Constructor for class org.apache.nifi.processors.standard.RouteOnContent
routers - Variable in class org.apache.nifi.websocket.AbstractWebSocketService
RouteText - Class in org.apache.nifi.processors.standard
RouteText() - Constructor for class org.apache.nifi.processors.standard.RouteText
routeTo(FlowFile, Relationship) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult
routeTo(List<FlowFile>, Relationship) - Method in class org.apache.nifi.processor.util.pattern.RoutingResult
ROUTING_KEY - Static variable in class org.apache.nifi.amqp.processors.PublishAMQP
RoutingResult - Class in org.apache.nifi.processor.util.pattern
RoutingResult() - Constructor for class org.apache.nifi.processor.util.pattern.RoutingResult
RoutingWebSocketListener - Class in org.apache.nifi.websocket.jetty
RoutingWebSocketListener(WebSocketMessageRouter) - Constructor for class org.apache.nifi.websocket.jetty.RoutingWebSocketListener
ROW_FIELD_NAME - Static variable in class org.apache.nifi.hbase.PutHBaseJSON
ROW_FIELD_NAME - Static variable in class org.apache.nifi.hbase.PutHBaseRecord
ROW_GROUP_SIZE - Static variable in class org.apache.nifi.processors.parquet.PutParquet
ROW_ID - Static variable in class org.apache.nifi.hbase.AbstractPutHBase
ROW_ID_ENCODING_BINARY - Static variable in class org.apache.nifi.hbase.AbstractPutHBase
ROW_ID_ENCODING_STRING - Static variable in class org.apache.nifi.hbase.AbstractPutHBase
ROW_ID_PREFIX - Static variable in class org.apache.nifi.hbase.GetHBase.ScanResult.StateKeys
ROW_NUM - Static variable in class org.apache.nifi.processors.poi.ConvertExcelToCSVProcessor
RowEventException - Exception in org.apache.nifi.cdc.event: A marker class for Exceptions that occur during the handling of CDC row modification events
RowEventException() - Constructor for exception org.apache.nifi.cdc.event.RowEventException
RowEventException(String) - Constructor for exception org.apache.nifi.cdc.event.RowEventException
RowEventException(String, Throwable) - Constructor for exception org.apache.nifi.cdc.event.RowEventException
RowEventException(Throwable) - Constructor for exception org.apache.nifi.cdc.event.RowEventException
RowEventInfo<RowEventDataType> - Interface in org.apache.nifi.cdc.event: An interface corresponding to row-level info from events on tabular data structures.
rows - Variable in class org.apache.nifi.cdc.event.BaseRowEventInfo
RowSerializer - Interface in org.apache.nifi.hbase.io
RowSerializerUtil - Class in org.apache.nifi.hbase.util
RowSerializerUtil() - Constructor for class org.apache.nifi.hbase.util.RowSerializerUtil
RSP_CMD - Static variable in class org.apache.nifi.processors.standard.relp.response.RELPResponse
Rule - Class in org.apache.nifi.update.attributes
Rule() - Constructor for class org.apache.nifi.update.attributes.Rule
RuleDTO - Class in org.apache.nifi.update.attributes.dto
RuleDTO() - Constructor for class org.apache.nifi.update.attributes.dto.RuleDTO
RuleEntity - Class in org.apache.nifi.update.attributes.entity
RuleEntity() - Constructor for class org.apache.nifi.update.attributes.entity.RuleEntity
RuleResource - Class in org.apache.nifi.update.attributes.api
RuleResource() - Constructor for class org.apache.nifi.update.attributes.api.RuleResource
RulesEntity - Class in org.apache.nifi.update.attributes.entity
RulesEntity() - Constructor for class org.apache.nifi.update.attributes.entity.RulesEntity
run() - Method in class org.apache.nifi.bootstrap.ShutdownHook
run() - Method in class org.apache.nifi.controller.tasks.ExpireFlowFiles
run() - Method in class org.apache.nifi.controller.tasks.ReportingTaskWrapper
run() - Method in class org.apache.nifi.hadoop.KerberosTicketRenewer
run() - Method in class org.apache.nifi.io.nio.AbstractChannelReader
run() - Method in class org.apache.nifi.io.nio.BufferPool
run() - Method in class org.apache.nifi.io.nio.ChannelDispatcher
run() - Method in class org.apache.nifi.io.nio.example.ServerMain.ConsumerRunner
run() - Method in class org.apache.nifi.processor.util.listen.dispatcher.DatagramChannelDispatcher
run() - Method in class org.apache.nifi.processor.util.listen.dispatcher.SocketChannelDispatcher
run() - Method in class org.apache.nifi.processor.util.listen.handler.socket.SSLSocketChannelHandler
run() - Method in class org.apache.nifi.processor.util.listen.handler.socket.StandardSocketChannelHandler
run(List<String>) - Method in class org.apache.nifi.processors.beats.handler.TestBeatsSocketChannelHandler
run(List<String>) - Method in class org.apache.nifi.processors.lumberjack.handler.TestLumberjackSocketChannelHandler
run(List<String>) - Method in class org.apache.nifi.processors.standard.relp.handler.TestRELPSocketChannelHandler
run(List<RELPFrame>, int, int, SSLContextService) - Method in class org.apache.nifi.processors.standard.TestListenRELP
run() - Method in class org.apache.nifi.processors.standard.TestListenSyslog.DatagramSender
run() - Method in class org.apache.nifi.processors.standard.TestListenSyslog.MultiConnectionSocketSender
run() - Method in class org.apache.nifi.processors.standard.TestListenSyslog.SingleConnectionSocketSender
run(DatagramSocket, List<String>, int, int) - Method in class org.apache.nifi.processors.standard.TestListenUDP
run() - Method in class org.apache.nifi.processors.standard.UDPTestServer
run() - Method in class org.apache.nifi.processors.standard.util.TCPTestServer
run(RunNotifier) - Method in class org.apache.nifi.processors.windows.event.log.JNAOverridingJUnitRunner
run() - Method in class org.apache.nifi.provenance.index.lucene.EventIndexTask
run() - Method in class org.apache.nifi.provenance.index.lucene.LuceneCacheWarmer
run() - Method in class org.apache.nifi.provenance.index.lucene.QueryTask
run() - Method in class org.apache.nifi.provenance.serialization.EventFileCompressor
run() - Method in class org.apache.nifi.record.listen.SocketChannelRecordReaderDispatcher
run() - Method in class org.apache.nifi.util.StandardProcessorTestRunner
run(int) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
run(int, boolean) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
run(int, boolean, boolean) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
run(int, boolean, boolean, long) - Method in class org.apache.nifi.util.StandardProcessorTestRunner
run() - Method in interface org.apache.nifi.util.TestRunner: Performs exactly the same operation as calling TestRunner.run(int) with a value of 1.
run(int) - Method in interface org.apache.nifi.util.TestRunner: Performs the same operation as calling TestRunner.run(int, boolean) with a value of true
run(int, boolean) - Method in interface org.apache.nifi.util.TestRunner: performs the same operation as calling TestRunner.run(int, boolean, boolean) with a value of iterations, stopOnFinish, true
run(int, boolean, boolean) - Method in interface org.apache.nifi.util.TestRunner: This method runs the Processor iterations times, using the sequence of steps below: If initialize is true, run all methods on the Processor that are annotated with the @OnScheduled annotation.
run(int, boolean, boolean, long) - Method in interface org.apache.nifi.util.TestRunner: This method runs the Processor iterations times, using the sequence of steps below: If initialize is true, run all methods on the Processor that are annotated with the @OnScheduled annotation.
runAndAssertExitCode(Runnable, ExitCode) - Method in class org.apache.nifi.toolkit.tls.SystemExitCapturer
runInsert(Insert) - Method in class org.apache.nifi.processors.rethinkdb.PutRethinkDB
runner - Variable in class org.apache.nifi.processors.rethinkdb.ITAbstractRethinkDBTest
runner - Variable in class org.apache.nifi.processors.script.BaseScriptTest
runner - Variable in class org.apache.nifi.processors.standard.util.TestInvokeHttpCommon
runner - Variable in class org.apache.nifi.processors.standard.util.TestPutTCPCommon
RunNiFi - Class in org.apache.nifi.bootstrap: The class which bootstraps Apache NiFi.
RunNiFi(File, boolean) - Constructor for class org.apache.nifi.bootstrap.RunNiFi
RunStatus - Enum in org.apache.nifi.controller.status
runTCP(List<String>, int, SSLContext) - Method in class org.apache.nifi.processors.standard.TestListenTCP
runTCP(List<String>, int, SSLContext) - Method in class org.apache.nifi.processors.standard.TestListenTCPRecord

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