Package org.apache.cassandra.db.partitions

Class BTreePartitionUpdater

java.lang.Object

org.apache.cassandra.db.partitions.BTreePartitionUpdater

All Implemented Interfaces:

ColumnData.PostReconciliationFunction, UpdateFunction<Row,Row>

public class BTreePartitionUpdater
extends Object
implements UpdateFunction<Row,Row>, ColumnData.PostReconciliationFunction

the function we provide to the trie and btree utilities to perform any row and column replacements

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.btree.UpdateFunction

UpdateFunction.Simple<V>

Field Summary

Fields

Modifier and Type	Field	Description
long	colUpdateTimeDelta
long	dataSize

Fields inherited from interface org.apache.cassandra.utils.btree.UpdateFunction

noOp

Constructor Summary

Constructors

Constructor	Description
BTreePartitionUpdater(MemtableAllocator allocator, Cloner cloner, OpOrder.Group writeOp, UpdateTransaction indexer)

Method Summary

Modifier and Type	Method	Description
void	delete(ColumnData existing)
ColumnData	insert(ColumnData insert)
Row	insert(Row insert)	Computes the value that should be inserted in the BTree.
protected BTreePartitionData	makeMergedPartition(BTreePartitionData current, PartitionUpdate update)
Cell<?>	merge(Cell<?> previous, Cell<?> insert)
Row	merge(Row existing, Row update)	Computes the result of merging the existing value with the one from the update.
BTreePartitionData	mergePartitions(BTreePartitionData current, PartitionUpdate update)
void	onAllocatedOnHeap(long heapSize)
void	reportAllocatedMemory()

Methods inherited from class java.lang.Object

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

Field Details

dataSize

public long dataSize

colUpdateTimeDelta

public long colUpdateTimeDelta

Constructor Details

BTreePartitionUpdater

public BTreePartitionUpdater(MemtableAllocator allocator,
 Cloner cloner,
 OpOrder.Group writeOp,
 UpdateTransaction indexer)

Method Details

mergePartitions

public BTreePartitionData mergePartitions(BTreePartitionData current,
 PartitionUpdate update)

makeMergedPartition

protected BTreePartitionData makeMergedPartition(BTreePartitionData current,
 PartitionUpdate update)

insert

public Row insert(Row insert)

Description copied from interface: UpdateFunction

Computes the value that should be inserted in the BTree.

Specified by:

insert in interface UpdateFunction<Row,Row>

Parameters:

insert - the update value

Returns:

the value that should be inserted in the BTree

merge

public Row merge(Row existing,
 Row 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<Row,Row>

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

merge

public Cell<?> merge(Cell<?> previous,
 Cell<?> insert)

Specified by:

merge in interface ColumnData.PostReconciliationFunction

insert

public ColumnData insert(ColumnData insert)

Specified by:

insert in interface ColumnData.PostReconciliationFunction

delete

public void delete(ColumnData existing)

Specified by:

delete in interface ColumnData.PostReconciliationFunction

onAllocatedOnHeap

public void onAllocatedOnHeap(long heapSize)

Specified by:

onAllocatedOnHeap in interface ColumnData.PostReconciliationFunction

Specified by:

onAllocatedOnHeap in interface UpdateFunction<Row,Row>

Parameters:

heapSize - extra heap space allocated (over previous tree)

reportAllocatedMemory

public void reportAllocatedMemory()