Change RoutingTableProvider to support direct aggregating routing inf…

…ormation from CurrentStates in each liveinstance. When sourceDataType is set as CurrentState, RoutingTableProvider will listen on CurrentStateChanges and refresh routing table from CurrentStates upon changes. RB=1221442 G=helix-reviewers A=jxue
apache · Apr 11, 2022 · 04f466e · 04f466e
1 parent 6b992c0
commit 04f466e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/helix-core/src/main/java/org/apache/helix/common/ClusterEventProcessor.java b/helix-core/src/main/java/org/apache/helix/common/ClusterEventProcessor.java
@@ -42,4 +42,9 @@ public ClusterEventProcessor(String clusterName, String processorName) {
   public void queueEvent(ClusterEvent event) {
     _eventQueue.put(event.getEventType(), event);
   }
+
+  public void shutdown() {
+    _eventQueue.clear();
+    this.interrupt();
+  }
 }
diff --git a/...ggregator/src/main/java/org/apache/helix/view/dataprovider/SourceClusterDataProvider.java b/...ggregator/src/main/java/org/apache/helix/view/dataprovider/SourceClusterDataProvider.java
@@ -43,6 +43,8 @@
 import org.apache.helix.model.ExternalView;
 import org.apache.helix.model.InstanceConfig;
 import org.apache.helix.model.LiveInstance;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * SourceClusterDataProvider listens to changes in 1 source cluster, notifies cluster data cache,
@@ -51,6 +53,8 @@
 public class SourceClusterDataProvider extends BasicClusterDataCache
     implements InstanceConfigChangeListener, LiveInstanceChangeListener,
     ExternalViewChangeListener {
+  private static final Logger LOG = LoggerFactory.getLogger(SourceClusterDataProvider.class);
+
   private final HelixManager _helixManager;
   private final ClusterEventProcessor _eventProcessor;