• 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.3.3.0-40

  • AttributesToCSV   2.4.0.4.3.3.0-40

  • AttributesToJSON   2.4.0.4.3.3.0-40

  • CalculateParquetOffsets   2.4.0.4.3.3.0-40

  • CalculateParquetRowGroupOffsets   2.4.0.4.3.3.0-40

  • CalculateRecordStats   2.4.0.4.3.3.0-40

  • CaptureChangeDebeziumDB2   2.4.0.4.3.3.0-40

  • CaptureChangeDebeziumMongoDB   2.4.0.4.3.3.0-40

  • CaptureChangeDebeziumMySQL   2.4.0.4.3.3.0-40

  • CaptureChangeDebeziumOracle   2.4.0.4.3.3.0-40

  • CaptureChangeDebeziumPostgreSQL   2.4.0.4.3.3.0-40

  • CaptureChangeDebeziumSQLServer   2.4.0.4.3.3.0-40

  • CaptureChangeMySQL   2.4.0.4.3.3.0-40

  • CompressContent   2.4.0.4.3.3.0-40

  • ConnectWebSocket   2.4.0.4.3.3.0-40

  • ConsumeAMQP   2.4.0.4.3.3.0-40

  • ConsumeAzureEventHub   2.4.0.4.3.3.0-40

  • ConsumeBoxEnterpriseEvents   2.4.0.4.3.3.0-40

  • ConsumeBoxEvents   2.4.0.4.3.3.0-40

  • ConsumeElasticsearch   2.4.0.4.3.3.0-40

  • ConsumeGCPubSub   2.4.0.4.3.3.0-40

  • ConsumeIMAP   2.4.0.4.3.3.0-40

  • ConsumeJMS   2.4.0.4.3.3.0-40

  • ConsumeKafka   2.4.0.4.3.3.0-40

  • ConsumeKafka_2_6   2.4.0.4.3.3.0-40

  • ConsumeKafka2CDP   2.4.0.4.3.3.0-40

  • ConsumeKafka2RecordCDP   2.4.0.4.3.3.0-40

  • ConsumeKafkaRecord_2_6   2.4.0.4.3.3.0-40

  • ConsumeKinesisStream   2.4.0.4.3.3.0-40

  • ConsumeMQTT   2.4.0.4.3.3.0-40

  • ConsumePLC   2.4.0.4.3.3.0-40

  • ConsumePOP3   2.4.0.4.3.3.0-40

  • ConsumeSlack   2.4.0.4.3.3.0-40

  • ConsumeTwitter   2.4.0.4.3.3.0-40

  • ConsumeWindowsEventLog   2.4.0.4.3.3.0-40

  • ControlRate   2.4.0.4.3.3.0-40

  • ConvertAvroToParquet   2.4.0.4.3.3.0-40

  • ConvertCharacterSet   2.4.0.4.3.3.0-40

  • ConvertProtobuf   2.4.0.4.3.3.0-40

  • ConvertRecord   2.4.0.4.3.3.0-40

  • CopyAzureBlobStorage_v12   2.4.0.4.3.3.0-40

  • CopyS3Object   2.4.0.4.3.3.0-40

  • CountText   2.4.0.4.3.3.0-40

  • CreateBoxFileMetadataInstance   2.4.0.4.3.3.0-40

  • CreateBoxMetadataTemplate   2.4.0.4.3.3.0-40

  • CreateHadoopSequenceFile   2.4.0.4.3.3.0-40

  • CryptographicHashContent   2.4.0.4.3.3.0-40

  • DebugFlow   2.4.0.4.3.3.0-40

  • DecryptContentAge   2.4.0.4.3.3.0-40

  • DecryptContentPGP   2.4.0.4.3.3.0-40

  • DeduplicateRecord   2.4.0.4.3.3.0-40

  • DeleteAzureBlobStorage_v12   2.4.0.4.3.3.0-40

  • DeleteAzureDataLakeStorage   2.4.0.4.3.3.0-40

  • DeleteBoxFileMetadataInstance   2.4.0.4.3.3.0-40

  • DeleteByQueryElasticsearch   2.4.0.4.3.3.0-40

  • DeleteCDPObjectStore   2.4.0.4.3.3.0-40

  • DeleteDynamoDB   2.4.0.4.3.3.0-40

  • DeleteFile   2.4.0.4.3.3.0-40

  • DeleteGCSObject   2.4.0.4.3.3.0-40

  • DeleteGridFS   2.4.0.4.3.3.0-40

  • DeleteHBaseCells   2.4.0.4.3.3.0-40

  • DeleteHBaseRow   2.4.0.4.3.3.0-40

  • DeleteHDFS   2.4.0.4.3.3.0-40

  • DeleteMongo   2.4.0.4.3.3.0-40

  • DeleteS3Object   2.4.0.4.3.3.0-40

  • DeleteSFTP   2.4.0.4.3.3.0-40

  • DeleteSQS   2.4.0.4.3.3.0-40

  • DetectDuplicate   2.4.0.4.3.3.0-40

  • DistributeLoad   2.4.0.4.3.3.0-40

  • DuplicateFlowFile   2.4.0.4.3.3.0-40

  • EncodeContent   2.4.0.4.3.3.0-40

  • EncryptContentAge   2.4.0.4.3.3.0-40

  • EncryptContentPGP   2.4.0.4.3.3.0-40

  • EnforceOrder   2.4.0.4.3.3.0-40

  • EvaluateJsonPath   2.4.0.4.3.3.0-40

  • EvaluateXPath   2.4.0.4.3.3.0-40

  • EvaluateXQuery   2.4.0.4.3.3.0-40

  • ExecuteGraphQuery   2.4.0.4.3.3.0-40

  • ExecuteGraphQueryRecord   2.4.0.4.3.3.0-40

  • ExecuteGroovyScript   2.4.0.4.3.3.0-40

  • ExecuteProcess   2.4.0.4.3.3.0-40

  • ExecuteScript   2.4.0.4.3.3.0-40

  • ExecuteSparkInteractive   2.4.0.4.3.3.0-40

  • ExecuteSQL   2.4.0.4.3.3.0-40

  • ExecuteSQLRecord   2.4.0.4.3.3.0-40

  • ExecuteStreamCommand   2.4.0.4.3.3.0-40

  • ExtractAvroMetadata   2.4.0.4.3.3.0-40

  • ExtractDocumentText   2.4.0.4.3.3.0-40

  • ExtractEmailAttachments   2.4.0.4.3.3.0-40

  • ExtractEmailHeaders   2.4.0.4.3.3.0-40

  • ExtractGrok   2.4.0.4.3.3.0-40

  • ExtractHL7Attributes   2.4.0.4.3.3.0-40

  • ExtractImageMetadata   2.4.0.4.3.3.0-40

  • ExtractMediaMetadata   2.4.0.4.3.3.0-40

  • ExtractRecordSchema   2.4.0.4.3.3.0-40

  • ExtractStructuredBoxFileMetadata   2.4.0.4.3.3.0-40

  • ExtractText   2.4.0.4.3.3.0-40

  • FetchAzureBlobStorage_v12   2.4.0.4.3.3.0-40

  • FetchAzureDataLakeStorage   2.4.0.4.3.3.0-40

  • FetchBoxFile   2.4.0.4.3.3.0-40

  • FetchBoxFileInfo   2.4.0.4.3.3.0-40

  • FetchBoxFileMetadataInstance   2.4.0.4.3.3.0-40

  • FetchBoxFileRepresentation   2.4.0.4.3.3.0-40

  • FetchCDPObjectStore   2.4.0.4.3.3.0-40

  • FetchDistributedMapCache   2.4.0.4.3.3.0-40

  • FetchDropbox   2.4.0.4.3.3.0-40

  • FetchFile   2.4.0.4.3.3.0-40

  • FetchFTP   2.4.0.4.3.3.0-40

  • FetchGCSObject   2.4.0.4.3.3.0-40

  • FetchGoogleDrive   2.4.0.4.3.3.0-40

  • FetchGridFS   2.4.0.4.3.3.0-40

  • FetchHBaseRow   2.4.0.4.3.3.0-40

  • FetchHDFS   2.4.0.4.3.3.0-40

  • FetchParquet   2.4.0.4.3.3.0-40

  • FetchPLC   2.4.0.4.3.3.0-40

  • FetchS3Object   2.4.0.4.3.3.0-40

  • FetchSFTP   2.4.0.4.3.3.0-40

  • FetchSmb   2.4.0.4.3.3.0-40

  • FilterAttribute   2.4.0.4.3.3.0-40

  • FlattenJson   2.4.0.4.3.3.0-40

  • ForkEnrichment   2.4.0.4.3.3.0-40

  • ForkRecord   2.4.0.4.3.3.0-40

  • GenerateFlowFile   2.4.0.4.3.3.0-40

  • GenerateRecord   2.4.0.4.3.3.0-40

  • GenerateTableFetch   2.4.0.4.3.3.0-40

  • GeoEnrichIP   2.4.0.4.3.3.0-40

  • GeoEnrichIPRecord   2.4.0.4.3.3.0-40

  • GeohashRecord   2.4.0.4.3.3.0-40

  • GetAsanaObject   2.4.0.4.3.3.0-40

  • GetAwsPollyJobStatus   2.4.0.4.3.3.0-40

  • GetAwsTextractJobStatus   2.4.0.4.3.3.0-40

  • GetAwsTranscribeJobStatus   2.4.0.4.3.3.0-40

  • GetAwsTranslateJobStatus   2.4.0.4.3.3.0-40

  • GetAzureEventHub   2.4.0.4.3.3.0-40

  • GetAzureQueueStorage_v12   2.4.0.4.3.3.0-40

  • GetBoxFileCollaborators   2.4.0.4.3.3.0-40

  • GetBoxGroupMembers   2.4.0.4.3.3.0-40

  • GetCouchbaseKey   2.4.0.4.3.3.0-40

  • GetDynamoDB   2.4.0.4.3.3.0-40

  • GetElasticsearch   2.4.0.4.3.3.0-40

  • GetFile   2.4.0.4.3.3.0-40

  • GetFileResource   2.4.0.4.3.3.0-40

  • GetFTP   2.4.0.4.3.3.0-40

  • GetGcpVisionAnnotateFilesOperationStatus   2.4.0.4.3.3.0-40

  • GetGcpVisionAnnotateImagesOperationStatus   2.4.0.4.3.3.0-40

  • GetHBase   2.4.0.4.3.3.0-40

  • GetHDFS   2.4.0.4.3.3.0-40

  • GetHDFSEvents   2.4.0.4.3.3.0-40

  • GetHDFSFileInfo   2.4.0.4.3.3.0-40

  • GetHDFSSequenceFile   2.4.0.4.3.3.0-40

  • GetHubSpot   2.4.0.4.3.3.0-40

  • GetJiraIssue   2.4.0.4.3.3.0-40

  • GetMongo   2.4.0.4.3.3.0-40

  • GetMongoRecord   2.4.0.4.3.3.0-40

  • GetS3ObjectMetadata   2.4.0.4.3.3.0-40

  • GetS3ObjectTags   2.4.0.4.3.3.0-40

  • GetSFTP   2.4.0.4.3.3.0-40

  • GetShopify   2.4.0.4.3.3.0-40

  • GetSlackReaction   2.4.0.4.3.3.0-40

  • GetSmbFile   2.4.0.4.3.3.0-40

  • GetSNMP   2.4.0.4.3.3.0-40

  • GetSnowflakeIngestStatus   2.4.0.4.3.3.0-40

  • GetSolr   2.4.0.4.3.3.0-40

  • GetSplunk   2.4.0.4.3.3.0-40

  • GetSQS   2.4.0.4.3.3.0-40

  • GetTCP   2.4.0.4.3.3.0-40

  • GetWorkdayReport   2.4.0.4.3.3.0-40

  • GetZendesk   2.4.0.4.3.3.0-40

  • HandleHttpRequest   2.4.0.4.3.3.0-40

  • HandleHttpResponse   2.4.0.4.3.3.0-40

  • IdentifyMimeType   2.4.0.4.3.3.0-40

  • InvokeGRPC   2.4.0.4.3.3.0-40

  • InvokeHTTP   2.4.0.4.3.3.0-40

  • InvokeScriptedProcessor   2.4.0.4.3.3.0-40

  • ISPEnrichIP   2.4.0.4.3.3.0-40

  • JoinEnrichment   2.4.0.4.3.3.0-40

  • JoltTransformJSON   2.4.0.4.3.3.0-40

  • JoltTransformRecord   2.4.0.4.3.3.0-40

  • JSLTTransformJSON   2.4.0.4.3.3.0-40

  • JsonQueryElasticsearch   2.4.0.4.3.3.0-40

  • ListAzureBlobStorage_v12   2.4.0.4.3.3.0-40

  • ListAzureDataLakeStorage   2.4.0.4.3.3.0-40

  • ListBoxFile   2.4.0.4.3.3.0-40

  • ListBoxFileInfo   2.4.0.4.3.3.0-40

  • ListBoxFileMetadataInstances   2.4.0.4.3.3.0-40

  • ListBoxFileMetadataTemplates   2.4.0.4.3.3.0-40

  • ListCDPObjectStore   2.4.0.4.3.3.0-40

  • ListDatabaseTables   2.4.0.4.3.3.0-40

  • ListDropbox   2.4.0.4.3.3.0-40

  • ListenBeats   2.4.0.4.3.3.0-40

  • ListenFTP   2.4.0.4.3.3.0-40

  • ListenGRPC   2.4.0.4.3.3.0-40

  • ListenHTTP   2.4.0.4.3.3.0-40

  • ListenNetFlow   2.4.0.4.3.3.0-40

  • ListenOTLP   2.4.0.4.3.3.0-40

  • ListenSlack   2.4.0.4.3.3.0-40

  • ListenSyslog   2.4.0.4.3.3.0-40

  • ListenTCP   2.4.0.4.3.3.0-40

  • ListenTrapSNMP   2.4.0.4.3.3.0-40

  • ListenUDP   2.4.0.4.3.3.0-40

  • ListenUDPRecord   2.4.0.4.3.3.0-40

  • ListenWebSocket   2.4.0.4.3.3.0-40

  • ListFile   2.4.0.4.3.3.0-40

  • ListFTP   2.4.0.4.3.3.0-40

  • ListGCSBucket   2.4.0.4.3.3.0-40

  • ListGoogleDrive   2.4.0.4.3.3.0-40

  • ListHBaseRegions   2.4.0.4.3.3.0-40

  • ListHDFS   2.4.0.4.3.3.0-40

  • ListS3   2.4.0.4.3.3.0-40

  • ListSFTP   2.4.0.4.3.3.0-40

  • ListSmb   2.4.0.4.3.3.0-40

  • LogAttribute   2.4.0.4.3.3.0-40

  • LogMessage   2.4.0.4.3.3.0-40

  • LookupAttribute   2.4.0.4.3.3.0-40

  • LookupRecord   2.4.0.4.3.3.0-40

  • MergeContent   2.4.0.4.3.3.0-40

  • MergeRecord   2.4.0.4.3.3.0-40

  • ModifyBytes   2.4.0.4.3.3.0-40

  • ModifyCompression   2.4.0.4.3.3.0-40

  • MonitorActivity   2.4.0.4.3.3.0-40

  • MoveAzureDataLakeStorage   2.4.0.4.3.3.0-40

  • MoveHDFS   2.4.0.4.3.3.0-40

  • Notify   2.4.0.4.3.3.0-40

  • PackageFlowFile   2.4.0.4.3.3.0-40

  • PaginatedJsonQueryElasticsearch   2.4.0.4.3.3.0-40

  • ParseEvtx   2.4.0.4.3.3.0-40

  • ParseNetflowv5   2.4.0.4.3.3.0-40

  • ParseSyslog   2.4.0.4.3.3.0-40

  • ParseSyslog5424   2.4.0.4.3.3.0-40

  • PartitionRecord   2.4.0.4.3.3.0-40

  • PublishAMQP   2.4.0.4.3.3.0-40

  • PublishGCPubSub   2.4.0.4.3.3.0-40

  • PublishJMS   2.4.0.4.3.3.0-40

  • PublishKafka   2.4.0.4.3.3.0-40

  • PublishKafka_2_6   2.4.0.4.3.3.0-40

  • PublishKafka2CDP   2.4.0.4.3.3.0-40

  • PublishKafka2RecordCDP   2.4.0.4.3.3.0-40

  • PublishKafkaRecord_2_6   2.4.0.4.3.3.0-40

  • PublishMQTT   2.4.0.4.3.3.0-40

  • PublishSlack   2.4.0.4.3.3.0-40

  • PutAccumuloRecord   2.4.0.4.3.3.0-40

  • PutAzureBlobStorage_v12   2.4.0.4.3.3.0-40

  • PutAzureCosmosDBRecord   2.4.0.4.3.3.0-40

  • PutAzureDataExplorer   2.4.0.4.3.3.0-40

  • PutAzureDataLakeStorage   2.4.0.4.3.3.0-40

  • PutAzureEventHub   2.4.0.4.3.3.0-40

  • PutAzureQueueStorage_v12   2.4.0.4.3.3.0-40

  • PutBigQuery   2.4.0.4.3.3.0-40

  • PutBoxFile   2.4.0.4.3.3.0-40

  • PutCassandraQL   2.4.0.4.3.3.0-40

  • PutCassandraRecord   2.4.0.4.3.3.0-40

  • PutCDPObjectStore   2.4.0.4.3.3.0-40

  • PutClouderaHiveQL   2.4.0.4.3.3.0-40

  • PutClouderaHiveStreaming   2.4.0.4.3.3.0-40

  • PutClouderaORC   2.4.0.4.3.3.0-40

  • PutCloudWatchMetric   2.4.0.4.3.3.0-40

  • PutCouchbaseKey   2.4.0.4.3.3.0-40

  • PutDatabaseRecord   2.4.0.4.3.3.0-40

  • PutDistributedMapCache   2.4.0.4.3.3.0-40

  • PutDropbox   2.4.0.4.3.3.0-40

  • PutDynamoDB   2.4.0.4.3.3.0-40

  • PutDynamoDBRecord   2.4.0.4.3.3.0-40

  • PutElasticsearchJson   2.4.0.4.3.3.0-40

  • PutElasticsearchRecord   2.4.0.4.3.3.0-40

  • PutEmail   2.4.0.4.3.3.0-40

  • PutFile   2.4.0.4.3.3.0-40

  • PutFTP   2.4.0.4.3.3.0-40

  • PutGCSObject   2.4.0.4.3.3.0-40

  • PutGoogleDrive   2.4.0.4.3.3.0-40

  • PutGridFS   2.4.0.4.3.3.0-40

  • PutHBaseCell   2.4.0.4.3.3.0-40

  • PutHBaseJSON   2.4.0.4.3.3.0-40

  • PutHBaseRecord   2.4.0.4.3.3.0-40

  • PutHDFS   2.4.0.4.3.3.0-40

  • PutIceberg   2.4.0.4.3.3.0-40

  • PutIcebergCDC   2.4.0.4.3.3.0-40

  • PutIoTDBRecord   2.4.0.4.3.3.0-40

  • PutJiraIssue   2.4.0.4.3.3.0-40

  • PutKinesisFirehose   2.4.0.4.3.3.0-40

  • PutKinesisStream   2.4.0.4.3.3.0-40

  • PutKudu   2.4.0.4.3.3.0-40

  • PutLambda   2.4.0.4.3.3.0-40

  • PutMongo   2.4.0.4.3.3.0-40

  • PutMongoBulkOperations   2.4.0.4.3.3.0-40

  • PutMongoRecord   2.4.0.4.3.3.0-40

  • PutParquet   2.4.0.4.3.3.0-40

  • PutPLC   2.4.0.4.3.3.0-40

  • PutRecord   2.4.0.4.3.3.0-40

  • PutRedisHashRecord   2.4.0.4.3.3.0-40

  • PutS3Object   2.4.0.4.3.3.0-40

  • PutSalesforceObject   2.4.0.4.3.3.0-40

  • PutSFTP   2.4.0.4.3.3.0-40

  • PutSmbFile   2.4.0.4.3.3.0-40

  • PutSnowflakeInternalStage   2.4.0.4.3.3.0-40

  • PutSNS   2.4.0.4.3.3.0-40

  • PutSolrContentStream   2.4.0.4.3.3.0-40

  • PutSolrRecord   2.4.0.4.3.3.0-40

  • PutSplunk   2.4.0.4.3.3.0-40

  • PutSplunkHTTP   2.4.0.4.3.3.0-40

  • PutSQL   2.4.0.4.3.3.0-40

  • PutSQS   2.4.0.4.3.3.0-40

  • PutSyslog   2.4.0.4.3.3.0-40

  • PutTCP   2.4.0.4.3.3.0-40

  • PutUDP   2.4.0.4.3.3.0-40

  • PutWebSocket   2.4.0.4.3.3.0-40

  • PutZendeskTicket   2.4.0.4.3.3.0-40

  • QueryAirtableTable   2.4.0.4.3.3.0-40

  • QueryAzureDataExplorer   2.4.0.4.3.3.0-40

  • QueryCassandra   2.4.0.4.3.3.0-40

  • QueryDatabaseTable   2.4.0.4.3.3.0-40

  • QueryDatabaseTableRecord   2.4.0.4.3.3.0-40

  • QueryIoTDBRecord   2.4.0.4.3.3.0-40

  • QueryRecord   2.4.0.4.3.3.0-40

  • QuerySalesforceObject   2.4.0.4.3.3.0-40

  • QuerySolr   2.4.0.4.3.3.0-40

  • QuerySplunkIndexingStatus   2.4.0.4.3.3.0-40

  • RemoveRecordField   2.4.0.4.3.3.0-40

  • RenameRecordField   2.4.0.4.3.3.0-40

  • ReplaceText   2.4.0.4.3.3.0-40

  • ReplaceTextWithMapping   2.4.0.4.3.3.0-40

  • ResizeImage   2.4.0.4.3.3.0-40

  • RetryFlowFile   2.4.0.4.3.3.0-40

  • RouteHL7   2.4.0.4.3.3.0-40

  • RouteOnAttribute   2.4.0.4.3.3.0-40

  • RouteOnContent   2.4.0.4.3.3.0-40

  • RouteText   2.4.0.4.3.3.0-40

  • RunMongoAggregation   2.4.0.4.3.3.0-40

  • SampleRecord   2.4.0.4.3.3.0-40

  • SawmillTransformJSON   2.4.0.4.3.3.0-40

  • SawmillTransformRecord   2.4.0.4.3.3.0-40

  • ScanAccumulo   2.4.0.4.3.3.0-40

  • ScanAttribute   2.4.0.4.3.3.0-40

  • ScanContent   2.4.0.4.3.3.0-40

  • ScanHBase   2.4.0.4.3.3.0-40

  • ScriptedFilterRecord   2.4.0.4.3.3.0-40

  • ScriptedPartitionRecord   2.4.0.4.3.3.0-40

  • ScriptedTransformRecord   2.4.0.4.3.3.0-40

  • ScriptedValidateRecord   2.4.0.4.3.3.0-40

  • SearchElasticsearch   2.4.0.4.3.3.0-40

  • SegmentContent   2.4.0.4.3.3.0-40

  • SelectClouderaHiveQL   2.4.0.4.3.3.0-40

  • SendTrapSNMP   2.4.0.4.3.3.0-40

  • SetSNMP   2.4.0.4.3.3.0-40

  • SignContentPGP   2.4.0.4.3.3.0-40

  • SplitAvro   2.4.0.4.3.3.0-40

  • SplitContent   2.4.0.4.3.3.0-40

  • SplitExcel   2.4.0.4.3.3.0-40

  • SplitJson   2.4.0.4.3.3.0-40

  • SplitPCAP   2.4.0.4.3.3.0-40

  • SplitRecord   2.4.0.4.3.3.0-40

  • SplitText   2.4.0.4.3.3.0-40

  • SplitXml   2.4.0.4.3.3.0-40

  • StartAwsPollyJob   2.4.0.4.3.3.0-40

  • StartAwsTextractJob   2.4.0.4.3.3.0-40

  • StartAwsTranscribeJob   2.4.0.4.3.3.0-40

  • StartAwsTranslateJob   2.4.0.4.3.3.0-40

  • StartGcpVisionAnnotateFilesOperation   2.4.0.4.3.3.0-40

  • StartGcpVisionAnnotateImagesOperation   2.4.0.4.3.3.0-40

  • StartSnowflakeIngest   2.4.0.4.3.3.0-40

  • TagS3Object   2.4.0.4.3.3.0-40

  • TailFile   2.4.0.4.3.3.0-40

  • TransformXml   2.4.0.4.3.3.0-40

  • TriggerClouderaHiveMetaStoreEvent   2.4.0.4.3.3.0-40

  • UnpackContent   2.4.0.4.3.3.0-40

  • UpdateAttribute   2.4.0.4.3.3.0-40

  • UpdateBoxFileMetadataInstance   2.4.0.4.3.3.0-40

  • UpdateByQueryElasticsearch   2.4.0.4.3.3.0-40

  • UpdateClouderaHiveTable   2.4.0.4.3.3.0-40

  • UpdateCounter   2.4.0.4.3.3.0-40

  • UpdateDatabaseTable   2.4.0.4.3.3.0-40

  • UpdateDeltaLakeTable   2.4.0.4.3.3.0-40

  • UpdateJiraIssue   2.4.0.4.3.3.0-40

  • UpdateRecord   2.4.0.4.3.3.0-40

  • ValidateCsv   2.4.0.4.3.3.0-40

  • ValidateJson   2.4.0.4.3.3.0-40

  • ValidateRecord   2.4.0.4.3.3.0-40

  • ValidateXml   2.4.0.4.3.3.0-40

  • VerifyContentMAC   2.4.0.4.3.3.0-40

  • VerifyContentPGP   2.4.0.4.3.3.0-40

  • Wait   2.4.0.4.3.3.0-40

• Controller Services

  • AccumuloService   2.4.0.4.3.3.0-40

  • ActiveMQJMSConnectionFactoryProvider   2.4.0.4.3.3.0-40

  • ADLSCredentialsControllerService   2.4.0.4.3.3.0-40

  • ADLSCredentialsControllerServiceLookup   2.4.0.4.3.3.0-40

  • ADLSIDBrokerCloudCredentialsProviderControllerService   2.4.0.4.3.3.0-40

  • AmazonGlueSchemaRegistry   2.4.0.4.3.3.0-40

  • AmazonMSKConnectionService   2.4.0.4.3.3.0-40

  • ApicurioSchemaRegistry   2.4.0.4.3.3.0-40

  • AvroReader   2.4.0.4.3.3.0-40

  • AvroRecordSetWriter   2.4.0.4.3.3.0-40

  • AvroSchemaRegistry   2.4.0.4.3.3.0-40

  • AWSCredentialsProviderControllerService   2.4.0.4.3.3.0-40

  • AWSIDBrokerCloudCredentialsProviderControllerService   2.4.0.4.3.3.0-40

  • AzureBlobIDBrokerCloudCredentialsProviderControllerService   2.4.0.4.3.3.0-40

  • AzureBlobStorageFileResourceService   2.4.0.4.3.3.0-40

  • AzureCosmosDBClientService   2.4.0.4.3.3.0-40

  • AzureDataLakeStorageFileResourceService   2.4.0.4.3.3.0-40

  • AzureEventHubRecordSink   2.4.0.4.3.3.0-40

  • AzureServiceBusJMSConnectionFactoryProvider   2.4.0.4.3.3.0-40

  • AzureStorageCredentialsControllerService_v12   2.4.0.4.3.3.0-40

  • AzureStorageCredentialsControllerServiceLookup_v12   2.4.0.4.3.3.0-40

  • CassandraDistributedMapCache   2.4.0.4.3.3.0-40

  • CassandraSessionProvider   2.4.0.4.3.3.0-40

  • CdpCredentialsProviderControllerService   2.4.0.4.3.3.0-40

  • CdpOauth2AccessTokenProviderControllerService   2.4.0.4.3.3.0-40

  • CEFReader   2.4.0.4.3.3.0-40

  • CiscoEmblemSyslogMessageReader   2.4.0.4.3.3.0-40

  • ClouderaAttributeSchemaReferenceReader   2.4.0.4.3.3.0-40

  • ClouderaAttributeSchemaReferenceWriter   2.4.0.4.3.3.0-40

  • ClouderaEncodedSchemaReferenceReader   2.4.0.4.3.3.0-40

  • ClouderaEncodedSchemaReferenceWriter   2.4.0.4.3.3.0-40

  • ClouderaHiveConnectionPool   2.4.0.4.3.3.0-40

  • ClouderaHiveConnectionPoolLookup   2.4.0.4.3.3.0-40

  • ClouderaSchemaRegistry   2.4.0.4.3.3.0-40

  • CMLLookupService   2.4.0.4.3.3.0-40

  • ConfluentEncodedSchemaReferenceReader   2.4.0.4.3.3.0-40

  • ConfluentEncodedSchemaReferenceWriter   2.4.0.4.3.3.0-40

  • ConfluentSchemaRegistry   2.4.0.4.3.3.0-40

  • CouchbaseClusterService   2.4.0.4.3.3.0-40

  • CouchbaseKeyValueLookupService   2.4.0.4.3.3.0-40

  • CouchbaseMapCacheClient   2.4.0.4.3.3.0-40

  • CouchbaseRecordLookupService   2.4.0.4.3.3.0-40

  • CSVReader   2.4.0.4.3.3.0-40

  • CSVRecordLookupService   2.4.0.4.3.3.0-40

  • CSVRecordSetWriter   2.4.0.4.3.3.0-40

  • DatabaseRecordLookupService   2.4.0.4.3.3.0-40

  • DatabaseRecordSink   2.4.0.4.3.3.0-40

  • DatabaseTableSchemaRegistry   2.4.0.4.3.3.0-40

  • DBCPConnectionPool   2.4.0.4.3.3.0-40

  • DBCPConnectionPoolLookup   2.4.0.4.3.3.0-40

  • DeveloperBoxClientService   2.4.0.4.3.3.0-40

  • DistributedMapCacheLookupService   2.4.0.4.3.3.0-40

  • EBCDICRecordReader   2.4.0.4.3.3.0-40

  • ElasticSearchClientServiceImpl   2.4.0.4.3.3.0-40

  • ElasticSearchLookupService   2.4.0.4.3.3.0-40

  • ElasticSearchStringLookupService   2.4.0.4.3.3.0-40

  • EmailRecordSink   2.4.0.4.3.3.0-40

  • EmbeddedHazelcastCacheManager   2.4.0.4.3.3.0-40

  • ExcelReader   2.4.0.4.3.3.0-40

  • ExternalHazelcastCacheManager   2.4.0.4.3.3.0-40

  • FreeFormTextRecordSetWriter   2.4.0.4.3.3.0-40

  • GCPCredentialsControllerService   2.4.0.4.3.3.0-40

  • GCSFileResourceService   2.4.0.4.3.3.0-40

  • GenericPLC4XConnectionPool   2.4.0.4.3.3.0-40

  • GrokReader   2.4.0.4.3.3.0-40

  • HadoopCatalogService   2.4.0.4.3.3.0-40

  • HadoopDBCPConnectionPool   2.4.0.4.3.3.0-40

  • HazelcastMapCacheClient   2.4.0.4.3.3.0-40

  • HBase_2_ClientMapCacheService   2.4.0.4.3.3.0-40

  • HBase_2_ClientService   2.4.0.4.3.3.0-40

  • HBase_2_RecordLookupService   2.4.0.4.3.3.0-40

  • HikariCPConnectionPool   2.4.0.4.3.3.0-40

  • HiveCatalogService   2.4.0.4.3.3.0-40

  • HttpRecordSink   2.4.0.4.3.3.0-40

  • ImpalaConnectionPool   2.4.0.4.3.3.0-40

  • IPFIXReader   2.4.0.4.3.3.0-40

  • IPLookupService   2.4.0.4.3.3.0-40

  • JASN1Reader   2.4.0.4.3.3.0-40

  • JdbcCatalogService   2.4.0.4.3.3.0-40

  • JettyWebSocketClient   2.4.0.4.3.3.0-40

  • JettyWebSocketServer   2.4.0.4.3.3.0-40

  • JiraRecordSink   2.4.0.4.3.3.0-40

  • JMSConnectionFactoryProvider   2.4.0.4.3.3.0-40

  • JndiJmsConnectionFactoryProvider   2.4.0.4.3.3.0-40

  • JsonConfigBasedBoxClientService   2.4.0.4.3.3.0-40

  • JsonPathReader   2.4.0.4.3.3.0-40

  • JsonRecordSetWriter   2.4.0.4.3.3.0-40

  • JsonTreeReader   2.4.0.4.3.3.0-40

  • JWTBearerOAuth2AccessTokenProvider   2.4.0.4.3.3.0-40

  • Kafka3ConnectionService   2.4.0.4.3.3.0-40

  • KafkaRecordSink_2_6   2.4.0.4.3.3.0-40

  • KerberosKeytabUserService   2.4.0.4.3.3.0-40

  • KerberosPasswordUserService   2.4.0.4.3.3.0-40

  • KerberosTicketCacheUserService   2.4.0.4.3.3.0-40

  • KuduLookupService   2.4.0.4.3.3.0-40

  • LivySessionController   2.4.0.4.3.3.0-40

  • LoggingRecordSink   2.4.0.4.3.3.0-40

  • MapCacheClientService   2.4.0.4.3.3.0-40

  • MapCacheServer   2.4.0.4.3.3.0-40

  • MongoDBControllerService   2.4.0.4.3.3.0-40

  • MongoDBLookupService   2.4.0.4.3.3.0-40

  • Neo4JCypherClientService   2.4.0.4.3.3.0-40

  • ParquetReader   2.4.0.4.3.3.0-40

  • ParquetRecordSetWriter   2.4.0.4.3.3.0-40

  • PEMEncodedSSLContextProvider   2.4.0.4.3.3.0-40

  • PhoenixThickConnectionPool   2.4.0.4.3.3.0-40

  • PhoenixThinConnectionPool   2.4.0.4.3.3.0-40

  • PostgreSQLConnectionPool   2.4.0.4.3.3.0-40

  • PropertiesFileLookupService   2.4.0.4.3.3.0-40

  • ProtobufReader   2.4.0.4.3.3.0-40

  • ProxyPLC4XConnectionPool   2.4.0.4.3.3.0-40

  • RabbitMQJMSConnectionFactoryProvider   2.4.0.4.3.3.0-40

  • ReaderLookup   2.4.0.4.3.3.0-40

  • RecordSetWriterLookup   2.4.0.4.3.3.0-40

  • RecordSinkServiceLookup   2.4.0.4.3.3.0-40

  • RedisConnectionPoolService   2.4.0.4.3.3.0-40

  • RedisDistributedMapCacheClientService   2.4.0.4.3.3.0-40

  • RedshiftConnectionPool   2.4.0.4.3.3.0-40

  • RESTCatalogService   2.4.0.4.3.3.0-40

  • RestLookupService   2.4.0.4.3.3.0-40

  • S3FileResourceService   2.4.0.4.3.3.0-40

  • ScriptedLookupService   2.4.0.4.3.3.0-40

  • ScriptedReader   2.4.0.4.3.3.0-40

  • ScriptedRecordSetWriter   2.4.0.4.3.3.0-40

  • ScriptedRecordSink   2.4.0.4.3.3.0-40

  • SetCacheClientService   2.4.0.4.3.3.0-40

  • SetCacheServer   2.4.0.4.3.3.0-40

  • SimpleCsvFileLookupService   2.4.0.4.3.3.0-40

  • SimpleDatabaseLookupService   2.4.0.4.3.3.0-40

  • SimpleKeyValueLookupService   2.4.0.4.3.3.0-40

  • SimpleRedisDistributedMapCacheClientService   2.4.0.4.3.3.0-40

  • SimpleScriptedLookupService   2.4.0.4.3.3.0-40

  • SiteToSiteReportingRecordSink   2.4.0.4.3.3.0-40

  • SlackRecordSink   2.4.0.4.3.3.0-40

  • SmbjClientProviderService   2.4.0.4.3.3.0-40

  • SnowflakeComputingConnectionPool   2.4.0.4.3.3.0-40

  • StandardAsanaClientProviderService   2.4.0.4.3.3.0-40

  • StandardAzureCredentialsControllerService   2.4.0.4.3.3.0-40

  • StandardDatabaseDialectService   2.4.0.4.3.3.0-40

  • StandardDropboxCredentialService   2.4.0.4.3.3.0-40

  • StandardFileResourceService   2.4.0.4.3.3.0-40

  • StandardHashiCorpVaultClientService   2.4.0.4.3.3.0-40

  • StandardHttpContextMap   2.4.0.4.3.3.0-40

  • StandardJiraCredentialService   2.4.0.4.3.3.0-40

  • StandardJsonSchemaRegistry   2.4.0.4.3.3.0-40

  • StandardKustoIngestService   2.4.0.4.3.3.0-40

  • StandardKustoQueryService   2.4.0.4.3.3.0-40

  • StandardOauth2AccessTokenProvider   2.4.0.4.3.3.0-40

  • StandardPGPPrivateKeyService   2.4.0.4.3.3.0-40

  • StandardPGPPublicKeyService   2.4.0.4.3.3.0-40

  • StandardPLC4XConnectionPool   2.4.0.4.3.3.0-40

  • StandardPrivateKeyService   2.4.0.4.3.3.0-40

  • StandardProxyConfigurationService   2.4.0.4.3.3.0-40

  • StandardRestrictedSSLContextService   2.4.0.4.3.3.0-40

  • StandardS3EncryptionService   2.4.0.4.3.3.0-40

  • StandardSnowflakeIngestManagerProviderService   2.4.0.4.3.3.0-40

  • StandardSSLContextService   2.4.0.4.3.3.0-40

  • StandardWebClientServiceProvider   2.4.0.4.3.3.0-40

  • Syslog5424Reader   2.4.0.4.3.3.0-40

  • SyslogReader   2.4.0.4.3.3.0-40

  • TinkerpopClientService   2.4.0.4.3.3.0-40

  • UDPEventRecordSink   2.4.0.4.3.3.0-40

  • VolatileSchemaCache   2.4.0.4.3.3.0-40

  • WindowsEventLogReader   2.4.0.4.3.3.0-40

  • XMLFileLookupService   2.4.0.4.3.3.0-40

  • XMLReader   2.4.0.4.3.3.0-40

  • XMLRecordSetWriter   2.4.0.4.3.3.0-40

  • YamlTreeReader   2.4.0.4.3.3.0-40

  • ZendeskRecordSink   2.4.0.4.3.3.0-40

• Reporting Tasks

  • AzureLogAnalyticsProvenanceReportingTask   2.4.0.4.3.3.0-40

  • AzureLogAnalyticsReportingTask   2.4.0.4.3.3.0-40

  • ControllerStatusReportingTask   2.4.0.4.3.3.0-40

  • MonitorDiskUsage   2.4.0.4.3.3.0-40

  • MonitorMemory   2.4.0.4.3.3.0-40

  • QueryNiFiReportingTask   2.4.0.4.3.3.0-40

  • ReportLineageToAtlas   2.4.0.4.3.3.0-40

  • ScriptedReportingTask   2.4.0.4.3.3.0-40

  • SiteToSiteBulletinReportingTask   2.4.0.4.3.3.0-40

  • SiteToSiteMetricsReportingTask   2.4.0.4.3.3.0-40

  • SiteToSiteProvenanceReportingTask   2.4.0.4.3.3.0-40

  • SiteToSiteStatusReportingTask   2.4.0.4.3.3.0-40

• Parameter Providers

  • AwsSecretsManagerParameterProvider   2.4.0.4.3.3.0-40

  • AzureKeyVaultSecretsParameterProvider   2.4.0.4.3.3.0-40

  • CyberArkConjurParameterProvider   2.4.0.4.3.3.0-40

  • DatabaseParameterProvider   2.4.0.4.3.3.0-40

  • EnvironmentVariableParameterProvider   2.4.0.4.3.3.0-40

  • GcpSecretManagerParameterProvider   2.4.0.4.3.3.0-40

  • HashiCorpVaultParameterProvider   2.4.0.4.3.3.0-40

  • KubernetesSecretParameterProvider   2.4.0.4.3.3.0-40

  • OnePasswordParameterProvider   2.4.0.4.3.3.0-40

  • PropertiesFileParameterProvider   2.4.0.4.3.3.0-40

• Flow Analysis Rules

  • DisallowComponentType   2.4.0.4.3.3.0-40

  • DisallowConsecutiveConnectionsWithRoundRobinLB   2.4.0.4.3.3.0-40

  • DisallowDeadEnd   2.4.0.4.3.3.0-40

  • DisallowDeprecatedProcessor   2.4.0.4.3.3.0-40

  • DisallowExtractTextForFullContent   2.4.0.4.3.3.0-40

  • RecommendRecordProcessor   2.4.0.4.3.3.0-40

  • RequireHandleHttpResponseAfterHandleHttpRequest   2.4.0.4.3.3.0-40

  • RequireMergeBeforePutIceberg   2.4.0.4.3.3.0-40

  • RequireServerSSLContextService   2.4.0.4.3.3.0-40

  • RestrictBackpressureSettings   2.4.0.4.3.3.0-40

  • RestrictComponentNaming   2.4.0.4.3.3.0-40

  • RestrictConcurrentTasksVsThreadPoolSizeInProcessors   2.4.0.4.3.3.0-40

  • RestrictFlowFileExpiration   2.4.0.4.3.3.0-40

  • RestrictProcessorConcurrency   2.4.0.4.3.3.0-40

  • RestrictSchedulingForListProcessors   2.4.0.4.3.3.0-40

  • RestrictThreadPoolSize   2.4.0.4.3.3.0-40

  • RestrictYieldDurationForConsumeKafkaProcessors   2.4.0.4.3.3.0-40

PutSnowflakeInternalStage 2.4.0.4.3.3.0-40

Bundle

org.apache.nifi | nifi-snowflake-processors-nar

Description

Puts files into a Snowflake internal stage. The internal stage must be created in the Snowflake account beforehand. This processor can be connected to a StartSnowflakeIngest processor to ingest the file in the internal stage

Tags

connection, database, jdbc, snowflake, snowpipe

Input Requirement

REQUIRED

Supports Sensitive Dynamic Properties

false

• Additional Details for PutSnowflakeInternalStage 2.4.0.4.3.3.0-40

  PutSnowflakeInternalStage

  Description

  The PutSnowflakeInternalStage processor can upload a file to a Snowflake internal stage. Please note, that named stages needs to be created in your Snowflake account manually. See the documentation on how to set up an internal stage here. The processor requires an upstream connection and the incoming FlowFiles’ content will be uploaded to the stage. A unique file name is generated for the file’s staged file name. While the processor may be used separately, it’s recommended to connect it to a StartSnowflakeIngest processor so that the uploaded file can be piped into your Snowflake table.

• org.apache.nifi.processors.snowflake.GetSnowflakeIngestStatus
• org.apache.nifi.processors.snowflake.StartSnowflakeIngest