PutClouderaORC

General

Developer

Processors
- AttributeRollingWindow 2.3.0.4.10.0.0-147
- AttributesToCSV 2.3.0.4.10.0.0-147
- AttributesToJSON 2.3.0.4.10.0.0-147
- CalculateParquetOffsets 2.3.0.4.10.0.0-147
- CalculateParquetRowGroupOffsets 2.3.0.4.10.0.0-147
- CalculateRecordStats 2.3.0.4.10.0.0-147
- CaptureChangeDebeziumDB2 2.3.0.4.10.0.0-147
- CaptureChangeDebeziumMongoDB 2.3.0.4.10.0.0-147
- CaptureChangeDebeziumMySQL 2.3.0.4.10.0.0-147
- CaptureChangeDebeziumOracle 2.3.0.4.10.0.0-147
- CaptureChangeDebeziumPostgreSQL 2.3.0.4.10.0.0-147
- CaptureChangeDebeziumSQLServer 2.3.0.4.10.0.0-147
- CaptureChangeMySQL 2.3.0.4.10.0.0-147
- CompressContent 2.3.0.4.10.0.0-147
- ConnectWebSocket 2.3.0.4.10.0.0-147
- ConsumeAMQP 2.3.0.4.10.0.0-147
- ConsumeAzureEventHub 2.3.0.4.10.0.0-147
- ConsumeBoxEnterpriseEvents 2.3.0.4.10.0.0-147
- ConsumeBoxEvents 2.3.0.4.10.0.0-147
- ConsumeElasticsearch 2.3.0.4.10.0.0-147
- ConsumeGCPubSub 2.3.0.4.10.0.0-147
- ConsumeIMAP 2.3.0.4.10.0.0-147
- ConsumeJMS 2.3.0.4.10.0.0-147
- ConsumeKafka 2.3.0.4.10.0.0-147
- ConsumeKafka_2_6 2.3.0.4.10.0.0-147
- ConsumeKafka2CDP 2.3.0.4.10.0.0-147
- ConsumeKafka2RecordCDP 2.3.0.4.10.0.0-147
- ConsumeKafkaRecord_2_6 2.3.0.4.10.0.0-147
- ConsumeKinesisStream 2.3.0.4.10.0.0-147
- ConsumeMQTT 2.3.0.4.10.0.0-147
- ConsumePLC 2.3.0.4.10.0.0-147
- ConsumePOP3 2.3.0.4.10.0.0-147
- ConsumeSlack 2.3.0.4.10.0.0-147
- ConsumeTwitter 2.3.0.4.10.0.0-147
- ConsumeWindowsEventLog 2.3.0.4.10.0.0-147
- ControlRate 2.3.0.4.10.0.0-147
- ConvertAvroToParquet 2.3.0.4.10.0.0-147
- ConvertCharacterSet 2.3.0.4.10.0.0-147
- ConvertProtobuf 2.3.0.4.10.0.0-147
- ConvertRecord 2.3.0.4.10.0.0-147
- CopyAzureBlobStorage_v12 2.3.0.4.10.0.0-147
- CopyS3Object 2.3.0.4.10.0.0-147
- CountText 2.3.0.4.10.0.0-147
- CreateHadoopSequenceFile 2.3.0.4.10.0.0-147
- CryptographicHashContent 2.3.0.4.10.0.0-147
- DebugFlow 2.3.0.4.10.0.0-147
- DecryptContentAge 2.3.0.4.10.0.0-147
- DecryptContentPGP 2.3.0.4.10.0.0-147
- DeduplicateRecord 2.3.0.4.10.0.0-147
- DeleteAzureBlobStorage_v12 2.3.0.4.10.0.0-147
- DeleteAzureDataLakeStorage 2.3.0.4.10.0.0-147
- DeleteByQueryElasticsearch 2.3.0.4.10.0.0-147
- DeleteCDPObjectStore 2.3.0.4.10.0.0-147
- DeleteDynamoDB 2.3.0.4.10.0.0-147
- DeleteFile 2.3.0.4.10.0.0-147
- DeleteGCSObject 2.3.0.4.10.0.0-147
- DeleteGridFS 2.3.0.4.10.0.0-147
- DeleteHBaseCells 2.3.0.4.10.0.0-147
- DeleteHBaseRow 2.3.0.4.10.0.0-147
- DeleteHDFS 2.3.0.4.10.0.0-147
- DeleteMongo 2.3.0.4.10.0.0-147
- DeleteS3Object 2.3.0.4.10.0.0-147
- DeleteSFTP 2.3.0.4.10.0.0-147
- DeleteSQS 2.3.0.4.10.0.0-147
- DetectDuplicate 2.3.0.4.10.0.0-147
- DistributeLoad 2.3.0.4.10.0.0-147
- DuplicateFlowFile 2.3.0.4.10.0.0-147
- EncodeContent 2.3.0.4.10.0.0-147
- EncryptContentAge 2.3.0.4.10.0.0-147
- EncryptContentPGP 2.3.0.4.10.0.0-147
- EnforceOrder 2.3.0.4.10.0.0-147
- EvaluateJsonPath 2.3.0.4.10.0.0-147
- EvaluateXPath 2.3.0.4.10.0.0-147
- EvaluateXQuery 2.3.0.4.10.0.0-147
- ExecuteGraphQuery 2.3.0.4.10.0.0-147
- ExecuteGraphQueryRecord 2.3.0.4.10.0.0-147
- ExecuteGroovyScript 2.3.0.4.10.0.0-147
- ExecuteProcess 2.3.0.4.10.0.0-147
- ExecuteScript 2.3.0.4.10.0.0-147
- ExecuteSparkInteractive 2.3.0.4.10.0.0-147
- ExecuteSQL 2.3.0.4.10.0.0-147
- ExecuteSQLRecord 2.3.0.4.10.0.0-147
- ExecuteStreamCommand 2.3.0.4.10.0.0-147
- ExtractAvroMetadata 2.3.0.4.10.0.0-147
- ExtractDocumentText 2.3.0.4.10.0.0-147
- ExtractEmailAttachments 2.3.0.4.10.0.0-147
- ExtractEmailHeaders 2.3.0.4.10.0.0-147
- ExtractGrok 2.3.0.4.10.0.0-147
- ExtractHL7Attributes 2.3.0.4.10.0.0-147
- ExtractImageMetadata 2.3.0.4.10.0.0-147
- ExtractMediaMetadata 2.3.0.4.10.0.0-147
- ExtractRecordSchema 2.3.0.4.10.0.0-147
- ExtractText 2.3.0.4.10.0.0-147
- FetchAzureBlobStorage_v12 2.3.0.4.10.0.0-147
- FetchAzureDataLakeStorage 2.3.0.4.10.0.0-147
- FetchBoxFile 2.3.0.4.10.0.0-147
- FetchBoxFileInfo 2.3.0.4.10.0.0-147
- FetchBoxFileRepresentation 2.3.0.4.10.0.0-147
- FetchCDPObjectStore 2.3.0.4.10.0.0-147
- FetchDistributedMapCache 2.3.0.4.10.0.0-147
- FetchDropbox 2.3.0.4.10.0.0-147
- FetchFile 2.3.0.4.10.0.0-147
- FetchFTP 2.3.0.4.10.0.0-147
- FetchGCSObject 2.3.0.4.10.0.0-147
- FetchGoogleDrive 2.3.0.4.10.0.0-147
- FetchGridFS 2.3.0.4.10.0.0-147
- FetchHBaseRow 2.3.0.4.10.0.0-147
- FetchHDFS 2.3.0.4.10.0.0-147
- FetchParquet 2.3.0.4.10.0.0-147
- FetchPLC 2.3.0.4.10.0.0-147
- FetchS3Object 2.3.0.4.10.0.0-147
- FetchSFTP 2.3.0.4.10.0.0-147
- FetchSmb 2.3.0.4.10.0.0-147
- FilterAttribute 2.3.0.4.10.0.0-147
- FlattenJson 2.3.0.4.10.0.0-147
- ForkEnrichment 2.3.0.4.10.0.0-147
- ForkRecord 2.3.0.4.10.0.0-147
- GenerateFlowFile 2.3.0.4.10.0.0-147
- GenerateRecord 2.3.0.4.10.0.0-147
- GenerateTableFetch 2.3.0.4.10.0.0-147
- GeoEnrichIP 2.3.0.4.10.0.0-147
- GeoEnrichIPRecord 2.3.0.4.10.0.0-147
- GeohashRecord 2.3.0.4.10.0.0-147
- GetAsanaObject 2.3.0.4.10.0.0-147
- GetAwsPollyJobStatus 2.3.0.4.10.0.0-147
- GetAwsTextractJobStatus 2.3.0.4.10.0.0-147
- GetAwsTranscribeJobStatus 2.3.0.4.10.0.0-147
- GetAwsTranslateJobStatus 2.3.0.4.10.0.0-147
- GetAzureEventHub 2.3.0.4.10.0.0-147
- GetAzureQueueStorage_v12 2.3.0.4.10.0.0-147
- GetBoxFileCollaborators 2.3.0.4.10.0.0-147
- GetBoxGroupMembers 2.3.0.4.10.0.0-147
- GetCouchbaseKey 2.3.0.4.10.0.0-147
- GetDynamoDB 2.3.0.4.10.0.0-147
- GetElasticsearch 2.3.0.4.10.0.0-147
- GetFile 2.3.0.4.10.0.0-147
- GetFileResource 2.3.0.4.10.0.0-147
- GetFTP 2.3.0.4.10.0.0-147
- GetGcpVisionAnnotateFilesOperationStatus 2.3.0.4.10.0.0-147
- GetGcpVisionAnnotateImagesOperationStatus 2.3.0.4.10.0.0-147
- GetHBase 2.3.0.4.10.0.0-147
- GetHDFS 2.3.0.4.10.0.0-147
- GetHDFSEvents 2.3.0.4.10.0.0-147
- GetHDFSFileInfo 2.3.0.4.10.0.0-147
- GetHDFSSequenceFile 2.3.0.4.10.0.0-147
- GetHubSpot 2.3.0.4.10.0.0-147
- GetJiraIssue 2.3.0.4.10.0.0-147
- GetMongo 2.3.0.4.10.0.0-147
- GetMongoRecord 2.3.0.4.10.0.0-147
- GetS3ObjectMetadata 2.3.0.4.10.0.0-147
- GetS3ObjectTags 2.3.0.4.10.0.0-147
- GetSFTP 2.3.0.4.10.0.0-147
- GetShopify 2.3.0.4.10.0.0-147
- GetSlackReaction 2.3.0.4.10.0.0-147
- GetSmbFile 2.3.0.4.10.0.0-147
- GetSNMP 2.3.0.4.10.0.0-147
- GetSnowflakeIngestStatus 2.3.0.4.10.0.0-147
- GetSolr 2.3.0.4.10.0.0-147
- GetSplunk 2.3.0.4.10.0.0-147
- GetSQS 2.3.0.4.10.0.0-147
- GetTCP 2.3.0.4.10.0.0-147
- GetWorkdayReport 2.3.0.4.10.0.0-147
- GetZendesk 2.3.0.4.10.0.0-147
- HandleHttpRequest 2.3.0.4.10.0.0-147
- HandleHttpResponse 2.3.0.4.10.0.0-147
- IdentifyMimeType 2.3.0.4.10.0.0-147
- InvokeGRPC 2.3.0.4.10.0.0-147
- InvokeHTTP 2.3.0.4.10.0.0-147
- InvokeScriptedProcessor 2.3.0.4.10.0.0-147
- ISPEnrichIP 2.3.0.4.10.0.0-147
- JoinEnrichment 2.3.0.4.10.0.0-147
- JoltTransformJSON 2.3.0.4.10.0.0-147
- JoltTransformRecord 2.3.0.4.10.0.0-147
- JSLTTransformJSON 2.3.0.4.10.0.0-147
- JsonQueryElasticsearch 2.3.0.4.10.0.0-147
- ListAzureBlobStorage_v12 2.3.0.4.10.0.0-147
- ListAzureDataLakeStorage 2.3.0.4.10.0.0-147
- ListBoxFile 2.3.0.4.10.0.0-147
- ListBoxFileInfo 2.3.0.4.10.0.0-147
- ListCDPObjectStore 2.3.0.4.10.0.0-147
- ListDatabaseTables 2.3.0.4.10.0.0-147
- ListDropbox 2.3.0.4.10.0.0-147
- ListenBeats 2.3.0.4.10.0.0-147
- ListenFTP 2.3.0.4.10.0.0-147
- ListenGRPC 2.3.0.4.10.0.0-147
- ListenHTTP 2.3.0.4.10.0.0-147
- ListenNetFlow 2.3.0.4.10.0.0-147
- ListenOTLP 2.3.0.4.10.0.0-147
- ListenSlack 2.3.0.4.10.0.0-147
- ListenSyslog 2.3.0.4.10.0.0-147
- ListenTCP 2.3.0.4.10.0.0-147
- ListenTrapSNMP 2.3.0.4.10.0.0-147
- ListenUDP 2.3.0.4.10.0.0-147
- ListenUDPRecord 2.3.0.4.10.0.0-147
- ListenWebSocket 2.3.0.4.10.0.0-147
- ListFile 2.3.0.4.10.0.0-147
- ListFTP 2.3.0.4.10.0.0-147
- ListGCSBucket 2.3.0.4.10.0.0-147
- ListGoogleDrive 2.3.0.4.10.0.0-147
- ListHBaseRegions 2.3.0.4.10.0.0-147
- ListHDFS 2.3.0.4.10.0.0-147
- ListS3 2.3.0.4.10.0.0-147
- ListSFTP 2.3.0.4.10.0.0-147
- ListSmb 2.3.0.4.10.0.0-147
- LogAttribute 2.3.0.4.10.0.0-147
- LogMessage 2.3.0.4.10.0.0-147
- LookupAttribute 2.3.0.4.10.0.0-147
- LookupRecord 2.3.0.4.10.0.0-147
- MergeContent 2.3.0.4.10.0.0-147
- MergeRecord 2.3.0.4.10.0.0-147
- ModifyBytes 2.3.0.4.10.0.0-147
- ModifyCompression 2.3.0.4.10.0.0-147
- MonitorActivity 2.3.0.4.10.0.0-147
- MoveAzureDataLakeStorage 2.3.0.4.10.0.0-147
- MoveHDFS 2.3.0.4.10.0.0-147
- Notify 2.3.0.4.10.0.0-147
- PackageFlowFile 2.3.0.4.10.0.0-147
- PaginatedJsonQueryElasticsearch 2.3.0.4.10.0.0-147
- ParseEvtx 2.3.0.4.10.0.0-147
- ParseNetflowv5 2.3.0.4.10.0.0-147
- ParseSyslog 2.3.0.4.10.0.0-147
- ParseSyslog5424 2.3.0.4.10.0.0-147
- PartitionRecord 2.3.0.4.10.0.0-147
- PublishAMQP 2.3.0.4.10.0.0-147
- PublishGCPubSub 2.3.0.4.10.0.0-147
- PublishJMS 2.3.0.4.10.0.0-147
- PublishKafka 2.3.0.4.10.0.0-147
- PublishKafka_2_6 2.3.0.4.10.0.0-147
- PublishKafka2CDP 2.3.0.4.10.0.0-147
- PublishKafka2RecordCDP 2.3.0.4.10.0.0-147
- PublishKafkaRecord_2_6 2.3.0.4.10.0.0-147
- PublishMQTT 2.3.0.4.10.0.0-147
- PublishSlack 2.3.0.4.10.0.0-147
- PutAccumuloRecord 2.3.0.4.10.0.0-147
- PutAzureBlobStorage_v12 2.3.0.4.10.0.0-147
- PutAzureCosmosDBRecord 2.3.0.4.10.0.0-147
- PutAzureDataExplorer 2.3.0.4.10.0.0-147
- PutAzureDataLakeStorage 2.3.0.4.10.0.0-147
- PutAzureEventHub 2.3.0.4.10.0.0-147
- PutAzureQueueStorage_v12 2.3.0.4.10.0.0-147
- PutBigQuery 2.3.0.4.10.0.0-147
- PutBoxFile 2.3.0.4.10.0.0-147
- PutCassandraQL 2.3.0.4.10.0.0-147
- PutCassandraRecord 2.3.0.4.10.0.0-147
- PutCDPObjectStore 2.3.0.4.10.0.0-147
- PutClouderaHiveQL 2.3.0.4.10.0.0-147
- PutClouderaHiveStreaming 2.3.0.4.10.0.0-147
- PutClouderaORC 2.3.0.4.10.0.0-147
- PutCloudWatchMetric 2.3.0.4.10.0.0-147
- PutCouchbaseKey 2.3.0.4.10.0.0-147
- PutDatabaseRecord 2.3.0.4.10.0.0-147
- PutDistributedMapCache 2.3.0.4.10.0.0-147
- PutDropbox 2.3.0.4.10.0.0-147
- PutDynamoDB 2.3.0.4.10.0.0-147
- PutDynamoDBRecord 2.3.0.4.10.0.0-147
- PutElasticsearchJson 2.3.0.4.10.0.0-147
- PutElasticsearchRecord 2.3.0.4.10.0.0-147
- PutEmail 2.3.0.4.10.0.0-147
- PutFile 2.3.0.4.10.0.0-147
- PutFTP 2.3.0.4.10.0.0-147
- PutGCSObject 2.3.0.4.10.0.0-147
- PutGoogleDrive 2.3.0.4.10.0.0-147
- PutGridFS 2.3.0.4.10.0.0-147
- PutHBaseCell 2.3.0.4.10.0.0-147
- PutHBaseJSON 2.3.0.4.10.0.0-147
- PutHBaseRecord 2.3.0.4.10.0.0-147
- PutHDFS 2.3.0.4.10.0.0-147
- PutIceberg 2.3.0.4.10.0.0-147
- PutIcebergCDC 2.3.0.4.10.0.0-147
- PutIoTDBRecord 2.3.0.4.10.0.0-147
- PutJiraIssue 2.3.0.4.10.0.0-147
- PutKinesisFirehose 2.3.0.4.10.0.0-147
- PutKinesisStream 2.3.0.4.10.0.0-147
- PutKudu 2.3.0.4.10.0.0-147
- PutLambda 2.3.0.4.10.0.0-147
- PutMongo 2.3.0.4.10.0.0-147
- PutMongoBulkOperations 2.3.0.4.10.0.0-147
- PutMongoRecord 2.3.0.4.10.0.0-147
- PutParquet 2.3.0.4.10.0.0-147
- PutPLC 2.3.0.4.10.0.0-147
- PutRecord 2.3.0.4.10.0.0-147
- PutRedisHashRecord 2.3.0.4.10.0.0-147
- PutS3Object 2.3.0.4.10.0.0-147
- PutSalesforceObject 2.3.0.4.10.0.0-147
- PutSFTP 2.3.0.4.10.0.0-147
- PutSmbFile 2.3.0.4.10.0.0-147
- PutSnowflakeInternalStage 2.3.0.4.10.0.0-147
- PutSNS 2.3.0.4.10.0.0-147
- PutSolrContentStream 2.3.0.4.10.0.0-147
- PutSolrRecord 2.3.0.4.10.0.0-147
- PutSplunk 2.3.0.4.10.0.0-147
- PutSplunkHTTP 2.3.0.4.10.0.0-147
- PutSQL 2.3.0.4.10.0.0-147
- PutSQS 2.3.0.4.10.0.0-147
- PutSyslog 2.3.0.4.10.0.0-147
- PutTCP 2.3.0.4.10.0.0-147
- PutUDP 2.3.0.4.10.0.0-147
- PutWebSocket 2.3.0.4.10.0.0-147
- PutZendeskTicket 2.3.0.4.10.0.0-147
- QueryAirtableTable 2.3.0.4.10.0.0-147
- QueryAzureDataExplorer 2.3.0.4.10.0.0-147
- QueryCassandra 2.3.0.4.10.0.0-147
- QueryDatabaseTable 2.3.0.4.10.0.0-147
- QueryDatabaseTableRecord 2.3.0.4.10.0.0-147
- QueryIoTDBRecord 2.3.0.4.10.0.0-147
- QueryRecord 2.3.0.4.10.0.0-147
- QuerySalesforceObject 2.3.0.4.10.0.0-147
- QuerySolr 2.3.0.4.10.0.0-147
- QuerySplunkIndexingStatus 2.3.0.4.10.0.0-147
- RemoveRecordField 2.3.0.4.10.0.0-147
- RenameRecordField 2.3.0.4.10.0.0-147
- ReplaceText 2.3.0.4.10.0.0-147
- ReplaceTextWithMapping 2.3.0.4.10.0.0-147
- ResizeImage 2.3.0.4.10.0.0-147
- RetryFlowFile 2.3.0.4.10.0.0-147
- RouteHL7 2.3.0.4.10.0.0-147
- RouteOnAttribute 2.3.0.4.10.0.0-147
- RouteOnContent 2.3.0.4.10.0.0-147
- RouteText 2.3.0.4.10.0.0-147
- RunMongoAggregation 2.3.0.4.10.0.0-147
- SampleRecord 2.3.0.4.10.0.0-147
- SawmillTransformJSON 2.3.0.4.10.0.0-147
- SawmillTransformRecord 2.3.0.4.10.0.0-147
- ScanAccumulo 2.3.0.4.10.0.0-147
- ScanAttribute 2.3.0.4.10.0.0-147
- ScanContent 2.3.0.4.10.0.0-147
- ScanHBase 2.3.0.4.10.0.0-147
- ScriptedFilterRecord 2.3.0.4.10.0.0-147
- ScriptedPartitionRecord 2.3.0.4.10.0.0-147
- ScriptedTransformRecord 2.3.0.4.10.0.0-147
- ScriptedValidateRecord 2.3.0.4.10.0.0-147
- SearchElasticsearch 2.3.0.4.10.0.0-147
- SegmentContent 2.3.0.4.10.0.0-147
- SelectClouderaHiveQL 2.3.0.4.10.0.0-147
- SendTrapSNMP 2.3.0.4.10.0.0-147
- SetSNMP 2.3.0.4.10.0.0-147
- SignContentPGP 2.3.0.4.10.0.0-147
- SplitAvro 2.3.0.4.10.0.0-147
- SplitContent 2.3.0.4.10.0.0-147
- SplitExcel 2.3.0.4.10.0.0-147
- SplitJson 2.3.0.4.10.0.0-147
- SplitPCAP 2.3.0.4.10.0.0-147
- SplitRecord 2.3.0.4.10.0.0-147
- SplitText 2.3.0.4.10.0.0-147
- SplitXml 2.3.0.4.10.0.0-147
- StartAwsPollyJob 2.3.0.4.10.0.0-147
- StartAwsTextractJob 2.3.0.4.10.0.0-147
- StartAwsTranscribeJob 2.3.0.4.10.0.0-147
- StartAwsTranslateJob 2.3.0.4.10.0.0-147
- StartGcpVisionAnnotateFilesOperation 2.3.0.4.10.0.0-147
- StartGcpVisionAnnotateImagesOperation 2.3.0.4.10.0.0-147
- StartSnowflakeIngest 2.3.0.4.10.0.0-147
- TagS3Object 2.3.0.4.10.0.0-147
- TailFile 2.3.0.4.10.0.0-147
- TransformXml 2.3.0.4.10.0.0-147
- TriggerClouderaHiveMetaStoreEvent 2.3.0.4.10.0.0-147
- UnpackContent 2.3.0.4.10.0.0-147
- UpdateAttribute 2.3.0.4.10.0.0-147
- UpdateByQueryElasticsearch 2.3.0.4.10.0.0-147
- UpdateClouderaHiveTable 2.3.0.4.10.0.0-147
- UpdateCounter 2.3.0.4.10.0.0-147
- UpdateDatabaseTable 2.3.0.4.10.0.0-147
- UpdateDeltaLakeTable 2.3.0.4.10.0.0-147
- UpdateJiraIssue 2.3.0.4.10.0.0-147
- UpdateRecord 2.3.0.4.10.0.0-147
- ValidateCsv 2.3.0.4.10.0.0-147
- ValidateJson 2.3.0.4.10.0.0-147
- ValidateRecord 2.3.0.4.10.0.0-147
- ValidateXml 2.3.0.4.10.0.0-147
- VerifyContentMAC 2.3.0.4.10.0.0-147
- VerifyContentPGP 2.3.0.4.10.0.0-147
- Wait 2.3.0.4.10.0.0-147

Controller Services
- AccumuloService 2.3.0.4.10.0.0-147
- ActiveMQJMSConnectionFactoryProvider 2.3.0.4.10.0.0-147
- ADLSCredentialsControllerService 2.3.0.4.10.0.0-147
- ADLSCredentialsControllerServiceLookup 2.3.0.4.10.0.0-147
- ADLSIDBrokerCloudCredentialsProviderControllerService 2.3.0.4.10.0.0-147
- AmazonGlueSchemaRegistry 2.3.0.4.10.0.0-147
- ApicurioSchemaRegistry 2.3.0.4.10.0.0-147
- AvroReader 2.3.0.4.10.0.0-147
- AvroRecordSetWriter 2.3.0.4.10.0.0-147
- AvroSchemaRegistry 2.3.0.4.10.0.0-147
- AWSCredentialsProviderControllerService 2.3.0.4.10.0.0-147
- AWSIDBrokerCloudCredentialsProviderControllerService 2.3.0.4.10.0.0-147
- AzureBlobIDBrokerCloudCredentialsProviderControllerService 2.3.0.4.10.0.0-147
- AzureBlobStorageFileResourceService 2.3.0.4.10.0.0-147
- AzureCosmosDBClientService 2.3.0.4.10.0.0-147
- AzureDataLakeStorageFileResourceService 2.3.0.4.10.0.0-147
- AzureEventHubRecordSink 2.3.0.4.10.0.0-147
- AzureServiceBusJMSConnectionFactoryProvider 2.3.0.4.10.0.0-147
- AzureStorageCredentialsControllerService_v12 2.3.0.4.10.0.0-147
- AzureStorageCredentialsControllerServiceLookup_v12 2.3.0.4.10.0.0-147
- CassandraDistributedMapCache 2.3.0.4.10.0.0-147
- CassandraSessionProvider 2.3.0.4.10.0.0-147
- CdpCredentialsProviderControllerService 2.3.0.4.10.0.0-147
- CdpOauth2AccessTokenProviderControllerService 2.3.0.4.10.0.0-147
- CEFReader 2.3.0.4.10.0.0-147
- CiscoEmblemSyslogMessageReader 2.3.0.4.10.0.0-147
- ClouderaAttributeSchemaReferenceReader 2.3.0.4.10.0.0-147
- ClouderaAttributeSchemaReferenceWriter 2.3.0.4.10.0.0-147
- ClouderaEncodedSchemaReferenceReader 2.3.0.4.10.0.0-147
- ClouderaEncodedSchemaReferenceWriter 2.3.0.4.10.0.0-147
- ClouderaHiveConnectionPool 2.3.0.4.10.0.0-147
- ClouderaSchemaRegistry 2.3.0.4.10.0.0-147
- CMLLookupService 2.3.0.4.10.0.0-147
- ConfluentEncodedSchemaReferenceReader 2.3.0.4.10.0.0-147
- ConfluentEncodedSchemaReferenceWriter 2.3.0.4.10.0.0-147
- ConfluentSchemaRegistry 2.3.0.4.10.0.0-147
- CouchbaseClusterService 2.3.0.4.10.0.0-147
- CouchbaseKeyValueLookupService 2.3.0.4.10.0.0-147
- CouchbaseMapCacheClient 2.3.0.4.10.0.0-147
- CouchbaseRecordLookupService 2.3.0.4.10.0.0-147
- CSVReader 2.3.0.4.10.0.0-147
- CSVRecordLookupService 2.3.0.4.10.0.0-147
- CSVRecordSetWriter 2.3.0.4.10.0.0-147
- DatabaseRecordLookupService 2.3.0.4.10.0.0-147
- DatabaseRecordSink 2.3.0.4.10.0.0-147
- DatabaseTableSchemaRegistry 2.3.0.4.10.0.0-147
- DBCPConnectionPool 2.3.0.4.10.0.0-147
- DBCPConnectionPoolLookup 2.3.0.4.10.0.0-147
- DeveloperBoxClientService 2.3.0.4.10.0.0-147
- DistributedMapCacheLookupService 2.3.0.4.10.0.0-147
- EBCDICRecordReader 2.3.0.4.10.0.0-147
- ElasticSearchClientServiceImpl 2.3.0.4.10.0.0-147
- ElasticSearchLookupService 2.3.0.4.10.0.0-147
- ElasticSearchStringLookupService 2.3.0.4.10.0.0-147
- EmailRecordSink 2.3.0.4.10.0.0-147
- EmbeddedHazelcastCacheManager 2.3.0.4.10.0.0-147
- ExcelReader 2.3.0.4.10.0.0-147
- ExternalHazelcastCacheManager 2.3.0.4.10.0.0-147
- FreeFormTextRecordSetWriter 2.3.0.4.10.0.0-147
- GCPCredentialsControllerService 2.3.0.4.10.0.0-147
- GCSFileResourceService 2.3.0.4.10.0.0-147
- GenericPLC4XConnectionPool 2.3.0.4.10.0.0-147
- GrokReader 2.3.0.4.10.0.0-147
- HadoopCatalogService 2.3.0.4.10.0.0-147
- HadoopDBCPConnectionPool 2.3.0.4.10.0.0-147
- HazelcastMapCacheClient 2.3.0.4.10.0.0-147
- HBase_2_ClientMapCacheService 2.3.0.4.10.0.0-147
- HBase_2_ClientService 2.3.0.4.10.0.0-147
- HBase_2_RecordLookupService 2.3.0.4.10.0.0-147
- HikariCPConnectionPool 2.3.0.4.10.0.0-147
- HiveCatalogService 2.3.0.4.10.0.0-147
- HttpRecordSink 2.3.0.4.10.0.0-147
- ImpalaConnectionPool 2.3.0.4.10.0.0-147
- IPFIXReader 2.3.0.4.10.0.0-147
- IPLookupService 2.3.0.4.10.0.0-147
- JASN1Reader 2.3.0.4.10.0.0-147
- JdbcCatalogService 2.3.0.4.10.0.0-147
- JettyWebSocketClient 2.3.0.4.10.0.0-147
- JettyWebSocketServer 2.3.0.4.10.0.0-147
- JiraRecordSink 2.3.0.4.10.0.0-147
- JMSConnectionFactoryProvider 2.3.0.4.10.0.0-147
- JndiJmsConnectionFactoryProvider 2.3.0.4.10.0.0-147
- JsonConfigBasedBoxClientService 2.3.0.4.10.0.0-147
- JsonPathReader 2.3.0.4.10.0.0-147
- JsonRecordSetWriter 2.3.0.4.10.0.0-147
- JsonTreeReader 2.3.0.4.10.0.0-147
- Kafka3ConnectionService 2.3.0.4.10.0.0-147
- KafkaRecordSink_2_6 2.3.0.4.10.0.0-147
- KerberosKeytabUserService 2.3.0.4.10.0.0-147
- KerberosPasswordUserService 2.3.0.4.10.0.0-147
- KerberosTicketCacheUserService 2.3.0.4.10.0.0-147
- KuduLookupService 2.3.0.4.10.0.0-147
- LivySessionController 2.3.0.4.10.0.0-147
- LoggingRecordSink 2.3.0.4.10.0.0-147
- MapCacheClientService 2.3.0.4.10.0.0-147
- MapCacheServer 2.3.0.4.10.0.0-147
- MongoDBControllerService 2.3.0.4.10.0.0-147
- MongoDBLookupService 2.3.0.4.10.0.0-147
- Neo4JCypherClientService 2.3.0.4.10.0.0-147
- ParquetReader 2.3.0.4.10.0.0-147
- ParquetRecordSetWriter 2.3.0.4.10.0.0-147
- PEMEncodedSSLContextProvider 2.3.0.4.10.0.0-147
- PhoenixThickConnectionPool 2.3.0.4.10.0.0-147
- PhoenixThinConnectionPool 2.3.0.4.10.0.0-147
- PostgreSQLConnectionPool 2.3.0.4.10.0.0-147
- PropertiesFileLookupService 2.3.0.4.10.0.0-147
- ProtobufReader 2.3.0.4.10.0.0-147
- ProxyPLC4XConnectionPool 2.3.0.4.10.0.0-147
- RabbitMQJMSConnectionFactoryProvider 2.3.0.4.10.0.0-147
- ReaderLookup 2.3.0.4.10.0.0-147
- RecordSetWriterLookup 2.3.0.4.10.0.0-147
- RecordSinkServiceLookup 2.3.0.4.10.0.0-147
- RedisConnectionPoolService 2.3.0.4.10.0.0-147
- RedisDistributedMapCacheClientService 2.3.0.4.10.0.0-147
- RedshiftConnectionPool 2.3.0.4.10.0.0-147
- RESTCatalogService 2.3.0.4.10.0.0-147
- RestLookupService 2.3.0.4.10.0.0-147
- S3FileResourceService 2.3.0.4.10.0.0-147
- ScriptedLookupService 2.3.0.4.10.0.0-147
- ScriptedReader 2.3.0.4.10.0.0-147
- ScriptedRecordSetWriter 2.3.0.4.10.0.0-147
- ScriptedRecordSink 2.3.0.4.10.0.0-147
- SetCacheClientService 2.3.0.4.10.0.0-147
- SetCacheServer 2.3.0.4.10.0.0-147
- SimpleCsvFileLookupService 2.3.0.4.10.0.0-147
- SimpleDatabaseLookupService 2.3.0.4.10.0.0-147
- SimpleKeyValueLookupService 2.3.0.4.10.0.0-147
- SimpleRedisDistributedMapCacheClientService 2.3.0.4.10.0.0-147
- SimpleScriptedLookupService 2.3.0.4.10.0.0-147
- SiteToSiteReportingRecordSink 2.3.0.4.10.0.0-147
- SlackRecordSink 2.3.0.4.10.0.0-147
- SmbjClientProviderService 2.3.0.4.10.0.0-147
- SnowflakeComputingConnectionPool 2.3.0.4.10.0.0-147
- StandardAsanaClientProviderService 2.3.0.4.10.0.0-147
- StandardAzureCredentialsControllerService 2.3.0.4.10.0.0-147
- StandardDatabaseDialectService 2.3.0.4.10.0.0-147
- StandardDropboxCredentialService 2.3.0.4.10.0.0-147
- StandardFileResourceService 2.3.0.4.10.0.0-147
- StandardHashiCorpVaultClientService 2.3.0.4.10.0.0-147
- StandardHttpContextMap 2.3.0.4.10.0.0-147
- StandardJiraCredentialService 2.3.0.4.10.0.0-147
- StandardJsonSchemaRegistry 2.3.0.4.10.0.0-147
- StandardKustoIngestService 2.3.0.4.10.0.0-147
- StandardKustoQueryService 2.3.0.4.10.0.0-147
- StandardOauth2AccessTokenProvider 2.3.0.4.10.0.0-147
- StandardPGPPrivateKeyService 2.3.0.4.10.0.0-147
- StandardPGPPublicKeyService 2.3.0.4.10.0.0-147
- StandardPLC4XConnectionPool 2.3.0.4.10.0.0-147
- StandardPrivateKeyService 2.3.0.4.10.0.0-147
- StandardProxyConfigurationService 2.3.0.4.10.0.0-147
- StandardRestrictedSSLContextService 2.3.0.4.10.0.0-147
- StandardS3EncryptionService 2.3.0.4.10.0.0-147
- StandardSnowflakeIngestManagerProviderService 2.3.0.4.10.0.0-147
- StandardSSLContextService 2.3.0.4.10.0.0-147
- StandardWebClientServiceProvider 2.3.0.4.10.0.0-147
- Syslog5424Reader 2.3.0.4.10.0.0-147
- SyslogReader 2.3.0.4.10.0.0-147
- TinkerpopClientService 2.3.0.4.10.0.0-147
- UDPEventRecordSink 2.3.0.4.10.0.0-147
- VolatileSchemaCache 2.3.0.4.10.0.0-147
- WindowsEventLogReader 2.3.0.4.10.0.0-147
- XMLFileLookupService 2.3.0.4.10.0.0-147
- XMLReader 2.3.0.4.10.0.0-147
- XMLRecordSetWriter 2.3.0.4.10.0.0-147
- YamlTreeReader 2.3.0.4.10.0.0-147
- ZendeskRecordSink 2.3.0.4.10.0.0-147

Reporting Tasks
- AzureLogAnalyticsProvenanceReportingTask 2.3.0.4.10.0.0-147
- AzureLogAnalyticsReportingTask 2.3.0.4.10.0.0-147
- ControllerStatusReportingTask 2.3.0.4.10.0.0-147
- MonitorDiskUsage 2.3.0.4.10.0.0-147
- MonitorMemory 2.3.0.4.10.0.0-147
- QueryNiFiReportingTask 2.3.0.4.10.0.0-147
- ReportLineageToAtlas 2.3.0.4.10.0.0-147
- ScriptedReportingTask 2.3.0.4.10.0.0-147
- SiteToSiteBulletinReportingTask 2.3.0.4.10.0.0-147
- SiteToSiteMetricsReportingTask 2.3.0.4.10.0.0-147
- SiteToSiteProvenanceReportingTask 2.3.0.4.10.0.0-147
- SiteToSiteStatusReportingTask 2.3.0.4.10.0.0-147

Parameter Providers
- AwsSecretsManagerParameterProvider 2.3.0.4.10.0.0-147
- AzureKeyVaultSecretsParameterProvider 2.3.0.4.10.0.0-147
- CyberArkConjurParameterProvider 2.3.0.4.10.0.0-147
- DatabaseParameterProvider 2.3.0.4.10.0.0-147
- EnvironmentVariableParameterProvider 2.3.0.4.10.0.0-147
- GcpSecretManagerParameterProvider 2.3.0.4.10.0.0-147
- HashiCorpVaultParameterProvider 2.3.0.4.10.0.0-147
- KubernetesSecretParameterProvider 2.3.0.4.10.0.0-147
- OnePasswordParameterProvider 2.3.0.4.10.0.0-147
- PropertiesFileParameterProvider 2.3.0.4.10.0.0-147

Flow Analysis Rules
- DisallowComponentType 2.3.0.4.10.0.0-147
- DisallowConsecutiveConnectionsWithRoundRobinLB 2.3.0.4.10.0.0-147
- DisallowDeadEnd 2.3.0.4.10.0.0-147
- DisallowDeprecatedProcessor 2.3.0.4.10.0.0-147
- DisallowExtractTextForFullContent 2.3.0.4.10.0.0-147
- RecommendRecordProcessor 2.3.0.4.10.0.0-147
- RequireHandleHttpResponseAfterHandleHttpRequest 2.3.0.4.10.0.0-147
- RequireMergeBeforePutIceberg 2.3.0.4.10.0.0-147
- RestrictBackpressureSettings 2.3.0.4.10.0.0-147
- RestrictComponentNaming 2.3.0.4.10.0.0-147
- RestrictConcurrentTasksVsThreadPoolSizeInProcessors 2.3.0.4.10.0.0-147
- RestrictFlowFileExpiration 2.3.0.4.10.0.0-147
- RestrictProcessorConcurrency 2.3.0.4.10.0.0-147
- RestrictSchedulingForListProcessors 2.3.0.4.10.0.0-147
- RestrictThreadPoolSize 2.3.0.4.10.0.0-147
- RestrictYieldDurationForConsumeKafkaProcessors 2.3.0.4.10.0.0-147

PutClouderaORC 2.3.0.4.10.0.0-147

Bundle: com.cloudera | nifi-cdf-hive-nar
Description: Reads records from an incoming FlowFile using the provided Record Reader, and writes those records to a ORC file in the location/filesystem specified in the configuration.
Tags: HDFS, ORC, filesystem, hadoop, put, record, restricted
Input Requirement: REQUIRED
Supports Sensitive Dynamic Properties: false

Properties

Additional Classpath Resources
A comma-separated list of paths to files and/or directories that will be added to the classpath and used for loading native libraries. When specifying a directory, all files with in the directory will be added to the classpath, but further sub-directories will not be included.

Display Name

Additional Classpath Resources

Description

A comma-separated list of paths to files and/or directories that will be added to the classpath and used for loading native libraries. When specifying a directory, all files with in the directory will be added to the classpath, but further sub-directories will not be included.

API Name

Additional Classpath Resources

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Compression Type
The type of compression for the file being written.
Display Name

Compression Type

Description

The type of compression for the file being written.

API Name

compression-type

Default Value

NONE

Allowable Values
- NONE
- ZLIB
- SNAPPY
- LZO
Expression Language Scope

Not Supported

Sensitive

false

Required

true
Directory
The parent directory to which files should be written. Will be created if it doesn't exist.

Display Name

Directory

Description

The parent directory to which files should be written. Will be created if it doesn't exist.

API Name

Directory

Expression Language Scope

Environment variables and FlowFile Attributes

Sensitive

false

Required

true
Hadoop Configuration Resources
A file or comma separated list of files which contains the Hadoop file system configuration. Without this, Hadoop will search the classpath for a 'core-site.xml' and 'hdfs-site.xml' file or will revert to a default configuration. To use swebhdfs, see 'Additional Details' section of PutHDFS's documentation.

Display Name

Hadoop Configuration Resources

Description

A file or comma separated list of files which contains the Hadoop file system configuration. Without this, Hadoop will search the classpath for a 'core-site.xml' and 'hdfs-site.xml' file or will revert to a default configuration. To use swebhdfs, see 'Additional Details' section of PutHDFS's documentation.

API Name

Hadoop Configuration Resources

Expression Language Scope

Environment variables defined at JVM level and system properties

Sensitive

false

Required

false
Kerberos User Service
Specifies the Kerberos User Controller Service that should be used for authenticating with Kerberos

Display Name

Kerberos User Service

Description

Specifies the Kerberos User Controller Service that should be used for authenticating with Kerberos

API Name

kerberos-user-service

Service Interface

org.apache.nifi.kerberos.KerberosUserService

Service Implementations

org.apache.nifi.kerberos.KerberosKeytabUserService

org.apache.nifi.kerberos.KerberosPasswordUserService

org.apache.nifi.kerberos.KerberosTicketCacheUserService

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Overwrite Files
Whether or not to overwrite existing files in the same directory with the same name. When set to false, flow files will be routed to failure when a file exists in the same directory with the same name.
Display Name

Overwrite Files

Description

Whether or not to overwrite existing files in the same directory with the same name. When set to false, flow files will be routed to failure when a file exists in the same directory with the same name.

API Name

overwrite

Default Value

false

Allowable Values
- true
- false
Expression Language Scope

Not Supported

Sensitive

false

Required

true
Permissions umask
A umask represented as an octal number which determines the permissions of files written to HDFS. This overrides the Hadoop Configuration dfs.umaskmode

Display Name

Permissions umask

Description

A umask represented as an octal number which determines the permissions of files written to HDFS. This overrides the Hadoop Configuration dfs.umaskmode

API Name

permissions-umask

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Buffer Size
The maximum size of the memory buffers (in bytes) used for compressing and storing a stripe in memory. This is a hint to the ORC writer, which may choose to use a smaller buffer size based on stripe size and number of columns for efficient stripe writing and memory utilization.

Display Name

Buffer Size

Description

The maximum size of the memory buffers (in bytes) used for compressing and storing a stripe in memory. This is a hint to the ORC writer, which may choose to use a smaller buffer size based on stripe size and number of columns for efficient stripe writing and memory utilization.

API Name

putorc-buffer-size

Default Value

10 KB

Expression Language Scope

Not Supported

Sensitive

false

Required

true
ORC Configuration Resources
A file or comma separated list of files which contains the ORC configuration (hive-site.xml, e.g.). Without this, Hadoop will search the classpath for a 'hive-site.xml' file or will revert to a default configuration. Please see the ORC documentation for more details.

Display Name

ORC Configuration Resources

Description

A file or comma separated list of files which contains the ORC configuration (hive-site.xml, e.g.). Without this, Hadoop will search the classpath for a 'hive-site.xml' file or will revert to a default configuration. Please see the ORC documentation for more details.

API Name

putorc-config-resources

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Normalize Field Names for Hive
Whether to normalize field names for Hive (force lowercase, e.g.). If the ORC file is going to be part of a Hive table, this property should be set to true. To preserve the original field names from the schema, this property should be set to false.
Display Name

Normalize Field Names for Hive

Description

Whether to normalize field names for Hive (force lowercase, e.g.). If the ORC file is going to be part of a Hive table, this property should be set to true. To preserve the original field names from the schema, this property should be set to false.

API Name

putorc-hive-field-names

Default Value

true

Allowable Values
- true
- false
Expression Language Scope

Not Supported

Sensitive

false

Required

true
Hive Table Name
An optional table name to insert into the hive.ddl attribute. The generated DDL can be used by a PutClouderaHiveQL processor (presumably after a PutHDFS processor) to create a table backed by the converted ORC file. If this property is not provided, the full name (including namespace) of the incoming Avro record will be normalized and used as the table name.

Display Name

Hive Table Name

Description

An optional table name to insert into the hive.ddl attribute. The generated DDL can be used by a PutClouderaHiveQL processor (presumably after a PutHDFS processor) to create a table backed by the converted ORC file. If this property is not provided, the full name (including namespace) of the incoming Avro record will be normalized and used as the table name.

API Name

putorc-hive-table-name

Expression Language Scope

Environment variables and FlowFile Attributes

Sensitive

false

Required

false
Stripe Size
The size of the memory buffer (in bytes) for writing stripes to an ORC file

Display Name

Stripe Size

Description

The size of the memory buffer (in bytes) for writing stripes to an ORC file

API Name

putorc-stripe-size

Default Value

64 MB

Expression Language Scope

Not Supported

Sensitive

false

Required

true
Record Reader
The service for reading records from incoming flow files.

Display Name

Record Reader

Description

The service for reading records from incoming flow files.

API Name

record-reader

Service Interface

org.apache.nifi.serialization.RecordReaderFactory

Service Implementations

org.apache.nifi.avro.AvroReader

org.apache.nifi.cef.CEFReader

org.apache.nifi.syslog.reader.CiscoEmblemSyslogMessageReader

org.apache.nifi.csv.CSVReader

com.cloudera.nifi.ebcdic.EBCDICRecordReader

org.apache.nifi.excel.ExcelReader

org.apache.nifi.grok.GrokReader

org.apache.nifi.ipfix.service.IPFIXReader

org.apache.nifi.jasn1.JASN1Reader

org.apache.nifi.json.JsonPathReader

org.apache.nifi.json.JsonTreeReader

org.apache.nifi.parquet.ParquetReader

org.apache.nifi.services.protobuf.ProtobufReader

org.apache.nifi.lookup.ReaderLookup

org.apache.nifi.record.script.ScriptedReader

org.apache.nifi.syslog.Syslog5424Reader

org.apache.nifi.syslog.SyslogReader

org.apache.nifi.windowsevent.WindowsEventLogReader

org.apache.nifi.xml.XMLReader

org.apache.nifi.yaml.YamlTreeReader

Expression Language Scope

Not Supported

Sensitive

false

Required

true
Remote Group
Changes the group of the HDFS file to this value after it is written. This only works if NiFi is running as a user that has HDFS super user privilege to change group

Display Name

Remote Group

Description

Changes the group of the HDFS file to this value after it is written. This only works if NiFi is running as a user that has HDFS super user privilege to change group

API Name

remote-group

Expression Language Scope

Not Supported

Sensitive

false

Required

false
Remote Owner
Changes the owner of the HDFS file to this value after it is written. This only works if NiFi is running as a user that has HDFS super user privilege to change owner

Display Name

Remote Owner

Description

Changes the owner of the HDFS file to this value after it is written. This only works if NiFi is running as a user that has HDFS super user privilege to change owner

API Name

remote-owner

Expression Language Scope

Not Supported

Sensitive

false

Required

false

Restrictions

Required Permission	Explanation
write distributed filesystem	Provides operator the ability to write to any file that NiFi has access to in HDFS or the local filesystem.

Relationships

Name	Description
retry	Flow Files that could not be processed due to issues that can be retried are transferred to this relationship
success	Flow Files that have been successfully processed are transferred to this relationship
failure	Flow Files that could not be processed due to issue that cannot be retried are transferred to this relationship

Reads Attributes

Name	Description
filename	The name of the file to write comes from the value of this attribute.

Writes Attributes

Name	Description
filename	The name of the file is stored in this attribute.
absolute.hdfs.path	The absolute path to the file is stored in this attribute.
hadoop.file.url	The hadoop url for the file is stored in this attribute.
record.count	The number of records written to the ORC file
hive.ddl	Creates a partial Hive DDL statement for creating an external table in Hive from the destination folder. This can be used in ReplaceText for setting the content to the DDL. To make it valid DDL, add "LOCATION '<path_to_orc_file_in_hdfs>'", where the path is the directory that contains this ORC file on HDFS. For example, this processor can send flow files downstream to ReplaceText to set the content to this DDL (plus the LOCATION clause as described), then to PutHiveQL processor to create the table if it doesn't exist.