Skip to content

Commit c5859aa

Browse files
author
dapeng
committed
hbase结果表文档更新
1 parent 966b171 commit c5859aa

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

cassandra/cassandra-side/cassandra-side-core/src/main/java/com/dtstack/flink/sql/side/cassandra/table/CassandraSideParser.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,7 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
9999
private void dealSideSign(Matcher matcher, TableInfo tableInfo) {
100100
}
101101

102+
@Override
102103
public Class dbTypeConvertToJavaType(String fieldType) {
103104
switch (fieldType.toLowerCase()) {
104105
case "bigint":

docs/plugin/hbaseSink.md

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,13 +34,13 @@ hbase2.0
3434
|zookeeperQuorum | hbase zk地址,多个直接用逗号隔开|||
3535
|zookeeperParent | zkParent 路径|||
3636
|tableName | 关联的hbase表名称|||
37-
|rowKey | hbase的rowkey关联的列信息|||
37+
|rowkey | hbase的rowkey关联的列信息,多个值以逗号隔开|||
38+
|updateMode|APPEND:不回撤数据,只下发增量数据,UPSERT:先删除回撤数据,然后更新|否|APPEND|
3839
|parallelism | 并行度设置||1|
3940
4041

4142
## 5.样例:
4243
```
43-
4444
CREATE TABLE MyResult(
4545
cf:info VARCHAR,
4646
cf:name VARCHAR,
@@ -52,4 +52,8 @@ hbase2.0
5252
tableName ='workerinfo01',
5353
rowKey ='channel'
5454
);
55-
```
55+
```
56+
57+
## 6.hbase数据
58+
### 数据内容说明
59+
### 数据内容示例

0 commit comments

Comments
 (0)