How to Query a FlowFile in Apache NiFi Using QueryRecord

Опубликовано: 15 Октябрь 2024
на канале: InsightByte

16,888

146

How to Query a FlowFile in Apache NiFi Using QueryRecord

http://www.aodba.com

Here are the Steps as described in the Demo

GenerateFlowfile

EId|PId|Date|Desc
1|ABC-123|2017-05-01|"Groove party"
2|ABC-111|2017-06-01|"Snack No. One"
3|ABC-123|2017-06-01|"The night out"

UpdateAttribute
schema.name schema_name

QueryRecord

AvroSchemaRegistry

{
"name": "myschema",
"namespace": "nifi",
"type": "record",
"fields": [
{"name": "EId" , "type" : "string"},
{"name": "PId" , "type" : "string"},
{"name": "Date" , "type" : "string"},
{"name": "Desc" , "type" : "string"}
]
}

Setup CSVReader

Setup JsonRecordSetWriter

sql = select * from FLOWFILE where EId='2'

apache nifi | nifi hadoop | nifi processors | nifi | nifi examples | nifi etl | apache nifi example