Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::Literal Class Reference

#include <literal.h>

Inheritance diagram for impala::Literal:
Collaboration diagram for impala::Literal:

Public Member Functions

 Literal (ColumnType type, bool v)
 Test ctors. More...
 
 Literal (ColumnType type, int8_t v)
 
 Literal (ColumnType type, int16_t v)
 
 Literal (ColumnType type, int32_t v)
 
 Literal (ColumnType type, int64_t v)
 
 Literal (ColumnType type, float v)
 
 Literal (ColumnType type, double v)
 
 Literal (ColumnType type, const std::string &v)
 
 Literal (ColumnType type, const StringValue &v)
 
virtual Status GetCodegendComputeFn (RuntimeState *state, llvm::Function **fn)
 
virtual impala_udf::BooleanVal GetBooleanVal (ExprContext *, TupleRow *)
 
virtual impala_udf::TinyIntVal GetTinyIntVal (ExprContext *, TupleRow *)
 
virtual impala_udf::SmallIntVal GetSmallIntVal (ExprContext *, TupleRow *)
 
virtual impala_udf::IntVal GetIntVal (ExprContext *, TupleRow *)
 
virtual impala_udf::BigIntVal GetBigIntVal (ExprContext *, TupleRow *)
 
virtual impala_udf::FloatVal GetFloatVal (ExprContext *, TupleRow *)
 
virtual impala_udf::DoubleVal GetDoubleVal (ExprContext *, TupleRow *)
 
virtual impala_udf::StringVal GetStringVal (ExprContext *, TupleRow *)
 
virtual impala_udf::DecimalVal GetDecimalVal (ExprContext *, TupleRow *)
 
virtual TimestampVal GetTimestampVal (ExprContext *context, TupleRow *)
 
int output_scale () const
 
void AddChild (Expr *expr)
 
ExprGetChild (int i) const
 
int GetNumChildren () const
 
const ColumnTypetype () const
 
bool is_slotref () const
 
const std::vector< Expr * > & children () const
 
virtual bool IsConstant () const
 
virtual int GetSlotIds (std::vector< SlotId > *slot_ids) const
 
virtual AnyValGetConstVal (ExprContext *context)
 

Static Public Member Functions

static LiteralCreateLiteral (const ColumnType &type, const std::string &str)
 
static Status CreateExprTree (ObjectPool *pool, const TExpr &texpr, ExprContext **ctx)
 
static Status CreateExprTrees (ObjectPool *pool, const std::vector< TExpr > &texprs, std::vector< ExprContext * > *ctxs)
 
static Status Prepare (const std::vector< ExprContext * > &ctxs, RuntimeState *state, const RowDescriptor &row_desc, MemTracker *tracker)
 
static Status Open (const std::vector< ExprContext * > &ctxs, RuntimeState *state)
 Convenience function for opening multiple expr trees. More...
 
static Status Clone (const std::vector< ExprContext * > &ctxs, RuntimeState *state, std::vector< ExprContext * > *new_ctxs)
 
static void Close (const std::vector< ExprContext * > &ctxs, RuntimeState *state)
 Convenience function for closing multiple expr trees. More...
 
static ExprCreateLiteral (ObjectPool *pool, const ColumnType &type, void *data)
 
static ExprCreateLiteral (ObjectPool *pool, const ColumnType &type, const std::string &)
 
static int ComputeResultsLayout (const std::vector< Expr * > &exprs, std::vector< int > *offsets, int *var_result_begin)
 
static int ComputeResultsLayout (const std::vector< ExprContext * > &ctxs, std::vector< int > *offsets, int *var_result_begin)
 
static std::string DebugString (const std::vector< Expr * > &exprs)
 
static std::string DebugString (const std::vector< ExprContext * > &ctxs)
 
static void InitBuiltinsDummy ()
 

Static Public Attributes

static const char * LLVM_CLASS_NAME = "class.impala::Expr"
 

Protected Member Functions

 Literal (const TExprNode &node)
 
virtual std::string DebugString () const
 
virtual Status Prepare (RuntimeState *state, const RowDescriptor &row_desc, ExprContext *context)
 
virtual Status Open (RuntimeState *state, ExprContext *context, FunctionContext::FunctionStateScope scope=FunctionContext::FRAGMENT_LOCAL)
 
virtual void Close (RuntimeState *state, ExprContext *context, FunctionContext::FunctionStateScope scope=FunctionContext::FRAGMENT_LOCAL)
 Subclasses overriding this function should call Expr::Close(). More...
 
std::string DebugString (const std::string &expr_name) const
 Simple debug string that provides no expr subclass-specific information. More...
 
FunctionContextRegisterFunctionContext (ExprContext *ctx, RuntimeState *state, int varargs_buffer_size=0)
 
llvm::Function * CreateIrFunctionPrototype (LlvmCodeGen *codegen, const std::string &name, llvm::Value *(*args)[2])
 
Status GetCodegendComputeFnWrapper (RuntimeState *state, llvm::Function **fn)
 
llvm::Function * GetStaticGetValWrapper (ColumnType type, LlvmCodeGen *codegen)
 

Protected Attributes

LibCache::LibCacheEntrycache_entry_
 Cache entry for the library implementing this function. More...
 
TFunction fn_
 Function description. More...
 
const bool is_slotref_
 recognize if this node is a slotref in order to speed up GetValue() More...
 
const ColumnType type_
 analysis is done, types are fixed at this point More...
 
std::vector< Expr * > children_
 
int output_scale_
 
int context_index_
 
llvm::Function * ir_compute_fn_
 Cached codegened compute function. Exprs should set this in GetCodegendComputeFn(). More...
 
boost::scoped_ptr< AnyValconstant_val_
 

Private Attributes

ExprValue value_
 

Friends

class Expr
 

Detailed Description

Definition at line 28 of file literal.h.

Constructor & Destructor Documentation

impala::Literal::Literal ( ColumnType  type,
bool  v 
)

Test ctors.

Definition at line 124 of file literal.cc.

References impala::ExprValue::bool_val, impala::ColumnType::type, impala::Expr::type(), impala::TYPE_BOOLEAN, and value_.

Referenced by CreateLiteral().

impala::Literal::Literal ( ColumnType  type,
int8_t  v 
)
impala::Literal::Literal ( ColumnType  type,
int16_t  v 
)
impala::Literal::Literal ( ColumnType  type,
int32_t  v 
)
impala::Literal::Literal ( ColumnType  type,
int64_t  v 
)
impala::Literal::Literal ( ColumnType  type,
float  v 
)
impala::Literal::Literal ( ColumnType  type,
const std::string &  v 
)
impala::Literal::Literal ( ColumnType  type,
const StringValue v 
)

Member Function Documentation

void impala::Expr::AddChild ( Expr expr)
inlineinherited

Definition at line 141 of file expr.h.

Referenced by impala::Expr::CreateTreeFromThrift().

const std::vector<Expr*>& impala::Expr::children ( ) const
inlineinherited
Status Expr::Clone ( const std::vector< ExprContext * > &  ctxs,
RuntimeState state,
std::vector< ExprContext * > *  new_ctxs 
)
staticinherited

Clones each ExprContext for multiple expr trees. 'new_ctxs' should be an empty vector, and a clone of each context in 'ctxs' will be added to it. The new ExprContexts are created in state->obj_pool().

Definition at line 374 of file expr.cc.

References impala::Status::OK, and RETURN_IF_ERROR.

Referenced by impala::HdfsScanNode::GetConjunctCtxs(), and impala::SortExecExprs::Open().

void Expr::Close ( RuntimeState state,
ExprContext context,
FunctionContext::FunctionStateScope  scope = FunctionContext::FRAGMENT_LOCAL 
)
protectedvirtualinherited

Subclasses overriding this function should call Expr::Close().

If scope if FRAGMENT_LOCAL, both fragment- and thread-local state should be torn down. Otherwise, if scope is THREAD_LOCAL, only thread-local state should be torn down.

Reimplemented in impala::HiveUdfCall, impala::ScalarFnCall, and impala::CaseExpr.

Definition at line 114 of file expr.cc.

References impala::Expr::cache_entry_, impala::Expr::children_, impala::LibCache::DecrementUseCount(), and impala::LibCache::instance().

static int impala::Expr::ComputeResultsLayout ( const std::vector< Expr * > &  exprs,
std::vector< int > *  offsets,
int *  var_result_begin 
)
staticinherited

Computes a memory efficient layout for storing the results of evaluating 'exprs' Returns the number of bytes necessary to store all the results and offsets where the result for each expr should be stored. Variable length types are guaranteed to be at the end and 'var_result_begin' will be set the beginning byte offset where variable length results begin. 'var_result_begin' will be set to -1 if there are no variable len types.

Referenced by impala::HashTableCtx::HashTableCtx(), and impala::OldHashTable::OldHashTable().

static int impala::Expr::ComputeResultsLayout ( const std::vector< ExprContext * > &  ctxs,
std::vector< int > *  offsets,
int *  var_result_begin 
)
staticinherited
Status Expr::CreateExprTree ( ObjectPool pool,
const TExpr &  texpr,
ExprContext **  ctx 
)
staticinherited
Status Expr::CreateExprTrees ( ObjectPool pool,
const std::vector< TExpr > &  texprs,
std::vector< ExprContext * > *  ctxs 
)
staticinherited

Creates vector of ExprContexts containing exprs from the given vector of TExprs within 'pool'. Returns an error if any of the individual conversions caused an error, otherwise OK.

Definition at line 149 of file expr.cc.

References impala::Expr::CreateExprTree(), impala::Status::OK, and RETURN_IF_ERROR.

Referenced by impala::DataStreamSender::DataStreamSender(), impala::UnionNode::Init(), impala::HashJoinNode::Init(), impala::AggregationNode::Init(), impala::ExecNode::Init(), impala::PartitionedHashJoinNode::Init(), impala::PartitionedAggregationNode::Init(), impala::HdfsScanNode::Prepare(), and impala::HdfsTableSink::Prepare().

Function * Expr::CreateIrFunctionPrototype ( LlvmCodeGen codegen,
const std::string &  name,
llvm::Value *(*)  args[2] 
)
protectedinherited
Literal * impala::Literal::CreateLiteral ( const ColumnType type,
const std::string &  str 
)
static
static Expr* impala::Expr::CreateLiteral ( ObjectPool pool,
const ColumnType type,
void *  data 
)
staticinherited

Create a new literal expr of 'type' with initial 'data'. data should match the ColumnType (i.e. type == TYPE_INT, data is a int*) The new Expr will be allocated from the pool.

static Expr* impala::Expr::CreateLiteral ( ObjectPool pool,
const ColumnType type,
const std::string &   
)
staticinherited

Create a new literal expr of 'type' by parsing the string. NULL will be returned if the string and type are not compatible. The new Expr will be allocated from the pool.

static std::string impala::Expr::DebugString ( const std::vector< Expr * > &  exprs)
staticinherited
static std::string impala::Expr::DebugString ( const std::vector< ExprContext * > &  ctxs)
staticinherited
std::string impala::Expr::DebugString ( const std::string &  expr_name) const
inlineprotectedinherited

Simple debug string that provides no expr subclass-specific information.

Definition at line 332 of file expr.h.

References impala_udf::DebugString().

BigIntVal impala::Literal::GetBigIntVal ( ExprContext context,
TupleRow row 
)
virtual
BooleanVal impala::Literal::GetBooleanVal ( ExprContext context,
TupleRow row 
)
virtual

Virtual compute functions for each *Val type. Each Expr subclass should implement the functions for the return type(s) it supports. For example, a boolean function will only implement GetBooleanVal(). Some Exprs, like Literal, have many possible return types and will implement multiple Get*Val() functions.

Reimplemented from impala::Expr.

Definition at line 242 of file literal.cc.

References impala::ExprValue::bool_val, impala::ColumnType::type, impala::Expr::type_, impala::TYPE_BOOLEAN, and value_.

Expr* impala::Expr::GetChild ( int  i) const
inlineinherited

Definition at line 142 of file expr.h.

Referenced by impala::HiveUdfCall::Evaluate(), and impala::HiveUdfCall::Prepare().

Status impala::Literal::GetCodegendComputeFn ( RuntimeState state,
llvm::Function **  fn 
)
virtual

Returns an llvm::Function* with signature: <subclass of="" anyval>=""> ComputeFn(ExprContext* context, TupleRow* row) The function should evaluate this expr over 'row' and return the result as the appropriate type of AnyVal.

Implements impala::Expr.

Definition at line 356 of file literal.cc.

References impala::ExprValue::bigint_val, impala::ExprValue::bool_val, impala::LlvmCodeGen::CastPtrToLlvmPtr(), impala::LlvmCodeGen::context(), impala::Expr::CreateIrFunctionPrototype(), impala::ColumnType::DebugString(), impala::ExprValue::decimal16_val, impala::ExprValue::decimal4_val, impala::ExprValue::decimal8_val, impala::ExprValue::double_val, impala::LlvmCodeGen::FinalizeFunction(), impala::ExprValue::float_val, impala::ColumnType::GetByteSize(), impala::RuntimeState::GetCodegen(), impala::CodegenAnyVal::GetNonNullVal(), impala::Expr::GetNumChildren(), impala::ExprValue::int_val, impala::Expr::ir_compute_fn_, impala::StringValue::len, impala::Status::OK, impala::StringValue::ptr, impala::LlvmCodeGen::ptr_type(), RETURN_IF_ERROR, impala::CodegenAnyVal::SetLen(), impala::CodegenAnyVal::SetPtr(), impala::CodegenAnyVal::SetVal(), impala::ExprValue::smallint_val, impala::ExprValue::string_val, impala::ExprValue::tinyint_val, impala::ColumnType::type, impala::Expr::type(), impala::Expr::type_, impala::TYPE_BIGINT, impala::TYPE_BOOLEAN, impala::TYPE_CHAR, impala::TYPE_DECIMAL, impala::TYPE_DOUBLE, impala::TYPE_FLOAT, impala::TYPE_INT, impala::TYPE_SMALLINT, impala::TYPE_STRING, impala::TYPE_TINYINT, impala::TYPE_VARCHAR, impala::CodegenAnyVal::value(), impala::DecimalValue< T >::value(), and value_.

Status Expr::GetCodegendComputeFnWrapper ( RuntimeState state,
llvm::Function **  fn 
)
protectedinherited

Generates an IR compute function that calls the appropriate interpreted Get*Val() compute function. This is useful for builtins that can't be implemented with the UDF interface (e.g. functions that need short-circuiting) and that don't have custom codegen functions that use the IRBuilder. It doesn't provide any performance benefit over the interpreted path. TODO: this should be replaced with fancier xcompiling infrastructure

Definition at line 546 of file expr.cc.

References impala::LlvmCodeGen::CastPtrToLlvmPtr(), impala::LlvmCodeGen::context(), impala::CodegenAnyVal::CreateCall(), impala::Expr::CreateIrFunctionPrototype(), impala::LlvmCodeGen::FinalizeFunction(), impala::RuntimeState::GetCodegen(), impala::LlvmCodeGen::GetPtrType(), impala::Expr::GetStaticGetValWrapper(), impala::Expr::ir_compute_fn_, impala::Expr::LLVM_CLASS_NAME, impala::Status::OK, RETURN_IF_ERROR, and impala::Expr::type().

Referenced by impala::TupleIsNullPredicate::GetCodegendComputeFn(), and impala::HiveUdfCall::GetCodegendComputeFn().

DoubleVal impala::Literal::GetDoubleVal ( ExprContext context,
TupleRow row 
)
virtual
FloatVal impala::Literal::GetFloatVal ( ExprContext context,
TupleRow row 
)
virtual
IntVal impala::Literal::GetIntVal ( ExprContext context,
TupleRow row 
)
virtual
int Expr::GetSlotIds ( std::vector< SlotId > *  slot_ids) const
virtualinherited

Returns the slots that are referenced by this expr tree in 'slot_ids'. Returns the number of slots added to the vector

Reimplemented in impala::SlotRef.

Definition at line 418 of file expr.cc.

References impala::Expr::children_.

SmallIntVal impala::Literal::GetSmallIntVal ( ExprContext context,
TupleRow row 
)
virtual
Function * Expr::GetStaticGetValWrapper ( ColumnType  type,
LlvmCodeGen codegen 
)
protectedinherited

Returns the IR version of the static Get*Val() wrapper function corresponding to 'type'. This is used for calling interpreted Get*Val() functions from codegen'd functions (e.g. in ScalarFnCall() when codegen is disabled).

Definition at line 426 of file expr.cc.

References impala::ColumnType::DebugString(), impala::LlvmCodeGen::GetFunction(), impala::ColumnType::type, impala::TYPE_BIGINT, impala::TYPE_BOOLEAN, impala::TYPE_CHAR, impala::TYPE_DECIMAL, impala::TYPE_DOUBLE, impala::TYPE_FLOAT, impala::TYPE_INT, impala::TYPE_SMALLINT, impala::TYPE_STRING, impala::TYPE_TIMESTAMP, impala::TYPE_TINYINT, and impala::TYPE_VARCHAR.

Referenced by impala::ScalarFnCall::GetCodegendComputeFn(), and impala::Expr::GetCodegendComputeFnWrapper().

StringVal impala::Literal::GetStringVal ( ExprContext context,
TupleRow row 
)
virtual
TinyIntVal impala::Literal::GetTinyIntVal ( ExprContext context,
TupleRow row 
)
virtual
void Expr::InitBuiltinsDummy ( )
staticinherited
bool impala::Expr::is_slotref ( ) const
inlineinherited

Definition at line 146 of file expr.h.

bool Expr::IsConstant ( ) const
virtualinherited

Returns true if GetValue(NULL) can be called on this expr and always returns the same result (e.g., exprs that don't contain slotrefs). The default implementation returns true if all children are constant.

Reimplemented in impala::ScalarFnCall, impala::TupleIsNullPredicate, and impala::SlotRef.

Definition at line 411 of file expr.cc.

References impala::Expr::children_.

Referenced by impala::Expr::GetConstVal(), and impala::ScalarFnCall::IsConstant().

Status Expr::Open ( RuntimeState state,
ExprContext context,
FunctionContext::FunctionStateScope  scope = FunctionContext::FRAGMENT_LOCAL 
)
protectedvirtualinherited

Initializes 'context' for execution. If scope if FRAGMENT_LOCAL, both fragment- and thread-local state should be initialized. Otherwise, if scope is THREAD_LOCAL, only thread-local state should be initialized. Subclasses overriding this function should call Expr::Open() to recursively call Open() on the expr tree.

Reimplemented in impala::HiveUdfCall, impala::ScalarFnCall, and impala::CaseExpr.

Definition at line 366 of file expr.cc.

References impala::Expr::children_, impala::Status::OK, impala::Expr::Open(), and RETURN_IF_ERROR.

int impala::Expr::output_scale ( ) const
inlineinherited

Get the number of digits after the decimal that should be displayed for this value. Returns -1 if no scale has been specified (currently the scale is only set for doubles set by RoundUpTo). GetValue() must have already been called. TODO: is this still necessary?

Definition at line 139 of file expr.h.

Status Expr::Prepare ( RuntimeState state,
const RowDescriptor row_desc,
ExprContext context 
)
protectedvirtualinherited

Initializes this expr instance for execution. This does not include initializing state in the ExprContext; 'context' should only be used to register a FunctionContext via RegisterFunctionContext(). Any IR functions must be generated here. Subclasses overriding this function should call Expr::Prepare() to recursively call Prepare() on the expr tree.

Reimplemented in impala::HiveUdfCall, impala::ScalarFnCall, impala::CaseExpr, impala::TupleIsNullPredicate, and impala::SlotRef.

Definition at line 350 of file expr.cc.

References impala::Expr::children_, impala::INVALID_TYPE, impala::Status::OK, impala::Expr::Prepare(), RETURN_IF_ERROR, impala::ColumnType::type, and impala::Expr::type_.

FunctionContext * Expr::RegisterFunctionContext ( ExprContext ctx,
RuntimeState state,
int  varargs_buffer_size = 0 
)
protectedinherited

Helper function that calls ctx->Register(), sets context_index_, and returns the registered FunctionContext.

Definition at line 80 of file expr.cc.

References impala::AnyValUtil::ColumnTypeToTypeDesc(), impala::ExprContext::fn_context(), and impala::ExprContext::Register().

Referenced by impala::CaseExpr::Prepare(), and impala::HiveUdfCall::Prepare().

Friends And Related Function Documentation

friend class Expr
friend

Definition at line 58 of file literal.h.

Member Data Documentation

LibCache::LibCacheEntry* impala::Expr::cache_entry_
protectedinherited

Cache entry for the library implementing this function.

Definition at line 281 of file expr.h.

Referenced by impala::Expr::Close(), impala::ScalarFnCall::GetFunction(), impala::ScalarFnCall::GetUdf(), impala::ScalarFnCall::Prepare(), and impala::Expr::~Expr().

boost::scoped_ptr<AnyVal> impala::Expr::constant_val_
protectedinherited

If this expr is constant, this will store and cache the value generated by GetConstVal().

Definition at line 303 of file expr.h.

Referenced by impala::Expr::GetConstVal().

llvm::Function* impala::Expr::ir_compute_fn_
protectedinherited
const bool impala::Expr::is_slotref_
protectedinherited

recognize if this node is a slotref in order to speed up GetValue()

Definition at line 287 of file expr.h.

const char * Expr::LLVM_CLASS_NAME = "class.impala::Expr"
staticinherited
int impala::Expr::output_scale_
protectedinherited

Definition at line 291 of file expr.h.

Referenced by impala::ExprContext::GetValue(), and impala::ScalarFnCall::Open().

const ColumnType impala::Expr::type_
protectedinherited

analysis is done, types are fixed at this point

Definition at line 289 of file expr.h.

Referenced by DebugString(), impala::Expr::DebugString(), impala::SlotRef::GetBigIntVal(), GetBigIntVal(), impala::ScalarFnCall::GetBigIntVal(), impala::HiveUdfCall::GetBigIntVal(), impala::SlotRef::GetBooleanVal(), GetBooleanVal(), impala::HiveUdfCall::GetBooleanVal(), impala::ScalarFnCall::GetBooleanVal(), impala::SlotRef::GetCodegendComputeFn(), GetCodegendComputeFn(), impala::Expr::GetConstVal(), impala::SlotRef::GetDecimalVal(), GetDecimalVal(), impala::ScalarFnCall::GetDecimalVal(), impala::HiveUdfCall::GetDecimalVal(), impala::SlotRef::GetDoubleVal(), GetDoubleVal(), impala::ScalarFnCall::GetDoubleVal(), impala::HiveUdfCall::GetDoubleVal(), impala::SlotRef::GetFloatVal(), GetFloatVal(), impala::ScalarFnCall::GetFloatVal(), impala::HiveUdfCall::GetFloatVal(), impala::SlotRef::GetIntVal(), GetIntVal(), impala::ScalarFnCall::GetIntVal(), impala::HiveUdfCall::GetIntVal(), impala::SlotRef::GetSmallIntVal(), GetSmallIntVal(), impala::ScalarFnCall::GetSmallIntVal(), impala::HiveUdfCall::GetSmallIntVal(), impala::SlotRef::GetStringVal(), GetStringVal(), impala::HiveUdfCall::GetStringVal(), impala::ScalarFnCall::GetStringVal(), impala::SlotRef::GetTimestampVal(), impala::ScalarFnCall::GetTimestampVal(), impala::HiveUdfCall::GetTimestampVal(), impala::SlotRef::GetTinyIntVal(), GetTinyIntVal(), impala::HiveUdfCall::GetTinyIntVal(), impala::ScalarFnCall::GetTinyIntVal(), impala::ExprContext::GetValue(), Literal(), impala::ScalarFnCall::Open(), impala::HiveUdfCall::Open(), impala::ScalarFnCall::Prepare(), and impala::Expr::Prepare().


The documentation for this class was generated from the following files: