You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by tu...@apache.org on 2022/04/18 13:58:33 UTC
[shardingsphere] branch master updated: Rename DataCalculateParameter to DataConsistencyCalculateParameter (#16906)
This is an automated email from the ASF dual-hosted git repository.
tuichenchuxin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 15ad053058f Rename DataCalculateParameter to DataConsistencyCalculateParameter (#16906)
15ad053058f is described below
commit 15ad053058fdd3af2f7e09539012ab41a9c71205
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Mon Apr 18 21:58:25 2022 +0800
Rename DataCalculateParameter to DataConsistencyCalculateParameter (#16906)
---
.../consistency/DataConsistencyCheckerImpl.java | 16 ++++++++--------
...StreamingDataConsistencyCalculateAlgorithm.java | 20 ++++++++++----------
...RC32MatchDataConsistencyCalculateAlgorithm.java | 18 +++++++++---------
...DataMatchDataConsistencyCalculateAlgorithm.java | 14 +++++++-------
...MatchDataConsistencyCalculateAlgorithmTest.java | 22 +++++++++++-----------
...java => DataConsistencyCalculateParameter.java} | 4 ++--
.../DataConsistencyCalculateAlgorithm.java | 6 +++---
.../FixtureDataConsistencyCalculateAlgorithm.java | 4 ++--
8 files changed, 52 insertions(+), 52 deletions(-)
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/DataConsistencyCheckerImpl.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/DataConsistencyCheckerImpl.java
index 694cbd8c794..9882fb742e9 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/DataConsistencyCheckerImpl.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/check/consistency/DataConsistencyCheckerImpl.java
@@ -20,7 +20,7 @@ package org.apache.shardingsphere.data.pipeline.core.check.consistency;
import com.google.common.base.Preconditions;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCheckResult;
import org.apache.shardingsphere.data.pipeline.api.config.rulealtered.JobConfiguration;
import org.apache.shardingsphere.data.pipeline.api.datasource.PipelineDataSourceWrapper;
@@ -168,10 +168,10 @@ public final class DataConsistencyCheckerImpl implements DataConsistencyChecker
TableMetaData tableMetaData = tableMetaDataMap.get(each);
Collection<String> columnNames = tableMetaData.getColumns().keySet();
String uniqueKey = tableMetaData.getPrimaryKeyColumns().get(0);
- DataCalculateParameter sourceCalculateParameter = buildDataCalculateParameter(sourceDataSource, sourceDatabaseType, targetDatabaseType, each, columnNames, uniqueKey);
- DataCalculateParameter targetCalculateParameter = buildDataCalculateParameter(targetDataSource, targetDatabaseType, sourceDatabaseType, each, columnNames, uniqueKey);
- Iterator<Object> sourceCalculatedResults = dataConsistencyCalculator.calculate(sourceCalculateParameter).iterator();
- Iterator<Object> targetCalculatedResults = dataConsistencyCalculator.calculate(targetCalculateParameter).iterator();
+ DataConsistencyCalculateParameter sourceParameter = buildParameter(sourceDataSource, sourceDatabaseType, targetDatabaseType, each, columnNames, uniqueKey);
+ DataConsistencyCalculateParameter targetParameter = buildParameter(targetDataSource, targetDatabaseType, sourceDatabaseType, each, columnNames, uniqueKey);
+ Iterator<Object> sourceCalculatedResults = dataConsistencyCalculator.calculate(sourceParameter).iterator();
+ Iterator<Object> targetCalculatedResults = dataConsistencyCalculator.calculate(targetParameter).iterator();
boolean calculateResultsEquals = true;
while (sourceCalculatedResults.hasNext() && targetCalculatedResults.hasNext()) {
if (null != inputRateLimitAlgorithm) {
@@ -222,9 +222,9 @@ public final class DataConsistencyCheckerImpl implements DataConsistencyChecker
}
}
- private DataCalculateParameter buildDataCalculateParameter(final PipelineDataSourceWrapper sourceDataSource, final String sourceDatabaseType, final String targetDatabaseType,
- final String tableName, final Collection<String> columnNames, final String uniqueKey) {
- return DataCalculateParameter.builder().dataSource(sourceDataSource).databaseType(sourceDatabaseType)
+ private DataConsistencyCalculateParameter buildParameter(final PipelineDataSourceWrapper sourceDataSource, final String sourceDatabaseType,
+ final String targetDatabaseType, final String tableName, final Collection<String> columnNames, final String uniqueKey) {
+ return DataConsistencyCalculateParameter.builder().dataSource(sourceDataSource).databaseType(sourceDatabaseType)
.peerDatabaseType(targetDatabaseType).logicTableName(tableName).columnNames(columnNames).uniqueKey(uniqueKey).build();
}
}
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/AbstractStreamingDataConsistencyCalculateAlgorithm.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/AbstractStreamingDataConsistencyCalculateAlgorithm.java
index 4253bb378f6..9c0987533d2 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/AbstractStreamingDataConsistencyCalculateAlgorithm.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/AbstractStreamingDataConsistencyCalculateAlgorithm.java
@@ -20,7 +20,7 @@ package org.apache.shardingsphere.data.pipeline.core.spi.check.consistency;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCalculateAlgorithm;
import java.util.Iterator;
@@ -36,17 +36,17 @@ import java.util.concurrent.atomic.AtomicInteger;
public abstract class AbstractStreamingDataConsistencyCalculateAlgorithm implements DataConsistencyCalculateAlgorithm {
@Override
- public final Iterable<Object> calculate(final DataCalculateParameter dataCalculateParameter) {
- return new ResultIterable(dataCalculateParameter);
+ public final Iterable<Object> calculate(final DataConsistencyCalculateParameter parameter) {
+ return new ResultIterable(parameter);
}
/**
* Calculate chunked records at one time.
*
- * @param dataCalculateParameter data calculate parameter
+ * @param parameter data consistency calculate parameter
* @return optional calculated result, empty means there's no more result
*/
- protected abstract Optional<Object> calculateChunk(DataCalculateParameter dataCalculateParameter);
+ protected abstract Optional<Object> calculateChunk(DataConsistencyCalculateParameter parameter);
/**
* It's not thread-safe, it should be executed in only one thread at the same time.
@@ -54,18 +54,18 @@ public abstract class AbstractStreamingDataConsistencyCalculateAlgorithm impleme
@RequiredArgsConstructor
final class ResultIterable implements Iterable<Object> {
- private final DataCalculateParameter dataCalculateParameter;
+ private final DataConsistencyCalculateParameter parameter;
@Override
public Iterator<Object> iterator() {
- return new ResultIterator(dataCalculateParameter);
+ return new ResultIterator(parameter);
}
}
@RequiredArgsConstructor
final class ResultIterator implements Iterator<Object> {
- private final DataCalculateParameter dataCalculateParameter;
+ private final DataConsistencyCalculateParameter parameter;
private final AtomicInteger calculationCount = new AtomicInteger(0);
@@ -81,7 +81,7 @@ public abstract class AbstractStreamingDataConsistencyCalculateAlgorithm impleme
public Object next() {
calculateIfNecessary();
Optional<Object> nextResult = this.nextResult;
- dataCalculateParameter.setPreviousCalculatedResult(nextResult.orElse(null));
+ parameter.setPreviousCalculatedResult(nextResult.orElse(null));
this.nextResult = null;
return nextResult.orElse(null);
}
@@ -90,7 +90,7 @@ public abstract class AbstractStreamingDataConsistencyCalculateAlgorithm impleme
if (null != nextResult) {
return;
}
- nextResult = calculateChunk(dataCalculateParameter);
+ nextResult = calculateChunk(parameter);
if (!nextResult.isPresent()) {
log.info("nextResult not present, calculation done. calculationCount={}", calculationCount);
}
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithm.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithm.java
index f2cfb3c0bcc..8128b6cda49 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithm.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithm.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.data.pipeline.core.spi.check.consistency;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.data.pipeline.core.exception.PipelineDataConsistencyCheckFailedException;
import org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory;
import org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCalculateAlgorithm;
@@ -46,21 +46,21 @@ public final class CRC32MatchDataConsistencyCalculateAlgorithm implements DataCo
}
@Override
- public Iterable<Object> calculate(final DataCalculateParameter dataCalculateParameter) {
- PipelineSQLBuilder sqlBuilder = PipelineSQLBuilderFactory.newInstance(dataCalculateParameter.getDatabaseType());
- return Collections.unmodifiableList(dataCalculateParameter.getColumnNames().stream().map(each -> calculateCRC32(sqlBuilder, dataCalculateParameter, each)).collect(Collectors.toList()));
+ public Iterable<Object> calculate(final DataConsistencyCalculateParameter parameter) {
+ PipelineSQLBuilder sqlBuilder = PipelineSQLBuilderFactory.newInstance(parameter.getDatabaseType());
+ return Collections.unmodifiableList(parameter.getColumnNames().stream().map(each -> calculateCRC32(sqlBuilder, parameter, each)).collect(Collectors.toList()));
}
- private long calculateCRC32(final PipelineSQLBuilder sqlBuilder, final DataCalculateParameter dataCalculateParameter, final String columnName) {
- Optional<String> sql = sqlBuilder.buildCRC32SQL(dataCalculateParameter.getLogicTableName(), columnName);
+ private long calculateCRC32(final PipelineSQLBuilder sqlBuilder, final DataConsistencyCalculateParameter parameter, final String columnName) {
+ Optional<String> sql = sqlBuilder.buildCRC32SQL(parameter.getLogicTableName(), columnName);
if (!sql.isPresent()) {
throw new PipelineDataConsistencyCheckFailedException(
- String.format("Unsupported CRC32 data consistency calculate algorithm with database type `%s`", dataCalculateParameter.getDatabaseType()));
+ String.format("Unsupported CRC32 data consistency calculate algorithm with database type `%s`", parameter.getDatabaseType()));
}
try {
- return calculateCRC32(dataCalculateParameter.getDataSource(), sql.get());
+ return calculateCRC32(parameter.getDataSource(), sql.get());
} catch (final SQLException ex) {
- throw new PipelineDataConsistencyCheckFailedException(String.format("Table `%s` data check failed.", dataCalculateParameter.getLogicTableName()), ex);
+ throw new PipelineDataConsistencyCheckFailedException(String.format("Table `%s` data check failed.", parameter.getLogicTableName()), ex);
}
}
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/DataMatchDataConsistencyCalculateAlgorithm.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/DataMatchDataConsistencyCalculateAlgorithm.java
index f0c53dea195..bf69453c271 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/DataMatchDataConsistencyCalculateAlgorithm.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/DataMatchDataConsistencyCalculateAlgorithm.java
@@ -25,7 +25,7 @@ import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.builder.EqualsBuilder;
import org.apache.commons.lang3.builder.HashCodeBuilder;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.data.pipeline.core.exception.PipelineDataConsistencyCheckFailedException;
import org.apache.shardingsphere.data.pipeline.core.sqlbuilder.PipelineSQLBuilderFactory;
import org.apache.shardingsphere.data.pipeline.spi.sqlbuilder.PipelineSQLBuilder;
@@ -77,15 +77,15 @@ public final class DataMatchDataConsistencyCalculateAlgorithm extends AbstractSt
}
@Override
- protected Optional<Object> calculateChunk(final DataCalculateParameter dataCalculateParameter) {
- String logicTableName = dataCalculateParameter.getLogicTableName();
- PipelineSQLBuilder sqlBuilder = PipelineSQLBuilderFactory.newInstance(dataCalculateParameter.getDatabaseType());
- String uniqueKey = dataCalculateParameter.getUniqueKey();
- CalculatedResult previousCalculatedResult = (CalculatedResult) dataCalculateParameter.getPreviousCalculatedResult();
+ protected Optional<Object> calculateChunk(final DataConsistencyCalculateParameter parameter) {
+ String logicTableName = parameter.getLogicTableName();
+ PipelineSQLBuilder sqlBuilder = PipelineSQLBuilderFactory.newInstance(parameter.getDatabaseType());
+ String uniqueKey = parameter.getUniqueKey();
+ CalculatedResult previousCalculatedResult = (CalculatedResult) parameter.getPreviousCalculatedResult();
Number startUniqueKeyValue = null != previousCalculatedResult ? previousCalculatedResult.getMaxUniqueKeyValue() : -1;
String sql = sqlBuilder.buildChunkedQuerySQL(logicTableName, uniqueKey, startUniqueKeyValue);
try {
- return query(dataCalculateParameter.getDataSource(), sql, uniqueKey, startUniqueKeyValue, chunkSize);
+ return query(parameter.getDataSource(), sql, uniqueKey, startUniqueKeyValue, chunkSize);
} catch (final SQLException ex) {
throw new PipelineDataConsistencyCheckFailedException(String.format("table %s data check failed.", logicTableName), ex);
}
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/test/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithmTest.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/test/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithmTest.java
index d4cb5ba4706..b182d7a6f88 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/test/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithmTest.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/test/java/org/apache/shardingsphere/data/pipeline/core/spi/check/consistency/CRC32MatchDataConsistencyCalculateAlgorithmTest.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.data.pipeline.core.spi.check.consistency;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.data.pipeline.api.datasource.PipelineDataSourceWrapper;
import org.apache.shardingsphere.data.pipeline.core.exception.PipelineDataConsistencyCheckFailedException;
import org.junit.Before;
@@ -45,7 +45,7 @@ import static org.mockito.Mockito.when;
public final class CRC32MatchDataConsistencyCalculateAlgorithmTest {
@Mock
- private DataCalculateParameter dataCalculateParameter;
+ private DataConsistencyCalculateParameter parameter;
private PipelineDataSourceWrapper pipelineDataSource;
@@ -62,17 +62,17 @@ public final class CRC32MatchDataConsistencyCalculateAlgorithmTest {
pipelineDataSource = mock(PipelineDataSourceWrapper.class, RETURNS_DEEP_STUBS);
connection = mock(Connection.class, RETURNS_DEEP_STUBS);
Collection<String> columnNames = Arrays.asList("fieldOne", "fieldTwo", "fieldThree");
- when(dataCalculateParameter.getLogicTableName()).thenReturn("tableName");
- when(dataCalculateParameter.getColumnNames()).thenReturn(columnNames);
- when(dataCalculateParameter.getDataSource()).thenReturn(pipelineDataSource);
- when(dataCalculateParameter.getDatabaseType()).thenReturn("FIXTURE");
+ when(parameter.getLogicTableName()).thenReturn("tableName");
+ when(parameter.getColumnNames()).thenReturn(columnNames);
+ when(parameter.getDataSource()).thenReturn(pipelineDataSource);
+ when(parameter.getDatabaseType()).thenReturn("FIXTURE");
}
@Test
public void assertCalculateSuccess() {
- Iterable<Object> calculate = new CRC32MatchDataConsistencyCalculateAlgorithm().calculate(dataCalculateParameter);
+ Iterable<Object> calculate = new CRC32MatchDataConsistencyCalculateAlgorithm().calculate(parameter);
long actualDatabaseTypesSize = StreamSupport.stream(calculate.spliterator(), false).count();
- long expectedDatabaseTypesSize = dataCalculateParameter.getColumnNames().size();
+ long expectedDatabaseTypesSize = parameter.getColumnNames().size();
assertThat(actualDatabaseTypesSize, is(expectedDatabaseTypesSize));
}
@@ -86,9 +86,9 @@ public final class CRC32MatchDataConsistencyCalculateAlgorithmTest {
when(connection.prepareStatement(sqlCommandForFieldTwo)).thenReturn(preparedStatement);
when(connection.prepareStatement(sqlCommandForFieldThree)).thenReturn(preparedStatement);
when(preparedStatement.executeQuery()).thenReturn(resultSet);
- Iterable<Object> calculate = new CRC32MatchDataConsistencyCalculateAlgorithm().calculate(dataCalculateParameter);
+ Iterable<Object> calculate = new CRC32MatchDataConsistencyCalculateAlgorithm().calculate(parameter);
long actualDatabaseTypesSize = StreamSupport.stream(calculate.spliterator(), false).count();
- long expectedDatabaseTypesSize = dataCalculateParameter.getColumnNames().size();
+ long expectedDatabaseTypesSize = parameter.getColumnNames().size();
assertThat(actualDatabaseTypesSize, is(expectedDatabaseTypesSize));
}
@@ -96,6 +96,6 @@ public final class CRC32MatchDataConsistencyCalculateAlgorithmTest {
public void assertCalculateFailed() throws SQLException {
when(pipelineDataSource.getConnection()).thenReturn(connection);
when(connection.prepareStatement(anyString())).thenThrow(new SQLException());
- new CRC32MatchDataConsistencyCalculateAlgorithm().calculate(dataCalculateParameter);
+ new CRC32MatchDataConsistencyCalculateAlgorithm().calculate(parameter);
}
}
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency/DataCalculateParameter.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency/DataConsistencyCalculateParameter.java
similarity index 96%
rename from shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency/DataCalculateParameter.java
rename to shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency/DataConsistencyCalculateParameter.java
index 50965ef2e96..3bce12ec0a6 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency/DataCalculateParameter.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/api/check/consistency/DataConsistencyCalculateParameter.java
@@ -27,13 +27,13 @@ import org.apache.shardingsphere.data.pipeline.api.datasource.PipelineDataSource
import java.util.Collection;
/**
- * Data calculate parameter.
+ * Data consistency calculate parameter.
*/
@Getter
@Setter
@Builder
@ToString
-public final class DataCalculateParameter {
+public final class DataConsistencyCalculateParameter {
/**
* Data source of source side or target side.
diff --git a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/consistency/DataConsistencyCalculateAlgorithm.java b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/consistency/DataConsistencyCalculateAlgorithm.java
index 21e1c13b27c..ca4bb5b2342 100644
--- a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/consistency/DataConsistencyCalculateAlgorithm.java
+++ b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-spi/src/main/java/org/apache/shardingsphere/data/pipeline/spi/check/consistency/DataConsistencyCalculateAlgorithm.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.data.pipeline.spi.check.consistency;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithm;
import org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithmPostProcessor;
import org.apache.shardingsphere.spi.type.typed.TypedSPIMetadataAware;
@@ -30,8 +30,8 @@ public interface DataConsistencyCalculateAlgorithm extends ShardingSphereAlgorit
/**
* Calculate data for consistency check.
*
- * @param dataCalculateParameter data calculate parameter
+ * @param parameter data consistency calculate parameter
* @return calculated result
*/
- Iterable<Object> calculate(DataCalculateParameter dataCalculateParameter);
+ Iterable<Object> calculate(DataConsistencyCalculateParameter parameter);
}
diff --git a/shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureDataConsistencyCalculateAlgorithm.java b/shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureDataConsistencyCalculateAlgorithm.java
index 8c6b439c801..389b682d403 100644
--- a/shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureDataConsistencyCalculateAlgorithm.java
+++ b/shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/fixture/FixtureDataConsistencyCalculateAlgorithm.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.data.pipeline.core.fixture;
-import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataCalculateParameter;
+import org.apache.shardingsphere.data.pipeline.api.check.consistency.DataConsistencyCalculateParameter;
import org.apache.shardingsphere.data.pipeline.spi.check.consistency.DataConsistencyCalculateAlgorithm;
import org.apache.shardingsphere.infra.database.type.DatabaseTypeRegistry;
@@ -31,7 +31,7 @@ public final class FixtureDataConsistencyCalculateAlgorithm implements DataConsi
}
@Override
- public Iterable<Object> calculate(final DataCalculateParameter dataCalculateParameter) {
+ public Iterable<Object> calculate(final DataConsistencyCalculateParameter parameter) {
return Collections.singletonList(true);
}