public class MiniSolrCloudCluster extends Object
Constructor and Description |
---|
MiniSolrCloudCluster(int numServers,
File baseDir,
File solrXml,
JettyConfig jettyConfig)
Create a MiniSolrCloudCluster
|
MiniSolrCloudCluster(int numServers,
String hostContext,
File baseDir,
File solrXml,
SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters)
Create a MiniSolrCloudCluster
|
MiniSolrCloudCluster(int numServers,
String hostContext,
File baseDir,
File solrXml,
SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters,
SSLConfig sslConfig)
Create a MiniSolrCloudCluster
|
Modifier and Type | Method and Description |
---|---|
protected CloudSolrClient |
buildSolrClient() |
NamedList<Object> |
createCollection(String name,
int numShards,
int replicationFactor,
String configName,
Map<String,String> collectionProperties) |
NamedList<Object> |
createCollection(String name,
int numShards,
int replicationFactor,
String configName,
String createNodeSet,
String asyncId,
Map<String,String> collectionProperties) |
NamedList<Object> |
deleteCollection(String name) |
List<JettySolrRunner> |
getJettySolrRunners() |
CloudSolrClient |
getSolrClient() |
ZkTestServer |
getZkServer() |
void |
shutdown()
Shut down the cluster, including all Solr nodes and ZooKeeper
|
JettySolrRunner |
startJettySolrRunner()
Start a new Solr instance, using the default config
|
JettySolrRunner |
startJettySolrRunner(JettyConfig config)
Start a new Solr instance
|
JettySolrRunner |
startJettySolrRunner(String hostContext,
JettyConfig config)
Start a new Solr instance on a particular servlet context
|
JettySolrRunner |
startJettySolrRunner(String hostContext,
SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters)
Start a new Solr instance
|
JettySolrRunner |
startJettySolrRunner(String hostContext,
SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets,
SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters,
SSLConfig sslConfig)
Start a new Solr instance
|
JettySolrRunner |
stopJettySolrRunner(int index)
Stop a Solr instance
|
protected JettySolrRunner |
stopJettySolrRunner(JettySolrRunner jetty) |
void |
uploadConfigDir(File configDir,
String configName) |
public MiniSolrCloudCluster(int numServers, String hostContext, File baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters) throws Exception
numServers
- number of Solr servers to starthostContext
- context path of Solr servers used by JettybaseDir
- base directory that the mini cluster should be run fromsolrXml
- solr.xml file to be uploaded to ZooKeeperextraServlets
- Extra servlets to be started by JettyextraRequestFilters
- extra filters to be started by JettyException
- if there was an error starting the clusterpublic MiniSolrCloudCluster(int numServers, String hostContext, File baseDir, File solrXml, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters, SSLConfig sslConfig) throws Exception
numServers
- number of Solr servers to starthostContext
- context path of Solr servers used by JettybaseDir
- base directory that the mini cluster should be run fromsolrXml
- solr.xml file to be uploaded to ZooKeeperextraServlets
- Extra servlets to be started by JettyextraRequestFilters
- extra filters to be started by JettysslConfig
- SSL configurationException
- if there was an error starting the clusterpublic MiniSolrCloudCluster(int numServers, File baseDir, File solrXml, JettyConfig jettyConfig) throws Exception
numServers
- number of Solr servers to startbaseDir
- base directory that the mini cluster should be run fromsolrXml
- solr.xml file to be uploaded to ZooKeeperjettyConfig
- Jetty configurationException
- if there was an error starting the clusterpublic ZkTestServer getZkServer()
public List<JettySolrRunner> getJettySolrRunners()
public JettySolrRunner startJettySolrRunner(String hostContext, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters) throws Exception
hostContext
- context path of Solr servers used by JettyextraServlets
- Extra servlets to be started by JettyextraRequestFilters
- extra filters to be started by JettyException
public JettySolrRunner startJettySolrRunner(String hostContext, SortedMap<org.eclipse.jetty.servlet.ServletHolder,String> extraServlets, SortedMap<Class<? extends javax.servlet.Filter>,String> extraRequestFilters, SSLConfig sslConfig) throws Exception
hostContext
- context path of Solr servers used by JettyextraServlets
- Extra servlets to be started by JettyextraRequestFilters
- extra filters to be started by JettysslConfig
- SSL configurationException
public JettySolrRunner startJettySolrRunner(JettyConfig config) throws Exception
config
- a JettyConfig for the instance's JettySolrRunner
Exception
public JettySolrRunner startJettySolrRunner(String hostContext, JettyConfig config) throws Exception
hostContext
- the context to run onconfig
- a JettyConfig for the instance's JettySolrRunner
Exception
public JettySolrRunner startJettySolrRunner() throws Exception
Exception
public JettySolrRunner stopJettySolrRunner(int index) throws Exception
index
- the index of node in collection returned by getJettySolrRunners()
Exception
protected JettySolrRunner stopJettySolrRunner(JettySolrRunner jetty) throws Exception
Exception
public void uploadConfigDir(File configDir, String configName) throws IOException, org.apache.zookeeper.KeeperException, InterruptedException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
public NamedList<Object> createCollection(String name, int numShards, int replicationFactor, String configName, Map<String,String> collectionProperties) throws SolrServerException, IOException
SolrServerException
IOException
public NamedList<Object> createCollection(String name, int numShards, int replicationFactor, String configName, String createNodeSet, String asyncId, Map<String,String> collectionProperties) throws SolrServerException, IOException
SolrServerException
IOException
public NamedList<Object> deleteCollection(String name) throws SolrServerException, IOException
SolrServerException
IOException
public void shutdown() throws Exception
Exception
public CloudSolrClient getSolrClient()
protected CloudSolrClient buildSolrClient()
Copyright © 2000–2015 The Apache Software Foundation. All rights reserved.