@@ -88,6 +88,24 @@ CREATE TABLE sideTable (
8888);
8989```
9090
91+ ## 6.hbase完整样例
92+
93+ ### 数据说明
94+
95+ 在hbase中,数据是以列簇的形式存储,其中rowKey作为主键,按字典排序。
96+
97+ 在样例中,wtz为列族名,message, info为列名,数据在hbase中的存储情况为:
98+ ```
99+ hbase(main):002:0> scan 'testFlinkStreamSql'
100+ ROW COLUMN+CELL
101+ 0 column=wtz:info, timestamp=1587089266719, value=hadoop
102+ 0 column=wtz:message, timestamp=1587089245780, value=hbase
103+ 1 column=wtz:info, timestamp=1587088818432, value=flink
104+ 1 column=wtz:message, timestamp=1587088796633, value=dtstack
105+ 2 column=wtz:info, timestamp=1587088858564, value=sql
106+ 2 column=wtz:message, timestamp=1587088840507, value=stream
107+ ```
108+
91109### hbase异步维表关联完整案例
92110```
93111CREATE TABLE MyTable(
@@ -150,18 +168,3 @@ into
150168 on a.id=b.rowkey;
151169```
152170
153- ## 6.hbase中数据存储形式
154-
155- 在hbase中,数据是以列簇的形式存储,其中rowKey作为主键,按字典排序。
156-
157- 在样例中,wtz为列族名,message, info为列名,数据在hbase中的存储情况为:
158- ```
159- hbase(main):002:0> scan 'testFlinkStreamSql'
160- ROW COLUMN+CELL
161- 0 column=wtz:info, timestamp=1587089266719, value=hadoop
162- 0 column=wtz:message, timestamp=1587089245780, value=hbase
163- 1 column=wtz:info, timestamp=1587088818432, value=flink
164- 1 column=wtz:message, timestamp=1587088796633, value=dtstack
165- 2 column=wtz:info, timestamp=1587088858564, value=sql
166- 2 column=wtz:message, timestamp=1587088840507, value=stream
167- ```
0 commit comments