You might try searching around for a Phoenix-compatible Storm bolt. For
example, a quick search turned up this which you may be able to use for
inspiration:
https://github.com/gvetticaden/storm-streaming/blob/master/src/main/java/com/hortonworks/streaming/impl/bolts/TruckPhoenixHBaseBolt.java

On Wed, Dec 13, 2017 at 9:28 AM, Josh Elser <[email protected]> wrote:

> If you want to use Phoenix, please use Phoenix APIs to read and write the
> data.
>
> You are wholly responsible for understanding how to correctly write the
> data given Phoenix's schema if you bypass it.
>
>
> On 12/13/17 9:25 AM, Oussama BEN BACCAR wrote:
>
>> Hello Phoenixers,
>>
>> I have a rowkey issue when i salt a phoenix table and insert data directly
>> from hbase.
>>
>> Here is the scenario:
>>
>> 1- Create a table on phoenix with salt_buckets=16
>>
>> 2- The data is inserted in the hbase table by a storm hbase bolt. The
>> hbasebolt insert data directly in hbase without passing by phoenix.
>>
>> The problem is the phoenix rowkey always missing the first character
>> compared to thehbase rowkey, when i run a select query on phoenix
>>
>> *Example:*
>> *- hbase rowkey:   1f05d01f-6a17-4d7b-8d97-df32d8856666*
>> *- phoenix rowkey:  f05d01f-6a17-4d7b-8d97-df32d8856666*
>>
>>
>> I look forward getting a response guys. Thank you in advance.
>>
>> Kind regards,
>>
>>

Reply via email to