Supported Apache NiFi Processors
Supported Apache NiFi Processors
Learn about the NiFi Processors supported by BigBox Support for use with BigAction.
Additional Processors are developed and tested by the BigBox community but are not officially supported by BigBox. Processors are excluded for a variety of reasons, including insufficient reliability or incomplete test case coverage, declaration of non-production readiness by the community at large, and feature deviation from BIgBox best practices. Do not use these features in your production environments.
AttributesToCSV
AttributesToJSON
Base64EncodeContent
CalculateRecordStats
CaptureChangeMySQL
CompressContent
ConnectWebSocket
ConsumeAMQP
ConsumeAzureEventHub
ConsumeEWS
ConsumeGCPubSub
ConsumeJMS
ConsumeKafka_1_0
ConsumeKafka_2_0
ConsumeKafka_2_6
ConsumeKafka2CDP
ConsumeKafka2RecordCDP
ConsumeKafkaRecord_1_0
ConsumeKafkaRecord_2_0
ConsumeKafkaRecord_2_6
ConsumeKinesisStream
ConsumeMQTT
ConsumePulsar
ConsumePulsarRecord
ConsumeWindowsEventLog
ControlRate
ConvertAvroSchema
ConvertAvroToJSON
ConvertAvroToORC
ConvertAvroToParquet
ConvertCharacterSet
ConvertCSVToAvro
ConvertJSONToAvro
ConvertJSONToSQL
ConvertRecord
CreateHadoopSequenceFile
CryptographicHashAttribute
CryptographicHashContent
DecryptContentPGP
DeduplicateRecord
DeleteAzureBlobStorage
DeleteAzureDataLakeStorage
DeleteByQueryElasticsearch
DeleteCDPObjectStore
DeleteDynamoDB
DeleteGCSObject
DeleteGridFS
DeleteHBaseCells
DeleteHBaseRow
DeleteHDFS
DeleteS3Object
DeleteSQS
DetectDuplicate
DistributeLoad
DuplicateFlowFile
EncryptContent
EncryptContentPGP
EnforceOrder
EvaluateJsonPath
EvaluateXPath
EvaluateXQuery
ExecuteGroovyScript
ExecuteInfluxDBQuery
ExecuteProcess
ExecuteScript
ExecuteSQL
ExecuteSQLRecord
ExecuteStateless
ExecuteStreamCommand
ExtractAvroMetadata
ExtractGrok
ExtractHL7Attributes
ExtractImageMetadata
ExtractText
FetchAzureBlobStorage
FetchAzureDataLakeStorage
FetchCDPObjectStore
FetchDistributedMapCache
FetchElasticsearchHttp
FetchFile
FetchFTP
FetchGCSObject
FetchGridFS
FetchHBaseRow
FetchHDFS
FetchParquet
FetchS3Object
FetchSFTP
FlattenJson
ForkEnrichment
ForkRecord
GenerateFlowFile
GenerateTableFetch
GeoEnrichIP
GeoEnrichIPRecord
GeohashRecord
GetAzureEventHub
GetAzureQueueStorage
GetCouchbaseKey
GetElasticsearch
GetFile
GetFTP
GetHBase
GetHDFS
GetHDFSFileInfo
GetHDFSSequenceFile
GetHTMLElement
GetHTTP
GetIgniteCache
GetJMSQueue
GetJMSTopic
GetMongoRecord
GetSFTP
GetSNMP
GetSolr
GetSplunk
GetSQS
GetTCP
GetTwitter
HandleHttpRequest
HandleHttpResponse
HashAttribute
HashContent
IdentifyMimeType
InvokeAWSGatewayApi
InvokeGRPC
InvokeHTTP
InvokeScriptedProcessor
JoinEnrichment
JoltTransformJSON
JoltTransformRecord
JsonQueryElasticsearch
ListAzureBlobStorage
ListAzureDataLakeStorage
ListCDPObjectStore
ListDatabaseTables
ListenFTP
ListenGRPC
ListenHTTP
ListenRELP
ListenSyslog
ListenTCP
ListenTCPRecord
ListenUDP
ListenUDPRecord
ListenWebSocket
ListFile
ListFTP
ListGCSBucket
ListHDFS
ListS3
ListSFTP
LogAttribute
LogMessage
LookupAttribute
LookupRecord
MergeContent
MergeRecord
ModifyHTMLElement
MonitorActivity
MoveAzureDataLakeStorage
Notify
PaginatedJsonQueryElasticsearch
ParseCEF
ParseEvtx
ParseSyslog
PartitionRecord
PostHTTP
PublishAMQP
PublishGCPubSub
PublishJMS
PublishKafka_1_0
PublishKafka_2_0
PublishKafka_2_6
PublishKafka2CDP
PublishKafka2RecordCDP
PublishKafkaRecord_1_0
PublishKafkaRecord_2_0
PublishKafkaRecord_2_6
PublishMQTT
PublishPulsar
PublishPulsarRecord
PutAccumuloRecord
PutAzureBlobStorage
PutAzureCosmosDBRecord
PutAzureDataLakeStorage
PutAzureEventHub
PutAzureQueueStorage
PutBigQueryBatch
PutBigQueryStreaming
PutCassandraQL
PutCassandraRecord
PutCDPObjectStore
PutCloudWatchMetric
PutCouchbaseKey
PutDatabaseRecord
PutDistributedMapCache
PutDynamoDB
PutDynamoDBRecord
PutElasticsearchHttp
PutElasticsearchHttpRecord
PutElasticsearchJson
PutElasticsearchRecord
PutEmail
PutFile
PutFTP
PutGCSObject
PutGridFS
PutHBaseCell
PutHBaseJSON
PutHBaseRecord
PutHDFS
PutHive3QL
PutHive3Streaming
PutHiveQL
PutHiveStreaming
PutHTMLElement
PutInfluxDB
PutJMS
PutKinesisFirehose
PutKinesisStream
PutKudu
PutLambda
PutMongoRecord
PutORC
PutParquet
PutRecord
PutRiemann
PutS3Object
PutSFTP
PutSNS
PutSolrContentStream
PutSolrRecord
PutSplunk
PutSplunkHTTP
PutSQL
PutSQS
PutSyslog
PutTCP
PutUDP
PutWebSocket
QueryCassandra
QueryDatabaseTable
QueryDatabaseTableRecord
QueryElasticsearchHttp
QueryRecord
QuerySalesforceObject
QuerySolr
QuerySplunkIndexingStatus
QueryWhois
ReplaceText
ReplaceTextWithMapping
ResizeImage
RetryFlowFile
RouteHL7
RouteOnAttribute
RouteOnContent
RouteText
SampleRecord
ScanAccumulo
ScanAttribute
ScanContent
ScanHBase
ScriptedFilterRecord
ScriptedPartitionRecord
ScriptedTransformRecord
ScriptedValidateRecord
ScrollElasticsearchHttp
SearchElasticsearch
SegmentContent
SelectHive3QL
SelectHiveQL
SetSNMP
SignContentPGP
SplitAvro
SplitContent
SplitJson
SplitRecord
SplitText
SplitXml
TagS3Object
TailFile
TransformXml
UnpackContent
UpdateAttribute
UpdateByQueryElasticsearch
UpdateCounter
UpdateHive3Table
UpdateHiveTable
UpdateRecord
ValidateCsv
ValidateRecord
ValidateXml
VerifyContentPGP
Wait
YandexTranslate