Package org.apache.cassandra.db.rows

Class ColumnData.Reconciler

java.lang.Object
org.apache.cassandra.db.rows.ColumnData.Reconciler
All Implemented Interfaces:
AutoCloseable, UpdateFunction<ColumnData,ColumnData>
Enclosing class:
ColumnData
public static class ColumnData.Reconciler extends Object implements UpdateFunction<ColumnData,ColumnData>, AutoCloseable

  • Constructor Details

    • Reconciler

      public Reconciler()

  • Method Details

    • merge

      public ColumnData merge(ColumnData existing, ColumnData update)
      Description copied from interface: UpdateFunction
      Computes the result of merging the existing value with the one from the update.
      Specified by:
      merge in interface UpdateFunction<ColumnData,ColumnData>
      Parameters:
      existing - the value in the original tree we have matched
      update - the value in the updating collection that matched
      Returns:
      the value to insert into the new tree

    • onAllocatedOnHeap

      public void onAllocatedOnHeap(long heapSize)
      Specified by:
      onAllocatedOnHeap in interface UpdateFunction<ColumnData,ColumnData>
      Parameters:
      heapSize - extra heap space allocated (over previous tree)

    • insert

      public ColumnData insert(ColumnData insert)
      Description copied from interface: UpdateFunction
      Computes the value that should be inserted in the BTree.
      Specified by:
      insert in interface UpdateFunction<ColumnData,ColumnData>
      Parameters:
      insert - the update value
      Returns:
      the value that should be inserted in the BTree

    • retain

      public ColumnData retain(ColumnData existing)
      Checks if the specified value should be deleted or not.
      Parameters:
      existing - the existing value to check
      Returns:
      null if the value should be removed from the BTree or the existing value if it should not.

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable