CardinalityEstimator.cpp File Reference

#include "CardinalityEstimator.h"
#include "ErrorHandling.h"
#include "ExpressionRewrite.h"
#include "RelAlgExecutor.h"

Include dependency graph for CardinalityEstimator.cpp:

Go to the source code of this file.

Namespaces
	Analyzer

Functions
ResultSetPtr	reduce_estimator_results (const RelAlgExecutionUnit &ra_exe_unit, std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &results_per_device)

Variables
int64_t	g_large_ndv_threshold = 10000000
size_t	g_large_ndv_multiplier = 256

Function Documentation

ResultSetPtr reduce_estimator_results	(	const RelAlgExecutionUnit &	ra_exe_unit,
		std::vector< std::pair< ResultSetPtr, std::vector< size_t >>> &	results_per_device
	)

Definition at line 141 of file CardinalityEstimator.cpp.

References CHECK, and RelAlgExecutionUnit::estimator.

Referenced by Executor::reduceMultiDeviceResults().

                                                                             {
  if (results_per_device.empty()) {
    return nullptr;
  }
  CHECK(dynamic_cast<const Analyzer::NDVEstimator*>(ra_exe_unit.estimator.get()));
  const auto& result_set = results_per_device.front().first;
  CHECK(result_set);
  auto estimator_buffer = result_set->getHostEstimatorBuffer();
  CHECK(estimator_buffer);
  for (size_t i = 1; i < results_per_device.size(); ++i) {
    const auto& next_result_set = results_per_device[i].first;
    const auto other_estimator_buffer = next_result_set->getHostEstimatorBuffer();
    for (size_t off = 0; off < ra_exe_unit.estimator->getBufferSize(); ++off) {
      estimator_buffer[off] |= other_estimator_buffer[off];
    }
  }
  return std::move(result_set);
}

Here is the caller graph for this function:

Variable Documentation

size_t g_large_ndv_multiplier = 256

Definition at line 23 of file CardinalityEstimator.cpp.

Referenced by CommandLineOptions::fillDeveloperOptions(), and Analyzer::LargeNDVEstimator::getBufferSize().

int64_t g_large_ndv_threshold = 10000000

Definition at line 22 of file CardinalityEstimator.cpp.

Referenced by RelAlgExecutionUnit::createNdvExecutionUnit(), and CommandLineOptions::fillDeveloperOptions().