Class Memtable

  • All Implemented Interfaces:
    java.lang.Comparable<Memtable>

    public class Memtable
    extends java.lang.Object
    implements java.lang.Comparable<Memtable>
    • Method Detail

      • compareTo

        public int compareTo​(Memtable that)
        Specified by:
        compareTo in interface java.lang.Comparable<Memtable>
      • getLiveDataSize

        public long getLiveDataSize()
      • getOperations

        public long getOperations()
      • setDiscarding

        public void setDiscarding​(OpOrder.Barrier writeBarrier,
                                  java.util.concurrent.atomic.AtomicReference<CommitLogPosition> commitLogUpperBound)
      • isLive

        public boolean isLive()
      • isClean

        public boolean isClean()
      • mayContainDataBefore

        public boolean mayContainDataBefore​(CommitLogPosition position)
      • isExpired

        public boolean isExpired()
        Returns:
        true if this memtable is expired. Expiration time is determined by CF's memtable_flush_period_in_ms.
      • partitionCount

        public int partitionCount()
      • flushRunnables

        public java.util.List<org.apache.cassandra.db.Memtable.FlushRunnable> flushRunnables​(LifecycleTransaction txn)
      • abortRunnables

        public java.lang.Throwable abortRunnables​(java.util.List<org.apache.cassandra.db.Memtable.FlushRunnable> runnables,
                                                  java.lang.Throwable t)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • getMinTimestamp

        public long getMinTimestamp()
      • makeUnflushable

        public void makeUnflushable()
        For testing only. Give this memtable too big a size to make it always fail flushing.