impala::SimpleTupleStreamTest Class Reference

Inheritance diagram for impala::SimpleTupleStreamTest:

Collaboration diagram for impala::SimpleTupleStreamTest:

Protected Member Functions
virtual void	SetUp ()
virtual void	CreateDescriptors ()
virtual void	TearDown ()
void	CreateMgr (int64_t limit, int block_size)
virtual RowBatch *	CreateIntBatch (int start_val, int num_rows, bool gen_null)
virtual RowBatch *	CreateStringBatch (int string_idx, int num_rows, bool gen_null)
void	AppendRowTuples (TupleRow *row, vector< int > *results)
void	AppendRowTuples (TupleRow *row, vector< StringValue > *results)
void	AppendValue (Tuple *t, vector< int > *results)
void	AppendValue (Tuple *t, vector< StringValue > *results)
template<typename T >
void	ReadValues (BufferedTupleStream *stream, RowDescriptor *desc, vector< T > *results, int num_batches=-1)
virtual void	VerifyResults (const vector< int > &results, int exp_rows, bool gen_null)
virtual void	VerifyResults (const vector< StringValue > &results, int exp_rows, bool gen_null)
template<typename T >
void	TestValues (int num_batches, RowDescriptor *desc, bool gen_null)
void	TestIntValuesInterleaved (int num_batches, int num_batches_before_read)

Protected Attributes
scoped_ptr< ExecEnv >	exec_env_
scoped_ptr< RuntimeState >	runtime_state_
scoped_ptr< MemTracker >	block_mgr_parent_tracker_
shared_ptr< BufferedBlockMgr >	block_mgr_
BufferedBlockMgr::Client *	client_
MemTracker	tracker_
ObjectPool	pool_
RowDescriptor *	int_desc_
RowDescriptor *	string_desc_
scoped_ptr< MemPool >	mem_pool_

Detailed Description

Definition at line 57 of file buffered-tuple-stream-test.cc.

Member Function Documentation

void impala::SimpleTupleStreamTest::AppendRowTuples ( TupleRow *  row, vector< int > *  results  )

inlineprotected

Definition at line 176 of file buffered-tuple-stream-test.cc.

References AppendValue(), impala::TupleRow::GetTuple(), int_desc_, and impala::RowDescriptor::tuple_descriptors().

Referenced by ReadValues().

void impala::SimpleTupleStreamTest::AppendRowTuples ( TupleRow *  row, vector< StringValue > *  results  )

inlineprotected

Definition at line 184 of file buffered-tuple-stream-test.cc.

References AppendValue(), impala::TupleRow::GetTuple(), string_desc_, and impala::RowDescriptor::tuple_descriptors().

void impala::SimpleTupleStreamTest::AppendValue ( Tuple *  t, vector< int > *  results  )

inlineprotected

Definition at line 192 of file buffered-tuple-stream-test.cc.

Referenced by AppendRowTuples().

void impala::SimpleTupleStreamTest::AppendValue ( Tuple *  t, vector< StringValue > *  results  )

inlineprotected

Definition at line 201 of file buffered-tuple-stream-test.cc.

References impala::StringValue::len, mem_pool_, and impala::StringValue::ptr.

virtual void impala::SimpleTupleStreamTest::CreateDescriptors ( )

inlineprotectedvirtual

Reimplemented in impala::MultiNullableTupleStreamTest, impala::MultiTupleStreamTest, and impala::SimpleNullStreamTest.

Definition at line 70 of file buffered-tuple-stream-test.cc.

References impala::ObjectPool::Add(), impala::DescriptorTblBuilder::Build(), impala::DescriptorTblBuilder::DeclareTuple(), int_desc_, pool_, string_desc_, impala::TYPE_INT, and impala::TYPE_STRING.

Referenced by SetUp().

virtual RowBatch* impala::SimpleTupleStreamTest::CreateIntBatch ( int  start_val, int  num_rows, bool  gen_null  )

inlineprotectedvirtual

Definition at line 101 of file buffered-tuple-stream-test.cc.

References impala::ObjectPool::Add(), impala::RowBatch::AddRow(), impala::MemPool::Allocate(), impala::RowBatch::CommitLastRow(), impala::RowBatch::GetRow(), gen_ir_descriptions::idx, int_desc_, pool_, impala::TupleRow::SetTuple(), tracker_, impala::RowBatch::tuple_data_pool(), and impala::RowDescriptor::tuple_descriptors().

Referenced by TestIntValuesInterleaved(), and TestValues().

void impala::SimpleTupleStreamTest::CreateMgr ( int64_t  limit, int  block_size  )

inlineprotected

Definition at line 93 of file buffered-tuple-stream-test.cc.

References block_mgr_, client_, impala::BufferedBlockMgr::Create(), impala::Status::ok(), runtime_state_, and tracker_.

virtual RowBatch* impala::SimpleTupleStreamTest::CreateStringBatch ( int  string_idx, int  num_rows, bool  gen_null  )

inlineprotectedvirtual

Definition at line 136 of file buffered-tuple-stream-test.cc.

References impala::ObjectPool::Add(), impala::RowBatch::AddRow(), impala::MemPool::Allocate(), impala::RowBatch::CommitLastRow(), impala::RowBatch::GetRow(), impala::NUM_STRINGS, pool_, impala::TupleRow::SetTuple(), string_desc_, impala::STRINGS, tracker_, impala::RowBatch::tuple_data_pool(), and impala::RowDescriptor::tuple_descriptors().

Referenced by TestValues().

template<typename T >

void impala::SimpleTupleStreamTest::ReadValues ( BufferedTupleStream *  stream, RowDescriptor *  desc, vector< T > *  results, int  num_batches = -1  )

inlineprotected

Definition at line 215 of file buffered-tuple-stream-test.cc.

References AppendRowTuples(), BATCH_SIZE, impala::BufferedTupleStream::GetNext(), impala::RowBatch::GetRow(), impala::RowBatch::num_rows(), impala::Status::ok(), impala::RowBatch::Reset(), and tracker_.

Referenced by TestIntValuesInterleaved(), and TestValues().

virtual void impala::SimpleTupleStreamTest::SetUp ( )

inlineprotectedvirtual

Definition at line 59 of file buffered-tuple-stream-test.cc.

References CreateDescriptors(), exec_env_, mem_pool_, runtime_state_, and tracker_.

virtual void impala::SimpleTupleStreamTest::TearDown ( )

inlineprotectedvirtual

Definition at line 85 of file buffered-tuple-stream-test.cc.

References block_mgr_, block_mgr_parent_tracker_, exec_env_, mem_pool_, and runtime_state_.

void impala::SimpleTupleStreamTest::TestIntValuesInterleaved ( int  num_batches, int  num_batches_before_read  )

inlineprotected

Definition at line 347 of file buffered-tuple-stream-test.cc.

References BATCH_SIZE, block_mgr_, client_, CreateIntBatch(), impala::RowBatch::GetRow(), int_desc_, impala::RowBatch::num_rows(), ReadValues(), impala::RowBatch::Reset(), runtime_state_, and impala::RowDescriptor::tuple_descriptors().

template<typename T >

void impala::SimpleTupleStreamTest::TestValues ( int  num_batches, RowDescriptor *  desc, bool  gen_null  )

inlineprotected

Definition at line 299 of file buffered-tuple-stream-test.cc.

References BATCH_SIZE, block_mgr_, client_, CreateIntBatch(), CreateStringBatch(), impala::Status::GetDetail(), impala::RowBatch::GetRow(), impala::RowBatch::num_rows(), offset, ReadValues(), impala::RowBatch::Reset(), runtime_state_, and VerifyResults().

virtual void impala::SimpleTupleStreamTest::VerifyResults ( const vector< int > &  results, int  exp_rows, bool  gen_null  )

inlineprotectedvirtual

Definition at line 231 of file buffered-tuple-stream-test.cc.

References int_desc_, and impala::RowDescriptor::tuple_descriptors().

Referenced by TestValues().

virtual void impala::SimpleTupleStreamTest::VerifyResults ( const vector< StringValue > &  results, int  exp_rows, bool  gen_null  )

inlineprotectedvirtual

Definition at line 263 of file buffered-tuple-stream-test.cc.

References gen_ir_descriptions::idx, impala::NUM_STRINGS, string_desc_, impala::STRINGS, and impala::RowDescriptor::tuple_descriptors().

Member Data Documentation

shared_ptr<BufferedBlockMgr> impala::SimpleTupleStreamTest::block_mgr_

protected

Definition at line 391 of file buffered-tuple-stream-test.cc.

Referenced by CreateMgr(), TearDown(), TestIntValuesInterleaved(), and TestValues().

scoped_ptr<MemTracker> impala::SimpleTupleStreamTest::block_mgr_parent_tracker_

protected

Definition at line 389 of file buffered-tuple-stream-test.cc.

Referenced by TearDown().

BufferedBlockMgr::Client* impala::SimpleTupleStreamTest::client_

protected

Definition at line 392 of file buffered-tuple-stream-test.cc.

Referenced by CreateMgr(), TestIntValuesInterleaved(), and TestValues().

scoped_ptr<ExecEnv> impala::SimpleTupleStreamTest::exec_env_

protected

Definition at line 387 of file buffered-tuple-stream-test.cc.

Referenced by SetUp(), and TearDown().

RowDescriptor* impala::SimpleTupleStreamTest::int_desc_

protected

Definition at line 396 of file buffered-tuple-stream-test.cc.

Referenced by AppendRowTuples(), CreateDescriptors(), impala::SimpleNullStreamTest::CreateDescriptors(), impala::MultiTupleStreamTest::CreateDescriptors(), impala::MultiNullableTupleStreamTest::CreateDescriptors(), CreateIntBatch(), TestIntValuesInterleaved(), and VerifyResults().

scoped_ptr<MemPool> impala::SimpleTupleStreamTest::mem_pool_

protected

Definition at line 398 of file buffered-tuple-stream-test.cc.

Referenced by AppendValue(), SetUp(), and TearDown().

ObjectPool impala::SimpleTupleStreamTest::pool_

protected

Definition at line 395 of file buffered-tuple-stream-test.cc.

Referenced by CreateDescriptors(), impala::SimpleNullStreamTest::CreateDescriptors(), impala::MultiTupleStreamTest::CreateDescriptors(), impala::MultiNullableTupleStreamTest::CreateDescriptors(), CreateIntBatch(), and CreateStringBatch().

scoped_ptr<RuntimeState> impala::SimpleTupleStreamTest::runtime_state_

protected

Definition at line 388 of file buffered-tuple-stream-test.cc.

Referenced by CreateMgr(), SetUp(), TearDown(), TestIntValuesInterleaved(), and TestValues().

RowDescriptor* impala::SimpleTupleStreamTest::string_desc_

protected

Definition at line 397 of file buffered-tuple-stream-test.cc.

Referenced by AppendRowTuples(), CreateDescriptors(), impala::SimpleNullStreamTest::CreateDescriptors(), impala::MultiTupleStreamTest::CreateDescriptors(), impala::MultiNullableTupleStreamTest::CreateDescriptors(), CreateStringBatch(), and VerifyResults().

MemTracker impala::SimpleTupleStreamTest::tracker_

protected

Definition at line 394 of file buffered-tuple-stream-test.cc.

Referenced by CreateIntBatch(), CreateMgr(), CreateStringBatch(), ReadValues(), and SetUp().

---

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

• be/src/runtime/buffered-tuple-stream-test.cc