(shardingsphere) branch master updated: Add HighFrequencyInvocation annotation on Broadcast (#33501)

[su...@apache.org]

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 cd9b8cec311 Add HighFrequencyInvocation annotation on Broadcast (#33501)
cd9b8cec311 is described below

commit cd9b8cec311a754f2434499cee52c66ed8425698
Author: Liang Zhang <zh...@apache.org>
AuthorDate: Fri Nov 1 19:40:59 2024 +0800

    Add HighFrequencyInvocation annotation on Broadcast (#33501)
    
    * Add HighFrequencyInvocation annotation on Broadcast
    
    * Add HighFrequencyInvocation annotation on Broadcast
---
 .../broadcast/route/engine/BroadcastRouteEngineFactory.java             | 2 ++
 .../engine/type/broadcast/BroadcastDatabaseBroadcastRoutingEngine.java  | 2 ++
 .../engine/type/broadcast/BroadcastInstanceBroadcastRoutingEngine.java  | 2 ++
 3 files changed, 6 insertions(+)

diff --git a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/BroadcastRouteEngineFactory.java b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/BroadcastRouteEngineFactory.java
index a74cb97eda9..3f4488ef8fd 100644
--- a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/BroadcastRouteEngineFactory.java
+++ b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/BroadcastRouteEngineFactory.java
@@ -25,6 +25,7 @@ import org.apache.shardingsphere.broadcast.route.engine.type.broadcast.Broadcast
 import org.apache.shardingsphere.broadcast.route.engine.type.ignore.BroadcastIgnoreRoutingEngine;
 import org.apache.shardingsphere.broadcast.route.engine.type.unicast.BroadcastUnicastRoutingEngine;
 import org.apache.shardingsphere.broadcast.rule.BroadcastRule;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
 import org.apache.shardingsphere.infra.binder.context.statement.SQLStatementContext;
 import org.apache.shardingsphere.infra.binder.context.statement.ddl.CloseStatementContext;
 import org.apache.shardingsphere.infra.binder.context.type.CursorAvailable;
@@ -53,6 +54,7 @@ import java.util.stream.Collectors;
 /**
  * Broadcast routing engine factory.
  */
+@HighFrequencyInvocation
 @NoArgsConstructor(access = AccessLevel.PRIVATE)
 public final class BroadcastRouteEngineFactory {
     
diff --git a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastDatabaseBroadcastRoutingEngine.java b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastDatabaseBroadcastRoutingEngine.java
index 97ecab07612..f42545d6114 100644
--- a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastDatabaseBroadcastRoutingEngine.java
+++ b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastDatabaseBroadcastRoutingEngine.java
@@ -19,6 +19,7 @@ package org.apache.shardingsphere.broadcast.route.engine.type.broadcast;
 
 import org.apache.shardingsphere.broadcast.route.engine.type.BroadcastRouteEngine;
 import org.apache.shardingsphere.broadcast.rule.BroadcastRule;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
 import org.apache.shardingsphere.infra.route.context.RouteContext;
 import org.apache.shardingsphere.infra.route.context.RouteMapper;
 import org.apache.shardingsphere.infra.route.context.RouteUnit;
@@ -28,6 +29,7 @@ import java.util.Collections;
 /**
  * Broadcast routing engine for database.
  */
+@HighFrequencyInvocation
 public final class BroadcastDatabaseBroadcastRoutingEngine implements BroadcastRouteEngine {
     
     @Override
diff --git a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastInstanceBroadcastRoutingEngine.java b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastInstanceBroadcastRoutingEngine.java
index c88487679da..84c19433813 100644
--- a/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastInstanceBroadcastRoutingEngine.java
+++ b/features/broadcast/core/src/main/java/org/apache/shardingsphere/broadcast/route/engine/type/broadcast/BroadcastInstanceBroadcastRoutingEngine.java
@@ -20,6 +20,7 @@ package org.apache.shardingsphere.broadcast.route.engine.type.broadcast;
 import lombok.RequiredArgsConstructor;
 import org.apache.shardingsphere.broadcast.route.engine.type.BroadcastRouteEngine;
 import org.apache.shardingsphere.broadcast.rule.BroadcastRule;
+import org.apache.shardingsphere.infra.annotation.HighFrequencyInvocation;
 import org.apache.shardingsphere.infra.metadata.database.resource.ResourceMetaData;
 import org.apache.shardingsphere.infra.route.context.RouteContext;
 import org.apache.shardingsphere.infra.route.context.RouteMapper;
@@ -30,6 +31,7 @@ import java.util.Collections;
 /**
  * Broadcast routing engine for database instance.
  */
+@HighFrequencyInvocation
 @RequiredArgsConstructor
 public final class BroadcastInstanceBroadcastRoutingEngine implements BroadcastRouteEngine {