RexWindowFunctionOperator Class Reference

#include <RelAlgDag.h>

Inheritance diagram for RexWindowFunctionOperator:

Collaboration diagram for RexWindowFunctionOperator:

Classes
struct	RexWindowBound

Public Member Functions
	RexWindowFunctionOperator ()
	RexWindowFunctionOperator (const SqlWindowFunctionKind kind, ConstRexScalarPtrVector &operands, ConstRexScalarPtrVector &partition_keys, ConstRexScalarPtrVector &order_keys, const std::vector< SortField > collation, const RexWindowBound &frame_start_bound, const RexWindowBound &frame_end_bound, const bool is_rows, const SQLTypeInfo &ti)
SqlWindowFunctionKind	getKind () const
const ConstRexScalarPtrVector &	getPartitionKeys () const
ConstRexScalarPtrVector	getPartitionKeysAndRelease () const
ConstRexScalarPtrVector	getOrderKeysAndRelease () const
const ConstRexScalarPtrVector &	getOrderKeys () const
void	replacePartitionKey (size_t offset, std::unique_ptr< const RexScalar > &&new_partition_key)
void	replaceOrderKey (size_t offset, std::unique_ptr< const RexScalar > &&new_order_key)
void	replaceOperands (std::vector< std::unique_ptr< const RexScalar >> &&new_operands)
const std::vector< SortField > &	getCollation () const
const RexWindowBound &	getFrameStartBound () const
const RexWindowBound &	getFrameEndBound () const
bool	isRows () const
std::unique_ptr< const RexOperator >	disambiguatedOperands (ConstRexScalarPtrVector &operands, ConstRexScalarPtrVector &partition_keys, ConstRexScalarPtrVector &order_keys, const std::vector< SortField > &collation) const
std::string	toString (RelRexToStringConfig config=RelRexToStringConfig::defaults()) const override
size_t	toHash () const override
Public Member Functions inherited from RexFunctionOperator
	RexFunctionOperator ()=default
	RexFunctionOperator (const std::string &name, ConstRexScalarPtrVector &operands, const SQLTypeInfo &ti)
std::unique_ptr< const RexOperator >	getDisambiguated (std::vector< std::unique_ptr< const RexScalar >> &operands) const override
const std::string &	getName () const
Public Member Functions inherited from RexOperator
	RexOperator ()
	RexOperator (const SQLOps op, std::vector< std::unique_ptr< const RexScalar >> &operands, const SQLTypeInfo &type)
size_t	size () const
const RexScalar *	getOperand (const size_t idx) const
const RexScalar *	getOperandAndRelease (const size_t idx) const
SQLOps	getOperator () const
const SQLTypeInfo &	getType () const
Public Member Functions inherited from Rex
virtual	~Rex ()

Private Attributes
SqlWindowFunctionKind	kind_
ConstRexScalarPtrVector	partition_keys_
ConstRexScalarPtrVector	order_keys_
std::vector< SortField >	collation_
RexWindowBound	frame_start_bound_
RexWindowBound	frame_end_bound_
bool	is_rows_

Friends
struct	RelAlgDagSerializer

Additional Inherited Members
Public Types inherited from RexFunctionOperator
using	ConstRexScalarPtr = std::unique_ptr< const RexScalar >
using	ConstRexScalarPtrVector = std::vector< ConstRexScalarPtr >
Protected Attributes inherited from RexOperator
SQLOps	op_
std::vector< std::unique_ptr < const RexScalar > >	operands_
SQLTypeInfo	type_
Protected Attributes inherited from Rex
std::optional< size_t >	hash_

Detailed Description

Definition at line 576 of file RelAlgDag.h.

Constructor & Destructor Documentation

RexWindowFunctionOperator::RexWindowFunctionOperator ( )

inline

Definition at line 604 of file RelAlgDag.h.

References INVALID.

Referenced by disambiguatedOperands(), and toHash().

      : RexFunctionOperator(), kind_{SqlWindowFunctionKind::INVALID}, is_rows_{false} {}

Here is the caller graph for this function:

RexWindowFunctionOperator::RexWindowFunctionOperator ( const SqlWindowFunctionKind  kind, ConstRexScalarPtrVector &  operands, ConstRexScalarPtrVector &  partition_keys, ConstRexScalarPtrVector &  order_keys, const std::vector< SortField >  collation, const RexWindowBound &  frame_start_bound, const RexWindowBound &  frame_end_bound, const bool  is_rows, const SQLTypeInfo &  ti  )

inline

Definition at line 607 of file RelAlgDag.h.

      : RexFunctionOperator(::toString(kind), operands, ti)
      , kind_(kind)
      , partition_keys_(std::move(partition_keys))
      , order_keys_(std::move(order_keys))
      , collation_(collation)
      , frame_start_bound_(frame_start_bound)
      , frame_end_bound_(frame_end_bound)
      , is_rows_(is_rows) {}

Member Function Documentation

std::unique_ptr<const RexOperator> RexWindowFunctionOperator::disambiguatedOperands ( ConstRexScalarPtrVector &  operands, ConstRexScalarPtrVector &  partition_keys, ConstRexScalarPtrVector &  order_keys, const std::vector< SortField > &  collation  ) const

inline

Definition at line 662 of file RelAlgDag.h.

References getFrameEndBound(), getFrameStartBound(), RexOperator::getType(), isRows(), kind_, and RexWindowFunctionOperator().

Referenced by RexDeepCopyVisitor::visitWindowFunctionOperator().

                                                   {
    return std::unique_ptr<const RexOperator>(
        new RexWindowFunctionOperator(kind_,
                                      operands,
                                      partition_keys,
                                      order_keys,
                                      collation,
                                      getFrameStartBound(),
                                      getFrameEndBound(),
                                      isRows(),
                                      getType()));
  }

Here is the call graph for this function:

Here is the caller graph for this function:

const std::vector<SortField>& RexWindowFunctionOperator::getCollation ( ) const

inline

Definition at line 654 of file RelAlgDag.h.

References collation_.

Referenced by RelAlgTranslator::translateWindowFunction(), and RexDeepCopyVisitor::visitWindowFunctionOperator().

{ return collation_; }

Here is the caller graph for this function:

const RexWindowBound& RexWindowFunctionOperator::getFrameEndBound ( ) const

inline

Definition at line 658 of file RelAlgDag.h.

References frame_end_bound_.

Referenced by disambiguatedOperands(), and RelAlgTranslator::translateWindowFunction().

{ return frame_end_bound_; }

Here is the caller graph for this function:

const RexWindowBound& RexWindowFunctionOperator::getFrameStartBound ( ) const

inline

Definition at line 656 of file RelAlgDag.h.

References frame_start_bound_.

Referenced by disambiguatedOperands(), and RelAlgTranslator::translateWindowFunction().

{ return frame_start_bound_; }

Here is the caller graph for this function:

SqlWindowFunctionKind RexWindowFunctionOperator::getKind ( ) const

inline

Definition at line 625 of file RelAlgDag.h.

References kind_.

Referenced by RelAlgTranslator::translateWindowFunction().

{ return kind_; }

Here is the caller graph for this function:

const ConstRexScalarPtrVector& RexWindowFunctionOperator::getOrderKeys ( ) const

inline

Definition at line 637 of file RelAlgDag.h.

References order_keys_.

Referenced by anonymous_namespace{RelAlgDag.cpp}::anonymous_namespace{RelAlgDag.cpp}::find_generic_expr_in_window_func(), anonymous_namespace{RelAlgDag.cpp}::PushDownGenericExpressionInWindowFunction::pushDownExpressionInWindowFunction(), RelAlgTranslator::translateWindowFunction(), RelRexDagVisitor::visit(), RexVisitor< T >::visitWindowFunctionOperator(), and RexDeepCopyVisitor::visitWindowFunctionOperator().

{ return order_keys_; }

Here is the caller graph for this function:

ConstRexScalarPtrVector RexWindowFunctionOperator::getOrderKeysAndRelease ( ) const

inline

Definition at line 633 of file RelAlgDag.h.

References order_keys_.

                                                         {
    return std::move(order_keys_);
  }

const ConstRexScalarPtrVector& RexWindowFunctionOperator::getPartitionKeys ( ) const

inline

Definition at line 627 of file RelAlgDag.h.

References partition_keys_.

Referenced by anonymous_namespace{RelAlgDag.cpp}::disambiguate_operator(), anonymous_namespace{RelAlgDag.cpp}::anonymous_namespace{RelAlgDag.cpp}::find_generic_expr_in_window_func(), anonymous_namespace{RelAlgDag.cpp}::PushDownGenericExpressionInWindowFunction::pushDownExpressionInWindowFunction(), RelAlgTranslator::translateWindowFunction(), RelRexDagVisitor::visit(), RexVisitor< T >::visitWindowFunctionOperator(), and RexDeepCopyVisitor::visitWindowFunctionOperator().

{ return partition_keys_; }

Here is the caller graph for this function:

ConstRexScalarPtrVector RexWindowFunctionOperator::getPartitionKeysAndRelease ( ) const

inline

Definition at line 629 of file RelAlgDag.h.

References partition_keys_.

                                                             {
    return std::move(partition_keys_);
  }

bool RexWindowFunctionOperator::isRows ( ) const

inline

Definition at line 660 of file RelAlgDag.h.

References is_rows_.

Referenced by disambiguatedOperands(), and RelAlgTranslator::translateWindowFunction().

{ return is_rows_; }

Here is the caller graph for this function:

void RexWindowFunctionOperator::replaceOperands ( std::vector< std::unique_ptr< const RexScalar >> &&  new_operands )

inline

Definition at line 650 of file RelAlgDag.h.

References RexOperator::operands_.

                                                                                 {
    operands_ = std::move(new_operands);
  }

void RexWindowFunctionOperator::replaceOrderKey ( size_t  offset, std::unique_ptr< const RexScalar > &&  new_order_key  )

inline

Definition at line 645 of file RelAlgDag.h.

References CHECK_LT, and order_keys_.

                                                                                      {
    CHECK_LT(offset, order_keys_.size());
    order_keys_[offset] = std::move(new_order_key);
  }

void RexWindowFunctionOperator::replacePartitionKey ( size_t  offset, std::unique_ptr< const RexScalar > &&  new_partition_key  )

inline

Definition at line 639 of file RelAlgDag.h.

References CHECK_LT, and partition_keys_.

                                                                               {
    CHECK_LT(offset, partition_keys_.size());
    partition_keys_[offset] = std::move(new_partition_key);
  }

size_t RexWindowFunctionOperator::toHash ( ) const

inlineoverridevirtual

Reimplemented from RexFunctionOperator.

Definition at line 696 of file RelAlgDag.h.

References collation_, frame_end_bound_, frame_start_bound_, RexFunctionOperator::getName(), RexOperator::getType(), Rex::hash_, HASH_N, is_rows_, RexOperator::operands_, order_keys_, partition_keys_, and RexWindowFunctionOperator().

                                 {
    if (!hash_) {
      hash_ = typeid(RexWindowFunctionOperator).hash_code();
      boost::hash_combine(*hash_, getType().get_type_name());
      boost::hash_combine(*hash_, getName());
      boost::hash_combine(*hash_, is_rows_);
      for (auto& collation : collation_) {
        boost::hash_combine(*hash_, collation.toHash());
      }
      for (auto& operand : operands_) {
        boost::hash_combine(*hash_, operand->toHash());
      }
      for (auto& key : partition_keys_) {
        boost::hash_combine(*hash_, key->toHash());
      }
      for (auto& key : order_keys_) {
        boost::hash_combine(*hash_, key->toHash());
      }
      auto get_window_bound_hash =
          [](const RexWindowFunctionOperator::RexWindowBound& bound) {
            auto h =
                boost::hash_value(bound.bound_expr ? bound.bound_expr->toHash() : HASH_N);
            boost::hash_combine(h, bound.unbounded);
            boost::hash_combine(h, bound.preceding);
            boost::hash_combine(h, bound.following);
            boost::hash_combine(h, bound.is_current_row);
            boost::hash_combine(h, bound.order_key);
            return h;
          };
      boost::hash_combine(*hash_, get_window_bound_hash(frame_start_bound_));
      boost::hash_combine(*hash_, get_window_bound_hash(frame_end_bound_));
    }
    return *hash_;
  }

Here is the call graph for this function:

std::string RexWindowFunctionOperator::toString ( RelRexToStringConfig  config = RelRexToStringConfig::defaults() ) const

inlineoverridevirtual

Reimplemented from RexFunctionOperator.

Definition at line 679 of file RelAlgDag.h.

References cat(), RexFunctionOperator::getName(), RexOperator::operands_, order_keys_, partition_keys_, and typeName().

                                                                                   {
    auto ret = cat(::typeName(this), "(", getName(), ", operands=");
    for (auto& operand : operands_) {
      ret += operand->toString(config) + " ";
    }
    ret += ", partition_keys=";
    for (auto& key : partition_keys_) {
      ret += key->toString(config) + " ";
    }
    ret += ", order_keys=";
    for (auto& key : order_keys_) {
      ret += key->toString(config) + " ";
    }
    return cat(ret, ")");
  }

Here is the call graph for this function:

Friends And Related Function Documentation

friend struct RelAlgDagSerializer

friend

Definition at line 740 of file RelAlgDag.h.

Member Data Documentation

std::vector<SortField> RexWindowFunctionOperator::collation_

private

Definition at line 735 of file RelAlgDag.h.

Referenced by getCollation(), and toHash().

RexWindowBound RexWindowFunctionOperator::frame_end_bound_

private

Definition at line 737 of file RelAlgDag.h.

Referenced by getFrameEndBound(), and toHash().

RexWindowBound RexWindowFunctionOperator::frame_start_bound_

private

Definition at line 736 of file RelAlgDag.h.

Referenced by getFrameStartBound(), and toHash().

bool RexWindowFunctionOperator::is_rows_

private

Definition at line 738 of file RelAlgDag.h.

Referenced by isRows(), and toHash().

SqlWindowFunctionKind RexWindowFunctionOperator::kind_

private

Definition at line 732 of file RelAlgDag.h.

Referenced by disambiguatedOperands(), and getKind().

ConstRexScalarPtrVector RexWindowFunctionOperator::order_keys_

mutableprivate

Definition at line 734 of file RelAlgDag.h.

Referenced by getOrderKeys(), getOrderKeysAndRelease(), replaceOrderKey(), toHash(), and toString().

ConstRexScalarPtrVector RexWindowFunctionOperator::partition_keys_

mutableprivate

Definition at line 733 of file RelAlgDag.h.

Referenced by getPartitionKeys(), getPartitionKeysAndRelease(), replacePartitionKey(), toHash(), and toString().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/QueryEngine/RelAlgDag.h