处理器 (Processor)
AttributeRollingWindow
AttributesToCSV
AttributesToJSON
CalculateRecordStats
CaptureChangeMySQL
CompressContent
ConnectWebSocket
ConsumeAMQP
ConsumeAzureEventHub
ConsumeBoxEnterpriseEvents
ConsumeBoxEvents
ConsumeElasticsearch
ConsumeGCPubSub
ConsumeIMAP
ConsumeJMS
ConsumeKafka
ConsumeKinesis
ConsumeKinesisStream
ConsumeMQTT
ConsumePOP3
ConsumeSlack
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
FetchAzureBlobStorageMetadata
FetchAzureBlobStorageTags
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
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
PutIcebergRecord
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
UpdateGauge
UpdateRecord
ValidateCsv
ValidateJson
ValidateRecord
ValidateXml
VerifyContentMAC
VerifyContentPGP
Wait
控制器服务 (Controller Service)
ADLSCredentialsControllerService
ADLSCredentialsControllerServiceLookup
ADLSIcebergFileIOProvider
AmazonGlueEncodedSchemaReferenceReader
AmazonGlueSchemaRegistry
AmazonMSKConnectionService
ApicurioSchemaRegistry
AvroReader
AvroRecordSetWriter
AvroSchemaRegistry
AWSCredentialsProviderControllerService
AwsRdsIamDatabasePasswordProvider
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
GCSIcebergFileIOProvider
GrokReader
HazelcastMapCacheClient
HikariCPConnectionPool
HttpRecordSink
IPLookupService
JettyWebSocketClient
JettyWebSocketServer
JMSConnectionFactoryProvider
JndiJmsConnectionFactoryProvider
JsonConfigBasedBoxClientService
JsonPathReader
JsonRecordSetWriter
JsonTreeReader
JWTBearerOAuth2AccessTokenProvider
Kafka3ConnectionService
KerberosKeytabUserService
KerberosPasswordUserService
KerberosTicketCacheUserService
LoggingRecordSink
MapCacheClientService
MapCacheServer
MongoDBControllerService
MongoDBLookupService
ParquetIcebergWriter
PEMEncodedSSLContextProvider
PropertiesFileLookupService
ProtobufReader
ReaderLookup
RecordSetWriterLookup
RecordSinkServiceLookup
RedisConnectionPoolService
RedisDistributedMapCacheClientService
RESTIcebergCatalog
RestLookupService
S3FileResourceService
S3IcebergFileIOProvider
ScriptedLookupService
ScriptedReader
ScriptedRecordSetWriter
ScriptedRecordSink
SetCacheClientService
SetCacheServer
SimpleCsvFileLookupService
SimpleDatabaseLookupService
SimpleKeyValueLookupService
SimpleRedisDistributedMapCacheClientService
SimpleScriptedLookupService
SiteToSiteReportingRecordSink
SlackRecordSink
SmbjClientProviderService
StandardAzureCredentialsControllerService
StandardAzureIdentityFederationTokenProvider
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