Package org.apache.solr.cloud

Class ZkSolrResourceLoader

java.lang.Object

org.apache.solr.core.SolrResourceLoader

org.apache.solr.cloud.ZkSolrResourceLoader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.lucene.util.ResourceLoader, org.apache.solr.common.cloud.SolrClassLoader, SolrCoreAware

public class ZkSolrResourceLoader
extends SolrResourceLoader

ResourceLoader that works with ZooKeeper.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ZkSolrResourceLoader.ZkByteArrayInputStream

Field Summary

Fields inherited from class org.apache.solr.core.SolrResourceLoader

classLoader, SOLR_ALLOW_UNSAFE_RESOURCELOADING_PARAM

Constructor Summary

Constructors

Constructor	Description
ZkSolrResourceLoader(Path instanceDir, String configSet, ClassLoader parent, ZkController zooKeeperController)	This loader will first attempt to load resources from ZooKeeper, but if not found will delegate to the context classloader when possible, otherwise it will attempt to resolve resources using any jar files found in the "lib/" directory in the specified instance directory.

Method Summary

Modifier and Type	Method	Description
String	getConfigDir()
String	getConfigSetZkPath()
CoreContainer	getCoreContainer()
ZkController	getZkController()
ZkIndexSchemaReader	getZkIndexSchemaReader()
org.apache.solr.common.util.Pair<String,Integer>	getZkResourceInfo(String resource)
InputStream	openResource(String resource)	Opens any resource by its name.
void	setZkIndexSchemaReader(ZkIndexSchemaReader zkIndexSchemaReader)

Methods inherited from class org.apache.solr.core.SolrResourceLoader

addToCoreAware, addToInfoBeans, addToResourceLoaderAware, assertAwareCompatibility, close, findClass, findClass, findClass, getClassLoader, getConfigPath, getFilteredURLs, getInfoMBeans, getInstancePath, getLines, getLines, getLines, getManagedResourceRegistry, getSchemaLoader, getSolrConfig, getURLs, getURLs, inform, inform, inform, informAware, newInstance, newInstance, newInstance, newInstance, persistConfLocally, resourceLocation

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkSolrResourceLoader

public ZkSolrResourceLoader(Path instanceDir,
                            String configSet,
                            ClassLoader parent,
                            ZkController zooKeeperController)

This loader will first attempt to load resources from ZooKeeper, but if not found will delegate to the context classloader when possible, otherwise it will attempt to resolve resources using any jar files found in the "lib/" directory in the specified instance directory.

Method Detail

getZkResourceInfo

public org.apache.solr.common.util.Pair<String,Integer> getZkResourceInfo(String resource)

openResource

public InputStream openResource(String resource)
                         throws IOException

Opens any resource by its name. By default, this will look in multiple locations to load the resource: $configDir/$resource from ZooKeeper. It will look for it in any jar accessible through the class loader if it cannot be found in ZooKeeper. Override this method to customize loading resources.

Specified by:

openResource in interface org.apache.lucene.util.ResourceLoader

Overrides:

openResource in class SolrResourceLoader

Returns:

the stream for the named resource

Throws:

IOException

getConfigDir

public String getConfigDir()

Overrides:

getConfigDir in class SolrResourceLoader

getConfigSetZkPath

public String getConfigSetZkPath()

getZkController

public ZkController getZkController()

setZkIndexSchemaReader

public void setZkIndexSchemaReader(ZkIndexSchemaReader zkIndexSchemaReader)

getZkIndexSchemaReader

public ZkIndexSchemaReader getZkIndexSchemaReader()

getCoreContainer

public CoreContainer getCoreContainer()

Overrides:

getCoreContainer in class SolrResourceLoader