org.apache.solr.update

Class UpdateShardHandler

java.lang.Object

org.apache.solr.update.UpdateShardHandler

All Implemented Interfaces:

SolrInfoBean, SolrMetricProducer

public class UpdateShardHandler
extends Object
implements SolrMetricProducer, SolrInfoBean

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.core.SolrInfoBean

SolrInfoBean.Category, SolrInfoBean.Group

Constructor Summary

Constructors

Constructor and Description
UpdateShardHandler(UpdateShardHandlerConfig cfg)

Method Summary

Modifier and Type	Method and Description
void	close()
SolrInfoBean.Category	getCategory() Category of this component
org.apache.http.impl.conn.PoolingHttpClientConnectionManager	getConnectionManager()
String	getDescription() Simple one or two line description
org.apache.http.client.HttpClient	getHttpClient()
Set<String>	getMetricNames() Modifiable set of metric names that this component reports (default is null, which means none).
com.codahale.metrics.MetricRegistry	getMetricRegistry() An instance of MetricRegistry that this component uses for metrics reporting (default is null, which means no registry).
String	getName() Simple common usage name, e.g.
ExecutorService	getRecoveryExecutor() In general, RecoveryStrategy threads do not do disk IO, but they open and close SolrCores in async threads, among other things, and can trigger disk IO, so we use this alternate executor rather than the 'updateExecutor', which is interrupted on shutdown.
ExecutorService	getUpdateExecutor() This method returns an executor that is not meant for disk IO and that will be interrupted on shutdown.
void	initializeMetrics(SolrMetricManager manager, String registryName, String scope) Initializes metrics specific to this producer

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.solr.core.SolrInfoBean

getMetricsSnapshot, registerMetricName

Constructor Detail

UpdateShardHandler

public UpdateShardHandler(UpdateShardHandlerConfig cfg)

Method Detail

getName

public String getName()

Description copied from interface: SolrInfoBean

Simple common usage name, e.g. BasicQueryHandler, or fully qualified class name.

Specified by:

getName in interface SolrInfoBean

initializeMetrics

public void initializeMetrics(SolrMetricManager manager,
                              String registryName,
                              String scope)

Description copied from interface: SolrMetricProducer

Initializes metrics specific to this producer

Specified by:

initializeMetrics in interface SolrMetricProducer

Parameters:

manager - an instance of SolrMetricManager

registryName - registry name where metrics are registered

scope - scope of the metrics (eg. handler name) to separate metrics of instances of the same component executing in different contexts

getDescription

public String getDescription()

Description copied from interface: SolrInfoBean

Simple one or two line description

Specified by:

getDescription in interface SolrInfoBean

getCategory

public SolrInfoBean.Category getCategory()

Description copied from interface: SolrInfoBean

Category of this component

Specified by:

getCategory in interface SolrInfoBean

getMetricNames

public Set<String> getMetricNames()

Description copied from interface: SolrInfoBean

Modifiable set of metric names that this component reports (default is null, which means none). If not null then this set is used by SolrInfoBean.registerMetricName(String) to capture what metrics names are reported from this component.

NOTE: this set has to allow iteration under modifications.

Specified by:

getMetricNames in interface SolrInfoBean

getMetricRegistry

public com.codahale.metrics.MetricRegistry getMetricRegistry()

Description copied from interface: SolrInfoBean

An instance of MetricRegistry that this component uses for metrics reporting (default is null, which means no registry).

Specified by:

getMetricRegistry in interface SolrInfoBean

getHttpClient

public org.apache.http.client.HttpClient getHttpClient()

getUpdateExecutor

public ExecutorService getUpdateExecutor()

This method returns an executor that is not meant for disk IO and that will be interrupted on shutdown.

Returns:

an executor for update related activities that do not do disk IO.

getConnectionManager

public org.apache.http.impl.conn.PoolingHttpClientConnectionManager getConnectionManager()

getRecoveryExecutor

public ExecutorService getRecoveryExecutor()

In general, RecoveryStrategy threads do not do disk IO, but they open and close SolrCores in async threads, among other things, and can trigger disk IO, so we use this alternate executor rather than the 'updateExecutor', which is interrupted on shutdown.

Returns:

executor for RecoveryStrategy thread which will not be interrupted on close.

close

public void close()