好的,我理解您的意思是:
1,目前我的数据已经写到hbase中,只是phoenix在获取数据的时候反序列化存在问题。

scan 'ods_iot_gasdevice'
ROW                                 COLUMN+CELL
 2900                               column=base_info:device_id, 
timestamp=1602319974755, value=\x00\x00\x0BT
 2900                               column=base_info:verify_code, 
timestamp=1602319974755, value=6682acbe69c1a14
 2900                               column=status_info:battery_power, 
timestamp=1602319974755, value=\x00\x00\x00=
 2900                               column=status_info:device_status, 
timestamp=1602319974755, value=\x00\x00\x00\x02
 2900                               column=time_characteristics:create_time, 
timestamp=1602319974755, value=\x00\x00\x01u\x13m\xC9D

2. 我改用hbase shell建库。
 create 'ods_iot_gasdevice', 'base_info', 'status_info', ‘time_characteristics'
然后flink写入数据,最后在建立phoenix映射。
CREATE TABLE IF NOT EXISTS "ods_iot_gasdevice"(
    "rowkey" varchar not null primary key,
    "base_info"."device_id" BIGINT,
    "base_info"."verify_code" varchar,
    "status_info"."battery_power" BIGINT,
    "status_info"."device_status" BIGINT,
    "time_characteristics"."create_time" varchar
);
在这样操作之后,phoenix获取数据仍是之前的现象。我已经用了最基本的数据类型。怎么判定哪些数据类型phoenix类型和hbase类型是兼容的?

谢谢

Best,
TonyChen

> 2020年10月10日 下午4:31,Dream-底限 <zhan...@akulaku.com> 写道:
> 
> hi、phoenix类型和hbase类型有一部分不兼容:1、使用phoenix建表并通过phoenix jdbc插入数据;2、使用hbase
> api建表并插入数据,然后phoenix映射到现有hbase表;现在是数据通过hbase
> api存到hbase了,但phoenix反序列化读取时候有问题,或者你建phoenix表的时候数据类型选择兼容hbase原始类型的类型
> 
> 
> TonyChen <tonychen0...@qq.com> 于2020年10月10日周六 下午4:25写道:
> 
>> 我这个表就是用 phoenix 创建的。。
>> 
>> 
>> Best,
>> TonyChen
>> 
>>> 2020年10月10日 下午4:11,Dream-底限 <zhan...@akulaku.com> 写道:
>>> 
>>> hi、phoenix要映射现有hbase表,改一下phoenix建标语句应该可以解决
>>> 
>>> TonyChen <tonychen0...@qq.com> 于2020年10月10日周六 下午4:03写道:
>>> 
>>>> 查了下
>>>> 
>>>> hbase(main):011:0> get 'ods_iot_gasdevice', '2900'
>>>> COLUMN                              CELL
>>>> base_info:device_id                timestamp=1602314819543,
>>>> value=\x00\x00\x0BT
>>>> base_info:verify_code              timestamp=1602314819543,
>>>> value=54976e8caf8f524
>>>> status_info:battery_power          timestamp=1602314819543,
>>>> value=\x00\x00\x00T
>>>> status_info:device_status          timestamp=1602314819543,
>>>> value=\x00\x00\x00\x02
>>>> time_characteristics:create_time   timestamp=1602314819543,
>>>> value=\x00\x00\x01u\x13\x1F\x1Fv
>>>> 1 row(s) in 0.1950 seconds
>>>> 
>>>> 
>>>> Best,
>>>> TonyChen
>>>> 
>>>>> 2020年10月10日 下午3:51,Jark Wu <imj...@gmail.com> 写道:
>>>>> 
>>>>> 我看你是在 phoenix 中查询的,有试过在 hbase shell 中查询吗?
>>>>> 
>>>>> On Sat, 10 Oct 2020 at 15:36, TonyChen <tonychen0...@qq.com> wrote:
>>>>> 
>>>>>> 补充下:print输出数据正常
>>>>>> 
>>>>>> 11> +I(2910,2910,c514eecbc5c4748,9,1,2020-10-10T15:26:48.182)
>>>>>> 12> +I(2911,2911,0d1508ec452d27e,68,4,2020-10-10T15:26:48.182)
>>>>>> 3> +I(2902,2902,54976e60b7e8f54,83,1,2020-10-10T15:26:48.182)
>>>>>> 5> +I(2904,2904,72806e351aa5849,75,1,2020-10-10T15:26:48.182)
>>>>>> 8> +I(2907,2907,1f17c8000abc9e1,38,2,2020-10-10T15:26:48.182)
>>>>>> 1> +I(2900,2900,54976e8caf8f524,84,2,2020-10-10T15:26:48.182)
>>>>>> 6> +I(2905,2905,70852c245fbd949,45,3,2020-10-10T15:26:48.182)
>>>>>> 10> +I(2909,2909,22854c002e08c80,48,2,2020-10-10T15:26:48.182)
>>>>>> 2> +I(2901,2901,4110ae7bfd85814,58,2,2020-10-10T15:26:48.182)
>>>>>> 9> +I(2908,2908,e5074eeedcaea14,46,3,2020-10-10T15:26:48.182)
>>>>>> 4> +I(2903,2903,cc936a01758c0f3,6,4,2020-10-10T15:26:48.182)
>>>>>> 7> +I(2906,2906,30864c59367e180,50,4,2020-10-10T15:26:48.182)
>>>>>> 7> +I(2918,2918,90bbe8079999fd5,7,4,2020-10-10T15:26:49.178)
>>>>>> 9> +I(2920,2920,7e2f257406c730f,54,4,2020-10-10T15:26:49.178)
>>>>>> 4> +I(2915,2915,b4f2549ea4436b7,60,2,2020-10-10T15:26:49.178)
>>>>>> 11> +I(2922,2922,d7bfa14a1a9555f,6,1,2020-10-10T15:26:49.178)
>>>>>> 6> +I(2917,2917,9515c66bb40527b,78,1,2020-10-10T15:26:49.178)
>>>>>> 12> +I(2923,2923,8f4535a229b3a32,1,1,2020-10-10T15:26:49.178)
>>>>>> 5> +I(2916,2916,093037cdc5acec9,50,4,2020-10-10T15:26:49.178)
>>>>>> 2> +I(2913,2913,2842267351e9487,55,2,2020-10-10T15:26:49.178)
>>>>>> 10> +I(2921,2921,7704923d1f5042b,33,4,2020-10-10T15:26:49.178)
>>>>>> 1> +I(2912,2912,eba073be1b6f4b2,72,2,2020-10-10T15:26:49.178)
>>>>>> 8> +I(2919,2919,dd4ae09e50859b9,3,3,2020-10-10T15:26:49.178)
>>>>>> 3> +I(2914,2914,49655f1ca53e26e,24,2,2020-10-10T15:26:49.178)
>>>>>> 11> +I(2934,2934,3a00563a0ecaf6b,57,2,2020-10-10T15:26:50.173)
>>>>>> 9> +I(2932,2932,9a67d05622a57ae,54,1,2020-10-10T15:26:50.173)
>>>>>> 4> +I(2927,2927,c6db9148eeddd51,26,1,2020-10-10T15:26:50.173)
>>>>>> 5> +I(2928,2928,ae06b971bdeaff4,35,1,2020-10-10T15:26:50.173)
>>>>>> 1> +I(2924,2924,176b97cbb37b8e6,62,1,2020-10-10T15:26:50.173)
>>>>>> 6> +I(2929,2929,115d2d3f33188a6,62,2,2020-10-10T15:26:50.173)
>>>>>> 2> +I(2925,2925,3f3db2f63e505c7,86,4,2020-10-10T15:26:50.173)
>>>>>> 3> +I(2926,2926,d88f38f093f274d,55,1,2020-10-10T15:26:50.173)
>>>>>> 12> +I(2935,2935,56d5fbf93fd515d,72,1,2020-10-10T15:26:50.173)
>>>>>> 8> +I(2931,2931,dd98a2999028a83,59,1,2020-10-10T15:26:50.173)
>>>>>> 10> +I(2933,2933,377ec5fa4e52ca3,28,1,2020-10-10T15:26:50.173)
>>>>>> 7> +I(2930,2930,d2e93ff01ba5d2b,18,1,2020-10-10T15:26:50.174)
>>>>>> 9> +I(2944,2944,8589c30a128c7eb,45,3,2020-10-10T15:26:51.173)
>>>>>> 1> +I(2936,2936,d536e4d1703d20c,98,3,2020-10-10T15:26:51.173)
>>>>>> 5> +I(2940,2940,8fd48a674b19424,10,2,2020-10-10T15:26:51.173)
>>>>>> 11> +I(2946,2946,862c6321430e164,74,1,2020-10-10T15:26:51.173)
>>>>>> 2> +I(2937,2937,d177b845862342f,83,3,2020-10-10T15:26:51.173)
>>>>>> 6> +I(2941,2941,7c45b6f1ae69811,86,1,2020-10-10T15:26:51.173)
>>>>>> 4> +I(2939,2939,8db073425a9d0a9,81,1,2020-10-10T15:26:51.173)
>>>>>> 8> +I(2943,2943,b0d63314e8f7c63,57,1,2020-10-10T15:26:51.173)
>>>>>> 10> +I(2945,2945,384375f5f161a93,67,2,2020-10-10T15:26:51.173)
>>>>>> 12> +I(2947,2947,7a7ed532a9e5b5a,61,4,2020-10-10T15:26:51.173)
>>>>>> 3> +I(2938,2938,10e55f27f137a7f,22,4,2020-10-10T15:26:51.173)
>>>>>> 7> +I(2942,2942,52ae903a2633739,91,1,2020-10-10T15:26:51.176)
>>>>>> 3> +I(2950,2950,e3e60cd0630aa66,88,4,2020-10-10T15:26:52.174)
>>>>>> 1> +I(2948,2948,2cca133cca14cbf,44,1,2020-10-10T15:26:52.174)
>>>>>> 2> +I(2949,2949,7cc761cdb8bb924,77,4,2020-10-10T15:26:52.174)
>>>>>> 
>>>>>> 
>>>>>> Best,
>>>>>> TonyChen
>>>>>> 
>>>>>> 
>>>> 
>>>> 
>> 
>> 

回复