Class MultiFileWriter

java.lang.Object
org.elasticsearch.core.AbstractRefCounted
org.elasticsearch.indices.recovery.MultiFileWriter
All Implemented Interfaces:
Closeable, AutoCloseable, RefCounted, Releasable

public class MultiFileWriter extends AbstractRefCounted implements Releasable
  • Constructor Details

  • Method Details

    • writeFileChunk

      public void writeFileChunk(StoreFileMetadata fileMetadata, long position, ReleasableBytesReference content, boolean lastChunk) throws IOException
      Throws:
      IOException
    • writeFile

      public void writeFile(StoreFileMetadata fileMetadata, long readSnapshotFileBufferSize, InputStream stream) throws Exception
      Throws:
      Exception
    • deleteTempFiles

      public void deleteTempFiles()
    • getOpenIndexOutput

      public org.apache.lucene.store.IndexOutput getOpenIndexOutput(String key)
    • removeOpenIndexOutputs

      public org.apache.lucene.store.IndexOutput removeOpenIndexOutputs(String name)
      remove and IndexOutput for a given file. It is the caller's responsibility to close it
    • openAndPutIndexOutput

      public org.apache.lucene.store.IndexOutput openAndPutIndexOutput(String fileName, StoreFileMetadata metadata, Store store) throws IOException
      Creates an IndexOutput for the given file name. Note that the IndexOutput actually point at a temporary file.

      Note: You can use getOpenIndexOutput(String) with the same filename to retrieve the same IndexOutput at a later stage

      Throws:
      IOException
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface Releasable
    • closeInternal

      protected void closeInternal()
      Specified by:
      closeInternal in class AbstractRefCounted
    • renameAllTempFiles

      public void renameAllTempFiles() throws IOException
      renames all temporary files to their true name, potentially overriding existing files
      Throws:
      IOException