Community Articles
Find and share helpful community-sourced technical articles
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.
Community Manager

Apache NiFi evolution from version 1.2 included in HDF 3.0 and version 1.5 included in HDF is significant. This article includes a Matrix that helps developers to take advantage of the latest NiFi processor to improve old and develop new flows. The following is a table of the matrix, arranged alphabetically from K-Z:

NiFi 1.5NiFi 1.4NiFi 1.3NiFi 1.2
ListAzureBlobStorageListAzureBlobStorageListAzureBlobStorageListAzureBlobStorage
ListDatabaseTablesListDatabaseTablesListDatabaseTablesListDatabaseTables
ListenBeatsListenBeatsListenBeatsListenBeats
ListenGRPCListenGRPC
ListenHTTPListenHTTPListenHTTPListenHTTP
ListenLumberjackListenLumberjackListenLumberjackListenLumberjack
ListenRELPListenRELPListenRELPListenRELP
ListenSMTPListenSMTPListenSMTPListenSMTP
ListenSyslogListenSyslogListenSyslogListenSyslog
ListenTCPListenTCPListenTCPListenTCP
ListenTCPRecordListenTCPRecord
ListenUDPListenUDPListenUDPListenUDP
ListenUDPRecordListenUDPRecord
ListenWebSocketListenWebSocketListenWebSocketListenWebSocket
ListFileListFileListFileListFile
ListFTPListFTPListFTPListFTP
ListGCSBucketListGCSBucketListGCSBucketListGCSBucket
ListHDFSListHDFSListHDFSListHDFS
ListS3ListS3ListS3ListS3
ListSFTPListSFTPListSFTPListSFTP
LogAttributeLogAttributeLogAttributeLogAttribute
LogMessageLogMessageLogMessageMergeContent
LookupAttributeLookupAttributeLookupAttributeModifyBytes
LookupRecordLookupRecordLookupRecordModifyHTMLElement
MergeContentMergeContentMergeContentMonitorActivity
MergeRecordMergeRecord
ModifyBytesModifyBytesModifyBytesNotify
ModifyHTMLElementModifyHTMLElementModifyHTMLElement
MonitorActivityMonitorActivityMonitorActivity
MoveHDFS
NotifyNotifyNotify
ParseCEFParseCEFParseCEFParseCEF
ParseEvtxParseEvtxParseEvtxParseEvtx
ParseSyslogParseSyslogParseSyslogParseSyslog
PartitionRecordPartitionRecordPartitionRecord
PostHTTPPostHTTPPostHTTPPostHTTP
PublishAMQPPublishAMQPPublishAMQPPublishAMQP
PublishJMSPublishJMSPublishJMSPublishJMS
PublishKafkaPublishKafkaPublishKafkaPublishKafka
PublishKafka_0_10PublishKafka_0_10PublishKafka_0_10PublishKafka_0_10
PublishKafka_0_11PublishKafka_0_11
PublishKafka_1_0
PublishKafkaRecord_0_10PublishKafkaRecord_0_10PublishKafkaRecord_0_10PublishKafkaRecord_0_10
PublishKafkaRecord_0_11PublishKafkaRecord_0_11
PublishKafkaRecord_1_0
PublishMQTTPublishMQTTPublishMQTTPublishMQTT
PutAzureBlobStoragePutAzureBlobStoragePutAzureBlobStoragePutAzureBlobStorage
PutAzureEventHubPutAzureEventHubPutAzureEventHubPutAzureEventHub
PutCassandraQLPutCassandraQLPutCassandraQLPutCassandraQL
PutCloudWatchMetricPutCloudWatchMetricPutCloudWatchMetricPutCloudWatchMetric
PutCouchbaseKeyPutCouchbaseKeyPutCouchbaseKeyPutCouchbaseKey
PutDatabaseRecordPutDatabaseRecordPutDatabaseRecordPutDatabaseRecord
PutDistributedMapCachePutDistributedMapCachePutDistributedMapCachePutDistributedMapCache
PutDynamoDBPutDynamoDBPutDynamoDBPutDynamoDB
PutElasticsearchPutElasticsearchPutElasticsearchPutElasticsearch
PutElasticsearch5PutElasticsearch5PutElasticsearch5PutElasticsearch5
PutElasticsearchHttpPutElasticsearchHttpPutElasticsearchHttpPutElasticsearchHttp
PutElasticsearchHttpRecordPutElasticsearchHttpRecordPutElasticsearchHttpRecord
PutEmailPutEmailPutEmailPutEmail
PutFilePutFilePutFilePutFile
PutFTPPutFTPPutFTPPutFTP
PutGCSObjectPutGCSObjectPutGCSObjectPutGCSObject
PutHBaseCellPutHBaseCellPutHBaseCellPutHBaseCell
PutHBaseJSONPutHBaseJSONPutHBaseJSONPutHBaseJSON
PutHBaseRecordPutHBaseRecord
PutHDFSPutHDFSPutHDFSPutHDFS
PutHiveQLPutHiveQLPutHiveQLPutHiveQL
PutHiveStreamingPutHiveStreamingPutHiveStreamingPutHiveStreaming
PutHTMLElementPutHTMLElementPutHTMLElementPutHTMLElement
PutIgniteCachePutIgniteCachePutIgniteCachePutIgniteCache
PutJMSPutJMSPutJMSPutJMS
PutKafkaPutKafkaPutKafkaPutKafka
PutKinesisFirehosePutKinesisFirehosePutKinesisFirehosePutKinesisFirehose
PutKinesisStreamPutKinesisStreamPutKinesisStreamPutKinesisStream
PutKuduPutKudu
PutLambdaPutLambdaPutLambdaPutLambda
PutMongoPutMongoPutMongoPutMongo
PutMongoRecordPutMongoRecord
PutParquetPutParquetPutParquetPutParquet
PutRethinkDBPutRethinkDB
PutRiemannPutRiemannPutRiemannPutRiemann
PutS3ObjectPutS3ObjectPutS3ObjectPutS3Object
PutSFTPPutSFTPPutSFTPPutSFTP
PutSlackPutSlackPutSlackPutSlack
PutSNSPutSNSPutSNSPutSNS
PutSolrContentStreamPutSolrContentStreamPutSolrContentStreamPutSolrContentStream
PutSplunkPutSplunkPutSplunkPutSplunk
PutSQLPutSQLPutSQLPutSQL
PutSQSPutSQSPutSQSPutSQS
PutSyslogPutSyslogPutSyslogPutSyslog
PutTCPPutTCPPutTCPPutTCP
PutUDPPutUDPPutUDPPutUDP
PutWebSocketPutWebSocketPutWebSocketPutWebSocket
QueryCassandraQueryCassandraQueryCassandraQueryCassandra
QueryDatabaseTableQueryDatabaseTableQueryDatabaseTableQueryDatabaseTable
QueryDNSQueryDNSQueryDNSQueryDNS
QueryElasticsearchHttpQueryElasticsearchHttpQueryElasticsearchHttpQueryElasticsearchHttp
QueryRecordQueryRecordQueryRecordQueryRecord
QueryWhoisQueryWhoisQueryWhoisQueryWhois
ReplaceTextReplaceTextReplaceTextReplaceText
ReplaceTextWithMappingReplaceTextWithMappingReplaceTextWithMappingReplaceTextWithMapping
ResizeImageResizeImageResizeImageResizeImage
RouteHL7RouteHL7RouteHL7RouteHL7
RouteOnAttributeRouteOnAttributeRouteOnAttributeRouteOnAttribute
RouteOnContentRouteOnContentRouteOnContentRouteOnContent
RouteTextRouteTextRouteTextRouteText
ScanAttributeScanAttributeScanAttributeScanAttribute
ScanContentScanContentScanContentScanContent
ScrollElasticsearchHttpScrollElasticsearchHttpScrollElasticsearchHttpScrollElasticsearchHttp
SegmentContentSegmentContentSegmentContentSegmentContent
SelectHiveQLSelectHiveQLSelectHiveQLSelectHiveQL
SetSNMPSetSNMPSetSNMPSetSNMP
SplitAvroSplitAvroSplitAvroSplitAvro
SplitContentSplitContentSplitContentSplitContent
SplitJsonSplitJsonSplitJsonSplitJson
SplitRecordSplitRecordSplitRecordSplitRecord
SplitTextSplitTextSplitTextSplitText
SplitXmlSplitXmlSplitXmlSplitXml
SpringContextProcessorSpringContextProcessorSpringContextProcessorSpringContextProcessor
StoreInKiteDatasetStoreInKiteDatasetStoreInKiteDatasetStoreInKiteDataset
TailFileTailFileTailFileTailFile
TransformXmlTransformXmlTransformXmlTransformXml
UnpackContentUnpackContentUnpackContentUnpackContent
UpdateAttributeUpdateAttributeUpdateAttributeUpdateAttribute
UpdateCounterUpdateCounterUpdateCounterUpdateCounter
UpdateRecordUpdateRecordUpdateRecord
ValidateCsvValidateCsvValidateCsvValidateCsv
ValidateRecordValidateRecord
ValidateXmlValidateXmlValidateXmlValidateXml
WaitWaitWaitWait
YandexTranslateYandexTranslateYandexTranslateYandexTranslate


Thanks to our friends at NiFi.Rocks!

76 Views
0 Kudos
Don't have an account?
Coming from Hortonworks? Activate your account here
Version history
Revision #:
1 of 1
Last update:
‎06-24-2019 09:29 AM
Updated by:
 
Contributors
Top Kudoed Authors