- 
            Processors
            
- AttributeRollingWindow
 - AttributesToCSV
 - AttributesToJSON
 - CalculateRecordStats
 - CaptureChangeMySQL
 - CompressContent
 - ConnectWebSocket
 - ConsumeAMQP
 - ConsumeAzureEventHub
 - ConsumeBoxEnterpriseEvents
 - ConsumeBoxEvents
 - ConsumeElasticsearch
 - ConsumeGCPubSub
 - ConsumeIMAP
 - ConsumeJMS
 - ConsumeKafka
 - ConsumeKinesisStream
 - ConsumeMQTT
 - ConsumePOP3
 - ConsumeSlack
 - ConsumeTwitter
 - ConsumeWindowsEventLog
 - ControlRate
 - ConvertCharacterSet
 - ConvertRecord
 - CopyAzureBlobStorage_v12
 - CopyS3Object
 - CountText
 - CreateBoxFileMetadataInstance
 - CreateBoxMetadataTemplate
 - CryptographicHashContent
 - DebugFlow
 - DecryptContentAge
 - DecryptContentPGP
 - DeduplicateRecord
 - DeleteAzureBlobStorage_v12
 - DeleteAzureDataLakeStorage
 - DeleteBoxFileMetadataInstance
 - DeleteByQueryElasticsearch
 - DeleteDynamoDB
 - DeleteFile
 - DeleteGCSObject
 - DeleteGridFS
 - DeleteMongo
 - DeleteS3Object
 - DeleteSFTP
 - DeleteSQS
 - DetectDuplicate
 - DistributeLoad
 - DuplicateFlowFile
 - EncodeContent
 - EncryptContentAge
 - EncryptContentPGP
 - EnforceOrder
 - EvaluateJsonPath
 - EvaluateXPath
 - EvaluateXQuery
 - ExecuteGroovyScript
 - ExecuteProcess
 - ExecuteScript
 - ExecuteSQL
 - ExecuteSQLRecord
 - ExecuteStreamCommand
 - ExtractAvroMetadata
 - ExtractEmailAttachments
 - ExtractEmailHeaders
 - ExtractGrok
 - ExtractHL7Attributes
 - ExtractRecordSchema
 - ExtractStructuredBoxFileMetadata
 - ExtractText
 - FetchAzureBlobStorage_v12
 - FetchAzureDataLakeStorage
 - FetchBoxFile
 - FetchBoxFileInfo
 - FetchBoxFileMetadataInstance
 - FetchBoxFileRepresentation
 - FetchDistributedMapCache
 - FetchDropbox
 - FetchFile
 - FetchFTP
 - FetchGCSObject
 - FetchGoogleDrive
 - FetchGridFS
 - FetchS3Object
 - FetchSFTP
 - FetchSmb
 - FilterAttribute
 - FlattenJson
 - ForkEnrichment
 - ForkRecord
 - GenerateFlowFile
 - GenerateRecord
 - GenerateTableFetch
 - GeoEnrichIP
 - GeoEnrichIPRecord
 - GeohashRecord
 - GetAsanaObject
 - GetAwsPollyJobStatus
 - GetAwsTextractJobStatus
 - GetAwsTranscribeJobStatus
 - GetAwsTranslateJobStatus
 - GetAzureEventHub
 - GetAzureQueueStorage_v12
 - GetBoxFileCollaborators
 - GetBoxGroupMembers
 - GetDynamoDB
 - GetElasticsearch
 - GetFile
 - GetFileResource
 - GetFTP
 - GetGcpVisionAnnotateFilesOperationStatus
 - GetGcpVisionAnnotateImagesOperationStatus
 - GetHubSpot
 - GetMongo
 - GetMongoRecord
 - GetS3ObjectMetadata
 - GetS3ObjectTags
 - GetSFTP
 - GetShopify
 - GetSmbFile
 - GetSNMP
 - GetSplunk
 - GetSQS
 - GetWorkdayReport
 - GetZendesk
 - HandleHttpRequest
 - HandleHttpResponse
 - IdentifyMimeType
 - InvokeHTTP
 - InvokeScriptedProcessor
 - ISPEnrichIP
 - JoinEnrichment
 - JoltTransformJSON
 - JoltTransformRecord
 - JSLTTransformJSON
 - JsonQueryElasticsearch
 - ListAzureBlobStorage_v12
 - ListAzureDataLakeStorage
 - ListBoxFile
 - ListBoxFileInfo
 - ListBoxFileMetadataInstances
 - ListBoxFileMetadataTemplates
 - ListDatabaseTables
 - ListDropbox
 - ListenFTP
 - ListenHTTP
 - ListenOTLP
 - ListenSlack
 - ListenSyslog
 - ListenTCP
 - ListenTrapSNMP
 - ListenUDP
 - ListenUDPRecord
 - ListenWebSocket
 - ListFile
 - ListFTP
 - ListGCSBucket
 - ListGoogleDrive
 - ListS3
 - ListSFTP
 - ListSmb
 - LogAttribute
 - LogMessage
 - LookupAttribute
 - LookupRecord
 - MergeContent
 - MergeRecord
 - ModifyBytes
 - ModifyCompression
 - MonitorActivity
 - MoveAzureDataLakeStorage
 - Notify
 - PackageFlowFile
 - PaginatedJsonQueryElasticsearch
 - ParseEvtx
 - ParseNetflowv5
 - ParseSyslog
 - ParseSyslog5424
 - PartitionRecord
 - PublishAMQP
 - PublishGCPubSub
 - PublishJMS
 - PublishKafka
 - PublishMQTT
 - PublishSlack
 - PutAzureBlobStorage_v12
 - PutAzureCosmosDBRecord
 - PutAzureDataExplorer
 - PutAzureDataLakeStorage
 - PutAzureEventHub
 - PutAzureQueueStorage_v12
 - PutBigQuery
 - PutBoxFile
 - PutCloudWatchMetric
 - PutDatabaseRecord
 - PutDistributedMapCache
 - PutDropbox
 - PutDynamoDB
 - PutDynamoDBRecord
 - PutElasticsearchJson
 - PutElasticsearchRecord
 - PutEmail
 - PutFile
 - PutFTP
 - PutGCSObject
 - PutGoogleDrive
 - PutGridFS
 - PutKinesisFirehose
 - PutKinesisStream
 - PutLambda
 - PutMongo
 - PutMongoBulkOperations
 - PutMongoRecord
 - PutRecord
 - PutRedisHashRecord
 - PutS3Object
 - PutSalesforceObject
 - PutSFTP
 - PutSmbFile
 - PutSNS
 - PutSplunk
 - PutSplunkHTTP
 - PutSQL
 - PutSQS
 - PutSyslog
 - PutTCP
 - PutUDP
 - PutWebSocket
 - PutZendeskTicket
 - QueryAirtableTable
 - QueryAzureDataExplorer
 - QueryDatabaseTable
 - QueryDatabaseTableRecord
 - QueryRecord
 - QuerySalesforceObject
 - QuerySplunkIndexingStatus
 - RemoveRecordField
 - RenameRecordField
 - ReplaceText
 - ReplaceTextWithMapping
 - RetryFlowFile
 - RouteHL7
 - RouteOnAttribute
 - RouteOnContent
 - RouteText
 - RunMongoAggregation
 - SampleRecord
 - ScanAttribute
 - ScanContent
 - ScriptedFilterRecord
 - ScriptedPartitionRecord
 - ScriptedTransformRecord
 - ScriptedValidateRecord
 - SearchElasticsearch
 - SegmentContent
 - SendTrapSNMP
 - SetSNMP
 - SignContentPGP
 - SplitAvro
 - SplitContent
 - SplitExcel
 - SplitJson
 - SplitPCAP
 - SplitRecord
 - SplitText
 - SplitXml
 - StartAwsPollyJob
 - StartAwsTextractJob
 - StartAwsTranscribeJob
 - StartAwsTranslateJob
 - StartGcpVisionAnnotateFilesOperation
 - StartGcpVisionAnnotateImagesOperation
 - TagS3Object
 - TailFile
 - TransformXml
 - UnpackContent
 - UpdateAttribute
 - UpdateBoxFileMetadataInstance
 - UpdateByQueryElasticsearch
 - UpdateCounter
 - UpdateDatabaseTable
 - UpdateRecord
 - ValidateCsv
 - ValidateJson
 - ValidateRecord
 - ValidateXml
 - VerifyContentMAC
 - VerifyContentPGP
 - Wait
 
 
- 
            Controller Services
            
- ADLSCredentialsControllerService
 - ADLSCredentialsControllerServiceLookup
 - AmazonGlueEncodedSchemaReferenceReader
 - AmazonGlueSchemaRegistry
 - AmazonMSKConnectionService
 - ApicurioSchemaRegistry
 - AvroReader
 - AvroRecordSetWriter
 - AvroSchemaRegistry
 - AWSCredentialsProviderControllerService
 - AzureBlobStorageFileResourceService
 - AzureCosmosDBClientService
 - AzureDataLakeStorageFileResourceService
 - AzureEventHubRecordSink
 - AzureStorageCredentialsControllerService_v12
 - AzureStorageCredentialsControllerServiceLookup_v12
 - CEFReader
 - ConfluentEncodedSchemaReferenceReader
 - ConfluentEncodedSchemaReferenceWriter
 - ConfluentProtobufMessageNameResolver
 - ConfluentSchemaRegistry
 - CSVReader
 - CSVRecordLookupService
 - CSVRecordSetWriter
 - DatabaseRecordLookupService
 - DatabaseRecordSink
 - DatabaseTableSchemaRegistry
 - DBCPConnectionPool
 - DBCPConnectionPoolLookup
 - DeveloperBoxClientService
 - DistributedMapCacheLookupService
 - ElasticSearchClientServiceImpl
 - ElasticSearchLookupService
 - ElasticSearchStringLookupService
 - EmailRecordSink
 - EmbeddedHazelcastCacheManager
 - ExcelReader
 - ExternalHazelcastCacheManager
 - FreeFormTextRecordSetWriter
 - GCPCredentialsControllerService
 - GCSFileResourceService
 - GrokReader
 - HazelcastMapCacheClient
 - HikariCPConnectionPool
 - HttpRecordSink
 - IPLookupService
 - JettyWebSocketClient
 - JettyWebSocketServer
 - JMSConnectionFactoryProvider
 - JndiJmsConnectionFactoryProvider
 - JsonConfigBasedBoxClientService
 - JsonPathReader
 - JsonRecordSetWriter
 - JsonTreeReader
 - JWTBearerOAuth2AccessTokenProvider
 - Kafka3ConnectionService
 - KerberosKeytabUserService
 - KerberosPasswordUserService
 - KerberosTicketCacheUserService
 - LoggingRecordSink
 - MapCacheClientService
 - MapCacheServer
 - MongoDBControllerService
 - MongoDBLookupService
 - PEMEncodedSSLContextProvider
 - PropertiesFileLookupService
 - ProtobufReader
 - ReaderLookup
 - RecordSetWriterLookup
 - RecordSinkServiceLookup
 - RedisConnectionPoolService
 - RedisDistributedMapCacheClientService
 - RestLookupService
 - S3FileResourceService
 - ScriptedLookupService
 - ScriptedReader
 - ScriptedRecordSetWriter
 - ScriptedRecordSink
 - SetCacheClientService
 - SetCacheServer
 - SimpleCsvFileLookupService
 - SimpleDatabaseLookupService
 - SimpleKeyValueLookupService
 - SimpleRedisDistributedMapCacheClientService
 - SimpleScriptedLookupService
 - SiteToSiteReportingRecordSink
 - SlackRecordSink
 - SmbjClientProviderService
 - StandardAsanaClientProviderService
 - StandardAzureCredentialsControllerService
 - StandardDatabaseDialectService
 - StandardDropboxCredentialService
 - StandardFileResourceService
 - StandardHashiCorpVaultClientService
 - StandardHttpContextMap
 - StandardJsonSchemaRegistry
 - StandardKustoIngestService
 - StandardKustoQueryService
 - StandardOauth2AccessTokenProvider
 - StandardPGPPrivateKeyService
 - StandardPGPPublicKeyService
 - StandardPrivateKeyService
 - StandardProtobufReader
 - StandardProxyConfigurationService
 - StandardRestrictedSSLContextService
 - StandardS3EncryptionService
 - StandardSSLContextService
 - StandardWebClientServiceProvider
 - Syslog5424Reader
 - SyslogReader
 - UDPEventRecordSink
 - VolatileSchemaCache
 - WindowsEventLogReader
 - XMLFileLookupService
 - XMLReader
 - XMLRecordSetWriter
 - YamlTreeReader
 - ZendeskRecordSink
 
 
AzureDataLakeStorageFileResourceService 2.6.0
- Bundle
 - org.apache.nifi | nifi-azure-nar
 - Description
 - Provides an Azure Data Lake Storage (ADLS) file resource for other components.
 - Tags
 - adlsgen2, azure, cloud, datalake, file, microsoft, resource, storage
 - Input Requirement
 - Supports Sensitive Dynamic Properties
 - false
 
Properties
    - 
            
                ADLS Credentials
                Controller Service used to obtain Azure Credentials.
- Display Name
 - ADLS Credentials
 - Description
 - Controller Service used to obtain Azure Credentials.
 - API Name
 - ADLS Credentials
 - Service Interface
 - org.apache.nifi.services.azure.storage.ADLSCredentialsService
 - Service Implementations
 - Expression Language Scope
 - Not Supported
 - Sensitive
 - false
 - Required
 - true
 
 - 
            
                Directory Name
                Name of the Azure Storage Directory. The Directory Name cannot contain a leading '/'. The root directory can be designated by the empty string value. In case of the PutAzureDataLakeStorage processor, the directory will be created if not already existing.
- Display Name
 - Directory Name
 - Description
 - Name of the Azure Storage Directory. The Directory Name cannot contain a leading '/'. The root directory can be designated by the empty string value. In case of the PutAzureDataLakeStorage processor, the directory will be created if not already existing.
 - API Name
 - Directory Name
 - Default Value
 - ${azure.directory}
 - Expression Language Scope
 - Environment variables and FlowFile Attributes
 - Sensitive
 - false
 - Required
 - true
 
 - 
            
                File Name
                The filename
- Display Name
 - File Name
 - Description
 - The filename
 - API Name
 - File Name
 - Default Value
 - ${azure.filename}
 - Expression Language Scope
 - Environment variables and FlowFile Attributes
 - Sensitive
 - false
 - Required
 - true
 
 - 
            
                Filesystem Name
                Name of the Azure Storage File System (also called Container). It is assumed to be already existing.
- Display Name
 - Filesystem Name
 - Description
 - Name of the Azure Storage File System (also called Container). It is assumed to be already existing.
 - API Name
 - Filesystem Name
 - Default Value
 - ${azure.filesystem}
 - Expression Language Scope
 - Environment variables and FlowFile Attributes
 - Sensitive
 - false
 - Required
 - true
 
 
See Also