Package org.rocksdb

Class FlushJobInfo

java.lang.Object
org.rocksdb.FlushJobInfo
public class FlushJobInfo extends Object

  • Method Details

    • getColumnFamilyId

      public long getColumnFamilyId()
      Get the id of the column family.
      Returns:
      the id of the column family

    • getColumnFamilyName

      public String getColumnFamilyName()
      Get the name of the column family.
      Returns:
      the name of the column family

    • getFilePath

      public String getFilePath()
      Get the path to the newly created file.
      Returns:
      the path to the newly created file

    • getThreadId

      public long getThreadId()
      Get the id of the thread that completed this flush job.
      Returns:
      the id of the thread that completed this flush job

    • getJobId

      public int getJobId()
      Get the job id, which is unique in the same thread.
      Returns:
      the job id

    • isTriggeredWritesSlowdown

      public boolean isTriggeredWritesSlowdown()
      Determine if rocksdb is currently slowing-down all writes to prevent creating too many Level 0 files as compaction seems not able to catch up the write request speed.

      This indicates that there are too many files in Level 0.

      Returns:
      true if rocksdb is currently slowing-down all writes, false otherwise

    • isTriggeredWritesStop

      public boolean isTriggeredWritesStop()
      Determine if rocksdb is currently blocking any writes to prevent creating more L0 files.

      This indicates that there are too many files in level 0. Compactions should try to compact L0 files down to lower levels as soon as possible.

      Returns:
      true if rocksdb is currently blocking any writes, false otherwise

    • getSmallestSeqno

      public long getSmallestSeqno()
      Get the smallest sequence number in the newly created file.
      Returns:
      the smallest sequence number

    • getLargestSeqno

      public long getLargestSeqno()
      Get the largest sequence number in the newly created file.
      Returns:
      the largest sequence number

    • getTableProperties

      public TableProperties getTableProperties()
      Get the Table properties of the table being flushed.
      Returns:
      the Table properties of the table being flushed

    • getFlushReason

      public FlushReason getFlushReason()
      Get the reason for initiating the flush.
      Returns:
      the reason for initiating the flush.

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object