greenplumn COrderedAggPreprocessor 源码
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 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
7、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦