Fennel: TupleDataWithBuffer Class Reference (original) (raw)

• Main Page

• Namespaces

• Classes

• Files

• Directories

• Related Pages

• Alphabetical List

• Class List

• Class Hierarchy

• Class Members

TupleDataWithBuffer is a convenience that creates a TupleData, and a supporting buffer from a TupleDescriptor. More...

#include <[TupleDataWithBuffer.h](TupleDataWithBuffer%5F8h-source.html)>

Inheritance diagram for TupleDataWithBuffer:

List of all members.

Detailed Description

TupleDataWithBuffer is a convenience that creates a TupleData, and a supporting buffer from a TupleDescriptor.

A common use is to create an input and output tuple for Calculator given the TupleDescriptor obtained from Calculator::getOutputRegisterDescriptor and from Calculator::getInputRegisterDescriptor()

Definition at line 43 of file TupleDataWithBuffer.h.

Constructor & Destructor Documentation

| TupleDataWithBuffer::TupleDataWithBuffer | ( | | ) | [explicit] | | ---------------------------------------- | - | | - | ------------ |

| TupleDataWithBuffer::~TupleDataWithBuffer | ( | | ) | | ------------------------------------------ | - | | - |

Member Function Documentation

Definition at line 37 of file TupleDataWithBuffer.cpp.

References array, TupleData::compute(), TupleAccessor::compute(), FixedBuffer, TupleAccessor::getMaxByteCount(), TupleAccessor::setCurrentTupleBuf(), TUPLE_FORMAT_ALL_FIXED, tupleAccessor, and TupleAccessor::unmarshal().

Referenced by LcsHash::init(), LhxHashTable::init(), LcsClusterReplaceExecStream::initTupleLoadParams(), CalcExtWinAggFuncTest::initWindowedAggDataBlock(), LcsCompareColKeyUsingOffsetIndex::LcsCompareColKeyUsingOffsetIndex(), LcsRowScanExecStream::prepare(), LbmSplicerExecStream::prepare(), LbmMinusExecStream::prepare(), LbmGeneratorExecStream::prepare(), SortedAggExecStream::prepare(), LcsRowScanExecStream::prepareResidualFilters(), and TupleDataWithBuffer().

| void TupleDataWithBuffer::resetBuffer | ( | | ) | | ------------------------------------- | - | | - |

Definition at line 46 of file TupleDataWithBuffer.cpp.

References tupleAccessor, and TupleAccessor::unmarshal().

Referenced by LhxHashTable::addKeyData(), LhxHashTable::aggData(), LbmMinusExecStream::copyPrefix(), SortedAggExecStream::copyPrevGroupByKey(), LcsRowScanExecStream::execute(), LcsColumnReader::findVal(), LbmGeneratorExecStream::generateBitmaps(), LbmGeneratorExecStream::generateMultiKeyBitmaps(), LbmGeneratorExecStream::generateSingletons(), LbmSplicerExecStream::getValidatedTuple(), LcsCompareColKeyUsingOffsetIndex::lessThan(), LcsClusterReplaceExecStream::readOrigClusterRow(), and LcsHash::search().

Definition at line 48 of file TupleData.cpp.

Referenced by BTreeReader::BTreeReader(), BTreeReadersTest::BTreeReadersTest(), BTreeTest::BTreeTest(), BTreeVerifier::BTreeVerifier(), computeAndAllocate(), LhxPlan::createChildren(), FtrsTableWriter::createIndexWriter(), LbmEntryDump::dump(), LhxAggExecStream::execute(), ExternalSortMerger::ExternalSortMerger(), ExternalSortRunLoader::ExternalSortRunLoader(), FtrsTableWriter::FtrsTableWriter(), LhxPlan::generatePartitions(), LbmSplicerExecStreamTest::generateRidInput(), LbmSplicerExecStreamTest::generateTupleInput(), LbmSegmentWriter::init(), LbmDeletionIndexReader::init(), LbmEntry::init(), LhxHashTable::init(), LhxHashKeyAccessor::init(), LhxHashDataAccessor::init(), ReshapeExecStream::initCompareData(), LbmSearchTest::initEqualSearch(), LbmExecStreamTestBase::initKeyBitmap(), LcsClusterReplaceExecStream::initTupleLoadParams(), LcsClusterAppendExecStream::initTupleLoadParams(), LcsClusterAccessBase::LcsClusterAccessBase(), FlatFileExecStreamImpl::logError(), BTreeNodeAccessor::onInit(), LhxPartitionWriter::open(), MockConsumerExecStream::open(), CollectExecStream::open(), LbmSplicerExecStream::postViolation(), LcsRowScanExecStream::prepare(), LcsClusterAppendExecStream::prepare(), LbmUnionExecStream::prepare(), LbmSplicerExecStream::prepare(), LbmSearchExecStream::prepare(), LbmNormalizerExecStream::prepare(), LbmMinusExecStream::prepare(), LbmGeneratorExecStream::prepare(), LbmChopperExecStream::prepare(), LhxJoinExecStream::prepare(), LhxAggExecStream::prepare(), FtrsTableWriterExecStream::prepare(), BTreeSearchExecStream::prepare(), BTreeReadExecStream::prepare(), BTreePrefetchSearchExecStream::prepare(), FlatFileExecStreamImpl::prepare(), UncollectExecStream::prepare(), SortedAggExecStream::prepare(), SegBufferWriterExecStream::prepare(), SegBufferReaderExecStream::prepare(), ReshapeExecStream::prepare(), MockResourceExecStream::prepare(), MockProducerExecStream::prepare(), CorrelationJoinExecStream::prepare(), CartesianJoinExecStream::prepare(), BernoulliSamplingExecStream::prepare(), BarrierExecStream::prepare(), CalcExecStream::prepare(), LhxHashTableTest::readPartition(), TestCalculator::setUp(), ExecStreamTestSuite::testBTreeInsertExecStream(), BTreeTest::testBulkLoad(), ExecStreamTestSuite::testCartesianJoinExecStream(), LbmExecStreamTestBase::testCaseSetUp(), CalcExecStreamTestSuite::testConstant(), ExecStreamTestSuite::testCopyExecStream(), ExecStreamGovernorTest::testGovernor(), LhxHashTableTest::testInsert(), BTreeTest::testInserts(), LbmEntryTest::testldb35(), LbmEntryTest::testler5920(), LbmSplicerExecStreamTest::testLER5968(), LbmSplicerExecStreamTest::testLER6473(), LbmEntryTest::testMergeEntry(), ExecStreamTestSuite::testMergeExecStream(), ExecStreamTestSuite::testMergeImplicitPullInputs(), LbmEntryTest::testMergeSingleton(), BTreeTest::testMultiKeySearches(), BTreeReadersTest::testReaders(), ExecStreamTestSuite::testReshapeExecStream(), ExecStreamTestSuite::testSegBufferExecStream(), ExecStreamTestSuite::testSegBufferReaderWriterExecStream(), LbmSplicerExecStreamTest::testSpliceRids(), LbmSplicerExecStreamTest::testSpliceWithKeys(), LbmEntryTest::testZeroBytes(), LhxHashKeyAccessor::toString(), TupleData::TupleData(), ExecStreamUnitTestBase::verifyBufferedOutput(), ExecStreamUnitTestBase::verifyConstantOutput(), FlatFileExecStreamTest::verifyOutput(), ExecStreamUnitTestBase::verifyOutput(), and LhxHashTableTest::writeHashTable().

00049 { 00050 clear(); 00051 for (uint i = 0; i < tupleDesc.size(); ++i) { 00052 TupleDatum datum; 00053 datum.cbData = tupleDesc[i].cbStorage; 00054 push_back(datum); 00055 } 00056 }

| bool TupleData::containsNull | ( | | ) | const [inherited] | | ---------------------------- | - | | - | ------------------- |

Definition at line 68 of file TupleData.cpp.

00069 { 00070 for (uint i = 0; i < tupleProj.size(); ++i) { 00071 if (!(*this)[tupleProj[i]].pData) { 00072 return true; 00073 } 00074 } 00075 return false; 00076 }

Member Data Documentation

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

• /home/pub/open/dev/fennel/tuple/TupleDataWithBuffer.h
• /home/pub/open/dev/fennel/tuple/TupleDataWithBuffer.cpp

Generated on Mon Jun 22 04:00:48 2009 for Fennel by 1.5.1