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

Nested classes/interfaces inherited from class org.apache.solr.core.SolrResourceLoader

SolrResourceLoader.SolrFileInputStream

Field Summary

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

classLoader, SOLR_RESOURCELOADING_RESTRICTED_ENABLED_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	getConfigSetZkPath()
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, getCoreContainer, getFilteredURLs, getInfoMBeans, getInstancePath, getLines, getLines, getLines, getManagedResourceRegistry, getSchemaLoader, getSolrConfig, getURLs, getURLs, inform, inform, inform, informAware, newInstance, newInstance, newInstance, newInstance, persistConfLocally, resourceLocation, setCoreContainer, setSolrConfig, setSolrCore

Methods inherited from class java.lang.Object

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

Constructor Details

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 Details

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

getConfigSetZkPath

public String getConfigSetZkPath()

getZkController

public ZkController getZkController()

setZkIndexSchemaReader

public void setZkIndexSchemaReader(ZkIndexSchemaReader zkIndexSchemaReader)

getZkIndexSchemaReader

public ZkIndexSchemaReader getZkIndexSchemaReader()