去除无用的引用

Author: dapeng

kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/CustomerFlinkPartition.java

@@ -3,8 +3,6 @@
 
 import org.apache.flink.streaming.connectors.kafka.partitioner.FlinkFixedPartitioner;
 
-import java.util.Arrays;
-import java.util.Random;
 import org.apache.flink.util.Preconditions;
 
 public class CustomerFlinkPartition<T> extends FlinkFixedPartitioner<T> {

kafka/kafka-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaSink.java

@@ -137,12 +137,6 @@ public TableSink<Tuple2<Boolean, Row>> configure(String[] fieldNames, TypeInform
         this.fieldTypes = fieldTypes;
         return this;
     }
-    private FlinkKafkaPartitioner getFlinkPartitioner(KafkaSinkTableInfo kafkaSinkTableInfo){
-        if("true".equalsIgnoreCase(kafkaSinkTableInfo.getEnableKeyPartition())){
-            return new CustomerFlinkPartition<>();
-        }
-        return new FlinkFixedPartitioner<>();
-    }
 
     private String[] getPartitionKeys(KafkaSinkTableInfo kafkaSinkTableInfo){
         if(StringUtils.isNotBlank(kafkaSinkTableInfo.getPartitionKeys())){

kafka09/kafka09-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaSink.java

@@ -144,13 +144,6 @@ public TableSink<Tuple2<Boolean, Row>> configure(String[] fieldNames, TypeInform
 		return this;
 	}
 
-	private FlinkKafkaPartitioner getFlinkPartitioner(KafkaSinkTableInfo kafkaSinkTableInfo){
-		if("true".equalsIgnoreCase(kafkaSinkTableInfo.getEnableKeyPartition())){
-			return new CustomerFlinkPartition<>();
-		}
-		return new FlinkFixedPartitioner<>();
-	}
-
 	private String[] getPartitionKeys(KafkaSinkTableInfo kafkaSinkTableInfo){
 		if(StringUtils.isNotBlank(kafkaSinkTableInfo.getPartitionKeys())){
 			return StringUtils.split(kafkaSinkTableInfo.getPartitionKeys(), ',');

kafka11/kafka11-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaSink.java

@@ -144,13 +144,6 @@ public TypeInformation<?>[] getFieldTypes() {
         return this;
     }
 
-    private FlinkKafkaPartitioner getFlinkPartitioner(KafkaSinkTableInfo kafkaSinkTableInfo){
-        if("true".equalsIgnoreCase(kafkaSinkTableInfo.getEnableKeyPartition())){
-            return new CustomerFlinkPartition<>();
-        }
-        return new FlinkFixedPartitioner<>();
-    }
-
     private String[] getPartitionKeys(KafkaSinkTableInfo kafkaSinkTableInfo){
         if(StringUtils.isNotBlank(kafkaSinkTableInfo.getPartitionKeys())){
             return StringUtils.split(kafkaSinkTableInfo.getPartitionKeys(), ',');