com.bigdata.service

Class TxId2CommitTimeIndex

java.lang.Object

com.bigdata.btree.AbstractBTree

com.bigdata.btree.BTree

com.bigdata.service.TxId2CommitTimeIndex

All Implemented Interfaces:

IAutoboxBTree, IBTreeStatistics, ICheckpointProtocol, IIndex, IIndexLocalCounter, ILinearList, ILocalBTreeView, IRangeQuery, IReadWriteLockManager, ISimpleBTree, ISimpleIndexAccess, ISimpleTreeIndexAccess, ICounterSetAccess, ICommitter

public class TxId2CommitTimeIndex
extends BTree

BTree whose keys are the absolute value of the txIds and whose values are ITxState0 tuples for the transaction.

Version:

$Id: TxId2CommitTimeIndex.java 5948 2012-02-02 20:16:05Z thompsonbry $

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	TxId2CommitTimeIndex.TupleSerializer Encapsulates key and value formation.

Nested classes/interfaces inherited from class com.bigdata.btree.BTree

BTree.Counter, BTree.LeafCursor, BTree.NodeFactory, BTree.PartitionedCounter, BTree.Stack

Nested classes/interfaces inherited from class com.bigdata.btree.AbstractBTree

AbstractBTree.IBTreeCounters

Field Summary

Fields inherited from class com.bigdata.btree.BTree

counter, height, nentries, nleaves, nnodes, recordVersion

Fields inherited from class com.bigdata.btree.AbstractBTree

branchingFactor, debug, DEBUG, dumpLog, error, ERROR_CLOSED, ERROR_ERROR_STATE, ERROR_LESS_THAN_ZERO, ERROR_READ_ONLY, ERROR_TOO_LARGE, ERROR_TRANSIENT, INFO, log, metadata, ndistinctOnWriteRetentionQueue, nodeSer, readOnly, root, store, storeCache, writeRetentionQueue

Fields inherited from interface com.bigdata.btree.IRangeQuery

ALL, CURSOR, DEFAULT, DELETED, FIXED_LENGTH_SUCCESSOR, KEYS, NONE, PARALLEL, READONLY, REMOVEALL, REVERSE, VALS

Constructor Summary

Constructors

Constructor and Description
TxId2CommitTimeIndex(IRawStore store, Checkpoint checkpoint, IndexMetadata metadata, boolean readOnly) Load from the store.

Method Summary

Methods

Modifier and Type	Method and Description
void	add(AbstractTransactionService.TxState txState) Add an entry.
static TxId2CommitTimeIndex	createTransient() Create a transient instance.
long	find(long timestamp) Return the largest key that is less than or equal to the given timestamp.
long	findIndexOf(long timestamp) Find the index having the largest timestamp that is less than or equal to the given timestamp.
long	findNext(long timestamp) Find the first commit time strictly greater than the timestamp.

Methods inherited from class com.bigdata.btree.BTree

_reopen, asReadOnly, create, createTransient, createViewCheckpoint, fireDirtyEvent, getBloomFilter, getCheckpoint, getCounter, getDirtyListener, getEntryCount, getHeight, getLastCommitTime, getLeafCount, getMetadataAddr, getMutableBTree, getNodeCount, getRecordVersion, getRevisionTimestamp, getRootAddr, getSourceCount, getSources, getStore, handleCommit, invalidate, load, needsCheckpoint, newLeafCursor, newLeafCursor, readBloomFilter, removeAll, setDirtyListener, setIndexMetadata, setLastCommitTime, writeCheckpoint, writeCheckpoint2

Methods inherited from class com.bigdata.btree.AbstractBTree

assertNotReadOnly, assertNotTransient, close, contains, contains, decodeRecordAddr, dump, dump, dumpPages, encodeRecordAddr, getBranchingFactor, getBtreeCounters, getContainsTuple, getCounters, getIndexMetadata, getLevel, getLevel, getLookupTuple, getNodeSerializer, getReadLockCount, getResourceMetadata, getRightMostNode, getRoot, getRootOrFinger, getStatistics, getUtilization, getWriteTuple, indexOf, insert, insert, insert, isBalanced, isOpen, isReadOnly, isTransient, keyAt, lookup, lookup, lookup, putIfAbsent, rangeCheck, rangeCopy, rangeCount, rangeCount, rangeCount, rangeCountExact, rangeCountExactWithDeleted, rangeIterator, rangeIterator, rangeIterator, rangeIterator, rangeIterator, readLock, readNodeOrLeaf, recycle, remove, remove, remove, reopen, scan, setBTreeCounters, submit, submit, submit, toString, touch, valueAt, valueAt, writeLock, writeNodeOrLeaf, writeNodeRecursive, writeNodeRecursiveCallersThread, writeNodeRecursiveConcurrent

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.btree.ICheckpointProtocol

close, dumpPages, getIndexMetadata, isOpen, reopen

Methods inherited from interface com.bigdata.counters.ICounterSetAccess

getCounters

Methods inherited from interface com.bigdata.btree.ISimpleIndexAccess

rangeCount, scan

Methods inherited from interface com.bigdata.btree.IReadWriteLockManager

getReadLockCount, isReadOnly, readLock, writeLock

Constructor Detail

TxId2CommitTimeIndex

public TxId2CommitTimeIndex(IRawStore store,
                    Checkpoint checkpoint,
                    IndexMetadata metadata,
                    boolean readOnly)

Load from the store.

Parameters:

store - The backing store.

checkpoint - The Checkpoint record.

metadata - The metadata record for the index.

Method Detail

createTransient

public static TxId2CommitTimeIndex createTransient()

Create a transient instance.

Returns:

The new instance.

find

public long find(long timestamp)

Return the largest key that is less than or equal to the given timestamp. This is used primarily to locate the commit point that will serve as the ground state for a transaction having timestamp as its start time. In this context the LTE search identifies the most recent commit point that not later than the start time of the transaction.

Parameters:

timestamp - The given timestamp.

Returns:

The timestamp -or- -1L iff there is no entry in the index which satisifies the probe.

Throws:

IllegalArgumentException - if timestamp is less than or equals to ZERO (0L).

findNext

public long findNext(long timestamp)

Find the first commit time strictly greater than the timestamp.

Parameters:

timestamp - The timestamp. A value of ZERO (0) may be used to find the first commit time.

Returns:

The commit time -or- -1L if there is no commit record whose timestamp is strictly greater than timestamp.

findIndexOf

public long findIndexOf(long timestamp)

Find the index having the largest timestamp that is less than or equal to the given timestamp.

Returns:

The index having the largest timestamp that is less than or equal to the given timestamp -or- -1 iff there are no index entries.

add

public void add(AbstractTransactionService.TxState txState)

Add an entry.

Parameters:

txState - The transaction object.

Throws:

IllegalArgumentException - if txState is null.