ExecutionResult Class Reference

#include <RelAlgExecutionDescriptor.h>

Public Types
enum	RType { QueryResult, SimpleResult, Explanation, CalciteDdl }

Public Member Functions
	ExecutionResult ()
	ExecutionResult (const std::shared_ptr< ResultSet > &rows, const std::vector< TargetMetaInfo > &targets_meta)
	ExecutionResult (ResultSetPtr &&result, const std::vector< TargetMetaInfo > &targets_meta)
	ExecutionResult (const ExecutionResult &that)
	ExecutionResult (ExecutionResult &&that)
	ExecutionResult (const std::vector< PushedDownFilterInfo > &pushed_down_filter_info, bool filter_push_down_enabled)
ExecutionResult &	operator= (const ExecutionResult &that)
const std::shared_ptr < ResultSet > &	getRows () const
bool	empty () const
const ResultSetPtr &	getDataPtr () const
const std::vector < TargetMetaInfo > &	getTargetsMeta () const
const std::vector < PushedDownFilterInfo > &	getPushedDownFilterInfo () const
const bool	isFilterPushDownEnabled () const
void	setQueueTime (const int64_t queue_time_ms)
std::string	toString () const
std::string	getExplanation ()
void	updateResultSet (const std::string &query_ra, RType type, bool success=true)
RType	getResultType () const
void	setResultType (RType type)
int64_t	getExecutionTime () const
void	setExecutionTime (int64_t execution_time_ms)
void	addExecutionTime (int64_t execution_time_ms)

Private Attributes
ResultSetPtr	result_
std::vector< TargetMetaInfo >	targets_meta_
std::vector< PushedDownFilterInfo >	pushed_down_filter_info_
bool	filter_push_down_enabled_
bool	success_
uint64_t	execution_time_ms_
RType	type_

Detailed Description

Definition at line 29 of file RelAlgExecutionDescriptor.h.

Member Enumeration Documentation

enum ExecutionResult::RType

Enumerator
QueryResult
SimpleResult
Explanation
CalciteDdl

Definition at line 69 of file RelAlgExecutionDescriptor.h.

{ QueryResult, SimpleResult, Explanation, CalciteDdl };

Constructor & Destructor Documentation

ExecutionResult::ExecutionResult

(

)

Definition at line 26 of file RelAlgExecutionDescriptor.cpp.

    : filter_push_down_enabled_(false)
    , success_(true)
    , execution_time_ms_(0)
    , type_(QueryResult) {}

ExecutionResult::ExecutionResult	(	const std::shared_ptr< ResultSet > &	rows,
		const std::vector< TargetMetaInfo > &	targets_meta
	)

Definition at line 32 of file RelAlgExecutionDescriptor.cpp.

    : result_(rows)
    , targets_meta_(targets_meta)
    , filter_push_down_enabled_(false)
    , success_(true)
    , execution_time_ms_(0)
    , type_(QueryResult) {}

ExecutionResult::ExecutionResult	(	ResultSetPtr &&	result,
		const std::vector< TargetMetaInfo > &	targets_meta
	)

Definition at line 41 of file RelAlgExecutionDescriptor.cpp.

    : result_(std::move(result))
    , targets_meta_(targets_meta)
    , filter_push_down_enabled_(false)
    , success_(true)
    , execution_time_ms_(0)
    , type_(QueryResult) {}

ExecutionResult::ExecutionResult

(

const ExecutionResult &

that

)

Definition at line 50 of file RelAlgExecutionDescriptor.cpp.

References filter_push_down_enabled_, pushed_down_filter_info_, and result_.

    : targets_meta_(that.targets_meta_)
    , pushed_down_filter_info_(that.pushed_down_filter_info_)
    , filter_push_down_enabled_(that.filter_push_down_enabled_)
    , success_(that.success_)
    , execution_time_ms_(that.execution_time_ms_)
    , type_(that.type_) {
  if (!pushed_down_filter_info_.empty() ||
      (filter_push_down_enabled_ && pushed_down_filter_info_.empty())) {
    return;
  }
  result_ = that.result_;
}

ExecutionResult::ExecutionResult

(

ExecutionResult &&

that

)

Definition at line 64 of file RelAlgExecutionDescriptor.cpp.

References filter_push_down_enabled_, pushed_down_filter_info_, and result_.

    : targets_meta_(std::move(that.targets_meta_))
    , pushed_down_filter_info_(std::move(that.pushed_down_filter_info_))
    , filter_push_down_enabled_(std::move(that.filter_push_down_enabled_))
    , success_(that.success_)
    , execution_time_ms_(that.execution_time_ms_)
    , type_(that.type_) {
  if (!pushed_down_filter_info_.empty() ||
      (filter_push_down_enabled_ && pushed_down_filter_info_.empty())) {
    return;
  }
  result_ = std::move(that.result_);
}

ExecutionResult::ExecutionResult	(	const std::vector< PushedDownFilterInfo > &	pushed_down_filter_info,
		bool	filter_push_down_enabled
	)

Definition at line 78 of file RelAlgExecutionDescriptor.cpp.

    : pushed_down_filter_info_(pushed_down_filter_info)
    , filter_push_down_enabled_(filter_push_down_enabled)
    , success_(true)
    , execution_time_ms_(0)
    , type_(QueryResult) {}

Member Function Documentation

void ExecutionResult::addExecutionTime ( int64_t  execution_time_ms )

inline

Definition at line 79 of file RelAlgExecutionDescriptor.h.

References execution_time_ms_.

Referenced by DBHandler::execute_rel_alg_with_filter_push_down(), and DBHandler::sql_execute_impl().

                                                   {
    execution_time_ms_ += execution_time_ms;
  }

Here is the caller graph for this function:

bool ExecutionResult::empty ( ) const

inline

Definition at line 49 of file RelAlgExecutionDescriptor.h.

References result_.

Referenced by DBHandler::convertData(), DBHandler::executeDdl(), and getExplanation().

{ return !result_; }

Here is the caller graph for this function:

const ResultSetPtr& ExecutionResult::getDataPtr ( ) const

inline

Definition at line 51 of file RelAlgExecutionDescriptor.h.

References result_.

Referenced by DBHandler::convertResultSet(), and RelAlgExecutor::executeSort().

{ return result_; }

Here is the caller graph for this function:

int64_t ExecutionResult::getExecutionTime ( ) const

inline

Definition at line 75 of file RelAlgExecutionDescriptor.h.

References execution_time_ms_.

Referenced by DBHandler::convertData(), DBHandler::execute_rel_alg(), DBHandler::sql_execute(), and DBHandler::sql_execute_df().

{ return execution_time_ms_; }

Here is the caller graph for this function:

std::string ExecutionResult::getExplanation

(

)

Definition at line 117 of file RelAlgExecutionDescriptor.cpp.

References empty(), and getRows().

                                          {
  if (!empty()) {
    return getRows()->getExplanation();
  }
  return {};
}

Here is the call graph for this function:

const std::vector< PushedDownFilterInfo > & ExecutionResult::getPushedDownFilterInfo

(

)

const

Definition at line 102 of file RelAlgExecutionDescriptor.cpp.

References pushed_down_filter_info_.

Referenced by DBHandler::execute_rel_alg().

          {
  return pushed_down_filter_info_;
}

Here is the caller graph for this function:

RType ExecutionResult::getResultType ( ) const

inline

Definition at line 73 of file RelAlgExecutionDescriptor.h.

References type_.

Referenced by DBHandler::convertData(), and DBHandler::executeDdl().

{ return type_; }

Here is the caller graph for this function:

const std::shared_ptr<ResultSet>& ExecutionResult::getRows ( ) const

inline

Definition at line 47 of file RelAlgExecutionDescriptor.h.

References result_.

Referenced by DBHandler::convertData(), DBHandler::execute_rel_alg(), DBHandler::executeDdl(), getExplanation(), result_set_arrow_loopback(), and DBHandler::sql_execute_df().

{ return result_; }

Here is the caller graph for this function:

const std::vector<TargetMetaInfo>& ExecutionResult::getTargetsMeta ( ) const

inline

Definition at line 53 of file RelAlgExecutionDescriptor.h.

References targets_meta_.

Referenced by DBHandler::convertData(), result_set_arrow_loopback(), and DBHandler::sql_execute_df().

{ return targets_meta_; }

Here is the caller graph for this function:

const bool ExecutionResult::isFilterPushDownEnabled ( ) const

inline

Definition at line 57 of file RelAlgExecutionDescriptor.h.

References filter_push_down_enabled_.

{ return filter_push_down_enabled_; }

ExecutionResult & ExecutionResult::operator=

(

const ExecutionResult &

that

)

Definition at line 87 of file RelAlgExecutionDescriptor.cpp.

References execution_time_ms_, filter_push_down_enabled_, pushed_down_filter_info_, result_, success_, targets_meta_, and type_.

                                                                       {
  if (!that.pushed_down_filter_info_.empty() ||
      (that.filter_push_down_enabled_ && that.pushed_down_filter_info_.empty())) {
    pushed_down_filter_info_ = that.pushed_down_filter_info_;
    filter_push_down_enabled_ = that.filter_push_down_enabled_;
    return *this;
  }
  result_ = that.result_;
  targets_meta_ = that.targets_meta_;
  success_ = that.success_;
  execution_time_ms_ = that.execution_time_ms_;
  type_ = that.type_;
  return *this;
}

void ExecutionResult::setExecutionTime ( int64_t  execution_time_ms )

inline

Definition at line 76 of file RelAlgExecutionDescriptor.h.

References execution_time_ms_.

Referenced by DBHandler::execute_rel_alg(), DBHandler::executeDdl(), and DBHandler::sql_execute().

                                                   {
    execution_time_ms_ = execution_time_ms;
  }

Here is the caller graph for this function:

void ExecutionResult::setQueueTime ( const int64_t  queue_time_ms )

inline

Definition at line 59 of file RelAlgExecutionDescriptor.h.

References CHECK, and result_.

                                                 {
    CHECK(result_);
    result_->setQueueTime(queue_time_ms);
  }

void ExecutionResult::setResultType ( RType  type )

inline

Definition at line 74 of file RelAlgExecutionDescriptor.h.

References run_benchmark_import::type, and type_.

Referenced by DBHandler::execute_rel_alg(), and DBHandler::executeDdl().

{ type_ = type; }

Here is the caller graph for this function:

std::string ExecutionResult::toString ( ) const

inline

Definition at line 64 of file RelAlgExecutionDescriptor.h.

References result_, targets_meta_, and typeName().

                             {
    return ::typeName(this) + "(" + ::toString(result_) + ", " +
           ::toString(targets_meta_) + ")";
  }

Here is the call graph for this function:

void ExecutionResult::updateResultSet	(	const std::string &	query_ra,
		RType	type,
		bool	success = true
	)

Definition at line 107 of file RelAlgExecutionDescriptor.cpp.

References pushed_down_filter_info_, result_, success_, targets_meta_, run_benchmark_import::type, and type_.

Referenced by ShowCreateTableCommand::execute(), and DBHandler::sql_execute_impl().

                                                    {
  targets_meta_.clear();
  pushed_down_filter_info_.clear();
  success_ = success;
  type_ = type;
  result_ = std::make_shared<ResultSet>(query);
}

Here is the caller graph for this function:

Member Data Documentation

uint64_t ExecutionResult::execution_time_ms_

private

Definition at line 92 of file RelAlgExecutionDescriptor.h.

Referenced by addExecutionTime(), getExecutionTime(), operator=(), and setExecutionTime().

bool ExecutionResult::filter_push_down_enabled_

private

Definition at line 89 of file RelAlgExecutionDescriptor.h.

Referenced by ExecutionResult(), isFilterPushDownEnabled(), and operator=().

std::vector<PushedDownFilterInfo> ExecutionResult::pushed_down_filter_info_

private

Definition at line 87 of file RelAlgExecutionDescriptor.h.

Referenced by ExecutionResult(), getPushedDownFilterInfo(), operator=(), and updateResultSet().

ResultSetPtr ExecutionResult::result_

private

Definition at line 84 of file RelAlgExecutionDescriptor.h.

Referenced by empty(), ExecutionResult(), getDataPtr(), getRows(), operator=(), setQueueTime(), toString(), and updateResultSet().

bool ExecutionResult::success_

private

Definition at line 91 of file RelAlgExecutionDescriptor.h.

Referenced by operator=(), and updateResultSet().

std::vector<TargetMetaInfo> ExecutionResult::targets_meta_

private

Definition at line 85 of file RelAlgExecutionDescriptor.h.

Referenced by getTargetsMeta(), operator=(), toString(), and updateResultSet().

RType ExecutionResult::type_

private

Definition at line 93 of file RelAlgExecutionDescriptor.h.

Referenced by getResultType(), operator=(), setResultType(), and updateResultSet().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/Descriptors/RelAlgExecutionDescriptor.h
• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/Descriptors/RelAlgExecutionDescriptor.cpp