How to Query a FlowFile in Apache NiFi Using QueryRecord
Автор: InsightByte
Загружено: 2018-05-07
Просмотров: 17650
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
Доступные форматы для скачивания:
Скачать видео mp4
-
Информация по загрузке:
