Fennel: LhxPartitionReader Class Reference (original) (raw)

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

List of all members.

Public Member Functions
void open (SharedLhxPartition srcPartition, LhxHashInfo const &hashInfo)
bool isTupleConsumptionPending ()
bool demandData ()
void unmarshalTuple (TupleData &outputTuple)
void consumeTuple ()
void close ()
ExecStreamBufState getState () const
TupleDescriptor const & getTupleDesc () const
SharedLhxPartition getSourcePartition () const
Private Attributes
SharedLhxPartition srcPartition
Partition to read from.
SharedSegInputStream pSegInputStream
Helper used for reading a partition.
TupleAccessor tupleAccessor
Tuple accessor to unmarshal the disk content to the outputTuple.
uint tupleStorageLength
Storage Length of last tuple read from the underlying partition.
bool srcIsInputStream
ExecStreamBufState bufState
TupleDescriptor outputTupleDesc
SharedExecStreamBufAccessor streamBufAccessor
If reader is on a partition which comes from the input exec stream, (this is when this accessor is opened on a partition without valid segStream), use an exec stream buf accessor to read tuples.

Detailed Description

Definition at line 123 of file LhxPartition.h.

Member Function Documentation

Definition at line 143 of file LhxPartition.cpp.

References bufState, TupleAccessor::compute(), EXECBUF_NONEMPTY, LhxHashInfo::inputDesc, outputTupleDesc, pSegInputStream, TupleAccessor::resetCurrentTupleBuf(), srcIsInputStream, srcPartition, LhxHashInfo::streamBufAccessor, streamBufAccessor, and tupleAccessor.

Referenced by LhxPlan::createChildren(), LhxJoinExecStream::execute(), LhxAggExecStream::execute(), LhxPartitionInfo::open(), LhxJoinExecStream::open(), LhxAggExecStream::open(), and LhxHashTableTest::readPartition().

| bool LhxPartitionReader::isTupleConsumptionPending | ( | | ) | | -------------------------------------------------- | - | | - |

| bool LhxPartitionReader::demandData | ( | | ) | | ----------------------------------- | - | | - |

Definition at line 225 of file LhxPartition.cpp.

References bufState, EXECBUF_EOS, TupleAccessor::getBufferByteCount(), pSegInputStream, TupleAccessor::setCurrentTupleBuf(), srcIsInputStream, srcPartition, streamBufAccessor, tupleAccessor, and tupleStorageLength.

Referenced by LhxPlan::createChildren(), LhxJoinExecStream::execute(), LhxAggExecStream::execute(), LhxPlan::generatePartitions(), and LhxHashTableTest::readPartition().

void LhxPartitionReader::unmarshalTuple ( TupleData & outputTuple )

| void LhxPartitionReader::consumeTuple | ( | | ) | | ------------------------------------- | - | | - |

| void LhxPartitionReader::close | ( | | ) | | ------------------------------ | - | | - |

| TupleDescriptor const & LhxPartitionReader::getTupleDesc | ( | | ) | const [inline] | | ------------------------------------------------------------------------------------- | - | | - | ---------------- |

Member Data Documentation

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

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