SortedAggExecStreamGenerator Class Reference

Generates sorted (key, value count) tuples like:. More...

Inheritance diagram for SortedAggExecStreamGenerator:

List of all members.

Public Member Functions
	SortedAggExecStreamGenerator (uint nRows, uint nKeys, std::vector< int > repeatSeqValues)
virtual int64_t	generateValue (uint iRow, uint iCol)
	Generates one data value.
Protected Attributes
uint	nRows
uint	nKeys
std::vector< int >	keyRepeats
uint	interval
boost::shared_array< uint >	sortedToUnsortedMap
int	current
boost::shared_array< uint >	currentRow

---

Detailed Description

Generates sorted (key, value count) tuples like:.

 0, 0, 0, 23 [row 0]
 0, 0, 1, 22 [row 1]
 ...
 

Definition at line 94 of file LbmSortedAggExecStreamTest.cpp.

---

Constructor & Destructor Documentation

SortedAggExecStreamGenerator::SortedAggExecStreamGenerator	(	uint	nRows,
		uint	nKeys,
		std::vector< int >	repeatSeqValues
	)			[inline]

Definition at line 106 of file LbmSortedAggExecStreamTest.cpp.

References current, currentRow, LbmExecStreamTestBase::getTupleInterval(), interval, keyRepeats, and sortedToUnsortedMap.

    {
        this->nRows = nRows;
        this->nKeys = nKeys;
        for (uint i = 0; i < nKeys; i++) {
            keyRepeats.push_back(repeatSeqValues[i]);
        }
        interval = LbmExecStreamTestBase::getTupleInterval(keyRepeats);

        sortedToUnsortedMap.reset(new uint[interval]);
        for (uint i = 0; i < interval; i++) {
            uint value = 0;
            uint scale = 1;
            // calculate sorted position (backwards)
            // value = key0 * scale_1_to_n + key1 * scale_2_to_n + ...
            for (int j = nKeys - 1; j >= 0; j--) {
                uint key = i % keyRepeats[j];
                value += key * scale;
                scale *= keyRepeats[j];
            }
            sortedToUnsortedMap[value] = i;
        }
        current = -1;
        currentRow.reset(new uint[nKeys + 1]);
    }

---

Member Function Documentation

virtual int64_t SortedAggExecStreamGenerator::generateValue	(	uint	iRow,
		uint	iCol
	)			[inline, virtual]

Generates one data value.

Parameters:

	iRow	0-based row number to generate
	iCol	0-based col number to generate

Implements MockProducerExecStreamGenerator.

Definition at line 133 of file LbmSortedAggExecStreamTest.cpp.

References current, currentRow, getValueCount(), interval, keyRepeats, nKeys, nRows, and sortedToUnsortedMap.

    {
        assert (iRow < interval);
        assert (iCol < nKeys + 1);

        if (iRow != current) {
            current = iRow;
            uint unsorted = sortedToUnsortedMap[current];
            for (uint i = 0; i < nKeys; i++) {
                currentRow[i] = unsorted % keyRepeats[i];
            }
            currentRow[nKeys] = getValueCount(nRows, interval, unsorted);
        }
        return currentRow[iCol];
    }

---

Member Data Documentation

uint SortedAggExecStreamGenerator::nRows [protected]

Definition at line 97 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue().

uint SortedAggExecStreamGenerator::nKeys [protected]

Definition at line 98 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue().

std::vector<int> SortedAggExecStreamGenerator::keyRepeats [protected]

Definition at line 99 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue(), and SortedAggExecStreamGenerator().

uint SortedAggExecStreamGenerator::interval [protected]

Definition at line 100 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue(), and SortedAggExecStreamGenerator().

boost::shared_array<uint> SortedAggExecStreamGenerator::sortedToUnsortedMap [protected]

Definition at line 101 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue(), and SortedAggExecStreamGenerator().

int SortedAggExecStreamGenerator::current [protected]

Definition at line 102 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue(), and SortedAggExecStreamGenerator().

boost::shared_array<uint> SortedAggExecStreamGenerator::currentRow [protected]

Definition at line 103 of file LbmSortedAggExecStreamTest.cpp.

Referenced by generateValue(), and SortedAggExecStreamGenerator().

---

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

• /home/pub/open/dev/fennel/lucidera/test/LbmSortedAggExecStreamTest.cpp

---