How to put Json data as a Json format in HBase

[#1]

Please tell me how to store json multiple line data in hbase from NiFi.

[#2]

@umang s

That's expected behavior from Hbase table because we are having unique Row Key for each record in Hbase table now. But your data that you are writing to this category1 table is duplicated data and Hbase only overwrites the existing data if it found same Row key already exists in the table. But in your case we are using UUID i.e unique id for the each flowfile in NiFi, so we will have unique id for each flowfile (although the content of the flowfile is same).

[#3]

i hve tried uuid() function but it repeat records like :-

[#4]

Hi @umang_instantwe ,

Could you please suggest how the same record can be put in HBase via HBase shell? 

{"id" : "1334134","name" : "Apparel Fabric","path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}

Ex. Below query does not work.

put 'table_name','row_key','cf:n1','{"id" : "1334134","name" : "Apparel Fabric","path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}', timestamp 

Thanks,

Priyanshu

[#5]

Hello @priyanshu_soni 

You can skip the "Timestamp" part as the same is inserted by HBase implicitly. I tried the same Query as you, excluding the Timestamp & the same was Successful:

hbase(main):018:0> put 'Table_X1','125','Cf1:CheckItem','{"ID" : "1334134","Name" : "Apparel Fabric","Path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}'
Took 0.0077 seconds                                                                                                                                                                                                                                                                                                           
hbase(main):019:0> scan 'Table_X1'
ROW                                                                              COLUMN+CELL                                                                                                                                                                                                                                  
 125                                                                             column=Cf1:CheckItem, timestamp=1621593487680, value={"ID" : "1334134","Name" : "Apparel Fabric","Path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}                                                                                     
1 row(s)
Took 0.0057 seconds 

As you may see above, the "timestamp" field corresponds to the Epoch Timestamp of the Inserted Row Time of Operation. If you wish to explicitly specify the Timestamp, You can include a EpochTime as shared below:

hbase(main):020:0> put 'Table_X1','126','Cf1:CheckItem','{"ID" : "1334134","Name" : "Apparel Fabric","Path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}',1621593487680
Took 0.0202 seconds                                                                                                                                                                                                                                                                                                           
hbase(main):021:0> scan 'Table_X1'
ROW                                                                              COLUMN+CELL                                                                                                                                                                                                                                  
 125                                                                             column=Cf1:CheckItem, timestamp=1621593487680, value={"ID" : "1334134","Name" : "Apparel Fabric","Path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}                                                                                     
 126                                                                             column=Cf1:CheckItem, timestamp=1621593487680, value={"ID" : "1334134","Name" : "Apparel Fabric","Path" : "Arts, Crafts & Sewing/Fabric/Apparel Fabric"}                                                                                     
2 row(s)
Took 0.0071 seconds 

Let us know if you have any issues with the Put Operation.

- Smarak