[update][plugins] Remove unused import or variables

wgzhao · Dec 6, 2023 · d72fa75 · d72fa75
1 parent 23fd22d
commit d72fa75
Show file tree

Hide file tree

Showing 10 changed files with 0 additions and 22 deletions.
diff --git a/.../datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/util/AddressUtil.java b/.../datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/util/AddressUtil.java
@@ -21,7 +21,6 @@
 
 package com.wgzhao.addax.plugin.reader.datareader.util;
 
-import org.apache.commons.rng.UniformRandomProvider;
 import org.apache.commons.rng.simple.RandomSource;
 
 /**

diff --git a/...ader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/util/GeoUtil.java b/...ader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/util/GeoUtil.java
@@ -21,7 +21,6 @@
 
 package com.wgzhao.addax.plugin.reader.datareader.util;
 
-import org.apache.commons.rng.UniformRandomProvider;
 import org.apache.commons.rng.simple.RandomSource;
 
 import java.math.BigDecimal;

diff --git a/...src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/DefaultMemberAccess.java b/...src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/DefaultMemberAccess.java
@@ -25,7 +25,6 @@
 import java.lang.reflect.AccessibleObject;
 import java.lang.reflect.Member;
 import java.lang.reflect.Modifier;
-import java.util.Map;
 
 /**
  * This class provides methods for setting up and restoring

diff --git a/...archreader/src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/EsReader.java b/...archreader/src/main/java/com/wgzhao/addax/plugin/reader/elasticsearchreader/EsReader.java
@@ -35,7 +35,6 @@
 import com.wgzhao.addax.common.plugin.RecordSender;
 import com.wgzhao.addax.common.spi.Reader;
 import com.wgzhao.addax.common.statistics.PerfRecord;
-import com.wgzhao.addax.common.statistics.PerfTrace;
 import com.wgzhao.addax.common.util.Configuration;
 import com.wgzhao.addax.plugin.reader.elasticsearchreader.gson.MapTypeAdapter;
 import io.searchbox.client.JestResult;

diff --git a/...der/excelreader/src/main/java/com/wgzhao/addax/plugin/reader/excelreader/ExcelReader.java b/...der/excelreader/src/main/java/com/wgzhao/addax/plugin/reader/excelreader/ExcelReader.java
@@ -33,10 +33,7 @@
 import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
-import java.util.regex.Pattern;
 
 public class ExcelReader
         extends Reader
@@ -50,8 +47,6 @@ public static class Job
         private Configuration originConfig = null;
         private List<String> path = null;
         private List<String> sourceFiles;
-        private final Map<String, Pattern> pattern = new HashMap<>();
-        private final Map<String, Boolean> isRegexPath = new HashMap<>();
 
         @Override
         public void init()

diff --git a/.../streamreader/src/main/java/com/wgzhao/addax/plugin/reader/streamreader/StreamReader.java b/.../streamreader/src/main/java/com/wgzhao/addax/plugin/reader/streamreader/StreamReader.java
@@ -51,7 +51,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
-import java.util.regex.Pattern;
 
 public class StreamReader
         extends Reader
@@ -80,17 +79,13 @@ public static class Job
     {
 
         private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-        private Pattern mixupFunctionPattern;
         private Configuration originalConfig;
         private static final List<String> validUnits = Arrays.asList("d", "day", "M", "month", "y", "year", "h", "hour", "m", "minute", "s", "second", "w", "week");
 
         @Override
         public void init()
         {
             this.originalConfig = getPluginJobConf();
-            // warn: 忽略大小写
-            this.mixupFunctionPattern = Pattern.compile(StreamConstant.MIXUP_FUNCTION_PATTERN,
-                    Pattern.CASE_INSENSITIVE);
             dealColumn(this.originalConfig);
 
             Long sliceRecordCount = this.originalConfig

diff --git a/...er/kuduwriter/src/main/java/com/wgzhao/addax/plugin/writer/kuduwriter/KuduWriterTask.java b/...er/kuduwriter/src/main/java/com/wgzhao/addax/plugin/writer/kuduwriter/KuduWriterTask.java
@@ -29,7 +29,6 @@
 import org.apache.kudu.Schema;
 import org.apache.kudu.Type;
 import org.apache.kudu.client.Insert;
-import org.apache.kudu.client.KuduClient;
 import org.apache.kudu.client.KuduSession;
 import org.apache.kudu.client.KuduTable;
 import org.apache.kudu.client.PartialRow;

diff --git a/...godbwriter/src/main/java/com/wgzhao/addax/plugin/writer/mongodbwriter/util/MongoUtil.java b/...godbwriter/src/main/java/com/wgzhao/addax/plugin/writer/mongodbwriter/util/MongoUtil.java
@@ -20,16 +20,13 @@
 package com.wgzhao.addax.plugin.writer.mongodbwriter.util;
 
 import com.wgzhao.addax.common.exception.AddaxException;
-import com.wgzhao.addax.common.util.Configuration;
-import com.wgzhao.addax.plugin.writer.mongodbwriter.KeyConstant;
 import com.wgzhao.addax.plugin.writer.mongodbwriter.MongoDBWriterErrorCode;
 import com.mongodb.MongoClient;
 import com.mongodb.MongoCredential;
 import com.mongodb.ServerAddress;
 
 import java.net.UnknownHostException;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 

diff --git a/.../sqlitewriter/src/main/java/com/wgzhao/addax/plugin/writer/sqlitewriter/SqliteWriter.java b/.../sqlitewriter/src/main/java/com/wgzhao/addax/plugin/writer/sqlitewriter/SqliteWriter.java
@@ -19,7 +19,6 @@
 
 package com.wgzhao.addax.plugin.writer.sqlitewriter;
 
-import com.wgzhao.addax.common.base.Key;
 import com.wgzhao.addax.common.element.Column;
 import com.wgzhao.addax.common.plugin.RecordReceiver;
 import com.wgzhao.addax.common.spi.Writer;

diff --git a/.../streamwriter/src/main/java/com/wgzhao/addax/plugin/writer/streamwriter/StreamWriter.java b/.../streamwriter/src/main/java/com/wgzhao/addax/plugin/writer/streamwriter/StreamWriter.java
@@ -37,9 +37,6 @@
 import java.io.IOException;
 import java.io.OutputStreamWriter;
 import java.nio.charset.StandardCharsets;
-import java.time.Instant;
-import java.time.ZoneId;
-import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.List;
-Original file line number
+Diff line change
@@ Expand Up / @@ -21,7 +21,6 @@ @@
     package com.wgzhao.addax.plugin.reader.datareader.util;
-    import org.apache.commons.rng.UniformRandomProvider;
     import org.apache.commons.rng.simple.RandomSource;
     /**
@@ Expand Down @@