greenplumn COrderedAggPreprocessor 代码
文件路径：/src/backend/gporca/libgpopt/include/gpopt/operators/COrderedAggPreprocessor.h
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2022 VMware, Inc. or its affiliates.
/
/ @filename:
/ COrderedAggPreprocessor.h
/
/ @doc:
/ Preprocessing routines of ordered-set aggregates
/---------------------------------------------------------------------------
#ifndef GPOPT_COrderedAggPreprocessor_H
#define GPOPT_COrderedAggPreprocessor_H
#include "gpos/base.h"
#include "gpopt/base/COrderSpec.h"
#include "gpopt/base/CWindowFrame.h"
#include "gpopt/operators/CExpression.h"
namespace gpopt
{
/---------------------------------------------------------------------------
/ @class:
/ COrderedAggPreprocessor
/
/ @doc:
/ Preprocessing routines of window functions
/
/---------------------------------------------------------------------------
class COrderedAggPreprocessor
{
private:
/ iterate over project elements and split elements between Ordered Aggs
/ list, and Others list
static void SplitPrjList(CMemoryPool *mp, CExpression *pexprInputAggPrj,
CExpressionArray **ppdrgpexprOrderedAggsPrEl,
CExpressionArray **ppdrgpexprOtherPrjElems);
/ split given InputAgg expression into:
/ - A GbAgg expression containing ordered aggs split to gp_percentile agg, and
/ - A GbAgg expression containing all other non-ordered agg functions
static void SplitOrderedAggsPrj(CMemoryPool *mp,
CExpression *pexprInputAggPrj,
CExpression **ppexprGbAgg,
CExpression **ppexprOutputSeqPrj);
/ create a CTE with two consumers using the child expression of Sequence
/ Project
static void CreateCTE(CMemoryPool *mp, CExpression *pexprInputAggPrj,
CExpression **ppexprFirstConsumer,
CExpression **ppexprSecondConsumer);
/ create an expression for final agg function
static CExpression *PexprFinalAgg(CMemoryPool *mp,
CExpression *pexprAggFunc,
CColRef *arg_col_ref,
CColRef *total_count_colref);
/ transform sequence project expression into an inner join expression
static CExpression *PexprInputAggPrj2Join(CMemoryPool *mp,
CExpression *pexprInputAggPrj);
public:
COrderedAggPreprocessor(const COrderedAggPreprocessor &) = delete;
/ main driver
static CExpression *PexprPreprocess(CMemoryPool *mp, CExpression *pexpr);
}; / class COrderedAggPreprocessor
} / namespace gpopt
#endif / !GPOPT_COrderedAggPreprocessor_H
/ EOF
相关信息
相关文章
greenplumn CExpressionFactorizer 源码
greenplumn CExpressionHandle 源码
greenplumn CExpressionPreprocessor 源码
greenplumn CExpressionUtils 源码