[opt] remove partition mode parameter

Author: FlechazoW

impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java

@@ -102,7 +102,6 @@ public class ImpalaOutputFormat extends AbstractDtRichOutputFormat<Tuple2<Boolea
     protected Boolean enablePartition;
     protected String schema;
     protected String storeType;
-    protected String partitionMode;
     protected String updateMode;
     public List<String> fieldList;
     public List<String> fieldTypeList;
@@ -518,11 +517,6 @@ public Builder setStoreType(String storeType) {
             return this;
         }
 
-        public Builder setPartitionMode(String partitionMode) {
-            format.partitionMode = partitionMode;
-            return this;
-        }
-
         public Builder setFieldExtraInfoList(List<AbstractTableInfo.FieldExtraInfo> fieldExtraInfoList) {
             format.fieldExtraInfoList = fieldExtraInfoList;
             return this;

impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaSink.java

@@ -64,7 +64,6 @@ public class ImpalaSink implements RetractStreamTableSink<Row>, IStreamSinkGener
     protected String tableName;
     protected String registerTabName;
     protected String storeType;
-    protected String partitionMode;
 
     protected List<String> primaryKeys;
     private int parallelism = 1;
@@ -113,8 +112,6 @@ public ImpalaSink genStreamSink(AbstractTargetTableInfo targetTableInfo) {
 
         this.storeType = Objects.isNull(impalaTableInfo.getStoreType()) ?
                 DEFAULT_STORE_TYPE : impalaTableInfo.getStoreType();
-        this.partitionMode = Objects.isNull(impalaTableInfo.getPartitionMode()) ?
-                DEFAULT_PARTITION_MODE : impalaTableInfo.getPartitionMode();
         this.enablePartition = impalaTableInfo.isEnablePartition();
 
         return this;
@@ -181,7 +178,6 @@ private ImpalaOutputFormat buildImpalaOutputFormat() {
                 .setFieldTypeList(fieldTypeList)
                 .setFieldExtraInfoList(fieldExtraInfoList)
                 .setStoreType(storeType)
-                .setPartitionMode(partitionMode)
                 .setEnablePartition(enablePartition)
                 .setUpdateMode(updateMode)
                 .setAuthMech(authMech)

impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/table/ImpalaSinkParser.java

@@ -74,8 +74,6 @@ public class ImpalaSinkParser extends AbstractTableParser {
 
     private static final String UPDATE_KEY = "updateMode";
 
-    private static final String PARTITION_MODE_KEY = "partitionMode";
-
     private static final String KUDU_TYPE = "kudu";
 
     private static final String STORE_TYPE_KEY = "storeType";
@@ -134,8 +132,6 @@ public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<S
         if (!storeType.equalsIgnoreCase(KUDU_TYPE) && enablePartition) {
             String partitionFields = MathUtil.getString(props.get(PARTITION_FIELDS_KEY.toLowerCase()));
             impalaTableInfo.setPartitionFields(partitionFields);
-            String partitionMode = MathUtil.getString(props.get(PARTITION_MODE_KEY.toLowerCase()));
-            impalaTableInfo.setPartitionMode(partitionMode);
         }
 
         impalaTableInfo.setType(CURRENT_TYPE);

impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/table/ImpalaTableInfo.java

@@ -77,8 +77,6 @@ public class ImpalaTableInfo extends AbstractTargetTableInfo {
 
     private String storeType;
 
-    private String partitionMode;
-
     public String getUrl() {
         return url;
     }
@@ -151,14 +149,6 @@ public void setSchema(String schema) {
         this.schema = schema;
     }
 
-    public boolean isAllReplace() {
-        return allReplace;
-    }
-
-    public void setAllReplace(boolean allReplace) {
-        this.allReplace = allReplace;
-    }
-
     public String getUpdateMode() {
         return updateMode;
     }
@@ -247,14 +237,6 @@ public void setStoreType(String storeType) {
         this.storeType = storeType;
     }
 
-    public String getPartitionMode() {
-        return partitionMode;
-    }
-
-    public void setPartitionMode(String partitionMode) {
-        this.partitionMode = partitionMode;
-    }
-
     @Override
     public String getType() {
         return super.getType().toLowerCase();