Learn about the NiFi Processors supported by Cloudera Support.
Additional Processors are developed and tested by the Cloudera community but are not officially
supported by Cloudera. Processors are excluded for a variety of reasons, including insufficient
reliability or incomplete test case coverage, declaration of non-production readiness by the
community at large, and feature deviation from Cloudera best practices. Do not use these features
in your production environments.
Supported processors
-
AttributesToCSV
-
AttributesToJSON
-
Base64EncodeContent
-
CalculateRecordStats
-
CaptureChangeMySQL
-
CompressContent
-
ConnectWebSocket
-
ConsumeAMQP
-
ConsumeAzureEventHub
-
ConsumeEWS
-
ConsumeGCPubSub
-
ConsumeJMS
-
ConsumeKafka
-
ConsumeKafka_0_10
-
ConsumeKafka_1_0
-
ConsumeKafka_2_0
-
ConsumeKafkaRecord_0_10
-
ConsumeKafkaRecord_1_0
-
ConsumeKafkaRecord_2_0
-
ConsumeMQTT
-
ConsumeWindowsEventLog
-
ControlRate
-
ConvertAvroSchema
-
ConvertAvroToJSON
-
ConvertAvroToORC
-
ConvertAvroToParquet
-
ConvertCharacterSet
-
ConvertCSVToAvro
-
ConvertJSONToAvro
-
ConvertJSONToSQL
-
ConvertRecord
-
CreateHadoopSequenceFile
-
CryptographicHashAttribute
-
CryptographicHashContent
-
DeleteAzureBlobStorage
-
DeleteAzureDataLakeStorage
-
DeleteByQueryElasticsearch
-
DeleteDynamoDB
-
DeleteElasticsearch5
-
DeleteGCSObject
-
DeleteGridFS
-
DeleteHBaseCells
-
DeleteHBaseRow
-
DeleteHDFS
-
DeleteS3Object
-
DeleteSQS
-
DetectDuplicate
-
DistributeLoad
-
DuplicateFlowFile
-
EncryptContent
-
EnforceOrder
-
EvaluateJsonPath
-
EvaluateXPath
-
EvaluateXQuery
-
ExecuteGroovyScript
-
ExecuteInfluxDBQuery
-
ExecuteProcess
-
ExecuteScript
-
ExecuteSQL
-
ExecuteSQLRecord
-
ExecuteStreamCommand
-
ExtractAvroMetadata
-
ExtractGrok
-
ExtractHL7Attributes
-
ExtractImageMetadata
-
ExtractText
-
FetchAzureBlobStorage
-
FetchDistributedMapCache
-
FetchElasticsearch
-
FetchElasticsearch5
-
FetchElasticsearchHttp
-
FetchFile
-
FetchFTP
-
FetchGCSObject
-
FetchGridFS
-
FetchHBaseRow
-
FetchHDFS
-
FetchParquet
-
FetchS3Object
-
FetchSFTP
-
FlattenJson
-
ForkRecord
-
GenerateFlowFile
-
GenerateTableFetch
-
GeoEnrichIP
|
-
GeoEnrichIPRecord
-
GetAzureEventHub
-
GetAzureQueueStorage
-
GetCouchbaseKey
-
GetFile
-
GetFTP
-
GetHBase
-
GetHDFS
-
GetHDFSFileInfo
-
GetHDFSSequenceFile
-
GetHTMLElement
-
GetHTTP
-
GetIgniteCache
-
GetJMSQueue
-
GetJMSTopic
-
GetKafka
-
GetMongoRecord
-
GetSFTP
-
GetSolr
-
GetSplunk
-
GetSQS
-
GetTCP
-
GetTwitter
-
HandleHttpRequest
-
HandleHttpResponse
-
HashAttribute
-
HashContent
-
IdentifyMimeType
-
InvokeAWSGatewayApi
-
InvokeHTTP
-
InvokeScriptedProcessor
-
JoltTransformJSON
-
JoltTransformRecord
-
JsonQueryElasticsearch
-
ListAzureBlobStorage
-
ListDatabaseTables
-
ListenHTTP
-
ListenRELP
-
ListenSyslog
-
ListenTCP
-
ListenTCPRecord
-
ListenUDP
-
ListenUDPRecord
-
ListenWebSocket
-
ListFile
-
ListFTP
-
ListGCSBucket
-
ListHDFS
-
ListS3
-
ListSFTP
-
LogAttribute
-
LogMessage
-
LookupAttribute
-
LookupRecord
-
MergeContent
-
MergeRecord
-
ModifyHTMLElement
-
MonitorActivity
-
Notify
-
ParseCEF
-
ParseEvtx
-
ParseSyslog
-
PartitionRecord
-
PostHTTP
-
PublishAMQP
-
PublishGCPubSub
-
PublishJMS
-
PublishKafka
-
PublishKafka_0_10
-
PublishKafka_1_0
-
PublishKafka_2_0
-
PublishKafkaRecord_0_10
-
PublishKafkaRecord_1_0
-
PublishKafkaRecord_2_0
-
PublishMQTT
-
PutAzureBlobStorage
-
PutAzureDataLakeStorage
-
PutAzureEventHub
-
PutAzureQueueStorage
-
PutBigQueryBatch
-
PutBigQueryStreaming
-
PutCassandraQL
-
PutCloudWatchMetric
-
PutCouchbaseKey
-
PutDatabaseRecord
|
|
