org.elasticsearch.index.store

Class FsDirectoryService

java.lang.Object

org.elasticsearch.index.shard.AbstractIndexShardComponent

org.elasticsearch.index.store.DirectoryService

org.elasticsearch.index.store.FsDirectoryService

All Implemented Interfaces:

StoreRateLimiting.Listener, StoreRateLimiting.Provider, IndexShardComponent

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

Field Summary

Fields

Modifier and Type	Field and Description
static Setting<org.apache.lucene.store.LockFactory>	INDEX_LOCK_FACTOR_SETTING
protected IndexStore	indexStore

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

deprecationLogger, indexSettings, logger, shardId

Constructor Summary

Constructors

Constructor and Description
FsDirectoryService(IndexSettings indexSettings, IndexStore indexStore, ShardPath path)

Method Summary

Modifier and Type	Method and Description
org.apache.lucene.store.Directory	newDirectory()
protected org.apache.lucene.store.Directory	newFSDirectory(java.nio.file.Path location, org.apache.lucene.store.LockFactory lockFactory)
void	onPause(long nanos)
StoreRateLimiting	rateLimiting()
long	throttleTimeInNanos()

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 IndexStore indexStore

INDEX_LOCK_FACTOR_SETTING

public static final Setting<org.apache.lucene.store.LockFactory> INDEX_LOCK_FACTOR_SETTING

Constructor Detail

FsDirectoryService

@Inject
public FsDirectoryService(IndexSettings indexSettings,
                                  IndexStore indexStore,
                                  ShardPath path)

Method Detail

throttleTimeInNanos

public long throttleTimeInNanos()

Specified by:

throttleTimeInNanos in class DirectoryService

rateLimiting

public StoreRateLimiting rateLimiting()

Specified by:

rateLimiting in interface StoreRateLimiting.Provider

newDirectory

public org.apache.lucene.store.Directory newDirectory()
                                               throws java.io.IOException

Specified by:

newDirectory in class DirectoryService

Throws:

java.io.IOException

onPause

public void onPause(long nanos)

Specified by:

onPause in interface StoreRateLimiting.Listener

newFSDirectory

protected org.apache.lucene.store.Directory newFSDirectory(java.nio.file.Path location,
                                                           org.apache.lucene.store.LockFactory lockFactory)
                                                    throws java.io.IOException

Throws:

java.io.IOException