Member since
06-06-2019
1
Post
0
Kudos Received
0
Solutions
06-06-2019
07:58 PM
I am trying to do UPSERT on hbase using PUTDATABASERECORD processor. For this I am preparing UPSERT query using UPDATERECORD processor My UPDATE RECORD processor settings are like this. In this one I have added one more field called query value of query is : concat('UPSERT INTO myschema.Parameter("DSN","LEGACYID","INTDATE","PARAMETERDATA")values(\'',/DSN,'\',',/legacyID,',\'',/intDate,'\',\'',/parameterData,'\')') The last field(parameterData) referred above is of type array. When the UPDATE RECORD processor runs my query is generated. In the query generated find I can find something called 'MapRecord[' for the parameterData which is mentioned above. Each array item is enclosed in a MapRecord. Is this something done by UpdateRecord processor? Is there any way to avoid this? It would be great if someone can guide me to avoid/fix this. Thanks Jithesh
... View more
Labels:
- Labels:
-
Apache Hadoop
-
Apache HBase
-
Apache NiFi