This is an automated email from the ASF dual-hosted git repository.
wuweijie 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 a5e594e7d4a Revise javadoc of ExecuteProcessReporter (#23695)
a5e594e7d4a is described below
commit a5e594e7d4a45141e331e1a8bbe4fe49261e709e
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Jan 21 23:41:46 2023 +0800
Revise javadoc of ExecuteProcessReporter (#23695)
---
.../infra/executor/sql/process/spi/ExecuteProcessReporter.java | 10 +++++++---
.../sql/process/fixture/ExecuteProcessReporterFixture.java | 5 +++--
2 files changed, 10 insertions(+), 5 deletions(-)
diff --git
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/process/spi/ExecuteProcessReporter.java
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/process/spi/ExecuteProcessReporter.java
index 7b8c949b1e0..a08fa318180 100644
---
a/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/process/spi/ExecuteProcessReporter.java
+++
b/infra/executor/src/main/java/org/apache/shardingsphere/infra/executor/sql/process/spi/ExecuteProcessReporter.java
@@ -33,33 +33,37 @@ public interface ExecuteProcessReporter extends OptionalSPI
{
/**
* Report this connection for proxy.
+ *
* @param executionGroupContext execution group context
*/
void report(ExecutionGroupContext<? extends SQLExecutionUnit>
executionGroupContext);
/**
* Report the summary of this task.
+ *
* @param queryContext query context
* @param executionGroupContext execution group context
* @param constants constants
- * @param eventBusContext event bus context
+ * @param eventBusContext event bus context
*/
void report(QueryContext queryContext, ExecutionGroupContext<? extends
SQLExecutionUnit> executionGroupContext, ExecuteProcessConstants constants,
EventBusContext eventBusContext);
/**
* Report a unit of this task.
+ *
* @param executionID execution ID
* @param executionUnit execution unit
* @param constants constants
- * @param eventBusContext event bus context
+ * @param eventBusContext event bus context
*/
void report(String executionID, SQLExecutionUnit executionUnit,
ExecuteProcessConstants constants, EventBusContext eventBusContext);
/**
* Report this task on completion.
+ *
* @param executionID execution ID
* @param constants constants
- * @param eventBusContext event bus context
+ * @param eventBusContext event bus context
*/
void report(String executionID, ExecuteProcessConstants constants,
EventBusContext eventBusContext);
diff --git
a/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/fixture/ExecuteProcessReporterFixture.java
b/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/fixture/ExecuteProcessReporterFixture.java
index 95155043b0b..c9ffcb69235 100644
---
a/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/fixture/ExecuteProcessReporterFixture.java
+++
b/infra/executor/src/test/java/org/apache/shardingsphere/infra/executor/sql/process/fixture/ExecuteProcessReporterFixture.java
@@ -18,17 +18,18 @@
package org.apache.shardingsphere.infra.executor.sql.process.fixture;
import org.apache.shardingsphere.infra.binder.QueryContext;
-import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import
org.apache.shardingsphere.infra.executor.kernel.model.ExecutionGroupContext;
import
org.apache.shardingsphere.infra.executor.sql.execute.engine.SQLExecutionUnit;
import
org.apache.shardingsphere.infra.executor.sql.process.model.ExecuteProcessConstants;
import
org.apache.shardingsphere.infra.executor.sql.process.spi.ExecuteProcessReporter;
+import org.apache.shardingsphere.infra.util.eventbus.EventBusContext;
import java.util.LinkedList;
+import java.util.List;
public final class ExecuteProcessReporterFixture implements
ExecuteProcessReporter {
- public static final LinkedList<String> ACTIONS = new LinkedList<>();
+ public static final List<String> ACTIONS = new LinkedList<>();
@Override
public void report(final ExecutionGroupContext<? extends SQLExecutionUnit>
executionGroupContext) {