Supported NiFi processors
Learn about the NiFi processors supported by Cloudera that you can use with Cloudera DataFlow.
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.
NiFi 1.25
AttributesToCSV | GetElasticsearch | PutDropbox |
AttributesToJSON | GetFile | PutDynamoDB |
Base64EncodeContent | GetFTP | PutDynamoDBRecord |
CalculateParquetOffsets | GetGcpVisionAnnotateFilesOperationStatus | PutElasticsearchHttp |
CalculateParquetRowGroupOffsets | GetGcpVisionAnnotateImagesOperationStatus | PutElasticsearchHttpRecord |
CalculateRecordStats | GetHBase | PutElasticsearchJson |
CaptureChangeDebeziumDB2 [Technical Preview] | GetHDFS | PutElasticsearchRecord |
CaptureChangeDebeziumMySQL [Technical Preview] | GetHDFSFileInfo | PutEmail |
CaptureChangeDebeziumOracle [Technical Preview] | GetHDFSSequenceFile | PutFile |
CaptureChangeDebeziumPostgreSQL [Technical Preview] | GetHTMLElement | PutFTP |
CaptureChangeDebeziumSQLServer [Technical Preview] | GetHTTP | PutGCSObject |
CaptureChangeMySQL | GetHubSpot | PutGoogleDrive |
CompressContent | PutGridFS | |
ConnectWebSocket | GetJiraIssue | PutHBaseCell |
ConsumeAMQP | GetJMSQueue | PutHBaseJSON |
ConsumeAzureEventHub | GetJMSTopic | PutHBaseRecord |
ConsumeElasticsearch | GetMongoRecord | PutHDFS |
ConsumeEWS | GetSFTP | PutHive3QL |
ConsumeGCPubSub | GetShopify | PutHive3Streaming |
ConsumeGCPubSubLite | GetSNMP | |
ConsumeJMS | GetSnowflakeIngestStatus | |
GetSolr | PutHTMLElement | |
GetSplunk | PutIceberg | |
ConsumeKafka_2_6 | GetSQS | PutIcebergCDC [Technical Preview] |
ConsumeKafka2CDP | GetTCP | PutInfluxDB |
ConsumeKafka2RecordCDP | GetTwitter | PutJiraIssue |
GetWorkdayReport | PutJMS | |
GetZendesk | PutKinesisFirehose | |
ConsumeKafkaRecord_2_6 | HandleHttpRequest | PutKinesisStream |
ConsumeKinesisStream | HandleHttpResponse | PutKudu |
ConsumeMQTT | HashAttribute | PutLambda |
ConsumeTwitter | HashContent | PutMongoRecord |
ConsumeWindowsEventLog | IdentifyMimeType | PutORC |
ControlRate | InvokeAWSGatewayApi | PutParquet |
InvokeGRPC | PutRecord | |
ConvertAvroToJSON | InvokeGRPC | PutRedisHashRecord [Technical Preview] |
InvokeHTTP | PutRiemann | |
ConvertAvroToParquet | InvokeScriptedProcessor | PutS3Object |
ConvertCharacterSet | JoinEnrichment | PutSalesforceObject |
JoltTransformJSON | PutSFTP | |
JoltTransformRecord | PutSmbFile | |
ConvertJSONToSQL | JSLTTransformJSON | PutSnowflakeInternalStage |
ConvertProtobuf | JsonQueryElasticsearch | PutSNS |
ConvertRecord | ListAzureBlobStorage | PutSolrContentStream |
CreateHadoopSequenceFile | ListAzureBlobStorage_v12 | PutSolrRecord |
CryptographicHashAttribute | ListAzureDataLakeStorage | PutSplunk |
CryptographicHashContent | ListBoxFile | PutSplunkHTTP |
DecryptContent | ListCDPObjectStore | PutSQL |
DecryptContentAge | ListDatabaseTables | PutSQS |
DecryptContentCompatibility | ListDropbox | PutSyslog |
DecryptContentPGP | ListenBeats | PutTCP |
DeduplicateRecord | ListenFTP | PutUDP |
DeleteAzureBlobStorage | ListenGRPC | PutWebSocket |
DeleteAzureBlobStorage_v12 | ListenGRPC | PutZendeskTicket |
DeleteAzureDataLakeStorage | ListenHTTP | QueryAirtableTable |
DeleteByQueryElasticsearch | ListenNetFlow | QueryCassandra |
DeleteCDPObjectStore | ListenOTLP | QueryDatabaseTable |
DeleteDynamoDB | ListenRELP | QueryDatabaseTableRecord |
DeleteGCSObject | ListenSyslog | QueryElasticsearchHttp |
DeleteGridFS | ListenTCP | QueryRecord |
DeleteHBaseCells | ListenTCPRecord | QuerySalesforceObject |
DeleteHBaseRow | ListenTrapSNMP | QuerySolr |
DeleteHDFS | ListenUDP | QuerySplunkIndexingStatus |
DeleteS3Object | ListenUDPRecord | QueryWhois |
DeleteSQS | ListenWebSocket | RemoveRecordField |
DetectDuplicate | ListFile | ReplaceText |
DistributeLoad | ListFTP | ReplaceTextWithMapping |
DuplicateFlowFile | ListGCSBucket | ResizeImage |
EncodeContent | ListGoogleDrive | RetryFlowFile |
EncryptContent | ListHDFS | RouteHL7 |
EncryptContentAge | ListS3 | RouteOnAttribute |
EncryptContentPGP | ListSFTP | RouteOnContent |
EnforceOrder | ListSmb | RouteText |
EvaluateJsonPath | LogAttribute | SampleRecord |
EvaluateXPath | LogMessage | ScanAccumulo |
EvaluateXQuery | LookupAttribute | ScanAttribute |
ExecuteGroovyScript | LookupRecord | ScanContent |
ExecuteInfluxDBQuery | MergeContent | ScanHBase |
ExecuteProcess | MergeRecord | ScriptedFilterRecord |
ExecuteScript | ModifyCompression | ScriptedPartitionRecord |
ExecuteSQL | ModifyHTMLElement | ScriptedTransformRecord |
ExecuteSQLRecord | MonitorActivity | ScriptedValidateRecord |
ExecuteStateless | MoveAzureDataLakeStorage | ScrollElasticsearchHttp |
ExecuteStreamCommand | MoveHDFS | SearchElasticsearch |
ExtractAvroMetadata | Notify | SegmentContent |
ExtractGrok | PackageFlowFile | SelectClouderaHiveQL |
ExtractHL7Attributes | PaginatedJsonQueryElasticsearch | SelectHive3QL |
ExtractImageMetadata | ParseCEF | |
ExtractRecordSchema | ParseEvtx | SendTrapSNMP |
ExtractText | ParseSyslog | SetSNMP |
FetchAzureBlobStorage | PartitionRecord | SignContentPGP |
FetchAzureBlobStorage_v12 | PostHTTP | SplitAvro |
FetchAzureDataLakeStorage | PublishAMQP | SplitContent |
FetchBoxFile | PublishGCPubSub | SplitJson |
FetchCDPObjectStore | PublishGCPubSubLite | SplitRecord |
FetchDistributedMapCache | PublishJMS | SplitText |
FetchDropbox | SplitXml | |
FetchElasticsearchHttp | StartAwsPollyJob | |
FetchFile | PublishKafka_2_6 | StartAwsTextractJob |
FetchFTP | PublishKafka2CDP | StartAwsTranscribeJob |
FetchGCSObject | PublishKafka2RecordCDP | StartAwsTranslateJob |
FetchGoogleDrive | StartGcpVisionAnnotateFilesOperation | |
FetchGridFS | StartGcpVisionAnnotateImagesOperation | |
FetchHBaseRow | PublishKafkaRecord_2_6 | StartSnowflakeIngest |
FetchHDFS | PublishMQTT | TagS3Object |
FetchParquet | PublishSlack | TailFile |
FetchS3Object | PutAccumuloRecord | TransformXml |
FetchSFTP | PutAzureBlobStorage | TriggerClouderaHiveMetaStoreEvent |
FetchSmb | PutAzureBlobStorage_v12 | TriggerHiveMetaStoreEvent |
FilterAttribute | PutAzureCosmosDBRecord | UnpackContent |
FlattenJson | PutAzureDataLakeStorage | UpdateAttribute |
ForkEnrichment | PutAzureEventHub | UpdateByQueryElasticsearch |
ForkRecord | PutAzureQueueStorage | UpdateClouderaHiveTable |
GenerateFlowFile | PutAzureQueueStorage_v12 | UpdateCounter |
GenerateRecord | PutBigQuery | UpdateDatabaseTable |
GenerateTableFetch | PutBigQueryBatch | UpdateDeltaLakeTable [Technical Preview] |
GeoEnrichIP | PutBigQueryStreaming | UpdateHive3Table |
GeoEnrichIPRecord | PutBoxFile | |
GeohashRecord | PutCassandraQL | UpdateRecord |
GetAsanaObject | PutCassandraRecord | ValidateCsv |
GetAwsPollyJobStatus | PutCDPObjectStore | ValidateJson |
GetAwsTextractJobStatus | PutClouderaHiveQL | ValidateRecord |
GetAwsTranscribeJobStatus | PutClouderaHiveStreaming | ValidateXml |
GetAwsTranslateJobStatus | PutClouderaORC | VerifyContentMAC |
GetAzureEventHub | PutCloudWatchMetric | VerifyContentPGP |
GetAzureQueueStorage | PutCouchbaseKey | Wait |
GetAzureQueueStorage_v12 | PutDatabaseRecord | YandexTranslate |
GetCouchbaseKey | PutDistributedMapCache |
NiFi 2.0 [Technical Preview]
AttributesToCSV | GetCouchbaseKey | PutElasticsearchRecord |
AttributesToJSON | GetElasticsearch | PutEmail |
CalculateParquetOffsets | GetFile | PutFile |
CalculateParquetRowGroupOffsets | GetFTP | PutFTP |
CalculateRecordStats | GetGcpVisionAnnotateFilesOperationStatus | PutGCSObject |
CaptureChangeDebeziumDB2 [Technical Preview] | GetGcpVisionAnnotateImagesOperationStatus | PutGoogleDrive |
CaptureChangeDebeziumMySQL [Technical Preview] | GetHBase | PutGridFS |
CaptureChangeDebeziumOracle [Technical Preview] | GetHDFS | PutHBaseCell |
CaptureChangeDebeziumPostgreSQL [Technical Preview] | GetHDFSFileInfo | PutHBaseJSON |
CaptureChangeDebeziumSQLServer [Technical Preview] | GetHDFSSequenceFile | PutHBaseRecord |
CaptureChangeMySQL | GetHubSpot | PutHDFS |
ChunkDocument [Technical Preview] | GetJiraIssue | PutHive3QL |
CompressContent | GetMongoRecord | PutHive3Streaming |
ConnectWebSocket | GetSFTP | PutIceberg |
ConsumeAMQP | GetShopify | PutIcebergCDC [Technical Preview] |
ConsumeAzureEventHub | GetSNMP | PutJiraIssue |
ConsumeElasticsearch | GetSnowflakeIngestStatus | PutKinesisFirehose |
ConsumeGCPubSub | GetSolr | PutKinesisStream |
ConsumeGCPubSubLite | GetSplunk | PutKudu |
ConsumeJMS | GetSQS | PutLambda |
ConsumeKafka_2_6 | GetWorkdayReport | PutMongoBulkOperations |
ConsumeKafka2CDP | GetZendesk | PutMongoRecord |
ConsumeKafka2RecordCDP | HandleHttpRequest | PutORC |
ConsumeKafkaRecord_2_6 | HandleHttpResponse | PutParquet |
ConsumeKinesisStream | IdentifyMimeType | PutPinecone [Technical Preview] |
ConsumeMQTT | InvokeAWSGatewayApi | PutPLC [Technical Preview] |
ConsumePLC [Technical Preview] | InvokeGRPC | PutRecord |
ConsumeSlack | InvokeHTTP | PutRedisHashRecord [Technical Preview] |
ConsumeTwitter | InvokeScriptedProcessor | PutS3Object |
ConsumeWindowsEventLog | JoinEnrichment | PutSalesforceObject |
ControlRate | JoltTransformJSON | PutSFTP |
ConvertAvroToJSON | JoltTransformRecord | PutSmbFile |
ConvertAvroToParquet | JSLTTransformJSON | PutSnowflakeInternalStage |
ConvertCharacterSet | JsonQueryElasticsearch | PutSNS |
ConvertJSONToSQL | ListAzureBlobStorage_v12 | PutSolrContentStream |
ConvertProtobuf | ListAzureDataLakeStorage | PutSolrRecord |
ConvertRecord | ListBoxFile | PutSplunk |
CopyAzureBlobStorage_v12 | ListCDPObjectStore | PutSplunkHTTP |
CreateHadoopSequenceFile | ListDatabaseTables | PutSQL |
CryptographicHashContent | ListDropbox | PutSQS |
DecryptContent | ListenBeats | PutSyslog |
DecryptContentAge | ListenFTP | PutTCP |
DecryptContentCompatibility | ListenGRPC | PutUDP |
DecryptContentPGP | ListenHTTP | PutWebSocket |
DeduplicateRecord | ListenNetFlow | PutZendeskTicket |
DeleteAzureBlobStorage_v12 | ListenOTLP | QueryAirtableTable |
DeleteAzureDataLakeStorage | ListenRELP | QueryCassandra |
DeleteByQueryElasticsearch | ListenSlack | QueryChroma [Technical Preview] |
DeleteCDPObjectStore | ListenSyslog | QueryDatabaseTable |
DeleteDynamoDB | ListenTCP | QueryDatabaseTableRecord |
DeleteGCSObject | ListenTCPRecord | QueryPinecone [Technical Preview] |
DeleteGridFS | ListenTrapSNMP | QueryRecord |
DeleteHBaseCells | ListenUDP | QuerySalesforceObject |
DeleteHBaseRow | ListenUDPRecord | QuerySolr |
DeleteHDFS | ListenWebSocket | QuerySplunkIndexingStatus |
DeleteS3Object | ListFile | QueryWhois |
DeleteSQS | ListFTP | RemoveRecordField |
DetectDuplicate | ListGCSBucket | RenameRecordField |
DistributeLoad | ListGoogleDrive | ReplaceText |
DuplicateFlowFile | ListHDFS | ReplaceTextWithMapping |
EncodeContent | ListS3 | ResizeImage |
EncryptContentAge | ListSFTP | RetryFlowFile |
EncryptContentPGP | ListSmb | RouteHL7 |
EnforceOrder | LogAttribute | RouteOnAttribute |
EvaluateJsonPath | LogMessage | RouteOnContent |
EvaluateXPath | LookupAttribute | RouteText |
EvaluateXQuery | LookupRecord | SampleRecord |
ExecuteGroovyScript | MergeContent | ScanAccumulo |
ExecuteProcess | MergeRecord | ScanAttribute |
ExecuteScript | ModifyCompression | ScanContent |
ExecuteSQL | MonitorActivity | ScanHBase |
ExecuteSQLRecord | MoveAzureDataLakeStorage | ScriptedFilterRecord |
ExecuteStateless | MoveHDFS | ScriptedPartitionRecord |
ExecuteStreamCommand | Notify | ScriptedTransformRecord |
ExtractAvroMetadata | PackageFlowFile | ScriptedValidateRecord |
ExtractGrok | PaginatedJsonQueryElasticsearch | SearchElasticsearch |
ExtractHL7Attributes | ParseCEF | SegmentContent |
ExtractImageMetadata | ParseDocument [Technical Preview] | SelectClouderaHiveQL |
ExtractRecordSchema | ParseEvtx | SelectHive3QL |
ExtractText | ParseSyslog | SendTrapSNMP |
FetchAzureBlobStorage_v12 | PartitionRecord | SetSNMP |
FetchAzureDataLakeStorage | PromptChatGPT [Technical Preview] | SignContentPGP |
FetchBoxFile | PublishAMQP | SplitAvro |
FetchCDPObjectStore | PublishGCPubSub | SplitContent |
FetchDistributedMapCache | PublishGCPubSubLite | SplitJson |
FetchDropbox | PublishJMS | SplitRecord |
FetchFile | PublishKafka_2_6 | SplitText |
FetchFTP | PublishKafka2CDP | SplitXml |
FetchGCSObject | PublishKafka2RecordCDP | StartAwsPollyJob |
FetchGoogleDrive | PublishKafkaRecord_2_6 | StartAwsTextractJob |
FetchGridFS | PublishMQTT | StartAwsTranscribeJob |
FetchHBaseRow | PublishSlack | StartAwsTranslateJob |
FetchHDFS | PutAccumuloRecord | StartGcpVisionAnnotateFilesOperation |
FetchParquet | PutAzureBlobStorage_v12 | StartGcpVisionAnnotateImagesOperation |
FetchPLC [Technical Preview] | PutAzureCosmosDBRecord | StartSnowflakeIngest |
FetchS3Object | PutAzureDataLakeStorage | TagS3Object |
FetchSFTP | PutAzureEventHub | TailFile |
FetchSmb | PutAzureQueueStorage_v12 | TransformXml |
FilterAttribute | PutBigQuery | TriggerClouderaHiveMetaStoreEvent |
FlattenJson | PutBoxFile | TriggerHiveMetaStoreEvent |
ForkEnrichment | PutCassandraQL | UnpackContent |
ForkRecord | PutCassandraRecord | UpdateAttribute |
GenerateFlowFile | PutCDPObjectStore | UpdateByQueryElasticsearch |
GenerateRecord | PutChroma [Technical Preview] | UpdateClouderaHiveTable |
GenerateTableFetch | PutClouderaHiveQL | UpdateCounter |
GeoEnrichIP | PutClouderaHiveStreaming | UpdateDatabaseTable |
GeoEnrichIPRecord | PutClouderaORC | UpdateDeltaLakeTable [Technical Preview] |
GeohashRecord | PutCloudWatchMetric | UpdateHive3Table |
GetAsanaObject | PutCouchbaseKey | UpdateRecord |
GetAwsPollyJobStatus | PutDatabaseRecord | ValidateCsv |
GetAwsTextractJobStatus | PutDistributedMapCache | ValidateJson |
GetAwsTranscribeJobStatus | PutDropbox | ValidateRecord |
GetAwsTranslateJobStatus | PutDynamoDB | ValidateXml |
GetAzureEventHub | PutDynamoDBRecord | VerifyContentMAC |
GetAzureQueueStorage_v12 | PutElasticsearchJson | VerifyContentPGP |
Wait | ||
YandexTranslate |