OmniSciDB  b24e664e58
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
anonymous_namespace{QueryFragmentDescriptor.cpp} Namespace Reference

Functions

std::optional< size_t > compute_fragment_tuple_count (const Fragmenter_Namespace::FragmentInfo &fragment, const ColumnDescriptor *deleted_cd)
 
bool is_sample_query (const RelAlgExecutionUnit &ra_exe_unit)
 

Function Documentation

std::optional<size_t> anonymous_namespace{QueryFragmentDescriptor.cpp}::compute_fragment_tuple_count ( const Fragmenter_Namespace::FragmentInfo fragment,
const ColumnDescriptor deleted_cd 
)

Definition at line 81 of file QueryFragmentDescriptor.cpp.

References Fragmenter_Namespace::FragmentInfo::getNumTuples().

Referenced by QueryFragmentDescriptor::buildFragmentPerKernelMap().

83  {
84  if (deleted_cd) {
85  return std::nullopt;
86  } else {
87  return fragment.getNumTuples();
88  }
89 }

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

bool anonymous_namespace{QueryFragmentDescriptor.cpp}::is_sample_query ( const RelAlgExecutionUnit ra_exe_unit)

Definition at line 258 of file QueryFragmentDescriptor.cpp.

References CHECK(), CHECK_EQ, RelAlgExecutionUnit::groupby_exprs, RelAlgExecutionUnit::input_descs, SortInfo::order_entries, RelAlgExecutionUnit::quals, run_benchmark_import::result, RelAlgExecutionUnit::scan_limit, RelAlgExecutionUnit::simple_quals, and RelAlgExecutionUnit::sort_info.

Referenced by QueryFragmentDescriptor::terminateDispatchMaybe().

258  {
259  const bool result = ra_exe_unit.input_descs.size() == 1 &&
260  ra_exe_unit.simple_quals.empty() && ra_exe_unit.quals.empty() &&
261  ra_exe_unit.sort_info.order_entries.empty() &&
262  ra_exe_unit.scan_limit;
263  if (result) {
264  CHECK_EQ(size_t(1), ra_exe_unit.groupby_exprs.size());
265  CHECK(!ra_exe_unit.groupby_exprs.front());
266  }
267  return result;
268 }
#define CHECK_EQ(x, y)
Definition: Logger.h:198
const std::list< Analyzer::OrderEntry > order_entries
const std::list< std::shared_ptr< Analyzer::Expr > > groupby_exprs
const std::vector< InputDescriptor > input_descs
CHECK(cgen_state)
const SortInfo sort_info
std::list< std::shared_ptr< Analyzer::Expr > > quals
std::list< std::shared_ptr< Analyzer::Expr > > simple_quals

+ Here is the call graph for this function:

+ Here is the caller graph for this function: