org.elasticsearch.index.store.fs

Class FsDirectoryService

java.lang.Object

org.elasticsearch.index.shard.AbstractIndexShardComponent

org.elasticsearch.index.store.DirectoryService

org.elasticsearch.index.store.fs.FsDirectoryService

All Implemented Interfaces:

StoreRateLimiting.Listener, StoreRateLimiting.Provider, IndexShardComponent

Direct Known Subclasses:

DefaultFsDirectoryService, MmapFsDirectoryService, NioFsDirectoryService, SimpleFsDirectoryService

public abstract class FsDirectoryService
extends DirectoryService
implements StoreRateLimiting.Listener, StoreRateLimiting.Provider

Field Summary

Fields

Modifier and Type	Field and Description
protected FsIndexStore	indexStore

Fields inherited from class org.elasticsearch.index.shard.AbstractIndexShardComponent

componentSettings, indexSettings, logger, shardId

Constructor Summary

Constructors

Constructor and Description
FsDirectoryService(ShardId shardId, Settings indexSettings, IndexStore indexStore)

Method Summary

Modifier and Type	Method and Description
org.apache.lucene.store.Directory[]	build()
static org.apache.lucene.store.LockFactory	buildLockFactory(Settings indexSettings)
protected abstract org.apache.lucene.store.Directory	newFSDirectory(File location, org.apache.lucene.store.LockFactory lockFactory)
void	onPause(long nanos)
StoreRateLimiting	rateLimiting()
void	renameFile(org.apache.lucene.store.Directory dir, String from, String to)
long	throttleTimeInNanos()

Methods inherited from class org.elasticsearch.index.store.DirectoryService

newFromDistributor

Methods inherited from class org.elasticsearch.index.shard.AbstractIndexShardComponent

indexSettings, nodeName, shardId

Methods inherited from class java.lang.Object

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

Field Detail

indexStore

protected final FsIndexStore indexStore

Constructor Detail

FsDirectoryService

public FsDirectoryService(ShardId shardId,
                          @IndexSettings
                          Settings indexSettings,
                          IndexStore indexStore)

Method Detail

throttleTimeInNanos

public long throttleTimeInNanos()

Specified by:

throttleTimeInNanos in class DirectoryService

rateLimiting

public StoreRateLimiting rateLimiting()

Specified by:

rateLimiting in interface StoreRateLimiting.Provider

buildLockFactory

public static org.apache.lucene.store.LockFactory buildLockFactory(@IndexSettings
                                                                   Settings indexSettings)
                                                            throws IOException

Throws:

IOException

renameFile

public final void renameFile(org.apache.lucene.store.Directory dir,
                             String from,
                             String to)
                      throws IOException

Specified by:

renameFile in class DirectoryService

Throws:

IOException

build

public org.apache.lucene.store.Directory[] build()
                                          throws IOException

Specified by:

build in class DirectoryService

Throws:

IOException

newFSDirectory

protected abstract org.apache.lucene.store.Directory newFSDirectory(File location,
                                                                    org.apache.lucene.store.LockFactory lockFactory)
                                                             throws IOException

Throws:

IOException

onPause

public void onPause(long nanos)

Specified by:

onPause in interface StoreRateLimiting.Listener