Skip to content

Commit 85c2737

Browse files
committed
hbase remove field to upper
1 parent 61d81e8 commit 85c2737

3 files changed

Lines changed: 5 additions & 5 deletions

File tree

hbase/hbase-side/hbase-all-side/src/main/java/com/dtstack/flink/sql/side/hbase/HbaseAllReqRow.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ private void loadData(Map<String, Map<String, Object>> tmpCache) throws SQLExcep
170170
StringBuilder key = new StringBuilder();
171171
key.append(family).append(":").append(qualifier);
172172

173-
kv.put(aliasNameInversion.get(key.toString().toUpperCase()), value);
173+
kv.put(aliasNameInversion.get(key.toString()), value);
174174
}
175175
tmpCache.put(new String(r.getRow()), kv);
176176
}

hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/PreRowKeyModeDealerDealer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,9 @@ private String dealOneRow(ArrayList<ArrayList<KeyValue>> args, String rowKeyStr,
9898
String mapKey = cf + ":" + col;
9999

100100
//The table format defined using different data type conversion byte
101-
String colType = colRefType.get(mapKey.toUpperCase());
101+
String colType = colRefType.get(mapKey);
102102
Object val = HbaseUtils.convertByte(keyValue.value(), colType);
103-
sideMap.put(mapKey.toUpperCase(), val);
103+
sideMap.put(mapKey, val);
104104
}
105105

106106
if (oneRow.size() > 0) {

hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/RowKeyEqualModeDealer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,9 +73,9 @@ public void asyncGetData(String tableName, String rowKeyStr, Row input, ResultFu
7373
String col = new String(keyValue.qualifier());
7474
String mapKey = cf + ":" + col;
7575
//The table format defined using different data type conversion byte
76-
String colType = colRefType.get(mapKey.toUpperCase());
76+
String colType = colRefType.get(mapKey);
7777
Object val = HbaseUtils.convertByte(keyValue.value(), colType);
78-
sideMap.put(mapKey.toUpperCase(), val);
78+
sideMap.put(mapKey, val);
7979
}
8080

8181
if(arg.size() > 0){

0 commit comments

Comments
 (0)