Package org.apache.hadoop.hbase.regionserver.storefiletracker

Class FailingStoreFileTrackerForTest

java.lang.Object
org.apache.hadoop.hbase.regionserver.storefiletracker.FailingStoreFileTrackerForTest
All Implemented Interfaces:
org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
public class FailingStoreFileTrackerForTest extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final org.apache.hadoop.conf.Configuration
    conf
     
    protected final org.apache.hadoop.hbase.regionserver.StoreContext
    ctx
     
    protected final boolean
    isPrimaryReplica
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    FailingStoreFileTrackerForTest(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, org.apache.hadoop.hbase.regionserver.StoreContext ctx)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    final void
    add(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
     
    org.apache.hadoop.hbase.io.Reference
    createReference(org.apache.hadoop.hbase.io.Reference arg0, org.apache.hadoop.fs.Path arg1)
     
    final org.apache.hadoop.hbase.regionserver.StoreFileWriter
    createWriter(org.apache.hadoop.hbase.regionserver.CreateStoreFileWriterParams arg0)
     
    protected void
    doAddCompactionResults(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
     
    protected void
    doAddNewStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
     
    protected List<org.apache.hadoop.hbase.regionserver.StoreFileInfo>
    doLoadStoreFiles(boolean readOnly)
     
    protected void
    doSetStoreFiles(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
     
    org.apache.hadoop.hbase.regionserver.StoreFileInfo
    getStoreFileInfo(org.apache.hadoop.fs.FileStatus arg0, org.apache.hadoop.fs.Path arg1, boolean arg2)
     
    org.apache.hadoop.hbase.regionserver.StoreFileInfo
    getStoreFileInfo(org.apache.hadoop.fs.Path arg0, boolean arg1)
     
    List<org.apache.hadoop.hbase.regionserver.StoreFileInfo>
    getStoreFiles(String arg0)
     
    protected final String
    getTrackerName()
     
    boolean
    hasReferences()
     
    final List<org.apache.hadoop.hbase.regionserver.StoreFileInfo>
    load()
     
    org.apache.hadoop.hbase.io.Reference
    readReference(org.apache.hadoop.fs.Path arg0)
     
    final void
    replace(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg1)
     
    boolean
    requireWritingToTmpDirFirst()
     
    final void
    set(List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
     
    org.apache.hadoop.hbase.client.TableDescriptorBuilder
    updateWithTrackerConfigs(org.apache.hadoop.hbase.client.TableDescriptorBuilder arg0)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • 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

    • FailingStoreFileTrackerForTest

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

  • Method Details

    • doLoadStoreFiles

      protected List<org.apache.hadoop.hbase.regionserver.StoreFileInfo> doLoadStoreFiles(boolean readOnly) throws IOException
      Throws:
      IOException

    • requireWritingToTmpDirFirst

      public boolean requireWritingToTmpDirFirst()

    • doAddNewStoreFiles

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

    • 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

    • readReference

      public org.apache.hadoop.hbase.io.Reference readReference(org.apache.hadoop.fs.Path arg0) throws IOException
      Specified by:
      readReference 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