Class RemoveCorruptedShardDataCommand

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class RemoveCorruptedShardDataCommand
    extends EnvironmentAwareCommand
    • Constructor Detail

      • RemoveCorruptedShardDataCommand

        public RemoveCorruptedShardDataCommand()
      • RemoveCorruptedShardDataCommand

        public RemoveCorruptedShardDataCommand​(boolean translogOnly)
    • Method Detail

      • getParser

        public joptsimple.OptionParser getParser()
      • getPath

        protected java.nio.file.Path getPath​(java.lang.String dirValue)
      • findAndProcessShardPath

        protected void findAndProcessShardPath​(joptsimple.OptionSet options,
                                               Environment environment,
                                               CheckedConsumer<ShardPath,​java.io.IOException> consumer)
                                        throws java.io.IOException
        Throws:
        java.io.IOException
      • isCorruptMarkerFileIsPresent

        public static boolean isCorruptMarkerFileIsPresent​(org.apache.lucene.store.Directory directory)
                                                    throws java.io.IOException
        Throws:
        java.io.IOException
      • dropCorruptMarkerFiles

        protected void dropCorruptMarkerFiles​(Terminal terminal,
                                              java.nio.file.Path path,
                                              org.apache.lucene.store.Directory directory,
                                              boolean clean)
                                       throws java.io.IOException
        Throws:
        java.io.IOException
      • addNewHistoryCommit

        protected void addNewHistoryCommit​(org.apache.lucene.store.Directory indexDirectory,
                                           Terminal terminal,
                                           boolean updateLocalCheckpoint)
                                    throws java.io.IOException
        Throws:
        java.io.IOException
      • newAllocationId

        protected void newAllocationId​(Environment environment,
                                       ShardPath shardPath,
                                       Terminal terminal)
                                throws java.io.IOException
        Throws:
        java.io.IOException