I want to merge source records from hive existing records based on some key and if records exist in hive table then only update the value of particular records. Example : i have a table in hive "Test" with records-1 (id : 1, name : abc, age : 20), records-2 (id : 2, name : xyz, age : 22) and i am getting the records from source (live sensor ). The same records i am getting from the sensor and doing some merge based on id, so if the records matched with existing records from hive table then only update new value else insert the key and value both. I want the way in java coding only, query i have for merging the records. merge into customer_name using ( select * from all_updates) sub on sub.id = customer_name.id when matched then update set name = sub.name, state = sub.state when not matched then insert values (sub.id, sub.name, sub.state); I did in java but not finding the way how to resolve this issue. Could anybody suggest me the way. Thanks. ... View more

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 !! ... View more