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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
