[opt] use map interface replace LinkedHashMap

Author: FlechazoW

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java

@@ -66,7 +66,7 @@ public class HbaseOutputFormat extends AbstractDtRichOutputFormat<Tuple2> {
     private String[] columnNames;
     private String updateMode;
     private String[] columnTypes;
-    private LinkedHashMap<String, String> columnNameFamily;
+    private Map<String, String> columnNameFamily;
 
     private boolean kerberosAuthEnable;
     private String regionserverKeytabFile;
@@ -306,7 +306,7 @@ public HbaseOutputFormatBuilder setColumnTypes(String[] columnTypes) {
             return this;
         }
 
-        public HbaseOutputFormatBuilder setColumnNameFamily(LinkedHashMap<String, String> columnNameFamily) {
+        public HbaseOutputFormatBuilder setColumnNameFamily(Map<String, String> columnNameFamily) {
             format.columnNameFamily = columnNameFamily;
             return this;
         }

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseSink.java

@@ -35,7 +35,7 @@
 import org.apache.flink.table.sinks.TableSink;
 import org.apache.flink.types.Row;
 
-import java.util.LinkedHashMap;
+import java.util.Map;
 
 /**
  * Date: 2018/09/14
@@ -45,7 +45,7 @@
 public class HbaseSink implements RetractStreamTableSink<Row>, IStreamSinkGener<HbaseSink> {
 
     protected String[] fieldNames;
-    protected LinkedHashMap<String, String> columnNameFamily;
+    protected Map<String, String> columnNameFamily;
     TypeInformation<?>[] fieldTypes;
     protected String zookeeperQuorum;
     protected String port;

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseSinkParser.java

@@ -127,8 +127,8 @@ public void parseFieldsInfo(String fieldsInfo, HbaseTableInfo tableInfo){
         tableInfo.finish();
     }
 
-    private LinkedHashMap<String, String> parseColumnFamily(Map<String, String> physicalFieldMap){
-        LinkedHashMap<String, String> columnFamiles = Maps.newLinkedHashMap();
+    private Map<String, String> parseColumnFamily(Map<String, String> physicalFieldMap){
+        Map<String, String> columnFamiles = Maps.newLinkedHashMap();
         physicalFieldMap.values().forEach(x -> {
             String[] columnFamily = StringUtils.split(x.trim(), ":");
             columnFamiles.put(x, columnFamily[1]);

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseTableInfo.java

@@ -45,7 +45,7 @@ public class HbaseTableInfo extends AbstractTargetTableInfo {
 
     private String rowkey;
 
-    private LinkedHashMap<String, String> columnNameFamily;
+    private Map<String, String> columnNameFamily;
 
     private String[] columnNames;
 
@@ -117,11 +117,11 @@ public void setRowkey(String rowkey) {
         this.rowkey = rowkey;
     }
 
-    public LinkedHashMap<String, String> getColumnNameFamily() {
+    public Map<String, String> getColumnNameFamily() {
         return columnNameFamily;
     }
 
-    public void setColumnNameFamily(LinkedHashMap<String, String> columnNameFamily) {
+    public void setColumnNameFamily(Map<String, String> columnNameFamily) {
         this.columnNameFamily = columnNameFamily;
     }