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

Class StoreFileTrackerForTest

java.lang.Object
org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTrackerForTest
All Implemented Interfaces:
org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
public class StoreFileTrackerForTest 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
     
    private static final org.slf4j.Logger
    LOG
     
    private String
    storeId
     
    private static ConcurrentMap<String,BlockingQueue<org.apache.hadoop.hbase.regionserver.StoreFileInfo>>
    trackedFiles
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    StoreFileTrackerForTest(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)
     
    static void
    clear()
     
    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> newFiles)
     
    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 p)
     
    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)
     
    static boolean
    tracked(String encodedRegionName, String family, org.apache.hadoop.fs.Path file)
     
    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

    • LOG

      private static final org.slf4j.Logger LOG

    • trackedFiles

      private static ConcurrentMap<String,BlockingQueue<org.apache.hadoop.hbase.regionserver.StoreFileInfo>> trackedFiles

    • storeId

      private String storeId

    • 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

    • StoreFileTrackerForTest

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

  • Method Details

    • doAddNewStoreFiles

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

    • doLoadStoreFiles

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

    • tracked

      public static boolean tracked(String encodedRegionName, String family, org.apache.hadoop.fs.Path file)

    • clear

      public static void clear()

    • readReference

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