greenplumn CDistributionSpecSingleton 代码
文件路径：/src/backend/gporca/libgpopt/src/base/CDistributionSpecSingleton.cpp
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2011 EMC Corp.
/
/ @filename:
/ CDistributionSpecSingleton.cpp
/
/ @doc:
/ Specification of singleton distribution
/---------------------------------------------------------------------------
#include "gpopt/base/CDistributionSpecSingleton.h"
#include "gpopt/base/CDistributionSpecHashed.h"
#include "gpopt/base/COptCtxt.h"
#include "gpopt/operators/CPhysicalMotionGather.h"
#include "naucrates/traceflags/traceflags.h"
using namespace gpopt;
/ initialization of static variables
const CHAR *CDistributionSpecSingleton::m_szSegmentType[EstSentinel] = {
"master", "segment"};
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecSingleton::CDistributionSpecSingleton
/
/ @doc:
/ Ctor
/
/---------------------------------------------------------------------------
CDistributionSpecSingleton::CDistributionSpecSingleton(ESegmentType est)
: m_est(est)
{
GPOS_ASSERT(EstSentinel != est);
}
CDistributionSpecSingleton::CDistributionSpecSingleton()
{
m_est = EstMaster;
if (COptCtxt::PoctxtFromTLS()->OptimizeDMLQueryWithSingletonSegment())
{
m_est = EstSegment;
}
}
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecSingleton::FSatisfies
/
/ @doc:
/ Check if this distribution spec satisfies the given one
/
/---------------------------------------------------------------------------
BOOL
CDistributionSpecSingleton::FSatisfies(const CDistributionSpec *pds) const
{
if (Matches(pds))
{
/ exact match implies satisfaction
return true;
}
if (EdtNonSingleton == pds->Edt())
{
/ singleton does not satisfy non-singleton requirements
return false;
}
if (EdtAny == pds->Edt())
{
/ a singleton distribution satisfies "any" distributions
return true;
}
if (EdtHashed == pds->Edt() &&
CDistributionSpecHashed::PdsConvert(pds)->FSatisfiedBySingleton())
{
/ a singleton distribution satisfies hashed distributions, if the hashed distribution allows satisfaction
return true;
}
return (EdtSingleton == pds->Edt() &&
m_est == ((CDistributionSpecSingleton *) pds)->Est());
}
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecSingleton::AppendEnforcers
/
/ @doc:
/ Add required enforcers to dynamic array
/
/---------------------------------------------------------------------------
void
CDistributionSpecSingleton::AppendEnforcers(CMemoryPool *mp,
CExpressionHandle &, / exprhdl
CReqdPropPlan *prpp,
CExpressionArray *pdrgpexpr,
CExpression *pexpr)
{
GPOS_ASSERT(nullptr != mp);
GPOS_ASSERT(nullptr != prpp);
GPOS_ASSERT(nullptr != pdrgpexpr);
GPOS_ASSERT(nullptr != pexpr);
GPOS_ASSERT(!GPOS_FTRACE(EopttraceDisableMotions));
GPOS_ASSERT(
this == prpp->Ped()->PdsRequired() &&
"required plan properties don't match enforced distribution spec");
if (GPOS_FTRACE(EopttraceDisableMotionGather))
{
/ gather Motion is disabled
return;
}
pexpr->AddRef();
CExpression *pexprMotion = GPOS_NEW(mp)
CExpression(mp, GPOS_NEW(mp) CPhysicalMotionGather(mp, m_est), pexpr);
pdrgpexpr->Append(pexprMotion);
if (!prpp->Peo()->PosRequired()->IsEmpty())
{
COrderSpec *pos = prpp->Peo()->PosRequired();
pos->AddRef();
pexpr->AddRef();
CExpression *pexprGatherMerge = GPOS_NEW(mp) CExpression(
mp, GPOS_NEW(mp) CPhysicalMotionGather(mp, m_est, pos), pexpr);
pdrgpexpr->Append(pexprGatherMerge);
}
}
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecSingleton::OsPrint
/
/ @doc:
/ Print function
/
/---------------------------------------------------------------------------
IOstream &
CDistributionSpecSingleton::OsPrint(IOstream &os) const
{
return os << "SINGLETON (" << m_szSegmentType[m_est] << ")";
}
/ EOF
相关信息
相关文章
greenplumn CColConstraintsArrayMapper 源码