From ead64f1a7e61ab2734180da82e5e240bbda1516c Mon Sep 17 00:00:00 2001 From: liuliu Date: Wed, 1 Jun 2022 15:19:38 +0800 Subject: [PATCH] [hotfix-#906][typo]Correct spelling mistakes BigIntegerAccmulator -> BigIntegerAccumulator --- .../chunjun/connector/jdbc/source/JdbcInputFormat.java | 10 +++++----- .../connector/api/DatabaseBaseRichInputFormat.java | 10 +++++----- ...tegerAccmulator.java => BigIntegerAccumulator.java} | 8 ++++---- 3 files changed, 14 insertions(+), 14 deletions(-) rename chunjun-core/src/main/java/com/dtstack/chunjun/metrics/{BigIntegerAccmulator.java => BigIntegerAccumulator.java} (89%) diff --git a/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java b/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java index 671badb697..1543980903 100644 --- a/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java +++ b/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); diff --git a/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/api/DatabaseBaseRichInputFormat.java b/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/api/DatabaseBaseRichInputFormat.java index cd6c9eec0e..6031f6acf9 100644 --- a/chunjun-connectors/chunjun-connector-pgwal/src/main/java/com/dtstack/chunjun/connector/api/DatabaseBaseRichInputFormat.java +++ b/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 extends BaseRic /** 用户脚本中填写的字段类型集合 */ protected StringAccumulator maxValueAccumulator; - protected BigIntegerAccmulator endLocationAccumulator; - protected BigIntegerAccmulator startLocationAccumulator; + protected BigIntegerAccumulator endLocationAccumulator; + protected BigIntegerAccumulator startLocationAccumulator; // 轮询增量标识字段类型 protected ColumnType type; private ServiceProcessor 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())) { diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccmulator.java b/chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccumulator.java similarity index 89% rename from chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccmulator.java rename to chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccumulator.java index 187d9d7d6a..ee163e23d1 100644 --- a/chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccmulator.java +++ b/chunjun-core/src/main/java/com/dtstack/chunjun/metrics/BigIntegerAccumulator.java @@ -27,13 +27,13 @@ * * @author tudou */ -public class BigIntegerAccmulator implements SimpleAccumulator { +public class BigIntegerAccumulator implements SimpleAccumulator { 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; }