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 StringCONFIGS_ZKNODEZkNode 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 testsZkConfigSetService(CoreContainer cc)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancheckConfigExists(String configName)Check whether a config existsStringconfigSetName(CoreDescriptor cd)Return a name for the ConfigSet for a core to be used for printing/diagnostic purposes.voidcopyConfig(String fromConfig, String toConfig)Copy a configSolrResourceLoadercreateCoreResourceLoader(CoreDescriptor cd)Create a SolrResourceLoader for a corevoiddeleteConfig(String configName)Delete a config (recursively deletes its files if not empty)voiddeleteFilesFromConfig(String configName, List<String> filesToDelete)Delete files in configvoiddownloadConfig(String configName, Path dir)Download all files from this config to the filesystem at dirbyte[]downloadFileFromConfig(String configName, String filePath)Download a file from config If the file does not exist, it returns nullList<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 LonggetCurrentSchemaModificationVersion(String configSet, SolrConfig solrConfig, String schemaFile)Returns a modification version for the schema file.org.apache.solr.client.solrj.cloud.SolrCloudManagergetSolrCloudManager()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.voidsetConfigMetadata(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 metadatavoiduploadConfig(String configName, Path dir)Upload files from a given path to configvoiduploadFileToConfig(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
-
-
-
-
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:ConfigSetServiceCreate a SolrResourceLoader for a core- Specified by:
createCoreResourceLoaderin classConfigSetService- 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:ConfigSetServiceReturn the ConfigSet flags or null if none.- Overrides:
loadConfigSetFlagsin classConfigSetService- Throws:
IOException
-
getCurrentSchemaModificationVersion
protected Long getCurrentSchemaModificationVersion(String configSet, SolrConfig solrConfig, String schemaFile) throws IOException
Description copied from class:ConfigSetServiceReturns a modification version for the schema file. Null may be returned if not known, and if so it defeats schema caching.- Specified by:
getCurrentSchemaModificationVersionin classConfigSetService- Throws:
IOException
-
configSetName
public String configSetName(CoreDescriptor cd)
Description copied from class:ConfigSetServiceReturn a name for the ConfigSet for a core to be used for printing/diagnostic purposes.- Specified by:
configSetNamein classConfigSetService- 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:ConfigSetServiceCheck whether a config exists- Specified by:
checkConfigExistsin classConfigSetService- 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:ConfigSetServiceDelete a config (recursively deletes its files if not empty)- Specified by:
deleteConfigin classConfigSetService- Parameters:
configName- the config to delete- Throws:
IOException
-
deleteFilesFromConfig
public void deleteFilesFromConfig(String configName, List<String> filesToDelete) throws IOException
Description copied from class:ConfigSetServiceDelete files in config- Specified by:
deleteFilesFromConfigin classConfigSetService- Parameters:
configName- the name of the configfilesToDelete- 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:ConfigSetServiceCopy a config- Specified by:
copyConfigin classConfigSetService- Parameters:
fromConfig- the config to copy fromtoConfig- the config to copy to- Throws:
IOException
-
uploadConfig
public void uploadConfig(String configName, Path dir) throws IOException
Description copied from class:ConfigSetServiceUpload files from a given path to config- Specified by:
uploadConfigin classConfigSetService- Parameters:
configName- the config namedir-Pathto 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:ConfigSetServiceUpload 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:
uploadFileToConfigin classConfigSetService- Parameters:
configName- the name to give the configfileName- the name of the file with '/' used as the file path separatordata- the content of the fileoverwriteOnExists- 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:ConfigSetServiceSet 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:
setConfigMetadatain classConfigSetService- Parameters:
configName- the config namedata- the metadata to be set on config- Throws:
IOException
-
getConfigMetadata
public Map<String,Object> getConfigMetadata(String configName) throws IOException
Description copied from class:ConfigSetServiceGet the config metadata (mutable, non-null)- Specified by:
getConfigMetadatain classConfigSetService- 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:ConfigSetServiceDownload all files from this config to the filesystem at dir- Specified by:
downloadConfigin classConfigSetService- Parameters:
configName- the config to downloaddir- thePathto write files under- Throws:
IOException
-
downloadFileFromConfig
public byte[] downloadFileFromConfig(String configName, String filePath) throws IOException
Description copied from class:ConfigSetServiceDownload a file from config If the file does not exist, it returns null- Specified by:
downloadFileFromConfigin classConfigSetService- Parameters:
configName- the name of the configfilePath- 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:ConfigSetServiceList the names of configs (non-null)- Specified by:
listConfigsin classConfigSetService- Returns:
- list of config names
- Throws:
IOException
-
getAllConfigFiles
public List<String> getAllConfigFiles(String configName) throws IOException
Description copied from class:ConfigSetServiceGet 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:
getAllConfigFilesin classConfigSetService- 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()
-
-