WinAggHistogramStrA Class Reference

#include <WinAggHistogramStrA.h>

List of all members.

Public Types
typedef WinAggHistogramStrA::_StringDescCompare	StringDescCompare
typedef multiset< StringDesc, StringDescCompare >	WinAggData
typedef deque< StringDesc >	WinAggQueue
Public Member Functions
	WinAggHistogramStrA ()
	~WinAggHistogramStrA ()
void	addRow (RegisterRef< char * > *node)
	addRow - Adds new value to tree and updates the running sum for current values.
void	dropRow (RegisterRef< char * > *node)
	dropRow - Removes a value from the tree and updates the running sum.
void	getMin (RegisterRef< char * > *node)
	getMin - Returns the current MIN() value for the window.
void	getMax (RegisterRef< char * > *node)
	getMax - Returns the current MAX() value for the window.
void	getFirstValue (RegisterRef< char * > *node)
	getFirstValue - returns the first value which entered the tree
void	getLastValue (RegisterRef< char * > *node)
	getLastValue - returns the last value which entered the tree
Protected Member Functions
void	setReturnReg (RegisterRef< char * > *dest, const StringDesc &src)
Private Attributes
WinAggData	currentWindow
int64_t	nullRows
WinAggQueue	queue
	FIFO queue of values, to enable FIRST_VALUE/LAST_VALUE support.
Classes
struct	_StringDescCompare

---

Detailed Description

Definition at line 86 of file WinAggHistogramStrA.h.

---

Member Typedef Documentation

typedef struct WinAggHistogramStrA::_StringDescCompare WinAggHistogramStrA::StringDescCompare

typedef multiset<StringDesc,StringDescCompare> WinAggHistogramStrA::WinAggData

Definition at line 113 of file WinAggHistogramStrA.h.

typedef deque<StringDesc> WinAggHistogramStrA::WinAggQueue

Definition at line 115 of file WinAggHistogramStrA.h.

---

Constructor & Destructor Documentation

WinAggHistogramStrA::WinAggHistogramStrA

(

)

[inline]

Definition at line 89 of file WinAggHistogramStrA.h.

        : currentWindow(),
          nullRows(0),
          queue()
    {}

WinAggHistogramStrA::~WinAggHistogramStrA

(

)

[inline]

Definition at line 95 of file WinAggHistogramStrA.h.

    {}

---

Member Function Documentation

void WinAggHistogramStrA::addRow

(

RegisterRef< char * > *

node

)

addRow - Adds new value to tree and updates the running sum for current values.

Input - New value to be added to the tree

Definition at line 46 of file WinAggHistogramStrA.cpp.

References currentWindow, FixedBuffer, RegisterReference::getBinding(), RegisterRef< TMPLT >::isNull(), nullRows, queue, RegisterRef< TMPLT >::storage(), and RegisterReference::type().

Referenced by add().

{
    if (!node->isNull()) {
        StringDesc desc;
        desc.cbStorage = node->storage();
        desc.mType = node->type();
        desc.pData = new FixedBuffer[desc.cbStorage];
        desc.memCopyFrom(*node->getBinding());
        // printf(
        //     "WinAggHistogramStrA::addRow cbStorage=%d cbData=%d String=%s\n",
        //      node->storage(),desc.cbData, desc.pData);

        // Insert the value into the window
        (void) currentWindow.insert(desc);

        // Add to the FIFO queue. Another copy of the StringDesc is
        // created, but it points to the same memory.
        queue.push_back(desc);
    } else {
        ++nullRows;
    }
}

void WinAggHistogramStrA::dropRow

(

RegisterRef< char * > *

node

)

dropRow - Removes a value from the tree and updates the running sum.

Input - Value to be removed from the tree

Definition at line 69 of file WinAggHistogramStrA.cpp.

References currentWindow, RegisterRef< TMPLT >::isNull(), RegisterRef< TMPLT >::length(), nullRows, RegisterRef< TMPLT >::pointer(), queue, RegisterRef< TMPLT >::storage(), and RegisterReference::type().

Referenced by drop().

{
    if (!node->isNull()) {
        // create a StringDesc from the node data to supply to the
        // search routine
        StringDesc desc;
        desc.cbStorage = node->storage();
        desc.cbData = node->length();
        desc.mType = node->type();
        desc.pData = reinterpret_cast<PBuffer>(node->pointer());
//        printf(
//            "WinAggHistogramStrA::dropRow cbStorage=%d cbData=%d String=%s",
//            node->storage(),desc.cbData, desc.pData);

        // Search the window for matching entries.  It may return more
        // than one but we will only delete one.
        assert(!currentWindow.empty());
        pair<WinAggData::iterator, WinAggData::iterator> entries =
            currentWindow.equal_range(desc);

        assert(entries.first != entries.second);  // should at least be one
        assert(NULL != entries.first->pData);

        if (entries.first != entries.second) {
//             printf(
//                 "  erasing entry cbStorage=%d cbData=%d String=%s\n",
//                 entries.first->cbStorage,
//                 entries.first->cbData,
//                 entries.first->pData);
            if (NULL != entries.first->pData) {
                delete [] entries.first->pData;
            }
            currentWindow.erase(entries.first);
        }

        // Remove from the FIFO queue.
        queue.pop_front();
    } else {
        assert(0 != nullRows);
        --nullRows;
    }
}

void WinAggHistogramStrA::getMin

(

RegisterRef< char * > *

node

)

getMin - Returns the current MIN() value for the window.

Returns NULL if the window is empty.

Definition at line 125 of file WinAggHistogramStrA.cpp.

References currentWindow, setReturnReg(), and RegisterRef< TMPLT >::toNull().

Referenced by min().

{
    if (0 != currentWindow.size()) {
        setReturnReg(node, *(currentWindow.begin()));
    } else {
        // either all the rows added to the window had null
        // entries or there are no rows in the window.  Either
        // way the function returns NULL.
        node->toNull();
    }
}

void WinAggHistogramStrA::getMax

(

RegisterRef< char * > *

node

)

getMax - Returns the current MAX() value for the window.

Returns NULL if the window is empty.

Definition at line 137 of file WinAggHistogramStrA.cpp.

References currentWindow, setReturnReg(), and RegisterRef< TMPLT >::toNull().

Referenced by max().

{
    if (0 != currentWindow.size()) {
        setReturnReg(node, *(--(currentWindow.end())));
    } else {
        // either all the rows added to the window had null
        // entries or there are no rows in the window.  Either
        // way the function returns NULL.
        node->toNull();
    }
}

void WinAggHistogramStrA::getFirstValue

(

RegisterRef< char * > *

node

)

getFirstValue - returns the first value which entered the tree

Returns NULL if the window is empty.

Definition at line 149 of file WinAggHistogramStrA.cpp.

References queue, setReturnReg(), and RegisterRef< TMPLT >::toNull().

Referenced by firstValue().

{
    if (queue.empty()) {
        node->toNull();
    } else {
        setReturnReg(node, queue.front());
    }
}

void WinAggHistogramStrA::getLastValue

(

RegisterRef< char * > *

node

)

getLastValue - returns the last value which entered the tree

Returns NULL if the window is empty.

Definition at line 159 of file WinAggHistogramStrA.cpp.

References queue, setReturnReg(), and RegisterRef< TMPLT >::toNull().

Referenced by lastValue().

{
    if (queue.empty()) {
        node->toNull();
    } else {
        setReturnReg(node, queue.back());
    }
}

void WinAggHistogramStrA::setReturnReg	(	RegisterRef< char * > *	dest,
		const StringDesc &	src
	)			[protected]

Definition at line 112 of file WinAggHistogramStrA.cpp.

References RegisterRef< TMPLT >::length(), StringDesc::pointer(), RegisterRef< TMPLT >::pointer(), and StringDesc::stringLength().

Referenced by getFirstValue(), getLastValue(), getMax(), and getMin().

{
    char* pData = dest->pointer();
    TupleStorageByteLength srcLength = src.stringLength();
    assert(pData);
    assert(srcLength <= dest->storage());
    memcpy(pData, src.pointer(), srcLength);
    dest->length(srcLength);
}

---

Member Data Documentation

WinAggData WinAggHistogramStrA::currentWindow [private]

Definition at line 155 of file WinAggHistogramStrA.h.

Referenced by addRow(), dropRow(), getMax(), and getMin().

int64_t WinAggHistogramStrA::nullRows [private]

Definition at line 156 of file WinAggHistogramStrA.h.

Referenced by addRow(), and dropRow().

WinAggQueue WinAggHistogramStrA::queue [private]

FIFO queue of values, to enable FIRST_VALUE/LAST_VALUE support.

Definition at line 159 of file WinAggHistogramStrA.h.

Referenced by addRow(), dropRow(), getFirstValue(), and getLastValue().

---

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

• /home/pub/open/dev/fennel/calculator/WinAggHistogramStrA.h
• /home/pub/open/dev/fennel/calculator/WinAggHistogramStrA.cpp

---