LcsClusterVerifier Class Reference

LcsClusterVerifier is a class for verifying cluster pages. More...

#include <LcsClusterVerifier.h>

Inheritance diagram for LcsClusterVerifier:

List of all members.

Public Member Functions
	LcsClusterVerifier (BTreeDescriptor const &treeDescriptor)
ClusterPageData &	getPageData ()
	Retrieves cluster page data for the current cluster page.
void	setRootPageId (PageId rootPageId)
	Sets the root pageId of the underlying btree corresponding to the cluster.
void	initColumnReaders (uint nClusterColsInit, TupleProjection const &clusterProj)
	Initializes cluster reader with column readers.
void	open ()
	Initializes state variables used by cluster reader.
void	close ()
	Performs shutdown on cluster reader.
bool	getFirstClusterPageForRead (PConstLcsClusterNode &pBlock)
	Gets first page in a cluster.
bool	getNextClusterPageForRead (PConstLcsClusterNode &pBlock)
	Gets next page in a cluster, based on current position in btree.
bool	isPositioned () const
	Returns true if positioned within some range in a batch.
LcsRid	getRangeStartRid () const
	Returns first rid in a range.
LcsRid	getRangeEndRid () const
	Returns first rid after the end of the current range.
uint	getRangeSize () const
	Returns number of rids in the range.
uint	getRangePos () const
	Returns offset within the current range.
LcsRid	getCurrentRid () const
	Returns rid currently positioned at.
uint	getRangeRowsLeft () const
	Returns number of rids yet to be read.
bool	position (LcsRid rid)
	Positions scan on the rid, moving to a new range if necessary.
bool	nextRange ()
	Positions scan on the first rid of the next range.
bool	advance (uint nRids)
	Moves "nRids" forward in the current range.
void	advanceWithinBatch (uint nRids)
	Advances nRids forward in the current batch.
virtual PageId	getNextPageForPrefetch (LcsRid &rid, bool &found)
	Determines the next page to be pre-fetched based on the rids that need to be read.
void	catchUp (uint parentBufPos, LcsRid parentNextRid)
	Resynchronizes the cluster reader's prefetch position to that of the parent scan.
RecordNum	getNumRows ()
	Returns: the number of rows in the cluster
uint	getNumClusterCols ()
	Returns number of columns in cluster.
void	setNumClusterCols (uint nCols)
	Sets number of columns in cluster.
void	unlockClusterPage ()
	Unlocks cluster page.
virtual void	initPrefetchEntry (LcsRid &entry)
	Initializes a specific entry in the pre-fetch queue.
Static Public Member Functions
static LcsRid	getFetchRids (CircularBufferIter< LcsRidRun > &ridRunIter, LcsRid &nextRid, bool remove)
	Retrieves the current and next rids that need to be read, based on the current rid run being processed.
Public Attributes
uint	nColsToRead
	Number of cluster columns that will be read.
boost::scoped_array< LcsColumnReader >	clusterCols
	Column readers for each cluster column that will be read.
Protected Member Functions
LcsRid	readRid ()
	Returns RID from btree tuple.
PageId	readClusterPageId ()
	Returns cluster pageid from btree tuple.
void	setHdrOffsets (PConstLcsClusterNode pHdr)
	Sets pointers to offset arrays in cluster page header.
Protected Attributes
TupleData	bTreeTupleData
	Tuple data representing the btree key corresponding to the cluster page.
SegmentAccessor	segmentAccessor
	Accessor for segment storing both btree and cluster pages.
ClusterPageLock	clusterLock
	Buffer lock for the actual cluster node pages.
PageId	clusterPageId
	Current cluster pageid.
LcsRid	bTreeRid
	Current rid in btree used to access current cluster page.
uint	nClusterCols
	Number of columns in cluster.
uint16_t *	lastVal
	Offsets to the last value stored on the page for each column in cluster.
uint16_t *	firstVal
	Offsets to the first value stored on the page for each column in cluster.
uint *	nVal
	Number of distinct values in the page for each column in cluster.
uint16_t *	delta
	For each column in the cluster, offset used to get the real offset within the page.
Private Attributes
ClusterPageData	pageData
	Information gathered for the current cluster page.

---

Detailed Description

LcsClusterVerifier is a class for verifying cluster pages.

It reads cluster pages and gathers data regarding the page.

Definition at line 49 of file LcsClusterVerifier.h.

---

Constructor & Destructor Documentation

LcsClusterVerifier::LcsClusterVerifier

(

BTreeDescriptor const &

treeDescriptor

)

[explicit]

Definition at line 28 of file LcsClusterVerifier.cpp.

                                                                            :
    LcsClusterReader(treeDescriptor)
{
}

---

Member Function Documentation

ClusterPageData & LcsClusterVerifier::getPageData

(

)

Retrieves cluster page data for the current cluster page.

Definition at line 33 of file LcsClusterVerifier.cpp.

References LcsClusterAccessBase::bTreeRid, ClusterPageData::bTreeRid, LcsClusterAccessBase::clusterPageId, ClusterPageData::clusterPageId, and pageData.

Referenced by LcsClusterAppendExecStreamTest::verifyClusterPages().

{
    pageData.bTreeRid = bTreeRid;
    pageData.clusterPageId = clusterPageId;
    return pageData;
}

void LcsClusterReader::setRootPageId

(

PageId

rootPageId

)

[inherited]

Sets the root pageId of the underlying btree corresponding to the cluster.

Parameters:

rootPageId

the root pageId that's set

Definition at line 53 of file LcsClusterReader.cpp.

References LcsClusterReader::bTreeReader.

{
    bTreeReader->setRootPageId(rootPageId);
}

void LcsClusterReader::initColumnReaders	(	uint	nClusterColsInit,
		TupleProjection const &	clusterProj
	)			[inherited]

Initializes cluster reader with column readers.

Parameters:

	nClusterColsInit	total number of columns in the cluster
	clusterProj	list of columns to be read from cluster; column numbers are 0-based relative to the cluster

Definition at line 100 of file LcsClusterReader.cpp.

References LcsClusterReader::clusterCols, LcsClusterAccessBase::nClusterCols, and LcsClusterReader::nColsToRead.

{
    nClusterCols = nClusterColsInit;
    nColsToRead = clusterProj.size();
    clusterCols.reset(new LcsColumnReader[nColsToRead]);
    for (uint i = 0; i < nColsToRead; i++) {
        clusterCols[i].init(this, clusterProj[i]);
    }
}

void LcsClusterReader::open

(

)

[inherited]

Initializes state variables used by cluster reader.

Definition at line 112 of file LcsClusterReader.cpp.

References LcsClusterReader::dumbPrefetch, MAXU, LcsClusterReader::nextBTreeEntry, LcsClusterReader::nextPrefetchEntry, LcsClusterReader::nextRid, LcsClusterReader::pLeaf, LcsClusterReader::pRangeBatches, CircularBufferIter< T >::reset(), and LcsClusterReader::ridRunIter.

{
    pLeaf = NULL;
    pRangeBatches = NULL;
    ridRunIter.reset();

    // values of (0, MAXU) indicate that entry has not been filled in yet
    nextBTreeEntry.first = PageId(0);
    nextBTreeEntry.second = LcsRid(MAXU);

    nextPrefetchEntry.first = PageId(0);
    nextPrefetchEntry.second = LcsRid(MAXU);

    dumbPrefetch = false;
    nextRid = LcsRid(0);
}

void LcsClusterReader::close

(

)

[inherited]

Performs shutdown on cluster reader.

Definition at line 129 of file LcsClusterReader.cpp.

References LcsClusterReader::bTreeReader, and LcsClusterAccessBase::unlockClusterPage().

{
    bTreeReader->endSearch();
    unlockClusterPage();
}

bool LcsClusterReader::getFirstClusterPageForRead

(

PConstLcsClusterNode &

pBlock

)

[inherited]

Gets first page in a cluster.

Parameters:

pBlock

output param returning cluster page

Returns:

true if page available

Definition at line 71 of file LcsClusterReader.cpp.

References LcsClusterReader::bTreeReader, and LcsClusterReader::readClusterPage().

Referenced by LcsClusterAppendExecStreamTest::verifyClusterPages().

{
    bool found;

    found = bTreeReader->searchFirst();
    if (!found) {
        return false;
    }

    LcsClusterNode const &node = readClusterPage();
    pBlock = &node;
    return true;
}

bool LcsClusterReader::getNextClusterPageForRead

(

PConstLcsClusterNode &

pBlock

)

[inherited]

Gets next page in a cluster, based on current position in btree.

Parameters:

pBlock

output param returning cluster page

Returns:

true if page available

Definition at line 86 of file LcsClusterReader.cpp.

References LcsClusterReader::bTreeReader, and LcsClusterReader::readClusterPage().

Referenced by LcsClusterAppendExecStreamTest::verifyClusterPages().

{
    bool found;

    found = bTreeReader->searchNext();
    if (!found) {
        return false;
    }

    LcsClusterNode const &node = readClusterPage();
    pBlock = &node;
    return true;
}

bool LcsClusterReader::isPositioned

(

)

const [inline, inherited]

Returns true if positioned within some range in a batch.

Definition at line 424 of file LcsClusterReader.h.

References LcsClusterReader::pRangeBatches.

{
    return pRangeBatches != NULL;
}

LcsRid LcsClusterReader::getRangeStartRid

(

)

const [inline, inherited]

Returns first rid in a range.

Definition at line 429 of file LcsClusterReader.h.

References LcsClusterReader::rangeStartRid.

Referenced by LcsClusterReader::getCurrentRid().

{
    return rangeStartRid;
}

LcsRid LcsClusterReader::getRangeEndRid

(

)

const [inline, inherited]

Returns first rid after the end of the current range.

Definition at line 434 of file LcsClusterReader.h.

References LcsClusterReader::rangeEndRid.

Referenced by LcsClusterReader::nextRange(), and LcsClusterReader::positionInBlock().

{
    return rangeEndRid;
}

uint LcsClusterReader::getRangeSize

(

)

const [inline, inherited]

Returns number of rids in the range.

Definition at line 439 of file LcsClusterReader.h.

References LcsBatchDir::nRow, and LcsClusterReader::pRangeBatches.

Referenced by LcsClusterReader::getRangeRowsLeft().

{
    return pRangeBatches->nRow;
}

uint LcsClusterReader::getRangePos

(

)

const [inline, inherited]

Returns offset within the current range.

E.g., 0 if at first rid in range

Definition at line 444 of file LcsClusterReader.h.

References LcsClusterReader::nRangePos.

Referenced by LcsClusterReader::getCurrentRid(), LcsColumnReader::getCurrentValueCode(), LcsColumnReader::getFixedValue(), LcsClusterReader::getRangeRowsLeft(), LcsColumnReader::getVariableValue(), and LcsColumnReader::readCompressedBatch().

{
    return nRangePos;
}

LcsRid LcsClusterReader::getCurrentRid

(

)

const [inline, inherited]

Returns rid currently positioned at.

Definition at line 449 of file LcsClusterReader.h.

References LcsClusterReader::getRangePos(), and LcsClusterReader::getRangeStartRid().

{
    return getRangeStartRid() + getRangePos();
}

uint LcsClusterReader::getRangeRowsLeft

(

)

const [inline, inherited]

Returns number of rids yet to be read.

(E.g., 1 if we're at the last rid)

Definition at line 454 of file LcsClusterReader.h.

References LcsClusterReader::getRangePos(), and LcsClusterReader::getRangeSize().

Referenced by LcsColumnReader::readCompressedBatch().

{
    return getRangeSize() - getRangePos();
}

bool LcsClusterReader::position

(

LcsRid

rid

)

[inherited]

Positions scan on the rid, moving to a new range if necessary.

Parameters:

rid

rid to position to

Returns:

false if rid is beyond end of cluster

Definition at line 135 of file LcsClusterReader.cpp.

References LcsClusterReader::bTreeReader, LcsClusterReader::currRid, SegPageEntryIter< EntryT >::mapRange(), LcsClusterReader::moveToBlock(), LcsClusterReader::moveToBlockWithRid(), LcsClusterReader::noPrefetch, NULL_PAGE_ID, LcsClusterReader::pLeaf, LcsClusterReader::positionInBlock(), LcsClusterReader::prefetchQueue, LcsClusterAccessBase::readClusterPageId(), LcsClusterReader::searchForRid(), and LcsClusterAccessBase::segmentAccessor.

Referenced by LcsClusterReader::nextRange().

{
    bool found;

    currRid = rid;
    if (pLeaf) {
        // Scan is already in progress. Try to find the row we want in the
        // current block.

        found = positionInBlock(rid);
        if (found) {
            return true;
        }
    } else {
        if (noPrefetch) {
            if (!bTreeReader->searchFirst()) {
                bTreeReader->endSearch();
            }
        } else {
            // Initiate the first set of pre-fetches.
            prefetchQueue.mapRange(segmentAccessor, NULL_PAGE_ID);
        }
    }

    if (noPrefetch) {
        found = searchForRid(rid);
        if (!found) {
            return false;
        }
        moveToBlock(readClusterPageId());
    } else {
        found = moveToBlockWithRid(rid);
        if (!found) {
            return false;
        }
    }

    found = positionInBlock(rid);
    // page ends before "rid"; we must be off the last block
    if (!found) {
        return false;
    }

    return true;
}

bool LcsClusterReader::nextRange

(

)

[inline, inherited]

Positions scan on the first rid of the next range.

Definition at line 459 of file LcsClusterReader.h.

References LcsClusterReader::getRangeEndRid(), and LcsClusterReader::position().

{
    return position(getRangeEndRid());
}

bool LcsClusterReader::advance

(

uint

nRids

)

[inherited]

Moves "nRids" forward in the current range.

Parameters:

nRids

number of rids to move forward

Returns:

false if we are at the endof the range and therefore cannot advance the desired number of rids

Definition at line 295 of file LcsClusterReader.cpp.

References LcsClusterReader::nRangePos.

{
    uint newPos = nRangePos + nRids;

    if (newPos < pRangeBatches->nRow) {
        nRangePos = newPos;
        return true;
    } else {
        return false;
    }
}

void LcsClusterReader::advanceWithinBatch

(

uint

nRids

)

[inline, inherited]

Advances nRids forward in the current batch.

Parameters:

nRids

number of rids to advance

Definition at line 464 of file LcsClusterReader.h.

References LcsClusterReader::nRangePos.

{
    nRangePos = nRangePos + nRids;
}

PageId LcsClusterReader::getNextPageForPrefetch	(	LcsRid &	rid,
		bool &	found
	)			[virtual, inherited]

Determines the next page to be pre-fetched based on the rids that need to be read.

Parameters:

[out]	rid	returns the rid corresponding to the page to be pre-fetched
[out]	found	true if a pre-fetch page was found

Returns:

the page to be pre-fetched next

Implements SegPageEntryIterSource< LcsRid >.

Definition at line 307 of file LcsClusterReader.cpp.

References LcsClusterReader::currRid, CircularBufferIter< T >::done(), LcsClusterReader::dumbPrefetch, LcsClusterReader::getFetchRids(), LcsClusterReader::getNextBTreeEntry(), MAXU, LcsClusterReader::nextBTreeEntry, LcsClusterReader::nextRid, NULL_PAGE_ID, LcsClusterAccessBase::readClusterPageId(), LcsClusterAccessBase::readRid(), LcsClusterReader::ridRunIter, and LcsClusterReader::searchForRid().

{
    found = true;
    for (;;) {
        if (dumbPrefetch) {
            rid = currRid;
        } else {
            rid = getFetchRids(ridRunIter, nextRid, false);
        }

        // If the rid run buffer is exhausted and there are still rid runs
        // to be filled in, we're pre-fetching faster than we can fill up
        // the rid run buffers.  So, switch to dumb pre-fetch in that case.
        if (rid == LcsRid(MAXU)) {
            if (ridRunIter.done()) {
                rid = LcsRid(0);
                return NULL_PAGE_ID;
            } else {
                // TODO - Use stricter criteria on when to switch to dumb
                // pre-fetch.  E.g., if there are less than a certain number
                // of pages already pre-fetched.
                dumbPrefetch = true;
                continue;
            }
        }

        if (!(nextBTreeEntry.second == LcsRid(MAXU) &&
            nextBTreeEntry.first == PageId(0)))
        {
            // If we hit the end of the btree on the last iteration, then
            // there are no more pages.
            if (nextBTreeEntry.first == NULL_PAGE_ID) {
                rid = LcsRid(0);
                return NULL_PAGE_ID;
            }

            // If the next rid to be read is on the same page as the last
            // one located, bump up the rid so we move over to the next page.
            // In the case of dumb pre-fetch, just use the next page in the
            // cluster sequence.
            if (rid < nextBTreeEntry.second) {
                if (dumbPrefetch) {
                    rid = nextBTreeEntry.second;
                    PageId pageId = nextBTreeEntry.first;
                    getNextBTreeEntry();
                    return pageId;
                }
                nextRid = nextBTreeEntry.second;
                continue;
            } else {
                // TODO - optimize by avoiding search from top of btree if
                // desired entry is within a few entries of the current
                break;
           }
        } else {
            // We haven't located any pages yet.  Initiate first btree search.
            break;
        }
    }

    bool rc = searchForRid(rid);
    if (!rc) {
        return NULL_PAGE_ID;
    }
    rid = readRid();
    PageId pageId = readClusterPageId();
    getNextBTreeEntry();
    return pageId;
}

LcsRid LcsClusterReader::getFetchRids	(	CircularBufferIter< LcsRidRun > &	ridRunIter,
		LcsRid &	nextRid,
		bool	remove
	)			[static, inherited]

Retrieves the current and next rids that need to be read, based on the current rid run being processed.

Parameters:

	ridRunIter	iterator over the circular buffer that provides the rid runs
[in,out]	nextRid	on input, indicates the minimum rid value to be retrieved; on return, the next rid that will need to be read
	remove	if true, remove the first element from the circular buffer if the rid run buffer's position is incremented

Returns:

the current rid that needs to be read

Definition at line 390 of file LcsClusterReader.cpp.

References CircularBufferIter< T >::end(), MAXU, LcsRidRun::nRids, CircularBufferIter< T >::removeFront(), LcsClusterReader::ridRunIter, and LcsRidRun::startRid.

Referenced by LcsRowScanExecStream::execute(), and LcsClusterReader::getNextPageForPrefetch().

{
    for (;;) {
        if (ridRunIter.end()) {
            return LcsRid(MAXU);
        }

        LcsRidRun &currRidRun = *ridRunIter;
        if (nextRid < currRidRun.startRid) {
            nextRid = currRidRun.startRid + 1;
            return currRidRun.startRid;
        } else if (
            (currRidRun.nRids == RecordNum(MAXU) &&
                nextRid >= currRidRun.startRid) ||
            (nextRid < currRidRun.startRid + currRidRun.nRids))
        {
            return nextRid++;
        } else {
            ++ridRunIter;
            if (remove) {
                ridRunIter.removeFront();
            }
        }
    }
}

void LcsClusterReader::catchUp	(	uint	parentBufPos,
		LcsRid	parentNextRid
	)			[inherited]

Resynchronizes the cluster reader's prefetch position to that of the parent scan.

Parameters:

	parentBufPos	buffer position of the parent scan
	parentNextRid	next rid of the parent scan

Definition at line 419 of file LcsClusterReader.cpp.

References CircularBufferIter< T >::getCurrPos(), LcsClusterReader::nextRid, LcsClusterReader::ridRunIter, and CircularBufferIter< T >::setCurrPos().

{
    if (parentNextRid - 1 > nextRid) {
        nextRid = parentNextRid - 1;
    }
    if (parentBufPos > ridRunIter.getCurrPos()) {
        ridRunIter.setCurrPos(parentBufPos);
    }
}

RecordNum LcsClusterReader::getNumRows

(

)

[inherited]

Returns:

the number of rows in the cluster

Definition at line 429 of file LcsClusterReader.cpp.

References LcsClusterReader::bTreeReader, LcsClusterAccessBase::bTreeTupleData, LcsClusterNode::firstRID, LcsClusterNode::nBatch, LcsClusterAccessBase::nClusterCols, LcsClusterNode::oBatch, opaqueToInt(), and LcsClusterReader::readClusterPage().

{
    // Read the last cluster page
    if (bTreeReader->searchLast() == false) {
        bTreeReader->endSearch();
        return RecordNum(0);
    }
    bTreeReader->getTupleAccessorForRead().unmarshal(bTreeTupleData);
    LcsClusterNode const &node = readClusterPage();

    // Then count the number of rows in each batch on that page
    RecordNum nRows = RecordNum(opaqueToInt(node.firstRID));
    PLcsBatchDir pBatch = (PLcsBatchDir) ((PBuffer) &node + node.oBatch);
    for (uint i = 0; i < node.nBatch; i += nClusterCols) {
        nRows += pBatch[i].nRow;
    }

    bTreeReader->endSearch();
    return nRows;
}

LcsRid LcsClusterAccessBase::readRid

(

)

[protected, inherited]

Returns RID from btree tuple.

Definition at line 37 of file LcsClusterAccessBase.cpp.

References LcsClusterAccessBase::bTreeTupleData.

Referenced by LcsClusterReader::getNextBTreeEntry(), LcsClusterReader::getNextPageForPrefetch(), LcsClusterReader::readClusterPage(), and LcsClusterReader::searchForRid().

{
    return *reinterpret_cast<LcsRid const *> (bTreeTupleData[0].pData);
}

PageId LcsClusterAccessBase::readClusterPageId

(

)

[protected, inherited]

Returns cluster pageid from btree tuple.

Definition at line 42 of file LcsClusterAccessBase.cpp.

References LcsClusterAccessBase::bTreeTupleData.

Referenced by LcsClusterNodeWriter::getLastClusterPageForWrite(), LcsClusterReader::getNextBTreeEntry(), LcsClusterReader::getNextPageForPrefetch(), LcsClusterReader::position(), and LcsClusterReader::readClusterPage().

{
    return *reinterpret_cast<PageId const *> (bTreeTupleData[1].pData);
}

void LcsClusterAccessBase::setHdrOffsets

(

PConstLcsClusterNode

pHdr

)

[protected, inherited]

Sets pointers to offset arrays in cluster page header.

Parameters:

pHdr

pointer to cluster node header

Definition at line 47 of file LcsClusterAccessBase.cpp.

References LcsClusterAccessBase::delta, LcsClusterAccessBase::firstVal, LcsClusterAccessBase::lastVal, LcsClusterAccessBase::nClusterCols, and LcsClusterAccessBase::nVal.

Referenced by LcsClusterDump::dump(), LcsClusterNodeWriter::init(), and LcsClusterReader::setUpBlock().

{
    PBuffer p = (PBuffer) pHdr;

    lastVal = (uint16_t *) (p += sizeof(LcsClusterNode));
    firstVal = (uint16_t *) (p += sizeof(uint16_t) * nClusterCols);
    nVal = (uint *) (p += sizeof(uint16_t) * nClusterCols);
    delta = (uint16_t *) (p += sizeof(uint) * nClusterCols);
}

uint LcsClusterAccessBase::getNumClusterCols

(

)

[inline, inherited]

Returns number of columns in cluster.

Definition at line 118 of file LcsClusterAccessBase.h.

    {
        return nClusterCols;
    }

void LcsClusterAccessBase::setNumClusterCols

(

uint

nCols

)

[inline, inherited]

Sets number of columns in cluster.

Definition at line 126 of file LcsClusterAccessBase.h.

    {
        nClusterCols = nCols;
    }

void LcsClusterAccessBase::unlockClusterPage

(

)

[inherited]

Unlocks cluster page.

Definition at line 57 of file LcsClusterAccessBase.cpp.

References LcsClusterAccessBase::clusterLock, and SegPageLock::unlock().

Referenced by LcsClusterReader::close().

{
    clusterLock.unlock();
}

virtual void SegPageEntryIterSource< LcsRid >::initPrefetchEntry

(

LcsRid &

entry

)

[inline, virtual, inherited]

Initializes a specific entry in the pre-fetch queue.

Parameters:

entry

the entry that will be initialized

Definition at line 46 of file SegPageEntryIterSource.h.

    {
    }

---

Member Data Documentation

ClusterPageData LcsClusterVerifier::pageData [private]

Information gathered for the current cluster page.

Definition at line 55 of file LcsClusterVerifier.h.

Referenced by getPageData().

uint LcsClusterReader::nColsToRead [inherited]

Number of cluster columns that will be read.

Definition at line 238 of file LcsClusterReader.h.

Referenced by LcsClusterReader::initColumnReaders().

boost::scoped_array<LcsColumnReader> LcsClusterReader::clusterCols [inherited]

Column readers for each cluster column that will be read.

Definition at line 243 of file LcsClusterReader.h.

Referenced by LcsClusterReader::initColumnReaders().

TupleData LcsClusterAccessBase::bTreeTupleData [protected, inherited]

Tuple data representing the btree key corresponding to the cluster page.

Definition at line 42 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::allocateClusterPage(), LcsClusterNodeWriter::getLastClusterPageForWrite(), LcsClusterReader::getNextBTreeEntry(), LcsClusterReader::getNumRows(), LcsClusterAccessBase::LcsClusterAccessBase(), LcsClusterReader::readClusterPage(), LcsClusterAccessBase::readClusterPageId(), LcsClusterAccessBase::readRid(), and LcsClusterReader::searchForRid().

SegmentAccessor LcsClusterAccessBase::segmentAccessor [protected, inherited]

Accessor for segment storing both btree and cluster pages.

Definition at line 47 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::allocateClusterPage(), LcsClusterAccessBase::LcsClusterAccessBase(), and LcsClusterReader::position().

ClusterPageLock LcsClusterAccessBase::clusterLock [protected, inherited]

Buffer lock for the actual cluster node pages.

Shares the same segment as the btree corresponding to the cluster.

Definition at line 53 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::allocateClusterPage(), LcsClusterNodeWriter::close(), LcsClusterNodeWriter::getLastClusterPageForWrite(), LcsClusterAccessBase::LcsClusterAccessBase(), LcsClusterReader::moveToBlock(), LcsClusterReader::moveToBlockWithRid(), LcsClusterReader::readClusterPage(), and LcsClusterAccessBase::unlockClusterPage().

PageId LcsClusterAccessBase::clusterPageId [protected, inherited]

Current cluster pageid.

Definition at line 58 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::allocateClusterPage(), LcsClusterNodeWriter::getLastClusterPageForWrite(), getPageData(), LcsClusterNodeWriter::moveFromTempToIndex(), LcsClusterReader::moveToBlockWithRid(), and LcsClusterReader::readClusterPage().

LcsRid LcsClusterAccessBase::bTreeRid [protected, inherited]

Current rid in btree used to access current cluster page.

Definition at line 63 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::allocateClusterPage(), getPageData(), and LcsClusterReader::readClusterPage().

uint LcsClusterAccessBase::nClusterCols [protected, inherited]

Number of columns in cluster.

Definition at line 68 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::addValue(), LcsClusterNodeWriter::allocArrays(), LcsClusterDump::dump(), LcsClusterReader::getNumRows(), LcsClusterNodeWriter::init(), LcsClusterReader::initColumnReaders(), LcsClusterNodeWriter::LcsClusterNodeWriter(), LcsClusterNodeWriter::moveFromIndexToTemp(), LcsClusterNodeWriter::moveFromTempToIndex(), LcsClusterNodeWriter::openAppend(), LcsClusterNodeWriter::openNew(), LcsClusterReader::positionInBlock(), and LcsClusterAccessBase::setHdrOffsets().

uint16_t* LcsClusterAccessBase::lastVal [protected, inherited]

Offsets to the last value stored on the page for each column in cluster.

Definition at line 74 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::addValue(), LcsClusterDump::dump(), LcsClusterNodeWriter::moveFromIndexToTemp(), LcsClusterNodeWriter::moveFromTempToIndex(), LcsClusterNodeWriter::openAppend(), LcsClusterNodeWriter::openNew(), LcsClusterNodeWriter::pickCompressionMode(), LcsClusterNodeWriter::putCompressedBatch(), LcsClusterNodeWriter::putFixedVarBatch(), LcsClusterNodeWriter::rollBackLastBatch(), LcsClusterAccessBase::setHdrOffsets(), and LcsClusterNodeWriter::undoValue().

uint16_t* LcsClusterAccessBase::firstVal [protected, inherited]

Offsets to the first value stored on the page for each column in cluster.

Points to the end of the firstVal, so subtracting lastVal from firstVal will tell you the number of bytes taken up by values for a column, since lastVals are appended in front of firstVal

Definition at line 82 of file LcsClusterAccessBase.h.

Referenced by LcsClusterDump::dump(), LcsClusterNodeWriter::moveFromIndexToTemp(), LcsClusterNodeWriter::moveFromTempToIndex(), LcsClusterNodeWriter::openNew(), and LcsClusterAccessBase::setHdrOffsets().

uint* LcsClusterAccessBase::nVal [protected, inherited]

Number of distinct values in the page for each column in cluster.

Definition at line 87 of file LcsClusterAccessBase.h.

Referenced by LcsClusterNodeWriter::addValue(), LcsClusterDump::dump(), LcsClusterNodeWriter::moveFromIndexToTemp(), LcsClusterNodeWriter::moveFromTempToIndex(), LcsClusterNodeWriter::openAppend(), LcsClusterNodeWriter::openNew(), LcsClusterNodeWriter::pickCompressionMode(), LcsClusterNodeWriter::putCompressedBatch(), LcsClusterNodeWriter::putFixedVarBatch(), LcsClusterNodeWriter::rollBackLastBatch(), LcsClusterAccessBase::setHdrOffsets(), and LcsClusterNodeWriter::undoValue().

uint16_t* LcsClusterAccessBase::delta [protected, inherited]

For each column in the cluster, offset used to get the real offset within the page.

Definition at line 93 of file LcsClusterAccessBase.h.

Referenced by LcsClusterDump::dump(), LcsClusterNodeWriter::moveFromTempToIndex(), LcsClusterNodeWriter::openNew(), LcsClusterAccessBase::setHdrOffsets(), and LcsColumnReader::sync().

---

The documentation for this class was generated from the following files:

• /home/pub/open/dev/fennel/lucidera/colstore/LcsClusterVerifier.h
• /home/pub/open/dev/fennel/lucidera/colstore/LcsClusterVerifier.cpp

---