This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng 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 a65eb5f3222 Remove InventoryDumperContext.firstDump (#36878)
a65eb5f3222 is described below
commit a65eb5f322288248672f03ba4a41cdbde71c796b
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Tue Oct 14 16:34:01 2025 +0800
Remove InventoryDumperContext.firstDump (#36878)
---
.../pipeline/core/ingest/dumper/inventory/InventoryDumper.java | 3 +--
.../core/ingest/dumper/inventory/InventoryDumperContext.java | 2 --
.../inventory/splitter/InventoryDumperContextSplitter.java | 10 ++--------
3 files changed, 3 insertions(+), 12 deletions(-)
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
index 260092795c0..085a14dec27 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
@@ -124,8 +124,7 @@ public final class InventoryDumper extends
AbstractPipelineLifecycleRunnable imp
List<String> columnNames = dumperContext.getQueryColumnNames();
TableInventoryCalculateParameter calculateParam = new
TableInventoryCalculateParameter(dataSource, table,
columnNames, dumperContext.getUniqueKeyColumns(),
QueryType.RANGE_QUERY, null);
- QueryRange queryRange = new QueryRange(((PrimaryKeyIngestPosition<?>)
initialPosition).getBeginValue(), dumperContext.isFirstDump(),
- ((PrimaryKeyIngestPosition<?>) initialPosition).getEndValue());
+ QueryRange queryRange = new QueryRange(((PrimaryKeyIngestPosition<?>)
initialPosition).getBeginValue(), true, ((PrimaryKeyIngestPosition<?>)
initialPosition).getEndValue());
calculateParam.setQueryRange(queryRange);
RecordTableInventoryDumpCalculator dumpCalculator = new
RecordTableInventoryDumpCalculator(dumperContext.getBatchSize(),
StreamingRangeType.SMALL);
long rowCount = 0L;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumperContext.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumperContext.java
index 62838155d0b..db0bd30dcf4 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumperContext.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumperContext.java
@@ -56,8 +56,6 @@ public final class InventoryDumperContext {
private JobRateLimitAlgorithm rateLimitAlgorithm;
- private boolean firstDump = true;
-
public InventoryDumperContext(final DumperCommonContext commonContext) {
this.commonContext = new DumperCommonContext(
commonContext.getDataSourceName(),
commonContext.getDataSourceConfig(), commonContext.getTableNameMapper(),
commonContext.getTableAndSchemaNameMapper());
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/preparer/inventory/splitter/InventoryDumperContextSplitter.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/preparer/inventory/splitter/InventoryDumperContextSplitter.java
index 9a9cf752d77..b16a9705cb8 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/preparer/inventory/splitter/InventoryDumperContextSplitter.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/preparer/inventory/splitter/InventoryDumperContextSplitter.java
@@ -94,7 +94,7 @@ public final class InventoryDumperContextSplitter {
JobRateLimitAlgorithm rateLimitAlgorithm =
jobProcessContext.getReadRateLimitAlgorithm();
int i = 0;
for (IngestPosition each : getInventoryPositions(dumperContext,
jobItemContext)) {
- result.add(createPrimaryKeySplitDumperContext(dumperContext, each,
i++, batchSize, rateLimitAlgorithm, jobItemContext));
+ result.add(createPrimaryKeySplitDumperContext(dumperContext, each,
i++, batchSize, rateLimitAlgorithm));
}
return result;
}
@@ -151,8 +151,7 @@ public final class InventoryDumperContextSplitter {
}
private InventoryDumperContext createPrimaryKeySplitDumperContext(final
InventoryDumperContext dumperContext, final IngestPosition position,
- final
int shardingItem, final int batchSize, final JobRateLimitAlgorithm
rateLimitAlgorithm,
- final
TransmissionJobItemContext jobItemContext) {
+ final
int shardingItem, final int batchSize, final JobRateLimitAlgorithm
rateLimitAlgorithm) {
InventoryDumperContext result = new
InventoryDumperContext(dumperContext.getCommonContext());
result.getCommonContext().setPosition(position);
result.setShardingItem(shardingItem);
@@ -162,11 +161,6 @@ public final class InventoryDumperContextSplitter {
result.setInsertColumnNames(dumperContext.getInsertColumnNames());
result.setBatchSize(batchSize);
result.setRateLimitAlgorithm(rateLimitAlgorithm);
- result.setFirstDump(isFirstDump(jobItemContext));
return result;
}
-
- private boolean isFirstDump(final TransmissionJobItemContext
jobItemContext) {
- return null == jobItemContext.getInitProgress() &&
jobItemContext.getProcessedRecordsCount() == 0;
- }
}
