James, The easiest would be to merge json in a custom processor. Not easy as in no work at all, but given your limitations with the NiFi version could be done sooner maybe.
Andrew On Mon, Dec 17, 2018, 9:53 AM James Srinivasan <james.sriniva...@gmail.com> wrote: > Hi all, > > I'm trying to enrich a data stream using NiFi. So far I have the following: > > 1) Stream of vehicle data in JSON format containing (id, make, model) > 2) This vehicle data goes into HBase, using id as the row key and the > json data as the cell value (cf:json) > 3) Stream of position data in JSON format, containing (id, lat, lon) > 4) I extract the id from each of these items, then use FetchHBaseRow > to populate the hbase.row attribute with the json content > corresponding to that vehicle > 5) I want to merge the NiFI attribute (which is actually JSON) into > the rest of the content, so I end up with (id, lat, lon, make, model). > This is where I am stuck - using the Jolt processor, I keep getting > unable to unmarshal json to an object > > Caveats > > 1) I'm on NiFi 1.3 > 2) Much as I would like to use the new record functionality, I'm > trying to be schema agnostic as much as possible > > Is this the right approach? Is there an easy way to add the attribute > value as a valid JSON object? Maybe ReplaceText capturing the trailing > } would work? > > Thanks in advance, > > James >
