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

Class DummyStoreFileTrackerForReadOnlyMode

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

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private boolean
    addExecuted
     
    private boolean
    compactionExecuted
     
    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 boolean
    readOnlyUsed
     
    private boolean
    setExecuted
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    DummyStoreFileTrackerForReadOnlyMode(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, org.apache.hadoop.hbase.TableName tableName)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    final void
    add(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> arg0)
     
    protected void
    archiveStoreFiles(List<org.apache.hadoop.hbase.regionserver.HStoreFile> arg0)
     
    private static org.apache.hadoop.hbase.regionserver.StoreContext
    buildStoreContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName)
     
    org.apache.hadoop.hbase.io.HFileLink
    createAndCommitHFileLink(org.apache.hadoop.hbase.TableName arg0, String arg1, String arg2, boolean arg3)
     
    org.apache.hadoop.hbase.io.Reference
    createAndCommitReference(org.apache.hadoop.hbase.io.Reference arg0, org.apache.hadoop.fs.Path arg1)
     
    org.apache.hadoop.hbase.io.HFileLink
    createFromHFileLink(String arg0, boolean arg1)
     
    org.apache.hadoop.hbase.io.HFileLink
    createHFileLink(org.apache.hadoop.hbase.TableName arg0, String arg1, String arg2, boolean arg3)
     
    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> compactedFiles, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> newFiles)
     
    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> files)
     
    org.apache.hadoop.hbase.regionserver.StoreContext
    getStoreContext()
     
    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)
     
    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)
     
    void
    removeStoreFiles(List<org.apache.hadoop.hbase.regionserver.HStoreFile> 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)
     
    (package private) boolean
    wasAddExecuted()
     
    (package private) boolean
    wasCompactionExecuted()
     
    (package private) boolean
    wasReadOnlyLoad()
     
    (package private) boolean
    wasSetExecuted()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

    onTransitionToActive

  • Field Details

    • LOG

      private static final org.slf4j.Logger LOG

    • readOnlyUsed

      private boolean readOnlyUsed

    • compactionExecuted

      private boolean compactionExecuted

    • addExecuted

      private boolean addExecuted

    • setExecuted

      private boolean setExecuted

    • 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

    • DummyStoreFileTrackerForReadOnlyMode

      public DummyStoreFileTrackerForReadOnlyMode(org.apache.hadoop.conf.Configuration conf, boolean isPrimaryReplica, org.apache.hadoop.hbase.TableName tableName)

  • Method Details

    • buildStoreContext

      private static org.apache.hadoop.hbase.regionserver.StoreContext buildStoreContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName)

    • doAddCompactionResults

      protected void doAddCompactionResults(Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> compactedFiles, Collection<org.apache.hadoop.hbase.regionserver.StoreFileInfo> newFiles)

    • doSetStoreFiles

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

    • doLoadStoreFiles

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

    • doAddNewStoreFiles

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

    • wasReadOnlyLoad

      boolean wasReadOnlyLoad()

    • wasCompactionExecuted

      boolean wasCompactionExecuted()

    • wasAddExecuted

      boolean wasAddExecuted()

    • wasSetExecuted

      boolean wasSetExecuted()

    • requireWritingToTmpDirFirst

      public boolean requireWritingToTmpDirFirst()

    • 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

    • createAndCommitReference

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

    • createAndCommitHFileLink

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

    • createHFileLink

      public org.apache.hadoop.hbase.io.HFileLink 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 org.apache.hadoop.hbase.io.HFileLink createFromHFileLink(String arg0, boolean arg1) throws IOException
      Specified by:
      createFromHFileLink in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker
      Throws:
      IOException

    • getStoreContext

      public org.apache.hadoop.hbase.regionserver.StoreContext getStoreContext()
      Specified by:
      getStoreContext in interface org.apache.hadoop.hbase.regionserver.storefiletracker.StoreFileTracker

    • removeStoreFiles

      public void removeStoreFiles(List<org.apache.hadoop.hbase.regionserver.HStoreFile> arg0) throws IOException
      Specified by:
      removeStoreFiles 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