Package org.elasticsearch.index.shard

Class RemoveCorruptedShardDataCommand

java.lang.Object

org.elasticsearch.cli.Command

org.elasticsearch.cli.EnvironmentAwareCommand

org.elasticsearch.cluster.coordination.ElasticsearchNodeCommand

org.elasticsearch.index.shard.RemoveCorruptedShardDataCommand

All Implemented Interfaces:

Closeable, AutoCloseable

public class RemoveCorruptedShardDataCommand
extends ElasticsearchNodeCommand

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	RemoveCorruptedShardDataCommand.CleanStatus

Nested classes/interfaces inherited from class org.elasticsearch.cluster.coordination.ElasticsearchNodeCommand

ElasticsearchNodeCommand.UnknownCondition, ElasticsearchNodeCommand.UnknownMetadataCustom

Field Summary

Fields inherited from class org.elasticsearch.cluster.coordination.ElasticsearchNodeCommand

ABORTED_BY_USER_MSG, CS_MISSING_MSG, DELIMITER, FAILED_TO_OBTAIN_NODE_LOCK_MSG, namedXContentRegistry

Fields inherited from class org.elasticsearch.cli.Command

description, parser

Constructor Summary

Constructors

Constructor	Description
RemoveCorruptedShardDataCommand()

Method Summary

Modifier and Type	Method	Description
protected void	addNewHistoryCommit(org.apache.lucene.store.Directory indexDirectory, Terminal terminal, boolean updateLocalCheckpoint)
protected void	dropCorruptMarkerFiles(Terminal terminal, Path path, org.apache.lucene.store.Directory directory, boolean clean)
protected void	findAndProcessShardPath(joptsimple.OptionSet options, Environment environment, Path[] dataPaths, int nodeLockId, ClusterState clusterState, CheckedConsumer<ShardPath,IOException> consumer)
joptsimple.OptionParser	getParser()
protected Path	getPath(String dirValue)
static boolean	isCorruptMarkerFileIsPresent(org.apache.lucene.store.Directory directory)
protected void	printAdditionalHelp(Terminal terminal)
void	processDataPaths(Terminal terminal, Path[] dataPaths, int nodeLockId, joptsimple.OptionSet options, Environment environment)	Process the paths.

Methods inherited from class org.elasticsearch.cluster.coordination.ElasticsearchNodeCommand

clusterState, confirm, createPersistedClusterStateService, execute, loadTermAndClusterState, processDataPaths, toDataPaths, validateBeforeLock

Methods inherited from class org.elasticsearch.cli.EnvironmentAwareCommand

createEnv, createEnv, execute

Methods inherited from class org.elasticsearch.cli.Command

addShutdownHook, close, exit, main, printUserException

Methods inherited from class java.lang.Object

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

Constructor Details

RemoveCorruptedShardDataCommand

public RemoveCorruptedShardDataCommand()

Method Details

printAdditionalHelp

protected void printAdditionalHelp(Terminal terminal)

Overrides:

printAdditionalHelp in class Command

getParser

public joptsimple.OptionParser getParser()

getPath

protected Path getPath(String dirValue)

findAndProcessShardPath

protected void findAndProcessShardPath(joptsimple.OptionSet options,
 Environment environment,
 Path[] dataPaths,
 int nodeLockId,
 ClusterState clusterState,
 CheckedConsumer<ShardPath,IOException> consumer)
                                throws IOException

Throws:

IOException

isCorruptMarkerFileIsPresent

public static boolean isCorruptMarkerFileIsPresent(org.apache.lucene.store.Directory directory)
                                            throws IOException

Throws:

IOException

dropCorruptMarkerFiles

protected void dropCorruptMarkerFiles(Terminal terminal,
 Path path,
 org.apache.lucene.store.Directory directory,
 boolean clean)
                               throws IOException

Throws:

IOException

processDataPaths

public void processDataPaths(Terminal terminal,
 Path[] dataPaths,
 int nodeLockId,
 joptsimple.OptionSet options,
 Environment environment)
                      throws IOException

Description copied from class: ElasticsearchNodeCommand

Process the paths. Locks for the paths is held during this method invocation.

Specified by:

processDataPaths in class ElasticsearchNodeCommand

Parameters:

terminal - the terminal to use for messages

dataPaths - the paths of the node to process

options - the command line options

environment - the env of the node to process

Throws:

IOException

addNewHistoryCommit

protected void addNewHistoryCommit(org.apache.lucene.store.Directory indexDirectory,
 Terminal terminal,
 boolean updateLocalCheckpoint)
                            throws IOException

Throws:

IOException