greenplumn CDecorrelator 代码
文件路径：/src/backend/gporca/libgpopt/include/gpopt/xforms/CDecorrelator.h
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2011 EMC Corp.
/
/ @filename:
/ CDecorrelator.h
/
/ @doc:
/ Decorrelation processor
/---------------------------------------------------------------------------
#ifndef GPOPT_CDecorrelator_H
#define GPOPT_CDecorrelator_H
#include "gpos/base.h"
#include "gpopt/operators/CExpression.h"
namespace gpopt
{
using namespace gpos;
/---------------------------------------------------------------------------
/ @class:
/ CDecorrelator
/
/ @doc:
/ Helper class for extracting correlated expressions
/
/---------------------------------------------------------------------------
class CDecorrelator
{
private:
/ definition of operator processor
using FnProcessor = BOOL(CMemoryPool *, CExpression *, BOOL, CExpression **,
CExpressionArray *, CColRefSet *);
/---------------------------------------------------------------------------
/ @struct:
/ SOperatorProcessor
/
/ @doc:
/ Mapping of operator to a processor function
/
/---------------------------------------------------------------------------
struct SOperatorProcessor
{
/ scalar operator id
COperator::EOperatorId m_eopid;
/ pointer to handler function
FnProcessor *m_pfnp;
}; / struct SOperatorHandler
/ helper to check if correlations below join are valid to be pulled-up
static BOOL FPullableCorrelations(CMemoryPool *mp, CExpression *pexpr,
CExpressionArray *pdrgpexpr,
CExpressionArray *pdrgpexprCorrelations);
/ check if scalar operator can be delayed
static BOOL FDelayableScalarOp(CExpression *pexprScalar);
/ check if scalar expression can be lifted
static BOOL FDelayable(CExpression *pexprLogical, CExpression *pexprScalar,
BOOL fEqualityOnly);
/ switch function for all operators
static BOOL FProcessOperator(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for predicates
static BOOL FProcessPredicate(CMemoryPool *mp, CExpression *pexprLogical,
CExpression *pexprScalar, BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for select operators
static BOOL FProcessSelect(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for aggregates
static BOOL FProcessGbAgg(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for joins (inner/n-ary)
static BOOL FProcessJoin(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for projects
static BOOL FProcessProject(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for assert
static BOOL FProcessAssert(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for MaxOneRow
static BOOL FProcessMaxOneRow(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
/ processor for limits
static BOOL FProcessLimit(CMemoryPool *mp, CExpression *pexpr,
BOOL fEqualityOnly,
CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
public:
/ private dtor
virtual ~CDecorrelator() = delete;
/ private ctor
CDecorrelator() = delete;
CDecorrelator(const CDecorrelator &) = delete;
/ main handler
static BOOL FProcess(CMemoryPool *mp, CExpression *pexprOrig,
BOOL fEqualityOnly, CExpression **ppexprDecorrelated,
CExpressionArray *pdrgpexprCorrelations,
CColRefSet *outerRefsToRemove);
}; / class CDecorrelator
} / namespace gpopt
#endif / !GPOPT_CDecorrelator_H
/ EOF
相关信息
相关文章
greenplumn CJoinOrderGreedy 源码
greenplumn CJoinOrderMinCard 源码
greenplumn CSubqueryHandler 源码
greenplumn CXformAntiSemiJoinAntiSemiJoinNotInSwap 源码