org.elasticsearch.index.deletionpolicy

Class KeepLastNDeletionPolicy

java.lang.Object

org.apache.lucene.index.IndexDeletionPolicy

org.elasticsearch.index.deletionpolicy.KeepLastNDeletionPolicy

All Implemented Interfaces:

IndexShardComponent

public class KeepLastNDeletionPolicy
extends org.apache.lucene.index.IndexDeletionPolicy

Field Summary

Fields

Modifier and Type	Field and Description
protected Settings	componentSettings
protected Settings	indexSettings
protected ESLogger	logger
protected ShardId	shardId

Constructor Summary

Constructors

Constructor and Description
KeepLastNDeletionPolicy(ShardId shardId, Settings indexSettings)

Method Summary

Modifier and Type	Method and Description
Settings	indexSettings()
String	nodeName()
void	onCommit(List<? extends org.apache.lucene.index.IndexCommit> commits)
void	onInit(List<? extends org.apache.lucene.index.IndexCommit> commits)
ShardId	shardId()

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final ESLogger logger

shardId

protected final ShardId shardId

indexSettings

protected final Settings indexSettings

componentSettings

protected final Settings componentSettings

Constructor Detail

KeepLastNDeletionPolicy

@Inject
public KeepLastNDeletionPolicy(ShardId shardId,
                                       @IndexSettings
                                       Settings indexSettings)

Method Detail

onInit

public void onInit(List<? extends org.apache.lucene.index.IndexCommit> commits)
            throws IOException

Specified by:

onInit in class org.apache.lucene.index.IndexDeletionPolicy

Throws:

IOException

onCommit

public void onCommit(List<? extends org.apache.lucene.index.IndexCommit> commits)
              throws IOException

Specified by:

onCommit in class org.apache.lucene.index.IndexDeletionPolicy

Throws:

IOException

shardId

public ShardId shardId()

Specified by:

shardId in interface IndexShardComponent

indexSettings

public Settings indexSettings()

Specified by:

indexSettings in interface IndexShardComponent

nodeName

public String nodeName()