Project
Loading...
Searching...
No Matches
Expressions.cxx File Reference
#include "Framework/ExpressionHelpers.h"
#include "Framework/RuntimeError.h"
#include "Framework/VariantHelpers.h"
#include "arrow/table.h"
#include "gandiva/tree_expr_builder.h"
#include <algorithm>
#include <iostream>
#include <set>
#include <stack>
#include <unordered_map>

Go to the source code of this file.

Namespaces

namespace  o2
 a couple of static helper functions to create timestamp values for CCDB queries or override obsolete objects
 
namespace  o2::framework
 Defining PrimaryVertex explicitly as messageable.
 
namespace  o2::framework::expressions
 

Functions

std::shared_ptr< arrow::DataType > o2::framework::expressions::concreteArrowType (atype::type type)
 
std::string o2::framework::expressions::upcastTo (atype::type f)
 
bool o2::framework::expressions::operator== (DatumSpec const &lhs, DatumSpec const &rhs)
 
std::ostream & o2::framework::expressions::operator<< (std::ostream &os, DatumSpec const &spec)
 
void o2::framework::expressions::updatePlaceholders (Filter &filter, InitContext &context)
 Update placeholder nodes from context.
 
const charo2::framework::expressions::stringType (atype::type t)
 
Operations o2::framework::expressions::createOperations (Filter const &expression)
 Function to create an internal operation sequence from a filter tree.
 
gandiva::ConditionPtr o2::framework::expressions::makeCondition (gandiva::NodePtr node)
 Function to create gandiva condition expression from generic gandiva expression tree.
 
gandiva::ExpressionPtr o2::framework::expressions::makeExpression (gandiva::NodePtr node, gandiva::FieldPtr result)
 Function to create gandiva projecting expression from generic gandiva expression tree.
 
std::shared_ptr< gandiva::Filter > o2::framework::expressions::createFilter (gandiva::SchemaPtr const &Schema, Operations const &opSpecs)
 Function to create gandiva filter from operation sequence.
 
std::shared_ptr< gandiva::Filter > o2::framework::expressions::createFilter (gandiva::SchemaPtr const &Schema, gandiva::ConditionPtr condition)
 Function to create gandiva filter from gandiva condition.
 
std::shared_ptr< gandiva::Projector > o2::framework::expressions::createProjector (gandiva::SchemaPtr const &Schema, Operations const &opSpecs, gandiva::FieldPtr result)
 Function to create gandiva projector from operation sequence.
 
std::shared_ptr< gandiva::Projector > o2::framework::expressions::createProjector (gandiva::SchemaPtr const &Schema, Projector &&p, gandiva::FieldPtr result)
 Function to create gandiva projector directly from expression.
 
std::shared_ptr< gandiva::Projector > o2::framework::expressions::createProjectorHelper (size_t nColumns, expressions::Projector *projectors, std::shared_ptr< arrow::Schema > schema, std::vector< std::shared_ptr< arrow::Field > > const &fields)
 
gandiva::Selection o2::framework::expressions::createSelection (std::shared_ptr< arrow::Table > const &table, std::shared_ptr< gandiva::Filter > const &gfilter)
 Function for creating gandiva selection from prepared gandiva expressions tree.
 
gandiva::Selection o2::framework::expressions::createSelection (std::shared_ptr< arrow::Table > const &table, Filter const &expression)
 Function for creating gandiva selection from our internal filter tree.
 
auto o2::framework::expressions::createProjection (std::shared_ptr< arrow::Table > const &table, std::shared_ptr< gandiva::Projector > const &gprojector)
 
gandiva::NodePtr o2::framework::expressions::createExpressionTree (Operations const &opSpecs, gandiva::SchemaPtr const &Schema)
 Function to create gandiva expression tree from operation sequence.
 
bool o2::framework::expressions::isTableCompatible (std::set< uint32_t > const &hashes, Operations const &specs)
 Function to check compatibility of a given arrow schema with operation sequence.
 
void o2::framework::expressions::updateExpressionInfos (expressions::Filter const &filter, std::vector< ExpressionInfo > &eInfos)
 Function for attaching gandiva filters to to compatible task inputs.
 
void o2::framework::expressions::updateFilterInfo (ExpressionInfo &info, std::shared_ptr< arrow::Table > &table)