greenplumn CGroupProxy 代码
文件路径：/src/backend/gporca/libgpopt/include/gpopt/search/CGroupProxy.h
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2008 Greenplum, Inc.
/
/ @filename:
/ CGroupProxy.h
/
/ @doc:
/ Lock mechanism for access to a given group
/---------------------------------------------------------------------------
#ifndef GPOPT_CGroupProxy_H
#define GPOPT_CGroupProxy_H
#include "gpos/base.h"
#include "gpopt/search/CGroup.h"
namespace gpopt
{
using namespace gpos;
/ forward declarations
class CGroupExpression;
class CDrvdProp;
class COptimizationContext;
/---------------------------------------------------------------------------
/ @class:
/ CGroupProxy
/
/ @doc:
/ Exclusive access to a given group
/
/---------------------------------------------------------------------------
class CGroupProxy
{
private:
/ group we're operating on
CGroup *m_pgroup;
/ skip group expressions starting from the given expression;
CGroupExpression *PgexprSkip(CGroupExpression *pgexprStart,
BOOL fSkipLogical);
public:
/ ctor
explicit CGroupProxy(CGroup *pgroup);
/ dtor
~CGroupProxy();
/ set group id
void
SetId(ULONG id)
{
m_pgroup->SetId(id);
}
/ set group state
void
SetState(CGroup::EState estNewState)
{
m_pgroup->SetState(estNewState);
}
/ set hash join keys
void
SetJoinKeys(CExpressionArray *pdrgpexprOuter,
CExpressionArray *pdrgpexprInner, IMdIdArray *join_opfamilies)
{
m_pgroup->SetJoinKeys(pdrgpexprOuter, pdrgpexprInner, join_opfamilies);
}
/ insert group expression
void Insert(CGroupExpression *pgexpr);
/ move duplicate group expression to duplicates list
void MoveDuplicateGExpr(CGroupExpression *pgexpr);
/ initialize group's properties;
void InitProperties(CDrvdProp *pdp);
/ initialize group's stat;
void InitStats(IStatistics *stats);
/ retrieve first group expression
CGroupExpression *PgexprFirst();
/ retrieve next group expression
CGroupExpression *PgexprNext(CGroupExpression *pgexpr);
/ get the first non-logical group expression following the given expression
CGroupExpression *PgexprSkipLogical(CGroupExpression *pgexpr);
/ get the next logical group expression following the given expression
CGroupExpression *PgexprNextLogical(CGroupExpression *pgexpr);
/ lookup best expression under optimization context
CGroupExpression *PgexprLookup(COptimizationContext *poc) const;
#ifdef GPOS_DEBUG
/ is group transition to given state complete?
BOOL
FTransitioned(CGroup::EState estate) const
{
return (CGroup::estExplored == estate && m_pgroup->FExplored()) ||
(CGroup::estImplemented == estate && m_pgroup->FImplemented()) ||
(CGroup::estOptimized == estate && m_pgroup->FOptimized());
}
#endif / GPOS_DEBUG
}; / class CGroupProxy
} / namespace gpopt
#endif / !GPOPT_CGroupProxy_H
/ EOF
相关信息
相关文章
greenplumn CGroupExpression 源码
greenplumn CJobGroupExploration 源码
greenplumn CJobGroupExpression 源码