org.apache.solr.core
Class CoreContainer

java.lang.Object
  org.apache.solr.core.CoreContainer

public class CoreContainer
extends Object

Since:

solr 1.3

Nested Class Summary

static class

CoreContainer.Initializer

Field Summary

protected String	adminHandler
protected String	adminPath
protected CollectionsHandler	collectionsHandler
protected File	configFile
protected Properties	containerProperties
protected CoreAdminHandler	coreAdminHandler
protected Map<String,Exception>	coreInitFailures
protected Map<String,SolrCore>	cores
static String	DEFAULT_DEFAULT_CORE_NAME
protected String	defaultCoreName
protected Map<String,CoreDescriptor>	dynamicDescriptors
protected String	host
protected String	hostContext
protected String	hostPort
protected Map<String,IndexSchema>	indexSchemaCache
protected String	libDir
protected ClassLoader	libLoader
protected SolrResourceLoader	loader
protected static org.slf4j.Logger	log
protected LogWatcher	logging
protected String	managementPath
protected Set<String>	pendingDynamicCoreLoads
protected boolean	persistent
protected boolean	shareSchema
protected String	solrHome
protected int	transientCacheSize
protected Map<String,SolrCore>	transientCores
protected Integer	zkClientTimeout

Constructor Summary

CoreContainer()
Deprecated. use the single arg constructure with locateSolrHome()

CoreContainer(SolrResourceLoader loader)
Minimal CoreContainer constructor.

CoreContainer(String solrHome)

CoreContainer(String dir, File configFile)
Initalize CoreContainer directly from the constructor

Method Summary

void	cancelCoreRecoveries()
SolrCore	create(CoreDescriptor dcore) Creates a new core based on a descriptor but does not register it.
protected CoreAdminHandler	createMultiCoreHandler(String adminHandlerClass) Creates a CoreAdminHandler for this MultiCore.
protected void	finalize()
String	getAdminPath()
CollectionsHandler	getCollectionsHandler()
File	getConfigFile()
Properties	getContainerProperties()
SolrCore	getCore(String name) Gets a core by name and increase its refcount.
Map<String,Exception>	getCoreInitFailures() Returns an immutable Map of Exceptions that occured when initializing SolrCores (either at startup, or do to runtime requests to create cores) keyed off of the name (String) of the SolrCore that had the Exception during initialization.
Collection<String>	getCoreNames()
Collection<String>	getCoreNames(SolrCore core) This method is currently experimental.
Collection<SolrCore>	getCores()
String	getDefaultCoreName() the default core name, or null if there is no default core name
LogWatcher	getLogging()
String	getManagementPath()
CoreAdminHandler	getMultiCoreHandler()
ShardHandlerFactory	getShardHandlerFactory() The default ShardHandlerFactory used to communicate with other solr instances
String	getSolrHome()
ZkController	getZkController()
protected void	initShardHandler(Config cfg)
protected void	initZooKeeper(String zkHost, int zkClientTimeout)
boolean	isPersistent()
boolean	isShareSchema()
boolean	isShutDown()
boolean	isZooKeeperAware()
void	load(String dir, File configFile) Load a config file listing the available solr cores.
void	load(String dir, InputSource cfgis) Load a config file listing the available solr cores.
void	persist() Persists the cores config file in cores.xml.
void	persistFile(File file) Persists the cores config file in a user provided file.
SolrCore	register(SolrCore core, boolean returnPrev) Registers a SolrCore descriptor in the registry using the core's name.
SolrCore	register(String name, SolrCore core, boolean returnPrevNotClosed) Registers a SolrCore descriptor in the registry using the specified name.
protected SolrCore	registerCore(Map<String,SolrCore> whichCores, String name, SolrCore core, boolean returnPrevNotClosed)
protected SolrCore	registerLazyCore(String name, SolrCore core, boolean returnPrevNotClosed)
void	reload(String name) Recreates a SolrCore.
SolrCore	remove(String name) Removes and returns registered core w/o decrementing it's reference count
void	rename(String name, String toName)
void	setAdminPath(String adminPath)
void	setLogging(LogWatcher v)
void	setManagementPath(String path) Sets the alternate path for multicore handling: This is used in case there is a registered unnamed core (aka name is "") to declare an alternate way of accessing named cores.
void	setPersistent(boolean persistent)
void	shutdown() Stops all cores.
void	swap(String n0, String n1) Swaps two SolrCore descriptors.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_DEFAULT_CORE_NAME

public static final String DEFAULT_DEFAULT_CORE_NAME

See Also:

Constant Field Values

log

protected static org.slf4j.Logger log

cores

protected final Map<String,SolrCore> cores

transientCores

protected Map<String,SolrCore> transientCores

dynamicDescriptors

protected final Map<String,CoreDescriptor> dynamicDescriptors

pendingDynamicCoreLoads

protected final Set<String> pendingDynamicCoreLoads

coreInitFailures

protected final Map<String,Exception> coreInitFailures

persistent

protected boolean persistent

adminPath

protected String adminPath

managementPath

protected String managementPath

hostPort

protected String hostPort

hostContext

protected String hostContext

host

protected String host

coreAdminHandler

protected CoreAdminHandler coreAdminHandler

collectionsHandler

protected CollectionsHandler collectionsHandler

configFile

protected File configFile

libDir

protected String libDir

libLoader

protected ClassLoader libLoader

loader

protected SolrResourceLoader loader

containerProperties

protected Properties containerProperties

indexSchemaCache

protected Map<String,IndexSchema> indexSchemaCache

adminHandler

protected String adminHandler

shareSchema

protected boolean shareSchema

zkClientTimeout

protected Integer zkClientTimeout

solrHome

protected String solrHome

defaultCoreName

protected String defaultCoreName

logging

protected LogWatcher logging

transientCacheSize

protected int transientCacheSize

Constructor Detail

CoreContainer

@Deprecated
public CoreContainer()

Deprecated. use the single arg constructure with locateSolrHome()

Deprecated

See Also:

SolrResourceLoader.locateSolrHome()

CoreContainer

public CoreContainer(String dir,
                     File configFile)

Initalize CoreContainer directly from the constructor

CoreContainer

public CoreContainer(SolrResourceLoader loader)

Minimal CoreContainer constructor.

Parameters:

loader - the CoreContainer resource loader

CoreContainer

public CoreContainer(String solrHome)

Method Detail

initZooKeeper

protected void initZooKeeper(String zkHost,
                             int zkClientTimeout)

getContainerProperties

public Properties getContainerProperties()

load

public void load(String dir,
                 File configFile)

Load a config file listing the available solr cores.

Parameters:

dir - the home directory of all resources.

configFile - the configuration file

load

public void load(String dir,
                 InputSource cfgis)

Load a config file listing the available solr cores.

Parameters:

dir - the home directory of all resources.

cfgis - the configuration file InputStream

initShardHandler

protected void initShardHandler(Config cfg)

isShutDown

public boolean isShutDown()

shutdown

public void shutdown()

Stops all cores.

cancelCoreRecoveries

public void cancelCoreRecoveries()

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

register

public SolrCore register(String name,
                         SolrCore core,
                         boolean returnPrevNotClosed)

Registers a SolrCore descriptor in the registry using the specified name. If returnPrevNotClosed==false, the old core, if different, is closed. if true, it is returned w/o closing the core

Returns:

a previous core having the same name if it existed

registerLazyCore

protected SolrCore registerLazyCore(String name,
                                    SolrCore core,
                                    boolean returnPrevNotClosed)

registerCore

protected SolrCore registerCore(Map<String,SolrCore> whichCores,
                                String name,
                                SolrCore core,
                                boolean returnPrevNotClosed)

register

public SolrCore register(SolrCore core,
                         boolean returnPrev)

Registers a SolrCore descriptor in the registry using the core's name. If returnPrev==false, the old core, if different, is closed.

Returns:

a previous core having the same name if it existed and returnPrev==true

create

public SolrCore create(CoreDescriptor dcore)

Creates a new core based on a descriptor but does not register it.

Parameters:

dcore - a core descriptor

Returns:

the newly created core

getCores

public Collection<SolrCore> getCores()

Returns:

a Collection of registered SolrCores

getCoreNames

public Collection<String> getCoreNames()

Returns:

a Collection of the names that cores are mapped to

getCoreNames

public Collection<String> getCoreNames(SolrCore core)

This method is currently experimental.

Returns:

a Collection of the names that a specific core is mapped to.

getCoreInitFailures

public Map<String,Exception> getCoreInitFailures()

Returns an immutable Map of Exceptions that occured when initializing SolrCores (either at startup, or do to runtime requests to create cores) keyed off of the name (String) of the SolrCore that had the Exception during initialization.

While the Map returned by this method is immutable and will not change once returned to the client, the source data used to generate this Map can be changed as various SolrCore operations are performed:

• Failed attempts to create new SolrCores will add new Exceptions.
• Failed attempts to re-create a SolrCore using a name already contained in this Map will replace the Exception.
• Failed attempts to reload a SolrCore will cause an Exception to be added to this list -- even though the existing SolrCore with that name will continue to be available.
• Successful attempts to re-created a SolrCore using a name already contained in this Map will remove the Exception.
• Registering an existing SolrCore with a name already contained in this Map (ie: ALIAS or SWAP) will remove the Exception.

reload

public void reload(String name)

Recreates a SolrCore. While the new core is loading, requests will continue to be dispatched to and processed by the old core

Parameters:

name - the name of the SolrCore to reload

swap

public void swap(String n0,
                 String n1)

Swaps two SolrCore descriptors.

remove

public SolrCore remove(String name)

Removes and returns registered core w/o decrementing it's reference count

rename

public void rename(String name,
                   String toName)

getCore

public SolrCore getCore(String name)

Gets a core by name and increase its refcount.

Parameters:

name - the core name

Returns:

the core if found

See Also:

SolrCore.close()

createMultiCoreHandler

protected CoreAdminHandler createMultiCoreHandler(String adminHandlerClass)

Creates a CoreAdminHandler for this MultiCore.

Returns:

a CoreAdminHandler

getMultiCoreHandler

public CoreAdminHandler getMultiCoreHandler()

getCollectionsHandler

public CollectionsHandler getCollectionsHandler()

getDefaultCoreName

public String getDefaultCoreName()

the default core name, or null if there is no default core name

isPersistent

public boolean isPersistent()

setPersistent

public void setPersistent(boolean persistent)

getAdminPath

public String getAdminPath()

setAdminPath

public void setAdminPath(String adminPath)

getManagementPath

public String getManagementPath()

setManagementPath

public void setManagementPath(String path)

Sets the alternate path for multicore handling: This is used in case there is a registered unnamed core (aka name is "") to declare an alternate way of accessing named cores. This can also be used in a pseudo single-core environment so admins can prepare a new version before swapping.

getLogging

public LogWatcher getLogging()

setLogging

public void setLogging(LogWatcher v)

getConfigFile

public File getConfigFile()

persist

public void persist()

Persists the cores config file in cores.xml.

persistFile

public void persistFile(File file)

Persists the cores config file in a user provided file.

getSolrHome

public String getSolrHome()

isZooKeeperAware

public boolean isZooKeeperAware()

getZkController

public ZkController getZkController()

isShareSchema

public boolean isShareSchema()

getShardHandlerFactory

public ShardHandlerFactory getShardHandlerFactory()

The default ShardHandlerFactory used to communicate with other solr instances