You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2023/06/20 18:02:56 UTC
[pinot] branch master updated: Adding method to register components in broker API (#10942)
This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 70fc973d66 Adding method to register components in broker API (#10942)
70fc973d66 is described below
commit 70fc973d662ef2051dbe2c0b261d1ae4db8c4e7e
Author: soumitra-st <12...@users.noreply.github.com>
AuthorDate: Tue Jun 20 11:02:50 2023 -0700
Adding method to register components in broker API (#10942)
---
.../apache/pinot/broker/broker/helix/BaseBrokerStarter.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java
index dddd93ce02..1682de1881 100644
--- a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java
+++ b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/helix/BaseBrokerStarter.java
@@ -332,6 +332,7 @@ public abstract class BaseBrokerStarter implements ServiceStartable {
_brokerAdminApplication =
new BrokerAdminApiApplication(_routingManager, _brokerRequestHandler, _brokerMetrics, _brokerConf,
_sqlQueryExecutor, _serverRoutingStatsManager, _accessControlFactory);
+ registerExtraComponents(_brokerAdminApplication);
_brokerAdminApplication.start(_listenerConfigs);
LOGGER.info("Initializing cluster change mediator");
@@ -394,6 +395,15 @@ public abstract class BaseBrokerStarter implements ServiceStartable {
LOGGER.info("Finish starting Pinot broker");
}
+ /**
+ * This method is called after initialization of BrokerAdminApiApplication object
+ * and before calling start to allow custom broker starters to register additional
+ * components.
+ * @param brokerAdminApplication is the application
+ */
+ protected void registerExtraComponents(BrokerAdminApiApplication brokerAdminApplication) {
+ }
+
private void updateInstanceConfigAndBrokerResourceIfNeeded() {
InstanceConfig instanceConfig = HelixHelper.getInstanceConfig(_participantHelixManager, _instanceId);
boolean updated = HelixHelper.updateHostnamePort(instanceConfig, _hostname, _port);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org