partitioning-throughput-test.cc File Reference

#include <emmintrin.h>
#include <stdlib.h>
#include <glog/logging.h>
#include "tuple-types.h"
#include "common/compiler-util.h"
#include "util/cpu-info.h"
#include "util/debug-util.h"
#include "util/stopwatch.h"

Include dependency graph for partitioning-throughput-test.cc:

Go to the source code of this file.

Classes
class	impala::PartitioningThroughputTest
struct	impala::PartitioningThroughputTest::Buffer
struct	impala::PartitioningThroughputTest::BufferBuffer

Namespaces
	impala
	This file contains type definitions that are used throughout the code base.

Macros
#define	STREAMING   true

Functions
	Buffer ()
	BufferBuffer ()
int	main (int argc, char **argv)

Variables
ProbeTuple	tuples [BUFFER_TUPLES]
uint64_t	count
uint8_t	offset [7 *64-sizeof(uint64_t)]
uint8_t	padding [64-sizeof(int)]

Macro Definition Documentation

#define STREAMING   true

Definition at line 12 of file partitioning-throughput-test.cc.

Function Documentation

__attribute__::Buffer

(

)

Definition at line 39 of file partitioning-throughput-test.cc.

Referenced by impala::GrowingTest::SanityCheck(), and impala::PartitioningThroughputTest::TestThroughput().

__attribute__::BufferBuffer

(

)

Definition at line 38 of file partitioning-throughput-test.cc.

Referenced by impala::PartitioningThroughputTest::TestThroughput().

int main	(	int	argc,
		char **	argv
	)

Definition at line 131 of file partitioning-throughput-test.cc.

References impala::CpuInfo::Init(), and impala::PartitioningThroughputTest::TestRawThroughput().

Variable Documentation

int count

Definition at line 35 of file partitioning-throughput-test.cc.

Referenced by com.cloudera.impala.analysis.Analyzer::addWarning(), impala::AggregateFunctions::DecimalAvgGetValue(), EncodeNdv(), impala::AggregationNode::GetNext(), impala::PartitionedAggregationNode::GetNext(), com.cloudera.impala.analysis.Analyzer::getWarnings(), impala::operator<<(), impala::BitUtil::PopcountNoHw(), impala::TEST(), TEST(), impala::StatsMetric< double >::ToHumanReadable(), impala::StatsMetric< double >::ToJson(), and impala::StatsMetric< double >::ToLegacyJson().

uint8_t offset[7 *64-sizeof(uint64_t)]

Definition at line 37 of file partitioning-throughput-test.cc.

Referenced by impala::Sorter::Run::AddBatch(), com.cloudera.impala.hive.executor.UdfExecutor::allocateInputObjects(), com.cloudera.impala.analysis.AnalyticExpr::checkOffset(), CodegenCrcHash(), com.cloudera.impala.analysis.TupleDescriptor::computeMemLayout(), Concat(), impala::Sorter::Run::CopyVarLenDataConvertOffset(), com.cloudera.impala.planner.DistributedPlanner::createOrderByFragment(), impala::BufferedTupleStream::RowIdx::DebugString(), impala::Tuple::DeepCopy(), apache::thrift::transport::TSaslTransport::encodeInt(), com.cloudera.impala.catalog.HdfsPartition.FileBlock::FileBlock(), impala::BaseSequenceScanner::FindSyncBlock(), impala::HBaseTableScanner::GetFamily(), impala::ScannerContext::Stream::GetNextBuffer(), impala::HBaseTableScanner::GetQualifier(), impala::HBaseTableScanner::GetRowKey(), impala::HBaseTableScanner::GetValue(), impala::KeyNormalizer::NormalizeKey(), impala::BufferedBlockMgr::PinBlock(), impala::DiskIoMgr::ScanRange::Reset(), impala::RowBatch::RowBatch(), impala::StringSearchSSE::Search(), impala::RowBatch::Serialize(), com.cloudera.impala.hive.executor.ImpalaTextWritable::set(), com.cloudera.impala.hive.executor.ImpalaBytesWritable::set(), com.cloudera.impala.hive.executor.ImpalaStringWritable::set(), com.cloudera.impala.planner.ExchangeNode::setMergeInfo(), com.cloudera.impala.planner.SortNode::setOffset(), impala::BaseSequenceScanner::SkipToSync(), com.cloudera.impala.planner.SortNode::SortNode(), impala::TEST(), impala::TEST_F(), impala::TestCompression(), impala::SimpleTupleStreamTest::TestValues(), and impala::Validate().

uint8_t padding[64-sizeof(int)]

Definition at line 36 of file partitioning-throughput-test.cc.

Referenced by main(), and impala::Benchmark::Measure().

ProbeTuple tuples

Definition at line 34 of file partitioning-throughput-test.cc.

Referenced by impala::GrowingTest::AggregateTest(), main(), DataPartitioner::Split(), and impala::PartitioningThroughputTest::TestThroughput().