Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[hotfix-#906][typo]Correct spelling mistakes #907

Merged
merged 1 commit into from
Jun 2, 2022
Merged

[hotfix-#906][typo]Correct spelling mistakes #907

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions ...or-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcInputFormat.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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);
Expand Down
10 changes: 5 additions & 5 deletions ...or-pgwal/src/main/java/com/dtstack/chunjun/connector/api/DatabaseBaseRichInputFormat.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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())) {
Expand Down
8 changes: 4 additions & 4 deletions ...chunjun/metrics/BigIntegerAccmulator.java → ...hunjun/metrics/BigIntegerAccumulator.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand All @@ -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;
}
Expand Down