Package org.apache.hadoop.hbase.regionserver

Class TestCompactionArchiveConcurrentClose.WaitingStoreFileTracker

java.lang.Object
org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerForTest
org.apache.hadoop.hbase.regionserver.TestCompactionArchiveConcurrentClose.WaitingStoreFileTracker
All Implemented Interfaces:
org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
Enclosing class:
TestCompactionArchiveConcurrentClose
public static class TestCompactionArchiveConcurrentClose.WaitingStoreFileTracker extends StoreFileTrackerForTest

  • Field Details

    • conf

      protected final org.apache.hadoop.conf.Configuration conf

    • isPrimaryReplica

      protected final boolean isPrimaryReplica

    • ctx

      protected final org.apache.hadoop.hbase.regionserver.StoreContext ctx

  • Constructor Details

    • WaitingStoreFileTracker

      public WaitingStoreFileTracker(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, org.apache.hadoop.hbase.regionserver.StoreContext ctx)

  • Method Details

    • removeStoreFiles

      public void removeStoreFiles(List<org.apache.hadoop.hbase.regionserver.HStoreFile> storeFiles) throws IOException
      Specified by:
      removeStoreFiles in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • requireWritingToTmpDirFirst

      public boolean requireWritingToTmpDirFirst()

    • doAddCompactionResults

      protected void doAddCompactionResults(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1) throws IOException
      Throws:
      IOException

    • doSetStoreFiles

      protected void doSetStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0) throws IOException
      Throws:
      IOException

    • getStoreFiles

      public List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> getStoreFiles(String arg0) throws IOException
      Throws:
      IOException

    • load

      public final List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> load() throws IOException
      Specified by:
      load in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • add

      public final void add(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0) throws IOException
      Specified by:
      add in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • replace

      public final void replace(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1) throws IOException
      Specified by:
      replace in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • set

      public final void set(List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0) throws IOException
      Specified by:
      set in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • updateWithTrackerConfigs

      public org.apache.hadoop.hbase.client.TableDescriptorBuilder updateWithTrackerConfigs(org.apache.hadoop.hbase.client.TableDescriptorBuilder arg0)
      Specified by:
      updateWithTrackerConfigs in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

    • getTrackerName

      protected final String getTrackerName()

    • createWriter

      public final org.apache.hadoop.hbase.regionserver.StoreFileWriter createWriter(org.apache.hadoop.hbase.regionserver.CreateStoreFileWriterParams arg0) throws IOException
      Specified by:
      createWriter in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • createReference

      public org.apache.hadoop.hbase.io.Reference createReference(org.apache.hadoop.hbase.io.Reference arg0, org.apache.hadoop.fs.Path arg1) throws IOException
      Specified by:
      createReference in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • hasReferences

      public boolean hasReferences() throws IOException
      Specified by:
      hasReferences in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • getStoreFileInfo

      public org.apache.hadoop.hbase.regionserver.StoreFileInfo getStoreFileInfo(org.apache.hadoop.fs.Path arg0, boolean arg1) throws IOException
      Specified by:
      getStoreFileInfo in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • getStoreFileInfo

      public org.apache.hadoop.hbase.regionserver.StoreFileInfo getStoreFileInfo(org.apache.hadoop.fs.FileStatus arg0, org.apache.hadoop.fs.Path arg1, boolean arg2) throws IOException
      Specified by:
      getStoreFileInfo in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • createHFileLink

      public String createHFileLink(org.apache.hadoop.hbase.TableName arg0, String arg1, String arg2, boolean arg3) throws IOException
      Specified by:
      createHFileLink in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • createFromHFileLink

      public String createFromHFileLink(String arg0, boolean arg1) throws IOException
      Specified by:
      createFromHFileLink in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • archiveStoreFiles

      protected void archiveStoreFiles(List<org.apache.hadoop.hbase.regionserver.HStoreFile> arg0) throws IOException
      Throws:
      IOException