Package org.elasticsearch.index.shard

Class RemoveCorruptedShardDataCommand

org.elasticsearch.cli.Command

org.elasticsearch.cli.EnvironmentAwareCommand

org.elasticsearch.cluster.coordination.ElasticsearchNodeCommand

org.elasticsearch.index.shard.RemoveCorruptedShardDataCommand

All Implemented Interfaces:

,

public class RemoveCorruptedShardDataCommand
extends ElasticsearchNodeCommand

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	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, org.elasticsearch.cli.Terminal terminal, boolean updateLocalCheckpoint)
protected void	dropCorruptMarkerFiles(org.elasticsearch.cli.Terminal terminal, path, org.apache.lucene.store.Directory directory, boolean clean)
protected void	findAndProcessShardPath(joptsimple.OptionSet options, Environment environment, [] dataPaths, int nodeLockId, ClusterState clusterState, org.elasticsearch.core.CheckedConsumer<> consumer)
joptsimple.OptionParser	getParser()
protected	dirValue)
static boolean	isCorruptMarkerFileIsPresent(org.apache.lucene.store.Directory directory)
protected void	printAdditionalHelp(org.elasticsearch.cli.Terminal terminal)
void	processNodePaths(org.elasticsearch.cli.Terminal terminal, [] 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, processNodePaths, toNodePaths, validateBeforeLock

Methods inherited from class org.elasticsearch.cli.EnvironmentAwareCommand

createEnv, createEnv, execute

Methods inherited from class org.elasticsearch.cli.Command

addShutdownHook, close, exit, main

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Details

RemoveCorruptedShardDataCommand

public RemoveCorruptedShardDataCommand()

Method Details

printAdditionalHelp

protected void printAdditionalHelp(org.elasticsearch.cli.Terminal terminal)

Overrides:

printAdditionalHelp in class org.elasticsearch.cli.Command

getParser

public joptsimple.OptionParser getParser()

getPath

protected  getPath( dirValue)

findAndProcessShardPath

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

Throws:

isCorruptMarkerFileIsPresent

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

Throws:

dropCorruptMarkerFiles

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

Throws:

processNodePaths

public void processNodePaths(org.elasticsearch.cli.Terminal terminal,
 [] dataPaths,
 int nodeLockId,
 joptsimple.OptionSet options,
 Environment environment)
                      throws 

Description copied from class: ElasticsearchNodeCommand

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

Specified by:

processNodePaths 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:

addNewHistoryCommit

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

Throws: