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

Functions

bool can_combine_with (const Analyzer::Expr *crt, const Analyzer::Expr *prev)
 
std::list< std::shared_ptr
< Analyzer::Expr > > 
make_composite_equals_impl (const std::vector< std::shared_ptr< Analyzer::Expr >> &crt_coalesced_quals)
 
std::list< std::shared_ptr
< Analyzer::Expr > > 
make_composite_equals (const std::vector< std::shared_ptr< Analyzer::Expr >> &crt_coalesced_quals)
 

Function Documentation

bool anonymous_namespace{EquiJoinCondition.cpp}::can_combine_with ( const Analyzer::Expr crt,
const Analyzer::Expr prev 
)

Definition at line 26 of file EquiJoinCondition.cpp.

References IS_EQUIVALENCE, kONE, remove_cast(), and ScalarExprVisitor< T >::visit().

Referenced by combine_equi_join_conditions().

26  {
27  const auto crt_bin = dynamic_cast<const Analyzer::BinOper*>(crt);
28  const auto prev_bin = dynamic_cast<const Analyzer::BinOper*>(prev);
29  if (!crt_bin || !prev_bin) {
30  return false;
31  }
32  if (!IS_EQUIVALENCE(crt_bin->get_optype()) || crt_bin->get_qualifier() != kONE ||
33  !IS_EQUIVALENCE(prev_bin->get_optype()) || prev_bin->get_qualifier() != kONE ||
34  // We could accept a mix of kEQ and kBW_EQ, but don't bother for now.
35  crt_bin->get_optype() != prev_bin->get_optype()) {
36  return false;
37  }
38 
39  auto get_rhs_col_var = [](const auto bin_oper) {
40  auto inner_col_var = std::dynamic_pointer_cast<Analyzer::ColumnVar>(
41  remove_cast(bin_oper->get_own_right_operand()));
42  if (!inner_col_var) {
43  const auto string_oper = std::dynamic_pointer_cast<Analyzer::StringOper>(
44  remove_cast(bin_oper->get_own_right_operand()));
45  if (string_oper && string_oper->getArity() >= 1UL) {
46  inner_col_var =
47  std::dynamic_pointer_cast<Analyzer::ColumnVar>(string_oper->getOwnArg(0));
48  }
49  }
50  return inner_col_var;
51  };
52 
53  const std::shared_ptr<Analyzer::ColumnVar> crt_inner_col_var = get_rhs_col_var(crt_bin);
54  const std::shared_ptr<Analyzer::ColumnVar> prev_inner_col_var =
55  get_rhs_col_var(prev_bin);
56  if (!crt_inner_col_var || !prev_inner_col_var) {
57  return false;
58  }
60  const auto crt_outer_rte_set = visitor.visit(crt_bin->get_left_operand());
61  const auto prev_outer_rte_set = visitor.visit(prev_bin->get_left_operand());
62  // We shouldn't treat mixed nesting levels columns as a composite key tuple.
63  if (crt_outer_rte_set.size() != 1 || prev_outer_rte_set.size() != 1 ||
64  crt_outer_rte_set != prev_outer_rte_set) {
65  return false;
66  }
67  if (crt_inner_col_var->get_table_id() != prev_inner_col_var->get_table_id() ||
68  crt_inner_col_var->get_rte_idx() != prev_inner_col_var->get_rte_idx()) {
69  return false;
70  }
71  return true;
72 }
std::shared_ptr< Analyzer::Expr > remove_cast(const std::shared_ptr< Analyzer::Expr > &expr)
Definition: Analyzer.cpp:4325
#define IS_EQUIVALENCE(X)
Definition: sqldefs.h:69
T visit(const Analyzer::Expr *expr) const
Definition: sqldefs.h:71
Expression class for string functions The &quot;arg&quot; constructor parameter must be an expression that reso...
Definition: Analyzer.h:1475

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::list<std::shared_ptr<Analyzer::Expr> > anonymous_namespace{EquiJoinCondition.cpp}::make_composite_equals ( const std::vector< std::shared_ptr< Analyzer::Expr >> &  crt_coalesced_quals)

Definition at line 119 of file EquiJoinCondition.cpp.

References make_composite_equals_impl().

Referenced by combine_equi_join_conditions().

120  {
121  if (crt_coalesced_quals.size() == 1) {
122  return {crt_coalesced_quals.front()};
123  }
124  return make_composite_equals_impl(crt_coalesced_quals);
125 }
std::list< std::shared_ptr< Analyzer::Expr > > make_composite_equals_impl(const std::vector< std::shared_ptr< Analyzer::Expr >> &crt_coalesced_quals)

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

std::list<std::shared_ptr<Analyzer::Expr> > anonymous_namespace{EquiJoinCondition.cpp}::make_composite_equals_impl ( const std::vector< std::shared_ptr< Analyzer::Expr >> &  crt_coalesced_quals)

Definition at line 74 of file EquiJoinCondition.cpp.

References CHECK, CHECK_EQ, IS_NUMBER, IS_STRING, kBOOLEAN, kENCODING_DICT, kONE, and remove_cast().

Referenced by coalesce_singleton_equi_join(), and make_composite_equals().

75  {
76  std::list<std::shared_ptr<Analyzer::Expr>> join_quals;
77  std::vector<std::shared_ptr<Analyzer::Expr>> lhs_tuple;
78  std::vector<std::shared_ptr<Analyzer::Expr>> rhs_tuple;
79  bool not_null{true};
80  for (const auto& qual : crt_coalesced_quals) {
81  const auto qual_binary = std::dynamic_pointer_cast<Analyzer::BinOper>(qual);
82  CHECK(qual_binary);
83  not_null = not_null && qual_binary->get_type_info().get_notnull();
84  const auto lhs_col = remove_cast(qual_binary->get_own_left_operand());
85  const auto rhs_col = remove_cast(qual_binary->get_own_right_operand());
86  const auto lhs_ti = lhs_col->get_type_info();
87  // Coalesce cols for integers, bool, and dict encoded strings. Forces baseline hash
88  // join.
89  if (IS_NUMBER(lhs_ti.get_type()) ||
90  (IS_STRING(lhs_ti.get_type()) && lhs_ti.get_compression() == kENCODING_DICT) ||
91  (lhs_ti.get_type() == kBOOLEAN)) {
92  lhs_tuple.push_back(lhs_col);
93  rhs_tuple.push_back(rhs_col);
94  } else {
95  join_quals.push_back(qual);
96  }
97  }
98  CHECK(!crt_coalesced_quals.empty());
99  const auto first_qual =
100  std::dynamic_pointer_cast<Analyzer::BinOper>(crt_coalesced_quals.front());
101  CHECK(first_qual);
102  CHECK_EQ(lhs_tuple.size(), rhs_tuple.size());
103  if (lhs_tuple.size() > 0) {
104  join_quals.push_front(std::make_shared<Analyzer::BinOper>(
105  SQLTypeInfo(kBOOLEAN, not_null),
106  false,
107  first_qual->get_optype(),
108  kONE,
109  lhs_tuple.size() > 1 ? std::make_shared<Analyzer::ExpressionTuple>(lhs_tuple)
110  : lhs_tuple.front(),
111  rhs_tuple.size() > 1 ? std::make_shared<Analyzer::ExpressionTuple>(rhs_tuple)
112  : rhs_tuple.front()));
113  }
114  return join_quals;
115 }
#define CHECK_EQ(x, y)
Definition: Logger.h:297
std::shared_ptr< Analyzer::Expr > remove_cast(const std::shared_ptr< Analyzer::Expr > &expr)
Definition: Analyzer.cpp:4325
Definition: sqldefs.h:71
#define IS_STRING(T)
Definition: sqltypes.h:297
#define CHECK(condition)
Definition: Logger.h:289
#define IS_NUMBER(T)
Definition: sqltypes.h:294

+ Here is the call graph for this function:

+ Here is the caller graph for this function: