You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by su...@apache.org on 2023/06/25 10:18:48 UTC
[shardingsphere] branch master updated: Remove useless @RequiredArgsConstructor on RuleConfigurationSubscribeCoordinator's impls (#26545)
This is an automated email from the ASF dual-hosted git repository.
sunnianjun 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 bb226fa22c5 Remove useless @RequiredArgsConstructor on RuleConfigurationSubscribeCoordinator's impls (#26545)
bb226fa22c5 is described below
commit bb226fa22c563798ee99c15d7b800ec7d21bf608
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Sun Jun 25 18:18:42 2023 +0800
Remove useless @RequiredArgsConstructor on RuleConfigurationSubscribeCoordinator's impls (#26545)
---
.../broadcast/subscriber/BroadcastConfigurationSubscriber.java | 2 --
.../shardingsphere/encrypt/subscriber/EncryptTableSubscriber.java | 2 --
.../apache/shardingsphere/encrypt/subscriber/EncryptorSubscriber.java | 2 --
.../apache/shardingsphere/mask/subscriber/MaskAlgorithmSubscriber.java | 2 --
.../org/apache/shardingsphere/mask/subscriber/MaskTableSubscriber.java | 2 --
.../subscriber/ReadwriteSplittingDataSourceSubscriber.java | 2 --
.../subscriber/ReadwriteSplittingLoadBalanceSubscriber.java | 2 --
.../shardingsphere/shadow/subscriber/ShadowAlgorithmSubscriber.java | 2 --
.../shardingsphere/shadow/subscriber/ShadowDataSourceSubscriber.java | 2 --
.../apache/shardingsphere/shadow/subscriber/ShadowTableSubscriber.java | 2 --
.../shardingsphere/sharding/subscriber/ShardingAlgorithmSubscriber.java | 2 --
.../sharding/subscriber/ShardingCacheConfigurationSubscriber.java | 2 --
.../sharding/subscriber/ShardingStrategyConfigurationSubscriber.java | 2 --
.../sharding/subscriber/ShardingTableConfigurationSubscriber.java | 2 --
.../shardingsphere/single/subscriber/SingleConfigurationSubscriber.java | 2 --
15 files changed, 30 deletions(-)
diff --git a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/subscriber/BroadcastConfigurationSubscriber.java b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/subscriber/BroadcastConfigurationSubscriber.java
index 438a257081c..a7e2da2d294 100644
--- a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/subscriber/BroadcastConfigurationSubscriber.java
+++ b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/subscriber/BroadcastConfigurationSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.broadcast.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.broadcast.api.config.BroadcastRuleConfiguration;
import org.apache.shardingsphere.broadcast.event.config.AddBroadcastTableEvent;
import org.apache.shardingsphere.broadcast.event.config.AlterBroadcastTableEvent;
@@ -38,7 +37,6 @@ import java.util.Optional;
* Broadcast configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class BroadcastConfigurationSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptTableSubscriber.java b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptTableSubscriber.java
index 23cacb5de20..92ac4393c0e 100644
--- a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptTableSubscriber.java
+++ b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptTableSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.encrypt.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.encrypt.api.config.EncryptRuleConfiguration;
import org.apache.shardingsphere.encrypt.api.config.rule.EncryptTableRuleConfiguration;
import org.apache.shardingsphere.encrypt.event.table.AddEncryptTableEvent;
@@ -41,7 +40,6 @@ import java.util.Optional;
* Encrypt table subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class EncryptTableSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptorSubscriber.java b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptorSubscriber.java
index f2a78a05e42..e083c000c1d 100644
--- a/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptorSubscriber.java
+++ b/features/encrypt/core/src/main/java/org/apache/shardingsphere/encrypt/subscriber/EncryptorSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.encrypt.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.encrypt.api.config.EncryptRuleConfiguration;
import org.apache.shardingsphere.encrypt.event.encryptor.AlterEncryptorEvent;
import org.apache.shardingsphere.encrypt.event.encryptor.DeleteEncryptorEvent;
@@ -38,7 +37,6 @@ import java.util.Map;
* Encrypt encryptor subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class EncryptorSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskAlgorithmSubscriber.java b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskAlgorithmSubscriber.java
index 2deb6bcbef6..eaa8196a680 100644
--- a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskAlgorithmSubscriber.java
+++ b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskAlgorithmSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.mask.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.config.algorithm.AlgorithmConfiguration;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -38,7 +37,6 @@ import java.util.Map;
* Mask algorithm subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class MaskAlgorithmSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskTableSubscriber.java b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskTableSubscriber.java
index c2fb4614e97..3d169fec10d 100644
--- a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskTableSubscriber.java
+++ b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/subscriber/MaskTableSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.mask.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -41,7 +40,6 @@ import java.util.Optional;
* Mask configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class MaskTableSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingDataSourceSubscriber.java b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingDataSourceSubscriber.java
index ca36fee008e..deacb97e368 100644
--- a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingDataSourceSubscriber.java
+++ b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingDataSourceSubscriber.java
@@ -19,7 +19,6 @@ package org.apache.shardingsphere.readwritesplitting.subscriber;
import com.google.common.base.Strings;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -42,7 +41,6 @@ import java.util.Optional;
* Readwrite-splitting configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ReadwriteSplittingDataSourceSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingLoadBalanceSubscriber.java b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingLoadBalanceSubscriber.java
index df039252871..8d002ada02c 100644
--- a/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingLoadBalanceSubscriber.java
+++ b/features/readwrite-splitting/core/src/main/java/org/apache/shardingsphere/readwritesplitting/subscriber/ReadwriteSplittingLoadBalanceSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.readwritesplitting.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.config.algorithm.AlgorithmConfiguration;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -38,7 +37,6 @@ import java.util.Map;
* Readwrite-splitting load-balance subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ReadwriteSplittingLoadBalanceSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowAlgorithmSubscriber.java b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowAlgorithmSubscriber.java
index c4220752786..13ee7accc19 100644
--- a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowAlgorithmSubscriber.java
+++ b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowAlgorithmSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.shadow.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.config.algorithm.AlgorithmConfiguration;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -38,7 +37,6 @@ import java.util.Map;
* Shadow algorithm subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShadowAlgorithmSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowDataSourceSubscriber.java b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowDataSourceSubscriber.java
index 241aafcc0b5..ecd6af56778 100644
--- a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowDataSourceSubscriber.java
+++ b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowDataSourceSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.shadow.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -39,7 +38,6 @@ import java.util.Optional;
* Shadow configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShadowDataSourceSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowTableSubscriber.java b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowTableSubscriber.java
index 6efc8d1410c..b413d932cb8 100644
--- a/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowTableSubscriber.java
+++ b/features/shadow/core/src/main/java/org/apache/shardingsphere/shadow/subscriber/ShadowTableSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.shadow.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -39,7 +38,6 @@ import java.util.Map;
* Shadow table subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShadowTableSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingAlgorithmSubscriber.java b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingAlgorithmSubscriber.java
index facc37c657a..a62a1fd1a98 100644
--- a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingAlgorithmSubscriber.java
+++ b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingAlgorithmSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.sharding.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.config.algorithm.AlgorithmConfiguration;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -42,7 +41,6 @@ import java.util.Map;
* Sharding algorithm subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShardingAlgorithmSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingCacheConfigurationSubscriber.java b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingCacheConfigurationSubscriber.java
index 4b488385062..e34a552c2e5 100644
--- a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingCacheConfigurationSubscriber.java
+++ b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingCacheConfigurationSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.sharding.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -39,7 +38,6 @@ import java.util.Map;
* Sharding cache configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShardingCacheConfigurationSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingStrategyConfigurationSubscriber.java b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingStrategyConfigurationSubscriber.java
index eb1f60743c9..91d1cfd8498 100644
--- a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingStrategyConfigurationSubscriber.java
+++ b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingStrategyConfigurationSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.sharding.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -58,7 +57,6 @@ import java.util.Optional;
* Sharding strategy configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShardingStrategyConfigurationSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingTableConfigurationSubscriber.java b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingTableConfigurationSubscriber.java
index 505982ff890..08e92f051d6 100644
--- a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingTableConfigurationSubscriber.java
+++ b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/subscriber/ShardingTableConfigurationSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.sharding.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -51,7 +50,6 @@ import java.util.Optional;
* Sharding table configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class ShardingTableConfigurationSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;
diff --git a/kernel/single/core/src/main/java/org/apache/shardingsphere/single/subscriber/SingleConfigurationSubscriber.java b/kernel/single/core/src/main/java/org/apache/shardingsphere/single/subscriber/SingleConfigurationSubscriber.java
index 395acea2b22..96f4fee4d46 100644
--- a/kernel/single/core/src/main/java/org/apache/shardingsphere/single/subscriber/SingleConfigurationSubscriber.java
+++ b/kernel/single/core/src/main/java/org/apache/shardingsphere/single/subscriber/SingleConfigurationSubscriber.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.single.subscriber;
import com.google.common.eventbus.Subscribe;
-import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.infra.instance.InstanceContext;
import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
import org.apache.shardingsphere.infra.rule.RuleConfigurationSubscribeCoordinator;
@@ -38,7 +37,6 @@ import java.util.Optional;
* Single configuration subscriber.
*/
@SuppressWarnings("UnstableApiUsage")
-@RequiredArgsConstructor
public final class SingleConfigurationSubscriber implements RuleConfigurationSubscribeCoordinator {
private Map<String, ShardingSphereDatabase> databases;