I was trying to load the data from SQL(QueryDatabseTable) to HBase (PutHbaseJSON) Via NiFi and on top of it I am trying to create Phoenix tables. I could see that there are some datatype issues. And at the later stage I came to know that we can load the data directly into Phoenix using PUTSQL. Can some one help me out the best processors used to get data from SQL to Phoenix, Please.
There are a couple of examples in HCC articles here and here, you can also use PutDatabaseRecord instead of splitting, replacing the content with SQL, and PutSQL, but it doesn't work for Upsert, only Insert Update and Delete.