Hi,
I want to do below process in NiFi.
Step 1) ConsumeMQTT using mosquitto
Step 2) UpdateAttributes
Step 3) EvaluateJsonPath
Step 4) SplitJson - will produce the separate flowfile for each JSON array
Step 5) PutHbaseJSON --> Store the Json Array to HBASE
Hope you can now simulate the same
or
i'm having json array as
{"weather": [ {"id":"1","latitude":"13.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"2","latitude":"14.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"3","latitude":"15.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"4","latitude":"16.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"}, {"id":"5","latitude":"17.08","longitude":"80.27","temprature":"39","pressure":"1009mb","visibility":"7km","wind":"4mph","cloudcover":"50%","momentmagnitude":"9.1"} ] }
i'm trying to insert the same to hbase,
how to get the each array into hbase row.
Any help would be appreciated, Thanks !!
