Package org.apache.druid.client

Class BrokerViewOfBrokerConfig

java.lang.Object

org.apache.druid.client.BaseBrokerViewOfConfig<BrokerDynamicConfig>

org.apache.druid.client.BrokerViewOfBrokerConfig

All Implemented Interfaces:

QueryConfigProvider

public class BrokerViewOfBrokerConfig
extends BaseBrokerViewOfConfig<BrokerDynamicConfig>
implements QueryConfigProvider

Broker view of broker dynamic configuration.

Also implements QueryConfigProvider to expose the effective default query context: the merge of static defaults (from DefaultQueryConfig) and operator-supplied overrides (from BrokerDynamicConfig.getQueryContext()). Dynamic values take precedence.

Constructor Summary

Constructors

Constructor	Description
BrokerViewOfBrokerConfig(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, ServiceClientFactory clientFactory, ServiceLocator serviceLocator, DefaultQueryConfig defaultQueryConfig)
BrokerViewOfBrokerConfig(CoordinatorClient coordinatorClient, DefaultQueryConfig defaultQueryConfig)

Method Summary

Modifier and Type	Method	Description
protected BrokerDynamicConfig	fetchConfigFromClient()	Fetch the configuration from the Coordinator via the HTTP client.
protected String	getConfigTypeName()	E.g., "coordinator dynamic configuration", "broker dynamic configuration"
Map<String,Object>	getContext()	Returns the pre-computed merge of static DefaultQueryConfig context and dynamic BrokerDynamicConfig.getQueryContext().
void	setDynamicConfig(@NotNull BrokerDynamicConfig updatedConfig)	Update the config view with a new broker dynamic config snapshot, and recompute the resolved default query context by merging static defaults with dynamic overrides.

Methods inherited from class org.apache.druid.client.BaseBrokerViewOfConfig

getDynamicConfig, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BrokerViewOfBrokerConfig

@Inject
public BrokerViewOfBrokerConfig(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
 ServiceClientFactory clientFactory,
 ServiceLocator serviceLocator,
 DefaultQueryConfig defaultQueryConfig)

BrokerViewOfBrokerConfig

public BrokerViewOfBrokerConfig(CoordinatorClient coordinatorClient,
 DefaultQueryConfig defaultQueryConfig)

Method Details

fetchConfigFromClient

protected BrokerDynamicConfig fetchConfigFromClient()
                                             throws Exception

Description copied from class: BaseBrokerViewOfConfig

Fetch the configuration from the Coordinator via the HTTP client. This is called once during broker startup.

Specified by:

fetchConfigFromClient in class BaseBrokerViewOfConfig<BrokerDynamicConfig>

Returns:

the configuration fetched from the Coordinator

Throws:

Exception - if the fetch fails

getConfigTypeName

protected String getConfigTypeName()

Description copied from class: BaseBrokerViewOfConfig

E.g., "coordinator dynamic configuration", "broker dynamic configuration"

Specified by:

getConfigTypeName in class BaseBrokerViewOfConfig<BrokerDynamicConfig>

setDynamicConfig

public void setDynamicConfig(@NotNull
 @NotNull BrokerDynamicConfig updatedConfig)

Update the config view with a new broker dynamic config snapshot, and recompute the resolved default query context by merging static defaults with dynamic overrides.

Overrides:

setDynamicConfig in class BaseBrokerViewOfConfig<BrokerDynamicConfig>

Parameters:

updatedConfig - the new configuration snapshot

getContext

public Map<String,Object> getContext()

Returns the pre-computed merge of static DefaultQueryConfig context and dynamic BrokerDynamicConfig.getQueryContext(). Dynamic values take precedence over static defaults.

Specified by:

getContext in interface QueryConfigProvider