(shardingsphere) branch master updated: Refactor TransmissionJobItemContext (#32601)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang 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 1229f419248 Refactor TransmissionJobItemContext (#32601)
1229f419248 is described below

commit 1229f4192480d6a62d365e2c1eafb1c1086c5830
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Tue Aug 20 15:37:31 2024 +0800

    Refactor TransmissionJobItemContext (#32601)
    
    * Refactor InventoryDumperContextSplitter
    
    * Remove useless comment on InventoryDumperContextSplitter
    
    * Refactor TransmissionJobItemContext
---
 .../data/pipeline/core/context/TransmissionJobItemContext.java      | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/TransmissionJobItemContext.java
 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/TransmissionJobItemContext.java
index bc3f2391b9a..b51eb9998d6 100644
--- 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/TransmissionJobItemContext.java
+++ 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/context/TransmissionJobItemContext.java
@@ -30,9 +30,6 @@ import java.util.Collection;
  */
 public interface TransmissionJobItemContext extends PipelineJobItemContext, 
PipelineJobProgressListener {
     
-    @Override
-    TransmissionProcessContext getJobProcessContext();
-    
     /**
      * Get inventory tasks.
      *
@@ -89,6 +86,9 @@ public interface TransmissionJobItemContext extends 
PipelineJobItemContext, Pipe
      */
     long getInventoryRecordsCount();
     
+    @Override
+    TransmissionProcessContext getJobProcessContext();
+    
     @Override
     default TransmissionJobItemProgress toProgress() {
         return new TransmissionJobItemProgress(this);