[update][plugin] Remove unused logger instance

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

Hide file tree

Showing 9 changed files with 1 addition and 30 deletions.
diff --git a/lib/addax-rdbms/src/main/java/com/wgzhao/addax/rdbms/writer/CommonRdbmsWriter.java b/lib/addax-rdbms/src/main/java/com/wgzhao/addax/rdbms/writer/CommonRdbmsWriter.java
@@ -561,7 +561,7 @@ protected PreparedStatement fillPreparedStatementColumnType(PreparedStatement pr
                     break;
 
                 default:
-                    Map map = this.resultSetMetaData.get(columnIndex);
+                    Map<String, Object> map = this.resultSetMetaData.get(columnIndex);
                     throw AddaxException.asAddaxException(
                             DBUtilErrorCode.UNSUPPORTED_TYPE,
                             String.format(

diff --git a/.../accessreader/src/main/java/com/wgzhao/addax/plugin/reader/accessreader/AccessReader.java b/.../accessreader/src/main/java/com/wgzhao/addax/plugin/reader/accessreader/AccessReader.java
@@ -7,8 +7,6 @@
 import com.wgzhao.addax.common.util.Configuration;
 import com.wgzhao.addax.rdbms.reader.CommonRdbmsReader;
 import com.wgzhao.addax.rdbms.util.DataBaseType;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
@@ -17,8 +15,6 @@ public class AccessReader extends Reader {
 
     public static class Job extends Reader.Job {
 
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration configuration = null;
 
         private CommonRdbmsReader.Job commonRdbmsReaderJob;

diff --git a/...endreader/src/main/java/com/wgzhao/addax/plugin/reader/databendreader/DatabendReader.java b/...endreader/src/main/java/com/wgzhao/addax/plugin/reader/databendreader/DatabendReader.java
@@ -26,8 +26,6 @@
 import com.wgzhao.addax.common.util.Configuration;
 import com.wgzhao.addax.rdbms.reader.CommonRdbmsReader;
 import com.wgzhao.addax.rdbms.util.DataBaseType;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.List;
 
@@ -40,8 +38,6 @@ public class DatabendReader
     public static class Job
             extends Reader.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration originalConfig = null;
         private CommonRdbmsReader.Job commonRdbmsReaderJob;
 

diff --git a/...reader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/DataReader.java b/...reader/datareader/src/main/java/com/wgzhao/addax/plugin/reader/datareader/DataReader.java
@@ -48,8 +48,6 @@
 import org.apache.commons.lang3.time.DateUtils;
 import org.apache.commons.rng.UniformRandomProvider;
 import org.apache.commons.rng.simple.RandomSource;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.math.BigDecimal;
 import java.text.ParseException;
@@ -95,8 +93,6 @@ private static boolean isTypeIllegal(String typeString)
     public static class Job
             extends Reader.Job
     {
-
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
         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");

diff --git a/...2reader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDB2Reader.java b/...2reader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDB2Reader.java
@@ -54,8 +54,6 @@ public class InfluxDB2Reader
     public static class Job
             extends Reader.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration originalConfig = null;
         private String endpoint;
         private List<String> tables;

diff --git a/...dbreader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDBReader.java b/...dbreader/src/main/java/com/wgzhao/addax/plugin/reader/influxdb2reader/InfluxDBReader.java
@@ -24,8 +24,6 @@
 import com.wgzhao.addax.common.spi.Reader;
 import com.wgzhao.addax.common.util.Configuration;
 import org.apache.commons.lang3.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -37,8 +35,6 @@ public class InfluxDBReader
     public static class Job
             extends Reader.Job
     {
-        private static final Logger LOG = LoggerFactory
-                .getLogger(Job.class);
 
         private Configuration originalConfig = null;
 

diff --git a/...endwriter/src/main/java/com/wgzhao/addax/plugin/writer/databendwriter/DatabendWriter.java b/...endwriter/src/main/java/com/wgzhao/addax/plugin/writer/databendwriter/DatabendWriter.java
@@ -7,8 +7,6 @@
 import com.wgzhao.addax.plugin.writer.databendwriter.util.DatabendWriterUtil;
 import com.wgzhao.addax.rdbms.util.DataBaseType;
 import com.wgzhao.addax.rdbms.writer.CommonRdbmsWriter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
@@ -20,7 +18,6 @@ public class DatabendWriter extends Writer {
 
     public static class Job
             extends Writer.Job {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
         private Configuration originalConfig;
         private CommonRdbmsWriter.Job commonRdbmsWriterMaster;
 
@@ -62,7 +59,6 @@ public void destroy() {
 
 
     public static class Task extends Writer.Task {
-        private static final Logger LOG = LoggerFactory.getLogger(Task.class);
 
         private Configuration writerSliceConfig;
 

diff --git a/...xdbwriter/src/main/java/com/wgzhao/addax/plugin/writer/influxdbwriter/InfluxDBWriter.java b/...xdbwriter/src/main/java/com/wgzhao/addax/plugin/writer/influxdbwriter/InfluxDBWriter.java
@@ -26,8 +26,6 @@
 import org.influxdb.InfluxDB;
 import org.influxdb.InfluxDBFactory;
 import org.influxdb.dto.Query;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -39,8 +37,6 @@ public class InfluxDBWriter
     public static class Job
             extends Writer.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
-
         private Configuration originalConfig = null;
 
         private String endpoint;

diff --git a/...ter/kafkawriter/src/main/java/com/wgzhao/addax/plugin/writer/kafkawriter/KafkaWriter.java b/...ter/kafkawriter/src/main/java/com/wgzhao/addax/plugin/writer/kafkawriter/KafkaWriter.java
@@ -25,8 +25,6 @@
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.serialization.StringSerializer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.util.Collections;
 import java.util.HashMap;
@@ -48,7 +46,6 @@ public class KafkaWriter
     public static class Job
             extends Writer.Job
     {
-        private static final Logger LOG = LoggerFactory.getLogger(Job.class);
         private Configuration config = null;
 
         @Override