public class HdfsDirectoryFactory extends CachingDirectoryFactory implements SolrCoreAware
CachingDirectoryFactory.CacheValue, CachingDirectoryFactory.CloseListenerDirectoryFactory.DirContext| Modifier and Type | Field and Description |
|---|---|
static String |
BLOCKCACHE_DIRECT_MEMORY_ALLOCATION |
static String |
BLOCKCACHE_ENABLED |
static String |
BLOCKCACHE_GLOBAL |
static String |
BLOCKCACHE_READ_ENABLED |
static String |
BLOCKCACHE_SLAB_COUNT |
static String |
BLOCKCACHE_WRITE_ENABLED |
static String |
CACHE_MERGES |
static String |
CACHE_READONCE |
static String |
CONFIG_DIRECTORY |
static String |
HDFS_HOME |
static String |
KERBEROS_ENABLED |
static String |
KERBEROS_KEYTAB |
static String |
KERBEROS_PRINCIPAL |
static String |
LOCALITYMETRICS_ENABLED |
static Metrics |
metrics |
static String |
NRTCACHINGDIRECTORY_ENABLE |
static String |
NRTCACHINGDIRECTORY_MAXCACHEMB |
static String |
NRTCACHINGDIRECTORY_MAXMERGESIZEMB |
static String |
NUMBEROFBLOCKSPERBANK |
byDirectoryCache, byPathCache, closeListeners, removeEntriescoreContainer, INDEX_W_TIMESTAMP_REGEX, IOCONTEXT_NO_CACHE, LOCK_TYPE_HDFS, LOCK_TYPE_NATIVE, LOCK_TYPE_NONE, LOCK_TYPE_SIMPLE, LOCK_TYPE_SINGLE| Constructor and Description |
|---|
HdfsDirectoryFactory() |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanupOldIndexDirectories(String dataDir,
String currentIndexDir) |
void |
close()
Close the this and all of the Directories it contains.
|
protected Directory |
create(String path,
LockFactory lockFactory,
DirectoryFactory.DirContext dirContext)
Creates a new Directory for a given path.
|
protected LockFactory |
createLockFactory(String rawLockType)
Creates a new LockFactory for a given path.
|
boolean |
exists(String path)
Returns true if a Directory exists for a given path.
|
org.apache.hadoop.conf.Configuration |
getConf() |
String |
getConfDir() |
String |
getDataHome(CoreDescriptor cd) |
void |
inform(SolrCore core) |
void |
init(NamedList args) |
boolean |
isAbsolute(String path) |
boolean |
isPersistent() |
boolean |
isSharedStorage() |
Collection<SolrInfoMBean> |
offerMBeans()
Optionally allow the DirectoryFactory to request registration of some MBeans.
|
protected void |
removeDirectory(CachingDirectoryFactory.CacheValue cacheValue) |
boolean |
searchersReserveCommitPoints()
If your implementation can count on delete-on-last-close semantics
or throws an exception when trying to remove a file in use, return
false (eg NFS).
|
long |
size(Directory directory) |
long |
size(String path) |
addCloseListener, deleteOldIndexDirectory, doneWithDirectory, get, getLivePaths, getPath, incRef, normalize, release, remove, remove, remove, remove, stripTrailingSlashempty, initCoreContainer, move, sizeOf, sizeOfDirectorypublic static final String BLOCKCACHE_SLAB_COUNT
public static final String BLOCKCACHE_DIRECT_MEMORY_ALLOCATION
public static final String BLOCKCACHE_ENABLED
public static final String BLOCKCACHE_GLOBAL
public static final String BLOCKCACHE_READ_ENABLED
public static final String BLOCKCACHE_WRITE_ENABLED
public static final String NRTCACHINGDIRECTORY_ENABLE
public static final String NRTCACHINGDIRECTORY_MAXMERGESIZEMB
public static final String NRTCACHINGDIRECTORY_MAXCACHEMB
public static final String NUMBEROFBLOCKSPERBANK
public static final String LOCALITYMETRICS_ENABLED
public static final String KERBEROS_ENABLED
public static final String KERBEROS_KEYTAB
public static final String KERBEROS_PRINCIPAL
public static final String HDFS_HOME
public static final String CONFIG_DIRECTORY
public static final String CACHE_MERGES
public static final String CACHE_READONCE
public static Metrics metrics
public void close()
throws IOException
DirectoryFactoryclose in interface Closeableclose in interface AutoCloseableclose in class CachingDirectoryFactoryIOException - If there is a low-level I/O error.public void init(NamedList args)
init in interface NamedListInitializedPlugininit in class CachingDirectoryFactoryprotected LockFactory createLockFactory(String rawLockType) throws IOException
DirectoryFactorycreateLockFactory in class DirectoryFactoryrawLockType - A string value as passed in config. Every factory should at least support 'none' to disable locking.IOException - If there is a low-level I/O error.protected Directory create(String path, LockFactory lockFactory, DirectoryFactory.DirContext dirContext) throws IOException
DirectoryFactorycreate in class DirectoryFactoryIOException - If there is a low-level I/O error.public boolean exists(String path)
DirectoryFactoryexists in class CachingDirectoryFactorypublic org.apache.hadoop.conf.Configuration getConf()
protected void removeDirectory(CachingDirectoryFactory.CacheValue cacheValue) throws IOException
removeDirectory in class CachingDirectoryFactoryIOExceptionpublic boolean isAbsolute(String path)
isAbsolute in class DirectoryFactorypath - the path to checkpublic boolean isPersistent()
isPersistent in class DirectoryFactorypublic boolean isSharedStorage()
isSharedStorage in class DirectoryFactorypublic boolean searchersReserveCommitPoints()
DirectoryFactorysearchersReserveCommitPoints in class DirectoryFactorypublic String getDataHome(CoreDescriptor cd) throws IOException
getDataHome in class DirectoryFactoryIOExceptionpublic long size(Directory directory) throws IOException
size in class DirectoryFactorydirectory - to calculate size ofIOException - on low level IO errorpublic long size(String path) throws IOException
size in class DirectoryFactorypath - to calculate size ofIOException - on low level IO errorpublic String getConfDir()
public Collection<SolrInfoMBean> offerMBeans()
DirectoryFactoryofferMBeans in class DirectoryFactorypublic void inform(SolrCore core)
inform in interface SolrCoreAwarepublic void cleanupOldIndexDirectories(String dataDir, String currentIndexDir)
cleanupOldIndexDirectories in class DirectoryFactoryCopyright © 2000-2016 Apache Software Foundation. All Rights Reserved.