Package org.apache.druid.client

Class BrokerViewOfCoordinatorConfig

java.lang.Object

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

org.apache.druid.client.BrokerViewOfCoordinatorConfig

All Implemented Interfaces:

HistoricalFilter

public class BrokerViewOfCoordinatorConfig
extends BaseBrokerViewOfConfig<CoordinatorDynamicConfig>
implements HistoricalFilter

Broker view of the coordinator dynamic configuration, and its derived values such as target and source clone servers. This class is registered as a managed lifecycle to fetch the coordinator dynamic configuration on startup. Further updates are handled through BrokerDynamicConfigResource.

Field Summary

Fields inherited from interface org.apache.druid.client.selector.HistoricalFilter

IDENTITY_FILTER

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected CoordinatorDynamicConfig	fetchConfigFromClient()	Fetch the configuration from the Coordinator via the HTTP client.
protected String	getConfigTypeName()	E.g., "coordinator dynamic configuration", "broker dynamic configuration"
it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>>	getQueryableServers(it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> historicalServers, CloneQueryMode mode)	Returns a Int2ObjectRBTreeMap after performing a filtering on the QueryableDruidServer, based on the cloneQueryMode paramter.
void	setDynamicConfig(@NotNull CoordinatorDynamicConfig updatedConfig)	Update the config view with a new coordinator dynamic config snapshot.

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

BrokerViewOfCoordinatorConfig

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

BrokerViewOfCoordinatorConfig

public BrokerViewOfCoordinatorConfig(CoordinatorClient coordinatorClient)

Method Details

fetchConfigFromClient

protected CoordinatorDynamicConfig 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<CoordinatorDynamicConfig>

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<CoordinatorDynamicConfig>

setDynamicConfig

public void setDynamicConfig(@NotNull
 @NotNull CoordinatorDynamicConfig updatedConfig)

Update the config view with a new coordinator dynamic config snapshot. Also updates the source and target clone servers based on the new dynamic configuration.

Overrides:

setDynamicConfig in class BaseBrokerViewOfConfig<CoordinatorDynamicConfig>

Parameters:

updatedConfig - the new configuration snapshot

getQueryableServers

public it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> getQueryableServers(it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> historicalServers,
 CloneQueryMode mode)

Description copied from interface: HistoricalFilter

Returns a Int2ObjectRBTreeMap after performing a filtering on the QueryableDruidServer, based on the cloneQueryMode paramter. The map in the parameter is not modified.

Specified by:

getQueryableServers in interface HistoricalFilter