-
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
-
ParquetRecordSetWriter 2.4.0.4.11.0.0-352
- Bundle
- org.apache.nifi | nifi-parquet-nar
- Description
- Writes the contents of a RecordSet in Parquet format.
- Tags
- parquet, record, recordset, result, row, serializer, set, writer
- Input Requirement
- Supports Sensitive Dynamic Properties
- false
-
Avro Add List Element Records
Specifies the value for 'parquet.avro.add-list-element-records' in the underlying Parquet library
- Display Name
- Avro Add List Element Records
- Description
- Specifies the value for 'parquet.avro.add-list-element-records' in the underlying Parquet library
- API Name
- avro-add-list-element-records
- Default Value
- true
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Avro Write Old List Structure
Specifies the value for 'parquet.avro.write-old-list-structure' in the underlying Parquet library
- Display Name
- Avro Write Old List Structure
- Description
- Specifies the value for 'parquet.avro.write-old-list-structure' in the underlying Parquet library
- API Name
- avro-write-old-list-structure
- Default Value
- true
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Cache Size
Specifies how many Schemas should be cached
- Display Name
- Cache Size
- Description
- Specifies how many Schemas should be cached
- API Name
- cache-size
- Default Value
- 1000
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
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
- UNCOMPRESSED
- Allowable Values
-
- UNCOMPRESSED
- SNAPPY
- GZIP
- LZO
- BROTLI
- LZ4
- ZSTD
- LZ4_RAW
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Dictionary Page Size
The dictionary page size used by the Parquet writer. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- Display Name
- Dictionary Page Size
- Description
- The dictionary page size used by the Parquet writer. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- API Name
- dictionary-page-size
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
-
Enable Dictionary Encoding
Specifies whether dictionary encoding should be enabled for the Parquet writer
- Display Name
- Enable Dictionary Encoding
- Description
- Specifies whether dictionary encoding should be enabled for the Parquet writer
- API Name
- enable-dictionary-encoding
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
Enable Validation
Specifies whether validation should be enabled for the Parquet writer
- Display Name
- Enable Validation
- Description
- Specifies whether validation should be enabled for the Parquet writer
- API Name
- enable-validation
- Allowable Values
-
- true
- false
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
INT96 Fields
List of fields with full path that should be treated as INT96 timestamps.
- Display Name
- INT96 Fields
- Description
- List of fields with full path that should be treated as INT96 timestamps.
- API Name
- int96-fields
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
Max Padding Size
The maximum amount of padding that will be used to align row groups with blocks in the underlying filesystem. If the underlying filesystem is not a block filesystem like HDFS, this has no effect. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- Display Name
- Max Padding Size
- Description
- The maximum amount of padding that will be used to align row groups with blocks in the underlying filesystem. If the underlying filesystem is not a block filesystem like HDFS, this has no effect. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- API Name
- max-padding-size
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
-
Page Size
The page size used by the Parquet writer. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- Display Name
- Page Size
- Description
- The page size used by the Parquet writer. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- API Name
- page-size
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
-
Row Group Size
The row group size used by the Parquet writer. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- Display Name
- Row Group Size
- Description
- The row group size used by the Parquet writer. The value is specified in the format of <Data Size> <Data Unit> where Data Unit is one of B, KB, MB, GB, TB.
- API Name
- row-group-size
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
-
Schema Reference Writer
Service implementation responsible for writing FlowFile attributes or content header with Schema reference information
- Display Name
- Schema Reference Writer
- Description
- Service implementation responsible for writing FlowFile attributes or content header with Schema reference information
- API Name
- Schema Reference Writer
- Service Interface
- org.apache.nifi.schemaregistry.services.SchemaReferenceWriter
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- Schema Write Strategy is set to any of [schema-reference-writer]
-
Schema Write Strategy
Specifies how the schema for a Record should be added to the data.
- Display Name
- Schema Write Strategy
- Description
- Specifies how the schema for a Record should be added to the data.
- API Name
- Schema Write Strategy
- Default Value
- no-schema
- Allowable Values
-
- Do Not Write Schema
- Set 'schema.name' Attribute
- Set 'avro.schema' Attribute
- Schema Reference Writer
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Schema Access Strategy
Specifies how to obtain the schema that is to be used for interpreting the data.
- Display Name
- Schema Access Strategy
- Description
- Specifies how to obtain the schema that is to be used for interpreting the data.
- API Name
- schema-access-strategy
- Default Value
- inherit-record-schema
- Allowable Values
-
- Inherit Record Schema
- Use 'Schema Name' Property
- Use 'Schema Text' Property
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
-
Schema Branch
Specifies the name of the branch to use when looking up the schema in the Schema Registry property. If the chosen Schema Registry does not support branching, this value will be ignored.
- Display Name
- Schema Branch
- Description
- Specifies the name of the branch to use when looking up the schema in the Schema Registry property. If the chosen Schema Registry does not support branching, this value will be ignored.
- API Name
- schema-branch
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
- Dependencies
-
- Schema Access Strategy is set to any of [schema-name]
-
Schema Cache
Specifies a Schema Cache to add the Record Schema to so that Record Readers can quickly lookup the schema.
- Display Name
- Schema Cache
- Description
- Specifies a Schema Cache to add the Record Schema to so that Record Readers can quickly lookup the schema.
- API Name
- schema-cache
- Service Interface
- org.apache.nifi.serialization.RecordSchemaCacheService
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
-
Schema Name
Specifies the name of the schema to lookup in the Schema Registry property
- Display Name
- Schema Name
- Description
- Specifies the name of the schema to lookup in the Schema Registry property
- API Name
- schema-name
- Default Value
- ${schema.name}
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
- Dependencies
-
- Schema Access Strategy is set to any of [schema-name]
-
Schema Reference Reader
Service implementation responsible for reading FlowFile attributes or content to determine the Schema Reference Identifier
- Display Name
- Schema Reference Reader
- Description
- Service implementation responsible for reading FlowFile attributes or content to determine the Schema Reference Identifier
- API Name
- schema-reference-reader
- Service Interface
- org.apache.nifi.schemaregistry.services.SchemaReferenceReader
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- true
- Dependencies
-
- Schema Access Strategy is set to any of [schema-reference-reader]
-
Schema Registry
Specifies the Controller Service to use for the Schema Registry
- Display Name
- Schema Registry
- Description
- Specifies the Controller Service to use for the Schema Registry
- API Name
- schema-registry
- Service Interface
- org.apache.nifi.schemaregistry.services.SchemaRegistry
- Service Implementations
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false
- Dependencies
-
- Schema Access Strategy is set to any of [schema-name, schema-reference-reader]
-
Schema Text
The text of an Avro-formatted Schema
- Display Name
- Schema Text
- Description
- The text of an Avro-formatted Schema
- API Name
- schema-text
- Default Value
- ${avro.schema}
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
- Dependencies
-
- Schema Access Strategy is set to any of [schema-text-property]
-
Schema Version
Specifies the version of the schema to lookup in the Schema Registry. If not specified then the latest version of the schema will be retrieved.
- Display Name
- Schema Version
- Description
- Specifies the version of the schema to lookup in the Schema Registry. If not specified then the latest version of the schema will be retrieved.
- API Name
- schema-version
- Expression Language Scope
- Environment variables and FlowFile Attributes
- Sensitive
- false
- Required
- false
- Dependencies
-
- Schema Access Strategy is set to any of [schema-name]
-
Writer Version
Specifies the version used by Parquet writer
- Display Name
- Writer Version
- Description
- Specifies the version used by Parquet writer
- API Name
- writer-version
- Allowable Values
-
- PARQUET_1_0
- PARQUET_2_0
- Expression Language Scope
- Not Supported
- Sensitive
- false
- Required
- false