-
Processors
- AttributeRollingWindow
- AttributesToCSV
- AttributesToJSON
- CalculateRecordStats
- CaptureChangeMySQL
- CompressContent
- ConnectWebSocket
- ConsumeAMQP
- ConsumeAzureEventHub
- ConsumeElasticsearch
- ConsumeGCPubSub
- ConsumeIMAP
- ConsumeJMS
- ConsumeKafka
- ConsumeKinesisStream
- ConsumeMQTT
- ConsumePOP3
- ConsumeSlack
- ConsumeTwitter
- ConsumeWindowsEventLog
- ControlRate
- ConvertCharacterSet
- ConvertRecord
- CopyAzureBlobStorage_v12
- CopyS3Object
- CountText
- CryptographicHashContent
- DebugFlow
- DecryptContentAge
- DecryptContentPGP
- DeduplicateRecord
- DeleteAzureBlobStorage_v12
- DeleteAzureDataLakeStorage
- DeleteByQueryElasticsearch
- DeleteDynamoDB
- DeleteFile
- DeleteGCSObject
- DeleteGridFS
- DeleteMongo
- DeleteS3Object
- DeleteSFTP
- DeleteSQS
- DetectDuplicate
- DistributeLoad
- DuplicateFlowFile
- EncodeContent
- EncryptContentAge
- EncryptContentPGP
- EnforceOrder
- EvaluateJsonPath
- EvaluateXPath
- EvaluateXQuery
- ExecuteGroovyScript
- ExecuteProcess
- ExecuteScript
- ExecuteSQL
- ExecuteSQLRecord
- ExecuteStreamCommand
- ExtractAvroMetadata
- ExtractEmailAttachments
- ExtractEmailHeaders
- ExtractGrok
- ExtractHL7Attributes
- ExtractRecordSchema
- ExtractText
- FetchAzureBlobStorage_v12
- FetchAzureDataLakeStorage
- FetchBoxFile
- FetchDistributedMapCache
- FetchDropbox
- FetchFile
- FetchFTP
- FetchGCSObject
- FetchGoogleDrive
- FetchGridFS
- FetchS3Object
- FetchSFTP
- FetchSmb
- FilterAttribute
- FlattenJson
- ForkEnrichment
- ForkRecord
- GenerateFlowFile
- GenerateRecord
- GenerateTableFetch
- GeoEnrichIP
- GeoEnrichIPRecord
- GeohashRecord
- GetAsanaObject
- GetAwsPollyJobStatus
- GetAwsTextractJobStatus
- GetAwsTranscribeJobStatus
- GetAwsTranslateJobStatus
- GetAzureEventHub
- GetAzureQueueStorage_v12
- GetDynamoDB
- GetElasticsearch
- GetFile
- GetFTP
- GetGcpVisionAnnotateFilesOperationStatus
- GetGcpVisionAnnotateImagesOperationStatus
- GetHubSpot
- GetMongo
- GetMongoRecord
- GetS3ObjectMetadata
- GetSFTP
- GetShopify
- GetSmbFile
- GetSNMP
- GetSplunk
- GetSQS
- GetWorkdayReport
- GetZendesk
- HandleHttpRequest
- HandleHttpResponse
- IdentifyMimeType
- InvokeHTTP
- InvokeScriptedProcessor
- ISPEnrichIP
- JoinEnrichment
- JoltTransformJSON
- JoltTransformRecord
- JSLTTransformJSON
- JsonQueryElasticsearch
- ListAzureBlobStorage_v12
- ListAzureDataLakeStorage
- ListBoxFile
- ListDatabaseTables
- ListDropbox
- ListenFTP
- ListenHTTP
- ListenOTLP
- ListenSlack
- ListenSyslog
- ListenTCP
- ListenTrapSNMP
- ListenUDP
- ListenUDPRecord
- ListenWebSocket
- ListFile
- ListFTP
- ListGCSBucket
- ListGoogleDrive
- ListS3
- ListSFTP
- ListSmb
- LogAttribute
- LogMessage
- LookupAttribute
- LookupRecord
- MergeContent
- MergeRecord
- ModifyBytes
- ModifyCompression
- MonitorActivity
- MoveAzureDataLakeStorage
- Notify
- PackageFlowFile
- PaginatedJsonQueryElasticsearch
- ParseEvtx
- ParseNetflowv5
- ParseSyslog
- ParseSyslog5424
- PartitionRecord
- PublishAMQP
- PublishGCPubSub
- PublishJMS
- PublishKafka
- PublishMQTT
- PublishSlack
- PutAzureBlobStorage_v12
- PutAzureCosmosDBRecord
- PutAzureDataExplorer
- PutAzureDataLakeStorage
- PutAzureEventHub
- PutAzureQueueStorage_v12
- PutBigQuery
- PutBoxFile
- PutCloudWatchMetric
- PutDatabaseRecord
- PutDistributedMapCache
- PutDropbox
- PutDynamoDB
- PutDynamoDBRecord
- PutElasticsearchJson
- PutElasticsearchRecord
- PutEmail
- PutFile
- PutFTP
- PutGCSObject
- PutGoogleDrive
- PutGridFS
- PutKinesisFirehose
- PutKinesisStream
- PutLambda
- PutMongo
- PutMongoBulkOperations
- PutMongoRecord
- PutRecord
- PutRedisHashRecord
- PutS3Object
- PutSalesforceObject
- PutSFTP
- PutSmbFile
- PutSNS
- PutSplunk
- PutSplunkHTTP
- PutSQL
- PutSQS
- PutSyslog
- PutTCP
- PutUDP
- PutWebSocket
- PutZendeskTicket
- QueryAirtableTable
- QueryAzureDataExplorer
- QueryDatabaseTable
- QueryDatabaseTableRecord
- QueryRecord
- QuerySalesforceObject
- QuerySplunkIndexingStatus
- RemoveRecordField
- RenameRecordField
- ReplaceText
- ReplaceTextWithMapping
- RetryFlowFile
- RouteHL7
- RouteOnAttribute
- RouteOnContent
- RouteText
- RunMongoAggregation
- SampleRecord
- ScanAttribute
- ScanContent
- ScriptedFilterRecord
- ScriptedPartitionRecord
- ScriptedTransformRecord
- ScriptedValidateRecord
- SearchElasticsearch
- SegmentContent
- SendTrapSNMP
- SetSNMP
- SignContentPGP
- SplitAvro
- SplitContent
- SplitExcel
- SplitJson
- SplitPCAP
- SplitRecord
- SplitText
- SplitXml
- StartAwsPollyJob
- StartAwsTextractJob
- StartAwsTranscribeJob
- StartAwsTranslateJob
- StartGcpVisionAnnotateFilesOperation
- StartGcpVisionAnnotateImagesOperation
- TagS3Object
- TailFile
- TransformXml
- UnpackContent
- UpdateAttribute
- UpdateByQueryElasticsearch
- UpdateCounter
- UpdateDatabaseTable
- UpdateRecord
- ValidateCsv
- ValidateJson
- ValidateRecord
- ValidateXml
- VerifyContentMAC
- VerifyContentPGP
- Wait
-
Controller Services
- ADLSCredentialsControllerService
- ADLSCredentialsControllerServiceLookup
- AmazonGlueSchemaRegistry
- ApicurioSchemaRegistry
- AvroReader
- AvroRecordSetWriter
- AvroSchemaRegistry
- AWSCredentialsProviderControllerService
- AzureBlobStorageFileResourceService
- AzureCosmosDBClientService
- AzureDataLakeStorageFileResourceService
- AzureEventHubRecordSink
- AzureStorageCredentialsControllerService_v12
- AzureStorageCredentialsControllerServiceLookup_v12
- CEFReader
- ConfluentEncodedSchemaReferenceReader
- ConfluentEncodedSchemaReferenceWriter
- ConfluentSchemaRegistry
- CSVReader
- CSVRecordLookupService
- CSVRecordSetWriter
- DatabaseRecordLookupService
- DatabaseRecordSink
- DatabaseTableSchemaRegistry
- DBCPConnectionPool
- DBCPConnectionPoolLookup
- DistributedMapCacheLookupService
- ElasticSearchClientServiceImpl
- ElasticSearchLookupService
- ElasticSearchStringLookupService
- EmailRecordSink
- EmbeddedHazelcastCacheManager
- ExcelReader
- ExternalHazelcastCacheManager
- FreeFormTextRecordSetWriter
- GCPCredentialsControllerService
- GCSFileResourceService
- GrokReader
- HazelcastMapCacheClient
- HikariCPConnectionPool
- HttpRecordSink
- IPLookupService
- JettyWebSocketClient
- JettyWebSocketServer
- JMSConnectionFactoryProvider
- JndiJmsConnectionFactoryProvider
- JsonConfigBasedBoxClientService
- JsonPathReader
- JsonRecordSetWriter
- JsonTreeReader
- Kafka3ConnectionService
- KerberosKeytabUserService
- KerberosPasswordUserService
- KerberosTicketCacheUserService
- LoggingRecordSink
- MapCacheClientService
- MapCacheServer
- MongoDBControllerService
- MongoDBLookupService
- PropertiesFileLookupService
- ProtobufReader
- ReaderLookup
- RecordSetWriterLookup
- RecordSinkServiceLookup
- RedisConnectionPoolService
- RedisDistributedMapCacheClientService
- RestLookupService
- S3FileResourceService
- ScriptedLookupService
- ScriptedReader
- ScriptedRecordSetWriter
- ScriptedRecordSink
- SetCacheClientService
- SetCacheServer
- SimpleCsvFileLookupService
- SimpleDatabaseLookupService
- SimpleKeyValueLookupService
- SimpleRedisDistributedMapCacheClientService
- SimpleScriptedLookupService
- SiteToSiteReportingRecordSink
- SlackRecordSink
- SmbjClientProviderService
- StandardAsanaClientProviderService
- StandardAzureCredentialsControllerService
- StandardDropboxCredentialService
- StandardFileResourceService
- StandardHashiCorpVaultClientService
- StandardHttpContextMap
- StandardJsonSchemaRegistry
- StandardKustoIngestService
- StandardKustoQueryService
- StandardOauth2AccessTokenProvider
- StandardPGPPrivateKeyService
- StandardPGPPublicKeyService
- StandardPrivateKeyService
- StandardProxyConfigurationService
- StandardRestrictedSSLContextService
- StandardS3EncryptionService
- StandardSSLContextService
- StandardWebClientServiceProvider
- Syslog5424Reader
- SyslogReader
- UDPEventRecordSink
- VolatileSchemaCache
- WindowsEventLogReader
- XMLFileLookupService
- XMLReader
- XMLRecordSetWriter
- YamlTreeReader
- ZendeskRecordSink
RedisConnectionPoolService 2.0.0
- Bundle
- org.apache.nifi | nifi-redis-nar
- Description
- A service that provides connections to Redis.
- Tags
- cache, redis
- Input Requirement
- Supports Sensitive Dynamic Properties
- false
Properties
-
Cluster Max Redirects
The maximum number of redirects that can be performed when clustered.
- Display Name
- Cluster Max Redirects
- Description
- The maximum number of redirects that can be performed when clustered.
- API Name
- Cluster Max Redirects
- Default Value
- 5
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Communication Timeout
The timeout to use when attempting to communicate with Redis.
- Display Name
- Communication Timeout
- Description
- The timeout to use when attempting to communicate with Redis.
- API Name
- Communication Timeout
- Default Value
- 10 seconds
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Connection String
The connection string for Redis. In a standalone instance this value will be of the form hostname:port. In a sentinel instance this value will be the comma-separated list of sentinels, such as host1:port1,host2:port2,host3:port3. In a clustered instance this value will be the comma-separated list of cluster masters, such as host1:port,host2:port,host3:port.
- Display Name
- Connection String
- Description
- The connection string for Redis. In a standalone instance this value will be of the form hostname:port. In a sentinel instance this value will be the comma-separated list of sentinels, such as host1:port1,host2:port2,host3:port3. In a clustered instance this value will be the comma-separated list of cluster masters, such as host1:port,host2:port,host3:port.
- API Name
- Connection String
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
-
Database Index
The database index to be used by connections created from this connection pool. See the databases property in redis.conf, by default databases 0-15 will be available.
- Display Name
- Database Index
- Description
- The database index to be used by connections created from this connection pool. See the databases property in redis.conf, by default databases 0-15 will be available.
- API Name
- Database Index
- Default Value
- 0
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- true
-
Password
The password used to authenticate to the Redis server. See the 'requirepass' property in redis.conf.
- Display Name
- Password
- Description
- The password used to authenticate to the Redis server. See the 'requirepass' property in redis.conf.
- API Name
- Password
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- true
- Required
- false
-
Pool - Block When Exhausted
Whether or not clients should block and wait when trying to obtain a connection from the pool when the pool has no available connections. Setting this to false means an error will occur immediately when a client requests a connection and none are available.
- Display Name
- Pool - Block When Exhausted
- Description
- Whether or not clients should block and wait when trying to obtain a connection from the pool when the pool has no available connections. Setting this to false means an error will occur immediately when a client requests a connection and none are available.
- API Name
- Pool - Block When Exhausted
- Default Value
- true
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Max Idle
The maximum number of idle connections that can be held in the pool, or a negative value if there is no limit.
- Display Name
- Pool - Max Idle
- Description
- The maximum number of idle connections that can be held in the pool, or a negative value if there is no limit.
- API Name
- Pool - Max Idle
- Default Value
- 8
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Max Total
The maximum number of connections that can be allocated by the pool (checked out to clients, or idle awaiting checkout). A negative value indicates that there is no limit.
- Display Name
- Pool - Max Total
- Description
- The maximum number of connections that can be allocated by the pool (checked out to clients, or idle awaiting checkout). A negative value indicates that there is no limit.
- API Name
- Pool - Max Total
- Default Value
- 8
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Max Wait Time
The amount of time to wait for an available connection when Block When Exhausted is set to true.
- Display Name
- Pool - Max Wait Time
- Description
- The amount of time to wait for an available connection when Block When Exhausted is set to true.
- API Name
- Pool - Max Wait Time
- Default Value
- 10 seconds
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Min Evictable Idle Time
The minimum amount of time an object may sit idle in the pool before it is eligible for eviction.
- Display Name
- Pool - Min Evictable Idle Time
- Description
- The minimum amount of time an object may sit idle in the pool before it is eligible for eviction.
- API Name
- Pool - Min Evictable Idle Time
- Default Value
- 60 seconds
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Min Idle
The target for the minimum number of idle connections to maintain in the pool. If the configured value of Min Idle is greater than the configured value for Max Idle, then the value of Max Idle will be used instead.
- Display Name
- Pool - Min Idle
- Description
- The target for the minimum number of idle connections to maintain in the pool. If the configured value of Min Idle is greater than the configured value for Max Idle, then the value of Max Idle will be used instead.
- API Name
- Pool - Min Idle
- Default Value
- 0
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Num Tests Per Eviction Run
The number of connections to tests per eviction attempt. A negative value indicates to test all connections.
- Display Name
- Pool - Num Tests Per Eviction Run
- Description
- The number of connections to tests per eviction attempt. A negative value indicates to test all connections.
- API Name
- Pool - Num Tests Per Eviction Run
- Default Value
- -1
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Test On Borrow
Whether or not connections should be tested upon borrowing from the pool.
- Display Name
- Pool - Test On Borrow
- Description
- Whether or not connections should be tested upon borrowing from the pool.
- API Name
- Pool - Test On Borrow
- Default Value
- false
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Test On Create
Whether or not connections should be tested upon creation.
- Display Name
- Pool - Test On Create
- Description
- Whether or not connections should be tested upon creation.
- API Name
- Pool - Test On Create
- Default Value
- false
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Test On Return
Whether or not connections should be tested upon returning to the pool.
- Display Name
- Pool - Test On Return
- Description
- Whether or not connections should be tested upon returning to the pool.
- API Name
- Pool - Test On Return
- Default Value
- false
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Test While Idle
Whether or not connections should be tested while idle.
- Display Name
- Pool - Test While Idle
- Description
- Whether or not connections should be tested while idle.
- API Name
- Pool - Test While Idle
- Default Value
- true
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Pool - Time Between Eviction Runs
The amount of time between attempting to evict idle connections from the pool.
- Display Name
- Pool - Time Between Eviction Runs
- Description
- The amount of time between attempting to evict idle connections from the pool.
- API Name
- Pool - Time Between Eviction Runs
- Default Value
- 30 seconds
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Redis Mode
The type of Redis being communicated with - standalone, sentinel, or clustered.
- Display Name
- Redis Mode
- Description
- The type of Redis being communicated with - standalone, sentinel, or clustered.
- API Name
- Redis Mode
- Default Value
- Standalone
- Allowable Values
-
- Standalone
- Sentinel
- Cluster
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Sentinel Master
The name of the sentinel master, require when Mode is set to Sentinel
- Display Name
- Sentinel Master
- Description
- The name of the sentinel master, require when Mode is set to Sentinel
- API Name
- Sentinel Master
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- false
-
Sentinel Password
The password used to authenticate to the Redis Sentinel server. See the 'requirepass' and 'sentinel sentinel-pass' properties in sentinel.conf.
- Display Name
- Sentinel Password
- Description
- The password used to authenticate to the Redis Sentinel server. See the 'requirepass' and 'sentinel sentinel-pass' properties in sentinel.conf.
- API Name
- Sentinel Password
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- true
- Required
- false
-
Sentinel Username
The username used to authenticate to the Redis sentinel server.
- Display Name
- Sentinel Username
- Description
- The username used to authenticate to the Redis sentinel server.
- API Name
- Sentinel Username
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- false
-
SSL Context Service
If specified, this service will be used to create an SSL Context that will be used to secure communications; if not specified, communications will not be secure
- Display Name
- SSL Context Service
- Description
- If specified, this service will be used to create an SSL Context that will be used to secure communications; if not specified, communications will not be secure
- API Name
- SSL Context Service
- Service Interface
- org.apache.nifi.ssl.RestrictedSSLContextService
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
Username
The username used to authenticate to the Redis server.
- Display Name
- Username
- Description
- The username used to authenticate to the Redis server.
- API Name
- Username
- Expression Language Scope
- Environment variables defined at JVM level and system properties
- Sensitive
- false
- Required
- false