Function planFilter

bolt/connectors/paimon/PaimonDataSource.cpp:133–167

}

std::pair<std::shared_ptr<::paimon::Predicate>, core::TypedExprPtr> planFilter(
    const core::TypedExprPtr& expression,
    const RowTypePtr& rowType,
    core::ExpressionEvaluator* evaluator) {
  std::vector<core::TypedExprPtr> conjuncts;
  exec::flattenTopLevelConjuncts(expression, conjuncts);

  std::vector<std::shared_ptr<::paimon::Predicate>> predicates;
  std::vector<core::TypedExprPtr> remainingConjuncts;
  for (const auto& conjunct : conjuncts) {
    auto result =
        PaimonFilterTranslator::translate(conjunct, rowType, evaluator);
    if (result.ok()) {
      predicates.push_back(std::move(result.value));
    } else {
      VLOG(1) << "PaimonDataSource: Keeping filter conjunct "
              << conjunct->toString()
              << " as remaining filter: " << result.reason;
      remainingConjuncts.push_back(conjunct);
    }
  }

  std::shared_ptr<::paimon::Predicate> predicate;
  if (predicates.size() == 1) {
    predicate = std::move(predicates.front());
  } else if (!predicates.empty()) {
    auto result = ::paimon::PredicateBuilder::And(predicates);
    BOLT_CHECK(
        result.ok(), "PredicateBuilder::And failed for translated conjuncts");
    predicate = std::move(result).value();
  }

  return {
      std::move(predicate), combineConjuncts(std::move(remainingConjuncts))};
}

} // namespace