Package org.apache.solr.cloud

Class ZkConfigSetService

java.lang.Object

org.apache.solr.core.ConfigSetService

org.apache.solr.cloud.ZkConfigSetService

public class ZkConfigSetService
extends ConfigSetService

SolrCloud Zookeeper ConfigSetService impl.

Nested Class Summary

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

ConfigSetService.ConfigResource

Field Summary

Fields

Modifier and Type	Field	Description
static String	CONFIGS_ZKNODE	ZkNode where named configs are stored

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

parentLoader, UPLOAD_FILENAME_EXCLUDE_PATTERN, UPLOAD_FILENAME_EXCLUDE_REGEX

Constructor Summary

Constructors

Constructor	Description
ZkConfigSetService(org.apache.solr.common.cloud.SolrZkClient zkClient)	This is for ZkCLI and some tests
ZkConfigSetService(CoreContainer cc)

Method Summary

Modifier and Type	Method	Description
boolean	checkConfigExists(String configName)	Check whether a config exists
String	configSetName(CoreDescriptor cd)	Return a name for the ConfigSet for a core to be used for printing/diagnostic purposes.
void	copyConfig(String fromConfig, String toConfig)	Copy a config
SolrResourceLoader	createCoreResourceLoader(CoreDescriptor cd)	Create a SolrResourceLoader for a core
void	deleteConfig(String configName)	Delete a config (recursively deletes its files if not empty)
void	deleteFilesFromConfig(String configName, List<String> filesToDelete)	Delete files in config
void	downloadConfig(String configName, Path dir)	Download all files from this config to the filesystem at dir
byte[]	downloadFileFromConfig(String configName, String filePath)	Download a file from config If the file does not exist, it returns null
List<String>	getAllConfigFiles(String configName)	Get the names of the files in config including dirs (mutable, non-null) sorted lexicographically e.g.
Map<String,Object>	getConfigMetadata(String configName)	Get the config metadata (mutable, non-null)
protected Long	getCurrentSchemaModificationVersion(String configSet, SolrConfig solrConfig, String schemaFile)	Returns a modification version for the schema file.
org.apache.solr.client.solrj.cloud.SolrCloudManager	getSolrCloudManager()
List<String>	listConfigs()	List the names of configs (non-null)
protected org.apache.solr.common.util.NamedList<Object>	loadConfigSetFlags(SolrResourceLoader loader)	Return the ConfigSet flags or null if none.
void	setConfigMetadata(String configName, Map<String,Object> data)	Set the config metadata If config does not exist, it will be created and set metadata on it Else metadata will be replaced with the provided metadata
protected void	uploadConfig(String configName, Path dir)	Upload files from a given path to config
void	uploadFileToConfig(String configName, String fileName, byte[] data, boolean overwriteOnExists)	Upload a file to config If file does not exist, it will be uploaded If overwriteOnExists is set to true then file will be overwritten

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

bootstrapConf, createConfigSetService, createIndexSchema, createSolrConfig, getConfigsetPath, getDefaultConfigDirPath, isConfigSetTrusted, isConfigSetTrusted, loadConfigSet, loadConfigSetProperties, setConfigMetadataWithTrust, setConfigSetTrust, uploadConfig

Methods inherited from class java.lang.Object

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

Field Detail

CONFIGS_ZKNODE

public static final String CONFIGS_ZKNODE

ZkNode where named configs are stored

See Also:

Constant Field Values

Constructor Detail

ZkConfigSetService

public ZkConfigSetService(CoreContainer cc)

ZkConfigSetService

public ZkConfigSetService(org.apache.solr.common.cloud.SolrZkClient zkClient)

This is for ZkCLI and some tests

Method Detail

createCoreResourceLoader

public SolrResourceLoader createCoreResourceLoader(CoreDescriptor cd)

Description copied from class: ConfigSetService

Create a SolrResourceLoader for a core

Specified by:

createCoreResourceLoader in class ConfigSetService

Parameters:

cd - the core's CoreDescriptor

Returns:

a SolrResourceLoader

loadConfigSetFlags

protected org.apache.solr.common.util.NamedList<Object> loadConfigSetFlags(SolrResourceLoader loader)
                                                                    throws IOException

Description copied from class: ConfigSetService

Return the ConfigSet flags or null if none.

Overrides:

loadConfigSetFlags in class ConfigSetService

Throws:

IOException

getCurrentSchemaModificationVersion

protected Long getCurrentSchemaModificationVersion(String configSet,
                                                   SolrConfig solrConfig,
                                                   String schemaFile)
                                            throws IOException

Description copied from class: ConfigSetService

Returns a modification version for the schema file. Null may be returned if not known, and if so it defeats schema caching.

Specified by:

getCurrentSchemaModificationVersion in class ConfigSetService

Throws:

IOException

configSetName

public String configSetName(CoreDescriptor cd)

Description copied from class: ConfigSetService

Return a name for the ConfigSet for a core to be used for printing/diagnostic purposes.

Specified by:

configSetName in class ConfigSetService

Parameters:

cd - the core's CoreDescriptor

Returns:

a name for the core's ConfigSet

checkConfigExists

public boolean checkConfigExists(String configName)
                          throws IOException

Description copied from class: ConfigSetService

Check whether a config exists

Specified by:

checkConfigExists in class ConfigSetService

Parameters:

configName - the config to check if it exists

Returns:

whether the config exists or not

Throws:

IOException

deleteConfig

public void deleteConfig(String configName)
                  throws IOException

Description copied from class: ConfigSetService

Delete a config (recursively deletes its files if not empty)

Specified by:

deleteConfig in class ConfigSetService

Parameters:

configName - the config to delete

Throws:

IOException

deleteFilesFromConfig

public void deleteFilesFromConfig(String configName,
                                  List<String> filesToDelete)
                           throws IOException

Description copied from class: ConfigSetService

Delete files in config

Specified by:

deleteFilesFromConfig in class ConfigSetService

Parameters:

configName - the name of the config

filesToDelete - a list of file paths to delete using '/' as file path separator

Throws:

IOException

copyConfig

public void copyConfig(String fromConfig,
                       String toConfig)
                throws IOException

Description copied from class: ConfigSetService

Copy a config

Specified by:

copyConfig in class ConfigSetService

Parameters:

fromConfig - the config to copy from

toConfig - the config to copy to

Throws:

IOException

uploadConfig

protected void uploadConfig(String configName,
                            Path dir)
                     throws IOException

Description copied from class: ConfigSetService

Upload files from a given path to config

Specified by:

uploadConfig in class ConfigSetService

Parameters:

configName - the config name

dir - Path to the files

Throws:

IOException - if an I/O error occurs or the path does not exist

uploadFileToConfig

public void uploadFileToConfig(String configName,
                               String fileName,
                               byte[] data,
                               boolean overwriteOnExists)
                        throws IOException

Description copied from class: ConfigSetService

Upload a file to config If file does not exist, it will be uploaded If overwriteOnExists is set to true then file will be overwritten

Specified by:

uploadFileToConfig in class ConfigSetService

Parameters:

configName - the name to give the config

fileName - the name of the file with '/' used as the file path separator

data - the content of the file

overwriteOnExists - if true then file will be overwritten

Throws:

IOException

setConfigMetadata

public void setConfigMetadata(String configName,
                              Map<String,Object> data)
                       throws IOException

Description copied from class: ConfigSetService

Set the config metadata If config does not exist, it will be created and set metadata on it Else metadata will be replaced with the provided metadata

Specified by:

setConfigMetadata in class ConfigSetService

Parameters:

configName - the config name

data - the metadata to be set on config

Throws:

IOException

getConfigMetadata

public Map<String,Object> getConfigMetadata(String configName)
                                           throws IOException

Description copied from class: ConfigSetService

Get the config metadata (mutable, non-null)

Specified by:

getConfigMetadata in class ConfigSetService

Parameters:

configName - the config name

Returns:

the config metadata

Throws:

IOException

downloadConfig

public void downloadConfig(String configName,
                           Path dir)
                    throws IOException

Description copied from class: ConfigSetService

Download all files from this config to the filesystem at dir

Specified by:

downloadConfig in class ConfigSetService

Parameters:

configName - the config to download

dir - the Path to write files under

Throws:

IOException

downloadFileFromConfig

public byte[] downloadFileFromConfig(String configName,
                                     String filePath)
                              throws IOException

Description copied from class: ConfigSetService

Download a file from config If the file does not exist, it returns null

Specified by:

downloadFileFromConfig in class ConfigSetService

Parameters:

configName - the name of the config

filePath - the file to download with '/' as the separator

Returns:

the content of the file

Throws:

IOException

listConfigs

public List<String> listConfigs()
                         throws IOException

Description copied from class: ConfigSetService

List the names of configs (non-null)

Specified by:

listConfigs in class ConfigSetService

Returns:

list of config names

Throws:

IOException

getAllConfigFiles

public List<String> getAllConfigFiles(String configName)
                               throws IOException

Description copied from class: ConfigSetService

Get the names of the files in config including dirs (mutable, non-null) sorted lexicographically e.g. solrconfig.xml, lang/, lang/stopwords_en.txt

Specified by:

getAllConfigFiles in class ConfigSetService

Parameters:

configName - the config name

Returns:

list of file name paths in the config with '/' uses as file path separators

Throws:

IOException

getSolrCloudManager

public org.apache.solr.client.solrj.cloud.SolrCloudManager getSolrCloudManager()