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: See here for the Matrix Table from A-D See here for the Matrix Table E-J NiFi 1.5 NiFi 1.4 NiFi 1.3 NiFi 1.2 ListAzureBlobStorage ListAzureBlobStorage ListAzureBlobStorage ListAzureBlobStorage ListDatabaseTables ListDatabaseTables ListDatabaseTables ListDatabaseTables ListenBeats ListenBeats ListenBeats ListenBeats ListenGRPC ListenGRPC ListenHTTP ListenHTTP ListenHTTP ListenHTTP ListenLumberjack ListenLumberjack ListenLumberjack ListenLumberjack ListenRELP ListenRELP ListenRELP ListenRELP ListenSMTP ListenSMTP ListenSMTP ListenSMTP ListenSyslog ListenSyslog ListenSyslog ListenSyslog ListenTCP ListenTCP ListenTCP ListenTCP ListenTCPRecord ListenTCPRecord ListenUDP ListenUDP ListenUDP ListenUDP ListenUDPRecord ListenUDPRecord ListenWebSocket ListenWebSocket ListenWebSocket ListenWebSocket ListFile ListFile ListFile ListFile ListFTP ListFTP ListFTP ListFTP ListGCSBucket ListGCSBucket ListGCSBucket ListGCSBucket ListHDFS ListHDFS ListHDFS ListHDFS ListS3 ListS3 ListS3 ListS3 ListSFTP ListSFTP ListSFTP ListSFTP LogAttribute LogAttribute LogAttribute LogAttribute LogMessage LogMessage LogMessage MergeContent LookupAttribute LookupAttribute LookupAttribute ModifyBytes LookupRecord LookupRecord LookupRecord ModifyHTMLElement MergeContent MergeContent MergeContent MonitorActivity MergeRecord MergeRecord ModifyBytes ModifyBytes ModifyBytes Notify ModifyHTMLElement ModifyHTMLElement ModifyHTMLElement MonitorActivity MonitorActivity MonitorActivity MoveHDFS Notify Notify Notify ParseCEF ParseCEF ParseCEF ParseCEF ParseEvtx ParseEvtx ParseEvtx ParseEvtx ParseSyslog ParseSyslog ParseSyslog ParseSyslog PartitionRecord PartitionRecord PartitionRecord PostHTTP PostHTTP PostHTTP PostHTTP PublishAMQP PublishAMQP PublishAMQP PublishAMQP PublishJMS PublishJMS PublishJMS PublishJMS PublishKafka PublishKafka PublishKafka PublishKafka PublishKafka_0_10 PublishKafka_0_10 PublishKafka_0_10 PublishKafka_0_10 PublishKafka_0_11 PublishKafka_0_11 PublishKafka_1_0 PublishKafkaRecord_0_10 PublishKafkaRecord_0_10 PublishKafkaRecord_0_10 PublishKafkaRecord_0_10 PublishKafkaRecord_0_11 PublishKafkaRecord_0_11 PublishKafkaRecord_1_0 PublishMQTT PublishMQTT PublishMQTT PublishMQTT PutAzureBlobStorage PutAzureBlobStorage PutAzureBlobStorage PutAzureBlobStorage PutAzureEventHub PutAzureEventHub PutAzureEventHub PutAzureEventHub PutCassandraQL PutCassandraQL PutCassandraQL PutCassandraQL PutCloudWatchMetric PutCloudWatchMetric PutCloudWatchMetric PutCloudWatchMetric PutCouchbaseKey PutCouchbaseKey PutCouchbaseKey PutCouchbaseKey PutDatabaseRecord PutDatabaseRecord PutDatabaseRecord PutDatabaseRecord PutDistributedMapCache PutDistributedMapCache PutDistributedMapCache PutDistributedMapCache PutDynamoDB PutDynamoDB PutDynamoDB PutDynamoDB PutElasticsearch PutElasticsearch PutElasticsearch PutElasticsearch PutElasticsearch5 PutElasticsearch5 PutElasticsearch5 PutElasticsearch5 PutElasticsearchHttp PutElasticsearchHttp PutElasticsearchHttp PutElasticsearchHttp PutElasticsearchHttpRecord PutElasticsearchHttpRecord PutElasticsearchHttpRecord PutEmail PutEmail PutEmail PutEmail PutFile PutFile PutFile PutFile PutFTP PutFTP PutFTP PutFTP PutGCSObject PutGCSObject PutGCSObject PutGCSObject PutHBaseCell PutHBaseCell PutHBaseCell PutHBaseCell PutHBaseJSON PutHBaseJSON PutHBaseJSON PutHBaseJSON PutHBaseRecord PutHBaseRecord PutHDFS PutHDFS PutHDFS PutHDFS PutHiveQL PutHiveQL PutHiveQL PutHiveQL PutHiveStreaming PutHiveStreaming PutHiveStreaming PutHiveStreaming PutHTMLElement PutHTMLElement PutHTMLElement PutHTMLElement PutIgniteCache PutIgniteCache PutIgniteCache PutIgniteCache PutJMS PutJMS PutJMS PutJMS PutKafka PutKafka PutKafka PutKafka PutKinesisFirehose PutKinesisFirehose PutKinesisFirehose PutKinesisFirehose PutKinesisStream PutKinesisStream PutKinesisStream PutKinesisStream PutKudu PutKudu PutLambda PutLambda PutLambda PutLambda PutMongo PutMongo PutMongo PutMongo PutMongoRecord PutMongoRecord PutParquet PutParquet PutParquet PutParquet PutRethinkDB PutRethinkDB PutRiemann PutRiemann PutRiemann PutRiemann PutS3Object PutS3Object PutS3Object PutS3Object PutSFTP PutSFTP PutSFTP PutSFTP PutSlack PutSlack PutSlack PutSlack PutSNS PutSNS PutSNS PutSNS PutSolrContentStream PutSolrContentStream PutSolrContentStream PutSolrContentStream PutSplunk PutSplunk PutSplunk PutSplunk PutSQL PutSQL PutSQL PutSQL PutSQS PutSQS PutSQS PutSQS PutSyslog PutSyslog PutSyslog PutSyslog PutTCP PutTCP PutTCP PutTCP PutUDP PutUDP PutUDP PutUDP PutWebSocket PutWebSocket PutWebSocket PutWebSocket QueryCassandra QueryCassandra QueryCassandra QueryCassandra QueryDatabaseTable QueryDatabaseTable QueryDatabaseTable QueryDatabaseTable QueryDNS QueryDNS QueryDNS QueryDNS QueryElasticsearchHttp QueryElasticsearchHttp QueryElasticsearchHttp QueryElasticsearchHttp QueryRecord QueryRecord QueryRecord QueryRecord QueryWhois QueryWhois QueryWhois QueryWhois ReplaceText ReplaceText ReplaceText ReplaceText ReplaceTextWithMapping ReplaceTextWithMapping ReplaceTextWithMapping ReplaceTextWithMapping ResizeImage ResizeImage ResizeImage ResizeImage RouteHL7 RouteHL7 RouteHL7 RouteHL7 RouteOnAttribute RouteOnAttribute RouteOnAttribute RouteOnAttribute RouteOnContent RouteOnContent RouteOnContent RouteOnContent RouteText RouteText RouteText RouteText ScanAttribute ScanAttribute ScanAttribute ScanAttribute ScanContent ScanContent ScanContent ScanContent ScrollElasticsearchHttp ScrollElasticsearchHttp ScrollElasticsearchHttp ScrollElasticsearchHttp SegmentContent SegmentContent SegmentContent SegmentContent SelectHiveQL SelectHiveQL SelectHiveQL SelectHiveQL SetSNMP SetSNMP SetSNMP SetSNMP SplitAvro SplitAvro SplitAvro SplitAvro SplitContent SplitContent SplitContent SplitContent SplitJson SplitJson SplitJson SplitJson SplitRecord SplitRecord SplitRecord SplitRecord SplitText SplitText SplitText SplitText SplitXml SplitXml SplitXml SplitXml SpringContextProcessor SpringContextProcessor SpringContextProcessor SpringContextProcessor StoreInKiteDataset StoreInKiteDataset StoreInKiteDataset StoreInKiteDataset TailFile TailFile TailFile TailFile TransformXml TransformXml TransformXml TransformXml UnpackContent UnpackContent UnpackContent UnpackContent UpdateAttribute UpdateAttribute UpdateAttribute UpdateAttribute UpdateCounter UpdateCounter UpdateCounter UpdateCounter UpdateRecord UpdateRecord UpdateRecord ValidateCsv ValidateCsv ValidateCsv ValidateCsv ValidateRecord ValidateRecord ValidateXml ValidateXml ValidateXml ValidateXml Wait Wait Wait Wait YandexTranslate YandexTranslate YandexTranslate YandexTranslate Thanks to our friends at NiFi.Rocks! ... View more

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 E-J: See here for the Table Matrix from A-D See here for the Table Matrix K-Z NiFi 1.5 NiFi 1.4 NiFi 1.3 NiFi 1.2 EncryptContent EncryptContent EncryptContent EncryptContent EnforceOrder EnforceOrder EnforceOrder EnforceOrder EvaluateJsonPath EvaluateJsonPath EvaluateJsonPath EvaluateJsonPath EvaluateXPath EvaluateXPath EvaluateXPath EvaluateXPath EvaluateXQuery EvaluateXQuery EvaluateXQuery EvaluateXQuery ExecuteFlumeSink ExecuteFlumeSink ExecuteFlumeSink ExecuteFlumeSink ExecuteFlumeSource ExecuteFlumeSource ExecuteFlumeSource ExecuteFlumeSource ExecuteGroovyScript ExecuteProcess ExecuteProcess ExecuteProcess ExecuteProcess ExecuteScript ExecuteScript ExecuteScript ExecuteScript ExecuteSparkInteractive ExecuteSQL ExecuteSQL ExecuteSQL ExecuteSQL ExecuteStreamCommand ExecuteStreamCommand ExecuteStreamCommand ExecuteStreamCommand ExtractAvroMetadata ExtractAvroMetadata ExtractAvroMetadata ExtractAvroMetadata ExtractCCDAAttributes ExtractCCDAAttributes ExtractCCDAAttributes ExtractCCDAAttributes ExtractEmailAttachments ExtractEmailAttachments ExtractEmailAttachments ExtractEmailAttachments ExtractEmailHeaders ExtractEmailHeaders ExtractEmailHeaders ExtractEmailHeaders ExtractGrok ExtractGrok ExtractGrok ExtractGrok ExtractHL7Attributes ExtractHL7Attributes ExtractHL7Attributes ExtractHL7Attributes ExtractImageMetadata ExtractImageMetadata ExtractImageMetadata ExtractImageMetadata ExtractMediaMetadata ExtractMediaMetadata ExtractMediaMetadata ExtractMediaMetadata ExtractText ExtractText ExtractText ExtractText ExtractTNEFAttachments ExtractTNEFAttachments ExtractTNEFAttachments ExtractTNEFAttachments FetchAzureBlobStorage FetchAzureBlobStorage FetchAzureBlobStorage FetchAzureBlobStorage FetchDistributedMapCache FetchDistributedMapCache FetchDistributedMapCache FetchDistributedMapCache FetchElasticsearch FetchElasticsearch FetchElasticsearch FetchElasticsearch FetchElasticsearch5 FetchElasticsearch5 FetchElasticsearch5 FetchElasticsearch5 FetchElasticsearchHttp FetchElasticsearchHttp FetchElasticsearchHttp FetchElasticsearchHttp FetchFile FetchFile FetchFile FetchFile FetchFTP FetchFTP FetchFTP FetchFTP FetchGCSObject FetchGCSObject FetchGCSObject FetchGCSObject FetchHBaseRow FetchHBaseRow FetchHBaseRow FetchHBaseRow FetchHDFS FetchHDFS FetchHDFS FetchHDFS FetchParquet FetchParquet FetchParquet FetchParquet FetchS3Object FetchS3Object FetchS3Object FetchS3Object FetchSFTP FetchSFTP FetchSFTP FetchSFTP FlattenJson FuzzyHashContent FuzzyHashContent FuzzyHashContent FuzzyHashContent GenerateFlowFile GenerateFlowFile GenerateFlowFile GenerateFlowFile GenerateTableFetch GenerateTableFetch GenerateTableFetch GenerateTableFetch GeoEnrichIP GeoEnrichIP GeoEnrichIP GeoEnrichIP GetAzureEventHub GetAzureEventHub GetAzureEventHub GetAzureEventHub GetCouchbaseKey GetCouchbaseKey GetCouchbaseKey GetCouchbaseKey GetDynamoDB GetDynamoDB GetDynamoDB GetDynamoDB GetFile GetFile GetFile GetFile GetFTP GetFTP GetFTP GetFTP GetHBase GetHBase GetHBase GetHBase GetHDFS GetHDFS GetHDFS GetHDFS GetHDFSEvents GetHDFSEvents GetHDFSEvents GetHDFSEvents GetHDFSSequenceFile GetHDFSSequenceFile GetHDFSSequenceFile GetHDFSSequenceFile GetHTMLElement GetHTMLElement GetHTMLElement GetHTMLElement GetHTTP GetHTTP GetHTTP GetHTTP GetIgniteCache GetIgniteCache GetIgniteCache GetIgniteCache GetJMSQueue GetJMSQueue GetJMSQueue GetJMSQueue GetJMSTopic GetJMSTopic GetJMSTopic GetJMSTopic GetKafka GetKafka GetKafka GetKafka GetMongo GetMongo GetMongo GetMongo GetRethinkDB GetRethinkDB GetSFTP GetSFTP GetSFTP GetSFTP GetSNMP GetSNMP GetSNMP GetSNMP GetSolr GetSolr GetSolr GetSolr GetSplunk GetSplunk GetSplunk GetSplunk GetSQS GetSQS GetSQS GetSQS GetTCP GetTCP GetTCP GetTCP GetTwitter GetTwitter GetTwitter GetTwitter HandleHttpRequest HandleHttpRequest HandleHttpRequest HandleHttpRequest HandleHttpResponse HandleHttpResponse HandleHttpResponse HandleHttpResponse HashAttribute HashAttribute HashAttribute HashAttribute HashContent HashContent HashContent HashContent IdentifyMimeType IdentifyMimeType IdentifyMimeType IdentifyMimeType InferAvroSchema InferAvroSchema InferAvroSchema InferAvroSchema InvokeGRPC InvokeGRPC InvokeHTTP InvokeHTTP InvokeHTTP InvokeHTTP InvokeScriptedProcessor InvokeScriptedProcessor InvokeScriptedProcessor InvokeScriptedProcessor ISPEnrichIP ISPEnrichIP ISPEnrichIP ISPEnrichIP JoltTransformJSON JoltTransformJSON JoltTransformJSON JoltTransformJSON ... View more