[hotfix-#906][typo]Correct spelling mistakes BigIntegerAccmulator -> BigIntegerAccumulator

Author: Paddy0523

chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java

@@ -25,7 +25,7 @@
 import com.dtstack.chunjun.constants.ConstantValue;
 import com.dtstack.chunjun.constants.Metrics;
 import com.dtstack.chunjun.enums.ColumnType;
-import com.dtstack.chunjun.metrics.BigIntegerAccmulator;
+import com.dtstack.chunjun.metrics.BigIntegerAccumulator;
 import com.dtstack.chunjun.metrics.StringAccumulator;
 import com.dtstack.chunjun.restore.FormatState;
 import com.dtstack.chunjun.source.format.BaseRichInputFormat;
@@ -89,8 +89,8 @@ public class JdbcInputFormat extends BaseRichInputFormat {
     protected Object state = null;
 
     protected StringAccumulator maxValueAccumulator;
-    protected BigIntegerAccmulator endLocationAccumulator;
-    protected BigIntegerAccmulator startLocationAccumulator;
+    protected BigIntegerAccumulator endLocationAccumulator;
+    protected BigIntegerAccumulator startLocationAccumulator;
 
     // 轮询增量标识字段类型
     protected ColumnType type;
@@ -305,8 +305,8 @@ protected void initMetric(InputSplit inputSplit) {
         }
         // 初始化增量、轮询字段类型
         type = ColumnType.fromString(jdbcConf.getIncreColumnType());
-        startLocationAccumulator = new BigIntegerAccmulator();
-        endLocationAccumulator = new BigIntegerAccmulator();
+        startLocationAccumulator = new BigIntegerAccumulator();
+        endLocationAccumulator = new BigIntegerAccumulator();
         JdbcInputSplit jdbcInputSplit = (JdbcInputSplit) inputSplit;
         String startLocation =
                 StringUtil.stringToTimestampStr(jdbcInputSplit.getStartLocation(), type);

chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/api/DatabaseBaseRichInputFormat.java

@@ -5,7 +5,7 @@
 import com.dtstack.chunjun.connector.jdbc.util.JdbcUtil;
 import com.dtstack.chunjun.constants.Metrics;
 import com.dtstack.chunjun.enums.ColumnType;
-import com.dtstack.chunjun.metrics.BigIntegerAccmulator;
+import com.dtstack.chunjun.metrics.BigIntegerAccumulator;
 import com.dtstack.chunjun.metrics.StringAccumulator;
 import com.dtstack.chunjun.source.format.BaseRichInputFormat;
 import com.dtstack.chunjun.throwable.ReadRecordException;
@@ -40,8 +40,8 @@ public class DatabaseBaseRichInputFormat<T, OUT extends RowData> extends BaseRic
     /** 用户脚本中填写的字段类型集合 */
     protected StringAccumulator maxValueAccumulator;
 
-    protected BigIntegerAccmulator endLocationAccumulator;
-    protected BigIntegerAccmulator startLocationAccumulator;
+    protected BigIntegerAccumulator endLocationAccumulator;
+    protected BigIntegerAccumulator startLocationAccumulator;
     // 轮询增量标识字段类型
     protected ColumnType type;
     private ServiceProcessor<T, OUT> processor;
@@ -104,8 +104,8 @@ protected void initMetric(InputSplit inputSplit) {
         }
         // 初始化增量、轮询字段类型
         type = ColumnType.fromString(jdbcConf.getIncreColumnType());
-        startLocationAccumulator = new BigIntegerAccmulator();
-        endLocationAccumulator = new BigIntegerAccmulator();
+        startLocationAccumulator = new BigIntegerAccumulator();
+        endLocationAccumulator = new BigIntegerAccumulator();
         String startLocation = StringUtil.stringToTimestampStr(jdbcConf.getStartLocation(), type);
 
         if (StringUtils.isNotEmpty(jdbcConf.getStartLocation())) {

…hunjun/metrics/BigIntegerAccmulator.java …unjun/metrics/BigIntegerAccumulator.javachunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccmulator.java renamed to chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccumulator.java chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccmulator.java renamed to chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccumulator.java

@@ -27,13 +27,13 @@
  *
  * @author tudou
  */
-public class BigIntegerAccmulator implements SimpleAccumulator<BigInteger> {
+public class BigIntegerAccumulator implements SimpleAccumulator<BigInteger> {
 
     private static final long serialVersionUID = 1L;
 
     private BigInteger max = BigInteger.valueOf(Integer.MIN_VALUE);
 
-    public BigIntegerAccmulator() {}
+    public BigIntegerAccumulator() {}
 
     @Override
     public void add(BigInteger value) {
@@ -60,8 +60,8 @@ public void resetLocal() {
     }
 
     @Override
-    public BigIntegerAccmulator clone() {
-        BigIntegerAccmulator clone = new BigIntegerAccmulator();
+    public BigIntegerAccumulator clone() {
+        BigIntegerAccumulator clone = new BigIntegerAccumulator();
         clone.max = this.max;
         return clone;
     }