• General
  • Overview
  • Getting Started
  • User Guide
  • Expression Language Guide
  • RecordPath Guide
  • Admin Guide
  • Toolkit Guide
  • Walkthroughs

• Developer
  • Developer Guide
  • Python Developer Guide
  • Apache NiFi In Depth
  • REST API
  • OpenAPI Specification

• Processors

  • AttributeRollingWindow   2.4.0.4.11.0.0-352

  • AttributesToCSV   2.4.0.4.11.0.0-352

  • AttributesToJSON   2.4.0.4.11.0.0-352

  • CalculateParquetOffsets   2.4.0.4.11.0.0-352

  • CalculateParquetRowGroupOffsets   2.4.0.4.11.0.0-352

  • CalculateRecordStats   2.4.0.4.11.0.0-352

  • CaptureChangeDebeziumDB2   2.4.0.4.11.0.0-352

  • CaptureChangeDebeziumMongoDB   2.4.0.4.11.0.0-352

  • CaptureChangeDebeziumMySQL   2.4.0.4.11.0.0-352

  • CaptureChangeDebeziumOracle   2.4.0.4.11.0.0-352

  • CaptureChangeDebeziumPostgreSQL   2.4.0.4.11.0.0-352

  • CaptureChangeDebeziumSQLServer   2.4.0.4.11.0.0-352

  • CaptureChangeMySQL   2.4.0.4.11.0.0-352

  • CompressContent   2.4.0.4.11.0.0-352

  • ConnectWebSocket   2.4.0.4.11.0.0-352

  • ConsumeAMQP   2.4.0.4.11.0.0-352

  • ConsumeAzureEventHub   2.4.0.4.11.0.0-352

  • ConsumeBoxEnterpriseEvents   2.4.0.4.11.0.0-352

  • ConsumeBoxEvents   2.4.0.4.11.0.0-352

  • ConsumeElasticsearch   2.4.0.4.11.0.0-352

  • ConsumeGCPubSub   2.4.0.4.11.0.0-352

  • ConsumeIMAP   2.4.0.4.11.0.0-352

  • ConsumeJMS   2.4.0.4.11.0.0-352

  • ConsumeKafka   2.4.0.4.11.0.0-352

  • ConsumeKafka_2_6   2.4.0.4.11.0.0-352

  • ConsumeKafka2CDP   2.4.0.4.11.0.0-352

  • ConsumeKafka2RecordCDP   2.4.0.4.11.0.0-352

  • ConsumeKafkaRecord_2_6   2.4.0.4.11.0.0-352

  • ConsumeKinesisStream   2.4.0.4.11.0.0-352

  • ConsumeMQTT   2.4.0.4.11.0.0-352

  • ConsumePLC   2.4.0.4.11.0.0-352

  • ConsumePOP3   2.4.0.4.11.0.0-352

  • ConsumeSlack   2.4.0.4.11.0.0-352

  • ConsumeTwitter   2.4.0.4.11.0.0-352

  • ConsumeWindowsEventLog   2.4.0.4.11.0.0-352

  • ControlRate   2.4.0.4.11.0.0-352

  • ConvertAvroToParquet   2.4.0.4.11.0.0-352

  • ConvertCharacterSet   2.4.0.4.11.0.0-352

  • ConvertProtobuf   2.4.0.4.11.0.0-352

  • ConvertRecord   2.4.0.4.11.0.0-352

  • CopyAzureBlobStorage_v12   2.4.0.4.11.0.0-352

  • CopyS3Object   2.4.0.4.11.0.0-352

  • CountText   2.4.0.4.11.0.0-352

  • CreateBoxFileMetadataInstance   2.4.0.4.11.0.0-352

  • CreateBoxMetadataTemplate   2.4.0.4.11.0.0-352

  • CreateHadoopSequenceFile   2.4.0.4.11.0.0-352

  • CryptographicHashContent   2.4.0.4.11.0.0-352

  • DebugFlow   2.4.0.4.11.0.0-352

  • DecryptContentAge   2.4.0.4.11.0.0-352

  • DecryptContentPGP   2.4.0.4.11.0.0-352

  • DeduplicateRecord   2.4.0.4.11.0.0-352

  • DeleteAzureBlobStorage_v12   2.4.0.4.11.0.0-352

  • DeleteAzureDataLakeStorage   2.4.0.4.11.0.0-352

  • DeleteBoxFileMetadataInstance   2.4.0.4.11.0.0-352

  • DeleteByQueryElasticsearch   2.4.0.4.11.0.0-352

  • DeleteCDPObjectStore   2.4.0.4.11.0.0-352

  • DeleteDynamoDB   2.4.0.4.11.0.0-352

  • DeleteFile   2.4.0.4.11.0.0-352

  • DeleteGCSObject   2.4.0.4.11.0.0-352

  • DeleteGridFS   2.4.0.4.11.0.0-352

  • DeleteHBaseCells   2.4.0.4.11.0.0-352

  • DeleteHBaseRow   2.4.0.4.11.0.0-352

  • DeleteHDFS   2.4.0.4.11.0.0-352

  • DeleteMongo   2.4.0.4.11.0.0-352

  • DeleteS3Object   2.4.0.4.11.0.0-352

  • DeleteSFTP   2.4.0.4.11.0.0-352

  • DeleteSQS   2.4.0.4.11.0.0-352

  • DetectDuplicate   2.4.0.4.11.0.0-352

  • DistributeLoad   2.4.0.4.11.0.0-352

  • DuplicateFlowFile   2.4.0.4.11.0.0-352

  • EncodeContent   2.4.0.4.11.0.0-352

  • EncryptContentAge   2.4.0.4.11.0.0-352

  • EncryptContentPGP   2.4.0.4.11.0.0-352

  • EnforceOrder   2.4.0.4.11.0.0-352

  • EvaluateJsonPath   2.4.0.4.11.0.0-352

  • EvaluateXPath   2.4.0.4.11.0.0-352

  • EvaluateXQuery   2.4.0.4.11.0.0-352

  • ExecuteGraphQuery   2.4.0.4.11.0.0-352

  • ExecuteGraphQueryRecord   2.4.0.4.11.0.0-352

  • ExecuteGroovyScript   2.4.0.4.11.0.0-352

  • ExecuteProcess   2.4.0.4.11.0.0-352

  • ExecuteScript   2.4.0.4.11.0.0-352

  • ExecuteSparkInteractive   2.4.0.4.11.0.0-352

  • ExecuteSQL   2.4.0.4.11.0.0-352

  • ExecuteSQLRecord   2.4.0.4.11.0.0-352

  • ExecuteStreamCommand   2.4.0.4.11.0.0-352

  • ExtractAvroMetadata   2.4.0.4.11.0.0-352

  • ExtractDocumentText   2.4.0.4.11.0.0-352

  • ExtractEmailAttachments   2.4.0.4.11.0.0-352

  • ExtractEmailHeaders   2.4.0.4.11.0.0-352

  • ExtractGrok   2.4.0.4.11.0.0-352

  • ExtractHL7Attributes   2.4.0.4.11.0.0-352

  • ExtractImageMetadata   2.4.0.4.11.0.0-352

  • ExtractMediaMetadata   2.4.0.4.11.0.0-352

  • ExtractRecordSchema   2.4.0.4.11.0.0-352

  • ExtractStructuredBoxFileMetadata   2.4.0.4.11.0.0-352

  • ExtractText   2.4.0.4.11.0.0-352

  • FetchAzureBlobStorage_v12   2.4.0.4.11.0.0-352

  • FetchAzureDataLakeStorage   2.4.0.4.11.0.0-352

  • FetchBoxFile   2.4.0.4.11.0.0-352

  • FetchBoxFileInfo   2.4.0.4.11.0.0-352

  • FetchBoxFileMetadataInstance   2.4.0.4.11.0.0-352

  • FetchBoxFileRepresentation   2.4.0.4.11.0.0-352

  • FetchCDPObjectStore   2.4.0.4.11.0.0-352

  • FetchDistributedMapCache   2.4.0.4.11.0.0-352

  • FetchDropbox   2.4.0.4.11.0.0-352

  • FetchFile   2.4.0.4.11.0.0-352

  • FetchFTP   2.4.0.4.11.0.0-352

  • FetchGCSObject   2.4.0.4.11.0.0-352

  • FetchGoogleDrive   2.4.0.4.11.0.0-352

  • FetchGridFS   2.4.0.4.11.0.0-352

  • FetchHBaseRow   2.4.0.4.11.0.0-352

  • FetchHDFS   2.4.0.4.11.0.0-352

  • FetchParquet   2.4.0.4.11.0.0-352

  • FetchPLC   2.4.0.4.11.0.0-352

  • FetchS3Object   2.4.0.4.11.0.0-352

  • FetchSFTP   2.4.0.4.11.0.0-352

  • FetchSmb   2.4.0.4.11.0.0-352

  • FilterAttribute   2.4.0.4.11.0.0-352

  • FlattenJson   2.4.0.4.11.0.0-352

  • ForkEnrichment   2.4.0.4.11.0.0-352

  • ForkRecord   2.4.0.4.11.0.0-352

  • GenerateFlowFile   2.4.0.4.11.0.0-352

  • GenerateRecord   2.4.0.4.11.0.0-352

  • GenerateTableFetch   2.4.0.4.11.0.0-352

  • GeoEnrichIP   2.4.0.4.11.0.0-352

  • GeoEnrichIPRecord   2.4.0.4.11.0.0-352

  • GeohashRecord   2.4.0.4.11.0.0-352

  • GetAsanaObject   2.4.0.4.11.0.0-352

  • GetAwsPollyJobStatus   2.4.0.4.11.0.0-352

  • GetAwsTextractJobStatus   2.4.0.4.11.0.0-352

  • GetAwsTranscribeJobStatus   2.4.0.4.11.0.0-352

  • GetAwsTranslateJobStatus   2.4.0.4.11.0.0-352

  • GetAzureEventHub   2.4.0.4.11.0.0-352

  • GetAzureQueueStorage_v12   2.4.0.4.11.0.0-352

  • GetBoxFileCollaborators   2.4.0.4.11.0.0-352

  • GetBoxGroupMembers   2.4.0.4.11.0.0-352

  • GetCouchbaseKey   2.4.0.4.11.0.0-352

  • GetDynamoDB   2.4.0.4.11.0.0-352

  • GetElasticsearch   2.4.0.4.11.0.0-352

  • GetFile   2.4.0.4.11.0.0-352

  • GetFileResource   2.4.0.4.11.0.0-352

  • GetFTP   2.4.0.4.11.0.0-352

  • GetGcpVisionAnnotateFilesOperationStatus   2.4.0.4.11.0.0-352

  • GetGcpVisionAnnotateImagesOperationStatus   2.4.0.4.11.0.0-352

  • GetHBase   2.4.0.4.11.0.0-352

  • GetHDFS   2.4.0.4.11.0.0-352

  • GetHDFSEvents   2.4.0.4.11.0.0-352

  • GetHDFSFileInfo   2.4.0.4.11.0.0-352

  • GetHDFSSequenceFile   2.4.0.4.11.0.0-352

  • GetHubSpot   2.4.0.4.11.0.0-352

  • GetJiraIssue   2.4.0.4.11.0.0-352

  • GetMongo   2.4.0.4.11.0.0-352

  • GetMongoRecord   2.4.0.4.11.0.0-352

  • GetS3ObjectMetadata   2.4.0.4.11.0.0-352

  • GetS3ObjectTags   2.4.0.4.11.0.0-352

  • GetSFTP   2.4.0.4.11.0.0-352

  • GetShopify   2.4.0.4.11.0.0-352

  • GetSlackReaction   2.4.0.4.11.0.0-352

  • GetSmbFile   2.4.0.4.11.0.0-352

  • GetSNMP   2.4.0.4.11.0.0-352

  • GetSnowflakeIngestStatus   2.4.0.4.11.0.0-352

  • GetSolr   2.4.0.4.11.0.0-352

  • GetSplunk   2.4.0.4.11.0.0-352

  • GetSQS   2.4.0.4.11.0.0-352

  • GetTCP   2.4.0.4.11.0.0-352

  • GetWorkdayReport   2.4.0.4.11.0.0-352

  • GetZendesk   2.4.0.4.11.0.0-352

  • HandleHttpRequest   2.4.0.4.11.0.0-352

  • HandleHttpResponse   2.4.0.4.11.0.0-352

  • IdentifyMimeType   2.4.0.4.11.0.0-352

  • InvokeGRPC   2.4.0.4.11.0.0-352

  • InvokeHTTP   2.4.0.4.11.0.0-352

  • InvokeScriptedProcessor   2.4.0.4.11.0.0-352

  • ISPEnrichIP   2.4.0.4.11.0.0-352

  • JoinEnrichment   2.4.0.4.11.0.0-352

  • JoltTransformJSON   2.4.0.4.11.0.0-352

  • JoltTransformRecord   2.4.0.4.11.0.0-352

  • JSLTTransformJSON   2.4.0.4.11.0.0-352

  • JsonQueryElasticsearch   2.4.0.4.11.0.0-352

  • ListAzureBlobStorage_v12   2.4.0.4.11.0.0-352

  • ListAzureDataLakeStorage   2.4.0.4.11.0.0-352

  • ListBoxFile   2.4.0.4.11.0.0-352

  • ListBoxFileInfo   2.4.0.4.11.0.0-352

  • ListBoxFileMetadataInstances   2.4.0.4.11.0.0-352

  • ListBoxFileMetadataTemplates   2.4.0.4.11.0.0-352

  • ListCDPObjectStore   2.4.0.4.11.0.0-352

  • ListDatabaseTables   2.4.0.4.11.0.0-352

  • ListDropbox   2.4.0.4.11.0.0-352

  • ListenBeats   2.4.0.4.11.0.0-352

  • ListenFTP   2.4.0.4.11.0.0-352

  • ListenGRPC   2.4.0.4.11.0.0-352

  • ListenHTTP   2.4.0.4.11.0.0-352

  • ListenNetFlow   2.4.0.4.11.0.0-352

  • ListenOTLP   2.4.0.4.11.0.0-352

  • ListenSlack   2.4.0.4.11.0.0-352

  • ListenSyslog   2.4.0.4.11.0.0-352

  • ListenTCP   2.4.0.4.11.0.0-352

  • ListenTrapSNMP   2.4.0.4.11.0.0-352

  • ListenUDP   2.4.0.4.11.0.0-352

  • ListenUDPRecord   2.4.0.4.11.0.0-352

  • ListenWebSocket   2.4.0.4.11.0.0-352

  • ListFile   2.4.0.4.11.0.0-352

  • ListFTP   2.4.0.4.11.0.0-352

  • ListGCSBucket   2.4.0.4.11.0.0-352

  • ListGoogleDrive   2.4.0.4.11.0.0-352

  • ListHBaseRegions   2.4.0.4.11.0.0-352

  • ListHDFS   2.4.0.4.11.0.0-352

  • ListS3   2.4.0.4.11.0.0-352

  • ListSFTP   2.4.0.4.11.0.0-352

  • ListSmb   2.4.0.4.11.0.0-352

  • LogAttribute   2.4.0.4.11.0.0-352

  • LogMessage   2.4.0.4.11.0.0-352

  • LookupAttribute   2.4.0.4.11.0.0-352

  • LookupRecord   2.4.0.4.11.0.0-352

  • MergeContent   2.4.0.4.11.0.0-352

  • MergeRecord   2.4.0.4.11.0.0-352

  • ModifyBytes   2.4.0.4.11.0.0-352

  • ModifyCompression   2.4.0.4.11.0.0-352

  • MonitorActivity   2.4.0.4.11.0.0-352

  • MoveAzureDataLakeStorage   2.4.0.4.11.0.0-352

  • MoveHDFS   2.4.0.4.11.0.0-352

  • Notify   2.4.0.4.11.0.0-352

  • PackageFlowFile   2.4.0.4.11.0.0-352

  • PaginatedJsonQueryElasticsearch   2.4.0.4.11.0.0-352

  • ParseEvtx   2.4.0.4.11.0.0-352

  • ParseNetflowv5   2.4.0.4.11.0.0-352

  • ParseSyslog   2.4.0.4.11.0.0-352

  • ParseSyslog5424   2.4.0.4.11.0.0-352

  • PartitionRecord   2.4.0.4.11.0.0-352

  • PublishAMQP   2.4.0.4.11.0.0-352

  • PublishGCPubSub   2.4.0.4.11.0.0-352

  • PublishJMS   2.4.0.4.11.0.0-352

  • PublishKafka   2.4.0.4.11.0.0-352

  • PublishKafka_2_6   2.4.0.4.11.0.0-352

  • PublishKafka2CDP   2.4.0.4.11.0.0-352

  • PublishKafka2RecordCDP   2.4.0.4.11.0.0-352

  • PublishKafkaRecord_2_6   2.4.0.4.11.0.0-352

  • PublishMQTT   2.4.0.4.11.0.0-352

  • PublishSlack   2.4.0.4.11.0.0-352

  • PutAccumuloRecord   2.4.0.4.11.0.0-352

  • PutAzureBlobStorage_v12   2.4.0.4.11.0.0-352

  • PutAzureCosmosDBRecord   2.4.0.4.11.0.0-352

  • PutAzureDataExplorer   2.4.0.4.11.0.0-352

  • PutAzureDataLakeStorage   2.4.0.4.11.0.0-352

  • PutAzureEventHub   2.4.0.4.11.0.0-352

  • PutAzureQueueStorage_v12   2.4.0.4.11.0.0-352

  • PutBigQuery   2.4.0.4.11.0.0-352

  • PutBoxFile   2.4.0.4.11.0.0-352

  • PutCassandraQL   2.4.0.4.11.0.0-352

  • PutCassandraRecord   2.4.0.4.11.0.0-352

  • PutCDPObjectStore   2.4.0.4.11.0.0-352

  • PutClouderaHiveQL   2.4.0.4.11.0.0-352

  • PutClouderaHiveStreaming   2.4.0.4.11.0.0-352

  • PutClouderaORC   2.4.0.4.11.0.0-352

  • PutCloudWatchMetric   2.4.0.4.11.0.0-352

  • PutCouchbaseKey   2.4.0.4.11.0.0-352

  • PutDatabaseRecord   2.4.0.4.11.0.0-352

  • PutDistributedMapCache   2.4.0.4.11.0.0-352

  • PutDropbox   2.4.0.4.11.0.0-352

  • PutDynamoDB   2.4.0.4.11.0.0-352

  • PutDynamoDBRecord   2.4.0.4.11.0.0-352

  • PutElasticsearchJson   2.4.0.4.11.0.0-352

  • PutElasticsearchRecord   2.4.0.4.11.0.0-352

  • PutEmail   2.4.0.4.11.0.0-352

  • PutFile   2.4.0.4.11.0.0-352

  • PutFTP   2.4.0.4.11.0.0-352

  • PutGCSObject   2.4.0.4.11.0.0-352

  • PutGoogleDrive   2.4.0.4.11.0.0-352

  • PutGridFS   2.4.0.4.11.0.0-352

  • PutHBaseCell   2.4.0.4.11.0.0-352

  • PutHBaseJSON   2.4.0.4.11.0.0-352

  • PutHBaseRecord   2.4.0.4.11.0.0-352

  • PutHDFS   2.4.0.4.11.0.0-352

  • PutIceberg   2.4.0.4.11.0.0-352

  • PutIcebergCDC   2.4.0.4.11.0.0-352

  • PutIoTDBRecord   2.4.0.4.11.0.0-352

  • PutJiraIssue   2.4.0.4.11.0.0-352

  • PutKinesisFirehose   2.4.0.4.11.0.0-352

  • PutKinesisStream   2.4.0.4.11.0.0-352

  • PutKudu   2.4.0.4.11.0.0-352

  • PutLambda   2.4.0.4.11.0.0-352

  • PutMongo   2.4.0.4.11.0.0-352

  • PutMongoBulkOperations   2.4.0.4.11.0.0-352

  • PutMongoRecord   2.4.0.4.11.0.0-352

  • PutParquet   2.4.0.4.11.0.0-352

  • PutPLC   2.4.0.4.11.0.0-352

  • PutRecord   2.4.0.4.11.0.0-352

  • PutRedisHashRecord   2.4.0.4.11.0.0-352

  • PutS3Object   2.4.0.4.11.0.0-352

  • PutSalesforceObject   2.4.0.4.11.0.0-352

  • PutSFTP   2.4.0.4.11.0.0-352

  • PutSmbFile   2.4.0.4.11.0.0-352

  • PutSnowflakeInternalStage   2.4.0.4.11.0.0-352

  • PutSNS   2.4.0.4.11.0.0-352

  • PutSolrContentStream   2.4.0.4.11.0.0-352

  • PutSolrRecord   2.4.0.4.11.0.0-352

  • PutSplunk   2.4.0.4.11.0.0-352

  • PutSplunkHTTP   2.4.0.4.11.0.0-352

  • PutSQL   2.4.0.4.11.0.0-352

  • PutSQS   2.4.0.4.11.0.0-352

  • PutSyslog   2.4.0.4.11.0.0-352

  • PutTCP   2.4.0.4.11.0.0-352

  • PutUDP   2.4.0.4.11.0.0-352

  • PutWebSocket   2.4.0.4.11.0.0-352

  • PutZendeskTicket   2.4.0.4.11.0.0-352

  • QueryAirtableTable   2.4.0.4.11.0.0-352

  • QueryAzureDataExplorer   2.4.0.4.11.0.0-352

  • QueryCassandra   2.4.0.4.11.0.0-352

  • QueryDatabaseTable   2.4.0.4.11.0.0-352

  • QueryDatabaseTableRecord   2.4.0.4.11.0.0-352

  • QueryIoTDBRecord   2.4.0.4.11.0.0-352

  • QueryRecord   2.4.0.4.11.0.0-352

  • QuerySalesforceObject   2.4.0.4.11.0.0-352

  • QuerySolr   2.4.0.4.11.0.0-352

  • QuerySplunkIndexingStatus   2.4.0.4.11.0.0-352

  • RemoveRecordField   2.4.0.4.11.0.0-352

  • RenameRecordField   2.4.0.4.11.0.0-352

  • ReplaceText   2.4.0.4.11.0.0-352

  • ReplaceTextWithMapping   2.4.0.4.11.0.0-352

  • ResizeImage   2.4.0.4.11.0.0-352

  • RetryFlowFile   2.4.0.4.11.0.0-352

  • RouteHL7   2.4.0.4.11.0.0-352

  • RouteOnAttribute   2.4.0.4.11.0.0-352

  • RouteOnContent   2.4.0.4.11.0.0-352

  • RouteText   2.4.0.4.11.0.0-352

  • RunMongoAggregation   2.4.0.4.11.0.0-352

  • SampleRecord   2.4.0.4.11.0.0-352

  • SawmillTransformJSON   2.4.0.4.11.0.0-352

  • SawmillTransformRecord   2.4.0.4.11.0.0-352

  • ScanAccumulo   2.4.0.4.11.0.0-352

  • ScanAttribute   2.4.0.4.11.0.0-352

  • ScanContent   2.4.0.4.11.0.0-352

  • ScanHBase   2.4.0.4.11.0.0-352

  • ScriptedFilterRecord   2.4.0.4.11.0.0-352

  • ScriptedPartitionRecord   2.4.0.4.11.0.0-352

  • ScriptedTransformRecord   2.4.0.4.11.0.0-352

  • ScriptedValidateRecord   2.4.0.4.11.0.0-352

  • SearchElasticsearch   2.4.0.4.11.0.0-352

  • SegmentContent   2.4.0.4.11.0.0-352

  • SelectClouderaHiveQL   2.4.0.4.11.0.0-352

  • SendTrapSNMP   2.4.0.4.11.0.0-352

  • SetSNMP   2.4.0.4.11.0.0-352

  • SignContentPGP   2.4.0.4.11.0.0-352

  • SplitAvro   2.4.0.4.11.0.0-352

  • SplitContent   2.4.0.4.11.0.0-352

  • SplitExcel   2.4.0.4.11.0.0-352

  • SplitJson   2.4.0.4.11.0.0-352

  • SplitPCAP   2.4.0.4.11.0.0-352

  • SplitRecord   2.4.0.4.11.0.0-352

  • SplitText   2.4.0.4.11.0.0-352

  • SplitXml   2.4.0.4.11.0.0-352

  • StartAwsPollyJob   2.4.0.4.11.0.0-352

  • StartAwsTextractJob   2.4.0.4.11.0.0-352

  • StartAwsTranscribeJob   2.4.0.4.11.0.0-352

  • StartAwsTranslateJob   2.4.0.4.11.0.0-352

  • StartGcpVisionAnnotateFilesOperation   2.4.0.4.11.0.0-352

  • StartGcpVisionAnnotateImagesOperation   2.4.0.4.11.0.0-352

  • StartSnowflakeIngest   2.4.0.4.11.0.0-352

  • TagS3Object   2.4.0.4.11.0.0-352

  • TailFile   2.4.0.4.11.0.0-352

  • TransformXml   2.4.0.4.11.0.0-352

  • TriggerClouderaHiveMetaStoreEvent   2.4.0.4.11.0.0-352

  • UnpackContent   2.4.0.4.11.0.0-352

  • UpdateAttribute   2.4.0.4.11.0.0-352

  • UpdateBoxFileMetadataInstance   2.4.0.4.11.0.0-352

  • UpdateByQueryElasticsearch   2.4.0.4.11.0.0-352

  • UpdateClouderaHiveTable   2.4.0.4.11.0.0-352

  • UpdateCounter   2.4.0.4.11.0.0-352

  • UpdateDatabaseTable   2.4.0.4.11.0.0-352

  • UpdateDeltaLakeTable   2.4.0.4.11.0.0-352

  • UpdateJiraIssue   2.4.0.4.11.0.0-352

  • UpdateRecord   2.4.0.4.11.0.0-352

  • ValidateCsv   2.4.0.4.11.0.0-352

  • ValidateJson   2.4.0.4.11.0.0-352

  • ValidateRecord   2.4.0.4.11.0.0-352

  • ValidateXml   2.4.0.4.11.0.0-352

  • VerifyContentMAC   2.4.0.4.11.0.0-352

  • VerifyContentPGP   2.4.0.4.11.0.0-352

  • Wait   2.4.0.4.11.0.0-352

• Controller Services

  • AccumuloService   2.4.0.4.11.0.0-352

  • ActiveMQJMSConnectionFactoryProvider   2.4.0.4.11.0.0-352

  • ADLSCredentialsControllerService   2.4.0.4.11.0.0-352

  • ADLSCredentialsControllerServiceLookup   2.4.0.4.11.0.0-352

  • ADLSIDBrokerCloudCredentialsProviderControllerService   2.4.0.4.11.0.0-352

  • AmazonGlueSchemaRegistry   2.4.0.4.11.0.0-352

  • AmazonMSKConnectionService   2.4.0.4.11.0.0-352

  • ApicurioSchemaRegistry   2.4.0.4.11.0.0-352

  • AvroReader   2.4.0.4.11.0.0-352

  • AvroRecordSetWriter   2.4.0.4.11.0.0-352

  • AvroSchemaRegistry   2.4.0.4.11.0.0-352

  • AWSCredentialsProviderControllerService   2.4.0.4.11.0.0-352

  • AWSIDBrokerCloudCredentialsProviderControllerService   2.4.0.4.11.0.0-352

  • AzureBlobIDBrokerCloudCredentialsProviderControllerService   2.4.0.4.11.0.0-352

  • AzureBlobStorageFileResourceService   2.4.0.4.11.0.0-352

  • AzureCosmosDBClientService   2.4.0.4.11.0.0-352

  • AzureDataLakeStorageFileResourceService   2.4.0.4.11.0.0-352

  • AzureEventHubRecordSink   2.4.0.4.11.0.0-352

  • AzureServiceBusJMSConnectionFactoryProvider   2.4.0.4.11.0.0-352

  • AzureStorageCredentialsControllerService_v12   2.4.0.4.11.0.0-352

  • AzureStorageCredentialsControllerServiceLookup_v12   2.4.0.4.11.0.0-352

  • CassandraDistributedMapCache   2.4.0.4.11.0.0-352

  • CassandraSessionProvider   2.4.0.4.11.0.0-352

  • CdpCredentialsProviderControllerService   2.4.0.4.11.0.0-352

  • CdpOauth2AccessTokenProviderControllerService   2.4.0.4.11.0.0-352

  • CEFReader   2.4.0.4.11.0.0-352

  • CiscoEmblemSyslogMessageReader   2.4.0.4.11.0.0-352

  • ClouderaAttributeSchemaReferenceReader   2.4.0.4.11.0.0-352

  • ClouderaAttributeSchemaReferenceWriter   2.4.0.4.11.0.0-352

  • ClouderaEncodedSchemaReferenceReader   2.4.0.4.11.0.0-352

  • ClouderaEncodedSchemaReferenceWriter   2.4.0.4.11.0.0-352

  • ClouderaHiveConnectionPool   2.4.0.4.11.0.0-352

  • ClouderaHiveConnectionPoolLookup   2.4.0.4.11.0.0-352

  • ClouderaSchemaRegistry   2.4.0.4.11.0.0-352

  • CMLLookupService   2.4.0.4.11.0.0-352

  • ConfluentEncodedSchemaReferenceReader   2.4.0.4.11.0.0-352

  • ConfluentEncodedSchemaReferenceWriter   2.4.0.4.11.0.0-352

  • ConfluentSchemaRegistry   2.4.0.4.11.0.0-352

  • CouchbaseClusterService   2.4.0.4.11.0.0-352

  • CouchbaseKeyValueLookupService   2.4.0.4.11.0.0-352

  • CouchbaseMapCacheClient   2.4.0.4.11.0.0-352

  • CouchbaseRecordLookupService   2.4.0.4.11.0.0-352

  • CSVReader   2.4.0.4.11.0.0-352

  • CSVRecordLookupService   2.4.0.4.11.0.0-352

  • CSVRecordSetWriter   2.4.0.4.11.0.0-352

  • DatabaseRecordLookupService   2.4.0.4.11.0.0-352

  • DatabaseRecordSink   2.4.0.4.11.0.0-352

  • DatabaseTableSchemaRegistry   2.4.0.4.11.0.0-352

  • DBCPConnectionPool   2.4.0.4.11.0.0-352

  • DBCPConnectionPoolLookup   2.4.0.4.11.0.0-352

  • DeveloperBoxClientService   2.4.0.4.11.0.0-352

  • DistributedMapCacheLookupService   2.4.0.4.11.0.0-352

  • EBCDICRecordReader   2.4.0.4.11.0.0-352

  • ElasticSearchClientServiceImpl   2.4.0.4.11.0.0-352

  • ElasticSearchLookupService   2.4.0.4.11.0.0-352

  • ElasticSearchStringLookupService   2.4.0.4.11.0.0-352

  • EmailRecordSink   2.4.0.4.11.0.0-352

  • EmbeddedHazelcastCacheManager   2.4.0.4.11.0.0-352

  • ExcelReader   2.4.0.4.11.0.0-352

  • ExternalHazelcastCacheManager   2.4.0.4.11.0.0-352

  • FreeFormTextRecordSetWriter   2.4.0.4.11.0.0-352

  • GCPCredentialsControllerService   2.4.0.4.11.0.0-352

  • GCSFileResourceService   2.4.0.4.11.0.0-352

  • GenericPLC4XConnectionPool   2.4.0.4.11.0.0-352

  • GrokReader   2.4.0.4.11.0.0-352

  • HadoopCatalogService   2.4.0.4.11.0.0-352

  • HadoopDBCPConnectionPool   2.4.0.4.11.0.0-352

  • HazelcastMapCacheClient   2.4.0.4.11.0.0-352

  • HBase_2_ClientMapCacheService   2.4.0.4.11.0.0-352

  • HBase_2_ClientService   2.4.0.4.11.0.0-352

  • HBase_2_RecordLookupService   2.4.0.4.11.0.0-352

  • HikariCPConnectionPool   2.4.0.4.11.0.0-352

  • HiveCatalogService   2.4.0.4.11.0.0-352

  • HttpRecordSink   2.4.0.4.11.0.0-352

  • ImpalaConnectionPool   2.4.0.4.11.0.0-352

  • IPFIXReader   2.4.0.4.11.0.0-352

  • IPLookupService   2.4.0.4.11.0.0-352

  • JASN1Reader   2.4.0.4.11.0.0-352

  • JdbcCatalogService   2.4.0.4.11.0.0-352

  • JettyWebSocketClient   2.4.0.4.11.0.0-352

  • JettyWebSocketServer   2.4.0.4.11.0.0-352

  • JiraRecordSink   2.4.0.4.11.0.0-352

  • JMSConnectionFactoryProvider   2.4.0.4.11.0.0-352

  • JndiJmsConnectionFactoryProvider   2.4.0.4.11.0.0-352

  • JsonConfigBasedBoxClientService   2.4.0.4.11.0.0-352

  • JsonPathReader   2.4.0.4.11.0.0-352

  • JsonRecordSetWriter   2.4.0.4.11.0.0-352

  • JsonTreeReader   2.4.0.4.11.0.0-352

  • JWTBearerOAuth2AccessTokenProvider   2.4.0.4.11.0.0-352

  • Kafka3ConnectionService   2.4.0.4.11.0.0-352

  • Kafka3ConnectionService   2.4.0.4.11.0.0-352

  • KafkaRecordSink_2_6   2.4.0.4.11.0.0-352

  • KerberosKeytabUserService   2.4.0.4.11.0.0-352

  • KerberosPasswordUserService   2.4.0.4.11.0.0-352

  • KerberosTicketCacheUserService   2.4.0.4.11.0.0-352

  • KuduLookupService   2.4.0.4.11.0.0-352

  • LivySessionController   2.4.0.4.11.0.0-352

  • LoggingRecordSink   2.4.0.4.11.0.0-352

  • MapCacheClientService   2.4.0.4.11.0.0-352

  • MapCacheServer   2.4.0.4.11.0.0-352

  • MongoDBControllerService   2.4.0.4.11.0.0-352

  • MongoDBLookupService   2.4.0.4.11.0.0-352

  • Neo4JCypherClientService   2.4.0.4.11.0.0-352

  • ParquetReader   2.4.0.4.11.0.0-352

  • ParquetRecordSetWriter   2.4.0.4.11.0.0-352

  • PEMEncodedSSLContextProvider   2.4.0.4.11.0.0-352

  • PhoenixThickConnectionPool   2.4.0.4.11.0.0-352

  • PhoenixThinConnectionPool   2.4.0.4.11.0.0-352

  • PostgreSQLConnectionPool   2.4.0.4.11.0.0-352

  • PropertiesFileLookupService   2.4.0.4.11.0.0-352

  • ProtobufReader   2.4.0.4.11.0.0-352

  • ProxyPLC4XConnectionPool   2.4.0.4.11.0.0-352

  • RabbitMQJMSConnectionFactoryProvider   2.4.0.4.11.0.0-352

  • ReaderLookup   2.4.0.4.11.0.0-352

  • RecordSetWriterLookup   2.4.0.4.11.0.0-352

  • RecordSinkServiceLookup   2.4.0.4.11.0.0-352

  • RedisConnectionPoolService   2.4.0.4.11.0.0-352

  • RedisDistributedMapCacheClientService   2.4.0.4.11.0.0-352

  • RedshiftConnectionPool   2.4.0.4.11.0.0-352

  • RESTCatalogService   2.4.0.4.11.0.0-352

  • RestLookupService   2.4.0.4.11.0.0-352

  • S3FileResourceService   2.4.0.4.11.0.0-352

  • ScriptedLookupService   2.4.0.4.11.0.0-352

  • ScriptedReader   2.4.0.4.11.0.0-352

  • ScriptedRecordSetWriter   2.4.0.4.11.0.0-352

  • ScriptedRecordSink   2.4.0.4.11.0.0-352

  • SetCacheClientService   2.4.0.4.11.0.0-352

  • SetCacheServer   2.4.0.4.11.0.0-352

  • SimpleCsvFileLookupService   2.4.0.4.11.0.0-352

  • SimpleDatabaseLookupService   2.4.0.4.11.0.0-352

  • SimpleKeyValueLookupService   2.4.0.4.11.0.0-352

  • SimpleRedisDistributedMapCacheClientService   2.4.0.4.11.0.0-352

  • SimpleScriptedLookupService   2.4.0.4.11.0.0-352

  • SiteToSiteReportingRecordSink   2.4.0.4.11.0.0-352

  • SlackRecordSink   2.4.0.4.11.0.0-352

  • SmbjClientProviderService   2.4.0.4.11.0.0-352

  • SnowflakeComputingConnectionPool   2.4.0.4.11.0.0-352

  • StandardAsanaClientProviderService   2.4.0.4.11.0.0-352

  • StandardAzureCredentialsControllerService   2.4.0.4.11.0.0-352

  • StandardDatabaseDialectService   2.4.0.4.11.0.0-352

  • StandardDropboxCredentialService   2.4.0.4.11.0.0-352

  • StandardFileResourceService   2.4.0.4.11.0.0-352

  • StandardHashiCorpVaultClientService   2.4.0.4.11.0.0-352

  • StandardHttpContextMap   2.4.0.4.11.0.0-352

  • StandardJiraCredentialService   2.4.0.4.11.0.0-352

  • StandardJsonSchemaRegistry   2.4.0.4.11.0.0-352

  • StandardKustoIngestService   2.4.0.4.11.0.0-352

  • StandardKustoQueryService   2.4.0.4.11.0.0-352

  • StandardOauth2AccessTokenProvider   2.4.0.4.11.0.0-352

  • StandardPGPPrivateKeyService   2.4.0.4.11.0.0-352

  • StandardPGPPublicKeyService   2.4.0.4.11.0.0-352

  • StandardPLC4XConnectionPool   2.4.0.4.11.0.0-352

  • StandardPrivateKeyService   2.4.0.4.11.0.0-352

  • StandardProxyConfigurationService   2.4.0.4.11.0.0-352

  • StandardRestrictedSSLContextService   2.4.0.4.11.0.0-352

  • StandardS3EncryptionService   2.4.0.4.11.0.0-352

  • StandardSnowflakeIngestManagerProviderService   2.4.0.4.11.0.0-352

  • StandardSSLContextService   2.4.0.4.11.0.0-352

  • StandardWebClientServiceProvider   2.4.0.4.11.0.0-352

  • Syslog5424Reader   2.4.0.4.11.0.0-352

  • SyslogReader   2.4.0.4.11.0.0-352

  • TinkerpopClientService   2.4.0.4.11.0.0-352

  • UDPEventRecordSink   2.4.0.4.11.0.0-352

  • VolatileSchemaCache   2.4.0.4.11.0.0-352

  • WindowsEventLogReader   2.4.0.4.11.0.0-352

  • XMLFileLookupService   2.4.0.4.11.0.0-352

  • XMLReader   2.4.0.4.11.0.0-352

  • XMLRecordSetWriter   2.4.0.4.11.0.0-352

  • YamlTreeReader   2.4.0.4.11.0.0-352

  • ZendeskRecordSink   2.4.0.4.11.0.0-352

• Reporting Tasks

  • AzureLogAnalyticsProvenanceReportingTask   2.4.0.4.11.0.0-352

  • AzureLogAnalyticsReportingTask   2.4.0.4.11.0.0-352

  • ControllerStatusReportingTask   2.4.0.4.11.0.0-352

  • MonitorDiskUsage   2.4.0.4.11.0.0-352

  • MonitorMemory   2.4.0.4.11.0.0-352

  • QueryNiFiReportingTask   2.4.0.4.11.0.0-352

  • ReportLineageToAtlas   2.4.0.4.11.0.0-352

  • ScriptedReportingTask   2.4.0.4.11.0.0-352

  • SiteToSiteBulletinReportingTask   2.4.0.4.11.0.0-352

  • SiteToSiteMetricsReportingTask   2.4.0.4.11.0.0-352

  • SiteToSiteProvenanceReportingTask   2.4.0.4.11.0.0-352

  • SiteToSiteStatusReportingTask   2.4.0.4.11.0.0-352

• Parameter Providers

  • AwsSecretsManagerParameterProvider   2.4.0.4.11.0.0-352

  • AzureKeyVaultSecretsParameterProvider   2.4.0.4.11.0.0-352

  • CyberArkConjurParameterProvider   2.4.0.4.11.0.0-352

  • DatabaseParameterProvider   2.4.0.4.11.0.0-352

  • EnvironmentVariableParameterProvider   2.4.0.4.11.0.0-352

  • GcpSecretManagerParameterProvider   2.4.0.4.11.0.0-352

  • HashiCorpVaultParameterProvider   2.4.0.4.11.0.0-352

  • KubernetesSecretParameterProvider   2.4.0.4.11.0.0-352

  • OnePasswordParameterProvider   2.4.0.4.11.0.0-352

• Flow Analysis Rules

  • DisallowComponentType   2.4.0.4.11.0.0-352

  • DisallowConsecutiveConnectionsWithRoundRobinLB   2.4.0.4.11.0.0-352

  • DisallowDeadEnd   2.4.0.4.11.0.0-352

  • DisallowDeprecatedProcessor   2.4.0.4.11.0.0-352

  • DisallowExtractTextForFullContent   2.4.0.4.11.0.0-352

  • RecommendRecordProcessor   2.4.0.4.11.0.0-352

  • RequireHandleHttpResponseAfterHandleHttpRequest   2.4.0.4.11.0.0-352

  • RequireMergeBeforePutIceberg   2.4.0.4.11.0.0-352

  • RequireServerSSLContextService   2.4.0.4.11.0.0-352

  • RestrictBackpressureSettings   2.4.0.4.11.0.0-352

  • RestrictComponentNaming   2.4.0.4.11.0.0-352

  • RestrictConcurrentTasksVsThreadPoolSizeInProcessors   2.4.0.4.11.0.0-352

  • RestrictFlowFileExpiration   2.4.0.4.11.0.0-352

  • RestrictProcessorConcurrency   2.4.0.4.11.0.0-352

  • RestrictSchedulingForListProcessors   2.4.0.4.11.0.0-352

  • RestrictThreadPoolSize   2.4.0.4.11.0.0-352

  • RestrictYieldDurationForConsumeKafkaProcessors   2.4.0.4.11.0.0-352

ParquetReader 2.4.0.4.11.0.0-352

Bundle

org.apache.nifi | nifi-parquet-nar

Description

Parses Parquet data and returns each Parquet record as a separate Record object. The schema will come from the Parquet data itself.

Tags

parquet, parse, reader, record, row

Input Requirement

Supports Sensitive Dynamic Properties

false