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 a2a3bd2bef7 Rename JobConfigurationChangedProcessor (#26870)
a2a3bd2bef7 is described below
commit a2a3bd2bef70ee4c733230d6a505f59330ac1c61
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Mon Jul 10 13:00:13 2023 +0800
Rename JobConfigurationChangedProcessor (#26870)
---
...gurationProcessor.java => JobConfigurationChangedProcessor.java} | 4 ++--
...Processor.java => AbstractJobConfigurationChangedProcessor.java} | 6 +++---
.../node/event/handler/impl/ConfigMetaDataChangedEventHandler.java | 4 ++--
...r.java => ConsistencyCheckJobConfigurationChangedProcessor.java} | 6 +++---
...metadata.node.config.processor.JobConfigurationChangedProcessor} | 2 +-
...rocessor.java => MigrationJobConfigurationChangedProcessor.java} | 6 +++---
...metadata.node.config.processor.JobConfigurationChangedProcessor} | 2 +-
7 files changed, 15 insertions(+), 15 deletions(-)
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/ChangedJobConfigurationProcessor.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/JobConfigurationChangedProcessor.java
similarity index 92%
rename from
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/ChangedJobConfigurationProcessor.java
rename to
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/JobConfigurationChangedProcessor.java
index c887df12e55..0b3bd1f906c 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/ChangedJobConfigurationProcessor.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/JobConfigurationChangedProcessor.java
@@ -22,9 +22,9 @@ import
org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI;
import org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
/**
- * Changed job configuration processor.
+ * Job configuration changed processor.
*/
-public interface ChangedJobConfigurationProcessor extends TypedSPI {
+public interface JobConfigurationChangedProcessor extends TypedSPI {
/**
* Process changed job configuration.
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/impl/AbstractChangedJobConfigurationProcessor.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/impl/AbstractJobConfigurationChangedProcessor.java
similarity index 95%
rename from
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/impl/AbstractChangedJobConfigurationProcessor.java
rename to
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/impl/AbstractJobConfigurationChangedProcessor.java
index 6685cdb2de8..53c1af69305 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/impl/AbstractChangedJobConfigurationProcessor.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/config/processor/impl/AbstractJobConfigurationChangedProcessor.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.proc
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.common.job.type.JobType;
import
org.apache.shardingsphere.data.pipeline.common.metadata.node.PipelineMetaDataNode;
-import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor;
+import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor;
import
org.apache.shardingsphere.data.pipeline.common.util.PipelineDistributedBarrier;
import org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob;
import org.apache.shardingsphere.data.pipeline.core.job.PipelineJobCenter;
@@ -33,10 +33,10 @@ import
org.apache.shardingsphere.mode.event.DataChangedEvent.Type;
import java.util.Collection;
/**
- * Abstract changed job configuration processor.
+ * Abstract job configuration changed processor.
*/
@Slf4j
-public abstract class AbstractChangedJobConfigurationProcessor implements
ChangedJobConfigurationProcessor {
+public abstract class AbstractJobConfigurationChangedProcessor implements
JobConfigurationChangedProcessor {
@Override
public void process(final Type eventType, final JobConfiguration
jobConfig) {
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/event/handler/impl/ConfigMetaDataChangedEventHandler.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/event/handler/impl/ConfigMetaDataChangedEventHandler.java
index 3373d60091c..247f811cefc 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/event/handler/impl/ConfigMetaDataChangedEventHandler.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/metadata/node/event/handler/impl/ConfigMetaDataChangedEventHandler.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.data.pipeline.common.metadata.node.event.handl
import lombok.extern.slf4j.Slf4j;
import
org.apache.shardingsphere.data.pipeline.common.metadata.node.PipelineMetaDataNode;
-import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor;
+import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor;
import
org.apache.shardingsphere.data.pipeline.common.metadata.node.event.handler.PipelineMetaDataChangedEventHandler;
import org.apache.shardingsphere.data.pipeline.core.job.PipelineJobIdUtils;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
@@ -53,7 +53,7 @@ public final class ConfigMetaDataChangedEventHandler
implements PipelineMetaData
return;
}
log.info("{} job configuration: {}, disabled={}", event.getType(),
event.getKey(), jobConfig.isDisabled());
- TypedSPILoader.findService(ChangedJobConfigurationProcessor.class,
PipelineJobIdUtils.parseJobType(jobConfig.getJobName()).getType())
+ TypedSPILoader.findService(JobConfigurationChangedProcessor.class,
PipelineJobIdUtils.parseJobType(jobConfig.getJobName()).getType())
.ifPresent(optional -> optional.process(event.getType(),
jobConfig));
}
}
diff --git
a/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/metadata/processor/ChangedConsistencyCheckJobConfigurationProcessor.java
b/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/metadata/processor/ConsistencyCheckJobConfigurationChangedProcessor.java
similarity index 88%
rename from
kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/metadata/processor/ChangedConsistencyCheckJobConfigurationProcessor.java
rename to
kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/metadata/processor/ConsistencyCheckJobConfigurationChangedProcessor.java
index 8032924da6a..89b4a40fc3a 100644
---
a/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/metadata/processor/ChangedConsistencyCheckJobConfigurationProcessor.java
+++
b/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/metadata/processor/ConsistencyCheckJobConfigurationChangedProcessor.java
@@ -19,17 +19,17 @@ package
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.metada
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.common.job.type.JobType;
-import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.impl.AbstractChangedJobConfigurationProcessor;
+import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.impl.AbstractJobConfigurationChangedProcessor;
import org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJob;
import
org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
/**
- * Changed consistency check job configuration processor.
+ * Consistency check job configuration changed processor.
*/
@Slf4j
-public final class ChangedConsistencyCheckJobConfigurationProcessor extends
AbstractChangedJobConfigurationProcessor {
+public final class ConsistencyCheckJobConfigurationChangedProcessor extends
AbstractJobConfigurationChangedProcessor {
@Override
protected void onDeleted(final JobConfiguration jobConfig) {
diff --git
a/kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor
b/kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor
similarity index 93%
rename from
kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor
rename to
kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor
index b5b3d90c3d6..d4cd5f7c4be 100644
---
a/kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor
+++
b/kernel/data-pipeline/scenario/consistencycheck/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.metadata.processor.ChangedConsistencyCheckJobConfigurationProcessor
+org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.metadata.processor.ConsistencyCheckJobConfigurationChangedProcessor
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/ChangedMigrationJobConfigurationProcessor.java
b/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
similarity index 90%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/ChangedMigrationJobConfigurationProcessor.java
rename to
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
index ceaf6e3769f..a15921a9adb 100644
---
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/ChangedMigrationJobConfigurationProcessor.java
+++
b/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.data.pipeline.scenario.migration.metadata.proc
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.data.pipeline.common.job.type.JobType;
-import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.impl.AbstractChangedJobConfigurationProcessor;
+import
org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.impl.AbstractJobConfigurationChangedProcessor;
import org.apache.shardingsphere.data.pipeline.core.job.AbstractPipelineJob;
import org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJob;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
@@ -28,10 +28,10 @@ import
org.apache.shardingsphere.data.pipeline.yaml.job.YamlMigrationJobConfigur
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
/**
- * Changed migration job configuration processor.
+ * Migration job configuration changed processor.
*/
@Slf4j
-public final class ChangedMigrationJobConfigurationProcessor extends
AbstractChangedJobConfigurationProcessor {
+public final class MigrationJobConfigurationChangedProcessor extends
AbstractJobConfigurationChangedProcessor {
@Override
protected void onDeleted(final JobConfiguration jobConfig) {
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor
b/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor
similarity index 93%
rename from
kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor
rename to
kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor
index c45d5a69c94..7da3290807f 100644
---
a/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.ChangedJobConfigurationProcessor
+++
b/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.common.metadata.node.config.processor.JobConfigurationChangedProcessor
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.data.pipeline.scenario.migration.metadata.processor.ChangedMigrationJobConfigurationProcessor
+org.apache.shardingsphere.data.pipeline.scenario.migration.metadata.processor.MigrationJobConfigurationChangedProcessor
