#include <boost/function.hpp>
#include <boost/scoped_ptr.hpp>
#include <boost/thread/mutex.hpp>
#include <boost/unordered_map.hpp>
#include <iostream>
#include <sys/time.h>
#include <sys/resource.h>
#include "common/atomic.h"
#include "common/logging.h"
#include "common/object-pool.h"
#include "util/thread.h"
#include "util/stopwatch.h"
#include "util/streaming-sampler.h"
#include "gen-cpp/RuntimeProfile_types.h"

Include dependency graph for runtime-profile.h:

This graph shows which files directly or indirectly include this file:

Classes
class	impala::RuntimeProfile

class	impala::RuntimeProfile::Counter

class	impala::RuntimeProfile::HighWaterMarkCounter

class	impala::RuntimeProfile::DerivedCounter

class	impala::RuntimeProfile::AveragedCounter

class	impala::RuntimeProfile::ThreadCounters
	A set of counters that measure thread info, such as total time, user time, sys time. More...

class	impala::RuntimeProfile::EventSequence

class	impala::RuntimeProfile::TimeSeriesCounter

class	impala::ScopedEvent
	Utility class to mark an event when the object is destroyed. More...

class	impala::ScopedCounter

class	impala::ScopedTimer< T >

class	impala::ThreadCounterMeasurement

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

Macros
#define	ENABLE_COUNTERS 1

#define	CONCAT_IMPL(x, y) x##y
	Some macro magic to generate unique ids using COUNTER More...

#define	MACRO_CONCAT(x, y) CONCAT_IMPL(x, y)

#define	ADD_COUNTER(profile, name, unit) (profile)->AddCounter(name, unit)

#define	ADD_TIME_SERIES_COUNTER(profile, name, src_counter) (profile)->AddTimeSeriesCounter(name, src_counter)

#define	ADD_TIMER(profile, name) (profile)->AddCounter(name, TUnit::TIME_NS)

#define	ADD_CHILD_TIMER(profile, name, parent) (profile)->AddCounter(name, TUnit::TIME_NS, parent)

#define	SCOPED_TIMER(c) ScopedTimer<MonotonicStopWatch> MACRO_CONCAT(SCOPED_TIMER, __COUNTER__)(c)

#define	COUNTER_ADD(c, v) (c)->Add(v)

#define	COUNTER_SET(c, v) (c)->Set(v)

#define	ADD_THREAD_COUNTERS(profile, prefix) (profile)->AddThreadCounters(prefix)

#define	SCOPED_THREAD_COUNTER_MEASUREMENT(c)

Macro Definition Documentation

#define ADD_CHILD_TIMER	(	profile,
		name,
		parent
	)	(profile)->AddCounter(name, TUnit::TIME_NS, parent)

Definition at line 51 of file runtime-profile.h.

Referenced by impala::HdfsTextScanner::Prepare(), and impala::ScanNode::Prepare().

#define ADD_COUNTER	(	profile,
		name,
		unit
	)	(profile)->AddCounter(name, unit)

#define ADD_THREAD_COUNTERS	(	profile,
		prefix
	)	(profile)->AddThreadCounters(prefix)

Definition at line 57 of file runtime-profile.h.

Referenced by impala::ScanNode::Prepare().

#define ADD_TIME_SERIES_COUNTER	(	profile,
		name,
		src_counter
	)	(profile)->AddTimeSeriesCounter(name, src_counter)

Definition at line 48 of file runtime-profile.h.

Referenced by impala::DataStreamRecvr::DataStreamRecvr(), and impala::ScanNode::Prepare().

#define ADD_TIMER	(	profile,
		name
	)	(profile)->AddCounter(name, TUnit::TIME_NS)

Definition at line 50 of file runtime-profile.h.

Referenced by impala::HdfsTableSink::CreateNewTmpFile(), impala::DataStreamRecvr::DataStreamRecvr(), impala::CatalogOpExecutor::Exec(), impala::CatalogOpExecutor::ExecComputeStats(), impala::HdfsTableSink::FinalizePartitionFile(), impala::HBaseTableWriter::Init(), impala::Sorter::Init(), impala::BufferedTupleStream::Init(), impala::RuntimeState::Init(), impala::BufferedBlockMgr::Init(), impala::LlvmCodeGen::LlvmCodeGen(), impala::HdfsScanNode::Open(), impala::HBaseScanNode::Prepare(), impala::ExchangeNode::Prepare(), impala::BlockingJoinNode::Prepare(), impala::AggregationNode::Prepare(), impala::PartitionedHashJoinNode::Prepare(), impala::AnalyticEvalNode::Prepare(), impala::DataStreamSender::Prepare(), impala::PlanFragmentExecutor::Prepare(), impala::PartitionedAggregationNode::Prepare(), impala::HdfsScanner::Prepare(), impala::HdfsTableSink::Prepare(), impala::ImpalaServer::QueryExecState::QueryExecState(), impala::SortedRunMerger::SortedRunMerger(), and impala::ImpalaServer::QueryExecState::UpdateCatalog().

#define CONCAT_IMPL	(	x,
		y
	)	x##y

Some macro magic to generate unique ids using COUNTER

Definition at line 43 of file runtime-profile.h.

#define COUNTER_ADD	(	c,
		v
	)	(c)->Add(v)

Definition at line 55 of file runtime-profile.h.

#define COUNTER_SET	(	c,
		v
	)	(c)->Set(v)

Definition at line 56 of file runtime-profile.h.

#define ENABLE_COUNTERS 1

Define macros for updating counters. The macros make it very easy to disable all counters at compile time. Set this to 0 to remove counters. This is useful to do to make sure the counters aren't affecting the system.

Definition at line 40 of file runtime-profile.h.