[hotfix-33089][hbase][async-side]add rowkey value to sideVal.

Author: HiLany

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

@@ -55,6 +55,8 @@ public abstract class AbstractRowKeyModeDealer {
 
     protected List<FieldInfo> outFieldInfoList;
 
+    protected static final String ROWKEY = "rowkey";
+
     //key:Returns the value of the position, returns the index values ​​in the input data
     protected Map<Integer, Integer> inFieldIndex = Maps.newHashMap();
 

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

@@ -110,6 +110,12 @@ private String dealOneRow(ArrayList<ArrayList<KeyValue>> args, String rowKeyStr,
                         //The order of the fields defined in the data conversion table
                         List<Object> sideVal = Lists.newArrayList();
                         for (String key : colNames) {
+
+                            if (ROWKEY.equalsIgnoreCase(key)) {
+                                sideVal.add(rowKeyStr);
+                                continue;
+                            }
+
                             Object val = sideMap.get(key);
                             if (val == null) {
                                 LOG.error("can't get data with column {}", key);

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

@@ -84,6 +84,12 @@ public void asyncGetData(String tableName, String rowKeyStr, BaseRow input, Resu
                         //The order of the fields defined in the data conversion table
                         List<Object> sideVal = Lists.newArrayList();
                         for(String key : colNames){
+
+                            if (ROWKEY.equalsIgnoreCase(key)) {
+                                sideVal.add(rowKeyStr);
+                                continue;
+                            }
+
                             Object val = sideMap.get(key);
                             if(val == null){
                                 LOG.error("can't get data with column {}", key);