org.apache.solr.update

Class UpdateShardHandler

java.lang.Object

org.apache.solr.update.UpdateShardHandler

All Implemented Interfaces:

SolrInfoMBean, SolrMetricProducer

public class UpdateShardHandler
extends Object
implements SolrMetricProducer, SolrInfoMBean

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UpdateShardHandler.IdleConnectionsEvictor This class is adapted from org.apache.http.impl.client.IdleConnectionEvictor and changed to use the deprecated ClientConnectionManager instead of the new HttpClientConnectionManager.

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

SolrInfoMBean.Category, SolrInfoMBean.Group

Constructor Summary

Constructors

Constructor and Description
UpdateShardHandler(UpdateShardHandlerConfig cfg)

Method Summary

Modifier and Type	Method and Description
void	close()
SolrInfoMBean.Category	getCategory() Purpose of this Class
protected ModifiableSolrParams	getClientParams()
org.apache.http.conn.ClientConnectionManager	getConnectionManager()
String	getDescription() Simple one or two line description
URL[]	getDocs() Documentation URL list.
org.apache.http.client.HttpClient	getHttpClient()
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.
String	getSource() CVS Source, SVN Source, etc
NamedList	getStatistics() Any statistics this instance would like to be publicly available via the Solr Administration interface.
ExecutorService	getUpdateExecutor() This method returns an executor that is not meant for disk IO and that will be interrupted on shutdown.
String	getVersion() Simple common usage version, e.g.
void	initializeMetrics(SolrMetricManager manager, String registry, String scope) Initializes metrics specific to this producer
void	reconfigureHttpClient(HttpClientConfigurer configurer)

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdateShardHandler

public UpdateShardHandler(UpdateShardHandlerConfig cfg)

Method Detail

getClientParams

protected ModifiableSolrParams getClientParams()

getName

public String getName()

Description copied from interface: SolrInfoMBean

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

Specified by:

getName in interface SolrInfoMBean

getVersion

public String getVersion()

Description copied from interface: SolrInfoMBean

Simple common usage version, e.g. 2.0

Specified by:

getVersion in interface SolrInfoMBean

initializeMetrics

public void initializeMetrics(SolrMetricManager manager,
                              String registry,
                              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

registry - 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: SolrInfoMBean

Simple one or two line description

Specified by:

getDescription in interface SolrInfoMBean

getCategory

public SolrInfoMBean.Category getCategory()

Description copied from interface: SolrInfoMBean

Purpose of this Class

Specified by:

getCategory in interface SolrInfoMBean

getSource

public String getSource()

Description copied from interface: SolrInfoMBean

CVS Source, SVN Source, etc

Specified by:

getSource in interface SolrInfoMBean

getDocs

public URL[] getDocs()

Description copied from interface: SolrInfoMBean

Documentation URL list.

Suggested documentation URLs: Homepage for sponsoring project, FAQ on class usage, Design doc for class, Wiki, bug reporting URL, etc...

Specified by:

getDocs in interface SolrInfoMBean

getStatistics

public NamedList getStatistics()

Description copied from interface: SolrInfoMBean

Any statistics this instance would like to be publicly available via the Solr Administration interface.

Any Object type may be stored in the list, but only the toString() representation will be used.

Specified by:

getStatistics in interface SolrInfoMBean

getHttpClient

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

reconfigureHttpClient

public void reconfigureHttpClient(HttpClientConfigurer configurer)

getConnectionManager

public org.apache.http.conn.ClientConnectionManager getConnectionManager()

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.

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()