MockProducerExecStreamParams Struct Reference

MockProducerExecStreamParams defines parameters for MockProducerExecStream. More...

#include <MockProducerExecStream.h>

Inheritance diagram for MockProducerExecStreamParams:

List of all members.

Public Member Functions
	MockProducerExecStreamParams ()
Public Attributes
uint64_t	nRows
	Number of rows to generate.
SharedMockProducerExecStreamGenerator	pGenerator
	Generator for row values.
bool	saveTuples
	When true, save a copy of each generated tuple for later perusal.
std::ostream *	echoTuples
	When not null, print each generated tuple to this stream, for tracing or for later comparison.
SharedInt64ColumnGenerator	pBatchGenerator
	Generator which determines batch size.
TupleDescriptor	outputTupleDesc
TupleFormat	outputTupleFormat
SharedCacheAccessor	pCacheAccessor
	CacheAccessor to use for any data access.
SegmentAccessor	scratchAccessor
	Accessor for segment to use for allocating scratch buffers.

---

Detailed Description

MockProducerExecStreamParams defines parameters for MockProducerExecStream.

Definition at line 83 of file MockProducerExecStream.h.

---

Constructor & Destructor Documentation

MockProducerExecStreamParams::MockProducerExecStreamParams

(

)

[inline]

Definition at line 119 of file MockProducerExecStream.h.

        : nRows(0), saveTuples(false), echoTuples(0) {}

---

Member Data Documentation

uint64_t MockProducerExecStreamParams::nRows

Number of rows to generate.

Definition at line 89 of file MockProducerExecStream.h.

Referenced by LcsClusterReplaceExecStreamTest::loadCluster(), LcsMultiClusterAppendTest::loadClusters(), LcsRowScanExecStreamTest::loadOneCluster(), LbmSearchTest::loadTableAndIndex(), MockProducerExecStream::prepare(), LcsClusterReplaceExecStreamTest::replaceCluster(), ExecStreamTestSuite::testCartesianJoinExecStream(), CollectExecStreamTestSuite::testCollectCollectUncollectUncollect(), CollectExecStreamTestSuite::testCollectInts(), CollectExecStreamTestSuite::testCollectUncollect(), CalcExecStreamTestSuite::testConstant(), CorrelationJoinExecStreamTestSuite::testCorrelationJoin(), LhxAggExecStreamTest::testCountImpl(), LhxAggExecStreamTest::testGroupCountImpl(), LhxJoinExecStreamTest::testImpl(), LbmLoadBitmapTest::testLoad(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), ExecStreamTestSuite::testMergeImplicitPullInputs(), ExecStreamTestSuite::testNestedLoopJoinExecStream(), ExecStreamTestSuite::testSingleValueAggExecStream(), LhxAggExecStreamTest::testSingleValueImpl(), LhxAggExecStreamTest::testSumImpl(), and ExecStreamFactory::visit().

SharedMockProducerExecStreamGenerator MockProducerExecStreamParams::pGenerator

Generator for row values.

If non-singular, the tuple descriptor for this stream must be a single int64_t. If singular, all output is constant 0.

Definition at line 96 of file MockProducerExecStream.h.

Referenced by LcsClusterReplaceExecStreamTest::loadCluster(), LcsMultiClusterAppendTest::loadClusters(), LcsRowScanExecStreamTest::loadOneCluster(), LbmSearchTest::loadTableAndIndex(), MockProducerExecStream::prepare(), LcsClusterReplaceExecStreamTest::replaceCluster(), CollectExecStreamTestSuite::testCollectCollectUncollectUncollect(), CollectExecStreamTestSuite::testCollectInts(), CollectExecStreamTestSuite::testCollectUncollect(), CorrelationJoinExecStreamTestSuite::testCorrelationJoin(), LhxAggExecStreamTest::testGroupCountImpl(), LhxJoinExecStreamTest::testImpl(), LbmLoadBitmapTest::testLoad(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), ExecStreamTestSuite::testMergeImplicitPullInputs(), ExecStreamTestSuite::testNestedLoopJoinExecStream(), ExecStreamTestSuite::testSingleValueAggExecStream(), LhxAggExecStreamTest::testSingleValueImpl(), and LhxAggExecStreamTest::testSumImpl().

bool MockProducerExecStreamParams::saveTuples

When true, save a copy of each generated tuple for later perusal.

Allowed only when a generator is provided.

Definition at line 102 of file MockProducerExecStream.h.

Referenced by MockProducerExecStream::prepare().

std::ostream* MockProducerExecStreamParams::echoTuples

When not null, print each generated tuple to this stream, for tracing or for later comparison.

Allowed only when a generator is provided.

Definition at line 109 of file MockProducerExecStream.h.

Referenced by MockProducerExecStream::prepare().

SharedInt64ColumnGenerator MockProducerExecStreamParams::pBatchGenerator

Generator which determines batch size.

If the generator returns a non-zero value, a new batch is started. If the generator is NULL, the effect is the same as a generator which always returns zero: batches are created as large as possible.

Definition at line 117 of file MockProducerExecStream.h.

Referenced by MockProducerExecStream::prepare().

TupleDescriptor SingleOutputExecStreamParams::outputTupleDesc [inherited]

Definition at line 37 of file SingleOutputExecStream.h.

Referenced by LcsClusterReplaceExecStreamTest::initClusterAppendParams(), LbmExecStreamTestBase::initValuesExecStream(), LcsClusterReplaceExecStreamTest::loadCluster(), LcsMultiClusterAppendTest::loadClusters(), LcsRowScanExecStreamTest::loadOneCluster(), LbmSearchTest::loadTableAndIndex(), BTreeSearchExecStream::prepare(), BTreeReadExecStream::prepare(), FlatFileExecStreamImpl::prepare(), SingleOutputExecStream::prepare(), MockProducerExecStream::prepare(), ExecStreamFactory::readTupleStreamParams(), LcsClusterReplaceExecStreamTest::replaceCluster(), LcsMultiClusterAppendTest::scanCols(), LcsClusterAppendExecStreamTest::setUpDelIndexScan(), LbmSplicerExecStreamTest::spliceInput(), ExecStreamTestSuite::testBTreeInsertExecStream(), CollectExecStreamTestSuite::testCollectCollectUncollectUncollect(), CollectExecStreamTestSuite::testCollectInts(), CollectExecStreamTestSuite::testCollectUncollect(), CalcExecStreamTestSuite::testConstant(), CorrelationJoinExecStreamTestSuite::testCorrelationJoin(), LhxAggExecStreamTest::testCountImpl(), LcsRowScanExecStreamTest::testFilterCols(), LhxAggExecStreamTest::testGroupCountImpl(), LhxJoinExecStreamTest::testImpl(), LbmLoadBitmapTest::testLoad(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), ExecStreamTestSuite::testMergeImplicitPullInputs(), ExecStreamTestSuite::testNestedLoopJoinExecStream(), LbmNormalizerExecStreamTest::testNormalizer(), LbmMinusExecStreamTest::testRestartingMinus(), LcsRowScanExecStreamTest::testSampleScanCols(), LcsRowScanExecStreamTest::testScanCols(), LbmSearchTest::testScanIdx(), ExecStreamTestSuite::testSingleValueAggExecStream(), LhxAggExecStreamTest::testSingleValueImpl(), LbmSortedAggExecStreamTest::testSortedAgg(), LhxAggExecStreamTest::testSumImpl(), and LcsClusterReplaceExecStreamTest::verifyCluster().

TupleFormat SingleOutputExecStreamParams::outputTupleFormat [inherited]

Definition at line 39 of file SingleOutputExecStream.h.

Referenced by SingleOutputExecStream::prepare(), and SingleOutputExecStreamParams::SingleOutputExecStreamParams().

SharedCacheAccessor ExecStreamParams::pCacheAccessor [inherited]

CacheAccessor to use for any data access.

This will be singular if the stream should not perform data access.

Definition at line 183 of file ExecStreamDefs.h.

Referenced by ExecStreamFactory::createPrivateScratchSegment(), LbmSearchTest::initBTreeExecStreamParam(), LbmLoadBitmapTest::initBTreeExecStreamParam(), LcsClusterReplaceExecStreamTest::initClusterAppendParams(), LbmSearchTest::initClusterScanDef(), LbmLoadBitmapTest::initClusterScanDef(), ExecStreamGraphEmbryo::initStreamParams(), FtrsTableWriterFactory::loadIndex(), LcsRowScanExecStreamTest::loadOneCluster(), BTreeExecStream::newWriter(), LcsRowScanBaseExecStream::prepare(), BTreeExecStream::prepare(), ExecStream::prepare(), ExecStreamFactory::readBTreeStreamParams(), ExecStreamTestSuite::testBTreeInsertExecStream(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), LcsClusterAppendExecStreamTest::testLoadSingleCol(), LcsClusterAppendExecStreamTest::testScanMultiCol(), LcsClusterAppendExecStreamTest::testScanSingleCol(), and LcsClusterReplaceExecStreamTest::verifyCluster().

SegmentAccessor ExecStreamParams::scratchAccessor [inherited]

Accessor for segment to use for allocating scratch buffers.

This will be singular if the stream should not use any scratch buffers.

Definition at line 189 of file ExecStreamDefs.h.

Referenced by ExecStreamFactory::createPrivateScratchSegment(), LbmSearchTest::initBTreeExecStreamParam(), LbmLoadBitmapTest::initBTreeExecStreamParam(), LcsClusterReplaceExecStreamTest::initClusterAppendParams(), ExecStreamGraphEmbryo::initStreamParams(), FtrsTableWriterFactory::loadIndex(), LcsRowScanExecStreamTest::loadOneCluster(), BTreeExecStream::newWriter(), LcsClusterAppendExecStream::prepare(), BTreeExecStream::prepare(), FlatFileExecStreamImpl::prepare(), MockResourceExecStream::prepare(), ExecStream::prepare(), ExecStreamTestSuite::testBTreeInsertExecStream(), LcsClusterAppendExecStreamTest::testLoadMultiCol(), and LcsClusterAppendExecStreamTest::testLoadSingleCol().

---

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

• /home/pub/open/dev/fennel/exec/MockProducerExecStream.h

---