RestartingMinusExecStreamGenerator Class Reference

Generates repeating tuples resulting from minus such as. More...

Inheritance diagram for RestartingMinusExecStreamGenerator:

List of all members.

Public Member Functions
	RestartingMinusExecStreamGenerator (uint nRows, std::vector< int > repeatSeqValues, uint subtrahendInterval)
virtual int64_t	generateValue (uint iRow, uint iCol)
	Generates one data value.
uint	getValueCount (uint nRows, uint iValue)
	Returns the number of times a value repeats over nRows.
uint	getRowCount ()
	Returns the total number of rows the result set should have.
Protected Attributes
uint	nKeys
std::vector< int >	repeatSeqValues
uint	subtrahendInterval
uint	interval
boost::shared_array< uint >	changeIndexes
uint	current
uint	lastRow

---

Detailed Description

Generates repeating tuples resulting from minus such as.

 0, 0, 0 [distinct row 0, repeats 12 times]
 0, 1, 1 [distinct row 1, repeats 11 times]
 0, 2, 2 [distinct row 1, repeats 12 times]
 ...
 

Definition at line 93 of file LbmMinusExecStreamTest.cpp.

---

Constructor & Destructor Documentation

RestartingMinusExecStreamGenerator::RestartingMinusExecStreamGenerator	(	uint	nRows,
		std::vector< int >	repeatSeqValues,
		uint	subtrahendInterval
	)			[inline]

Definition at line 106 of file LbmMinusExecStreamTest.cpp.

References changeIndexes, current, LbmExecStreamTestBase::getTupleInterval(), getValueCount(), interval, lastRow, and nKeys.

    {
        this->nKeys = repeatSeqValues.size();
        this->repeatSeqValues = repeatSeqValues;
        interval = LbmExecStreamTestBase::getTupleInterval(repeatSeqValues);

        // find the number of times each key value repeats
        boost::scoped_array<uint> valueCounts;
        valueCounts.reset(new uint[interval]);
        for (uint i = 0; i < interval; i++) {
            valueCounts[i] = getValueCount(nRows, i);
        }
        // account for subtrahend
        for (uint iRow = 0; iRow < nRows; iRow += subtrahendInterval) {
            valueCounts[iRow % interval]--;
        }

        // find indexes where the values change
        changeIndexes.reset(new uint[interval]);
        changeIndexes[0] = valueCounts[0];
        for (uint i = 1; i < interval; i++) {
            changeIndexes[i] = changeIndexes[i - 1] + valueCounts[i];
        }
        current = 0;
        lastRow = 0;
    }

---

Member Function Documentation

virtual int64_t RestartingMinusExecStreamGenerator::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 134 of file LbmMinusExecStreamTest.cpp.

References changeIndexes, current, interval, lastRow, nKeys, and repeatSeqValues.

    {
        // must be generated in order
        assert (lastRow <= iRow);
        lastRow = iRow;

        if (iRow >= changeIndexes[current]) {
            current++;
            assert (current < interval);
        }
        assert (iCol < nKeys);
        return current % repeatSeqValues[iCol];
    }

uint RestartingMinusExecStreamGenerator::getValueCount	(	uint	nRows,
		uint	iValue
	)			[inline]

Returns the number of times a value repeats over nRows.

Definition at line 151 of file LbmMinusExecStreamTest.cpp.

References interval.

Referenced by RestartingMinusExecStreamGenerator().

    {
        uint nCopies = nRows / interval;
        if (iValue < nRows % interval) {
            nCopies++;
        }
        return nCopies;
    }

uint RestartingMinusExecStreamGenerator::getRowCount

(

)

[inline]

Returns the total number of rows the result set should have.

Definition at line 163 of file LbmMinusExecStreamTest.cpp.

References changeIndexes, and interval.

Referenced by LbmMinusExecStreamTest::testRestartingMinus().

    {
        return changeIndexes[interval - 1];
    }

---

Member Data Documentation

uint RestartingMinusExecStreamGenerator::nKeys [protected]

Definition at line 97 of file LbmMinusExecStreamTest.cpp.

Referenced by generateValue(), and RestartingMinusExecStreamGenerator().

std::vector<int> RestartingMinusExecStreamGenerator::repeatSeqValues [protected]

Definition at line 98 of file LbmMinusExecStreamTest.cpp.

Referenced by generateValue().

uint RestartingMinusExecStreamGenerator::subtrahendInterval [protected]

Definition at line 99 of file LbmMinusExecStreamTest.cpp.

uint RestartingMinusExecStreamGenerator::interval [protected]

Definition at line 100 of file LbmMinusExecStreamTest.cpp.

Referenced by generateValue(), getRowCount(), getValueCount(), and RestartingMinusExecStreamGenerator().

boost::shared_array<uint> RestartingMinusExecStreamGenerator::changeIndexes [protected]

Definition at line 101 of file LbmMinusExecStreamTest.cpp.

Referenced by generateValue(), getRowCount(), and RestartingMinusExecStreamGenerator().

uint RestartingMinusExecStreamGenerator::current [protected]

Definition at line 102 of file LbmMinusExecStreamTest.cpp.

Referenced by generateValue(), and RestartingMinusExecStreamGenerator().

uint RestartingMinusExecStreamGenerator::lastRow [protected]

Definition at line 103 of file LbmMinusExecStreamTest.cpp.

Referenced by generateValue(), and RestartingMinusExecStreamGenerator().

---

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

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

---