Class RemoveCorruptedShardDataCommand

java.lang.Object
org.elasticsearch.cli.Command
All Implemented Interfaces:
Closeable, AutoCloseable

public class RemoveCorruptedShardDataCommand extends ElasticsearchNodeCommand
  • 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 Path getPath(String dirValue)
    • findAndProcessShardPath

      protected void findAndProcessShardPath(joptsimple.OptionSet options, Environment environment, Path[] dataPaths, int nodeLockId, ClusterState clusterState, org.elasticsearch.core.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(org.elasticsearch.cli.Terminal terminal, Path path, org.apache.lucene.store.Directory directory, boolean clean) throws IOException
      Throws:
      IOException
    • processNodePaths

      public void processNodePaths(org.elasticsearch.cli.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:
      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:
      IOException
    • addNewHistoryCommit

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