greenplumn CDistributionSpecNonSingleton 代码
文件路径：/src/backend/gporca/libgpopt/src/base/CDistributionSpecNonSingleton.cpp
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2013 EMC Corp.
/
/ @filename:
/ CDistributionSpecNonSingleton.cpp
/
/ @doc:
/ Specification of non-singleton distribution
/---------------------------------------------------------------------------
#include "gpopt/base/CDistributionSpecNonSingleton.h"
#include "gpopt/base/CColRefSet.h"
#include "gpopt/base/CColRefSetIter.h"
#include "gpopt/base/CDistributionSpecStrictRandom.h"
#include "gpopt/base/CUtils.h"
#include "gpopt/operators/CPhysicalMotionRandom.h"
#include "naucrates/traceflags/traceflags.h"
using namespace gpopt;
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecNonSingleton::CDistributionSpecNonSingleton
/
/ @doc:
/ Ctor
/
/---------------------------------------------------------------------------
CDistributionSpecNonSingleton::CDistributionSpecNonSingleton() = default;
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecNonSingleton::CDistributionSpecNonSingleton
/
/ @doc:
/ Ctor
/
/---------------------------------------------------------------------------
CDistributionSpecNonSingleton::CDistributionSpecNonSingleton(
BOOL fAllowReplicated, BOOL fAllowEnforced)
: m_fAllowReplicated(fAllowReplicated), m_fAllowEnforced(fAllowEnforced)
{
}
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecNonSingleton::FSatisfies
/
/ @doc:
/ Check if this distribution spec satisfies the given one
/
/---------------------------------------------------------------------------
BOOL
CDistributionSpecNonSingleton::FSatisfies(const CDistributionSpec * / pds
) const
{
GPOS_ASSERT(!"Non-Singleton distribution cannot be derived");
return false;
}
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecNonSingleton::AppendEnforcers
/
/ @doc:
/ Add required enforcers to dynamic array;
/ non-singleton distribution is enforced by spraying data randomly
/ on segments
/
/---------------------------------------------------------------------------
void
CDistributionSpecNonSingleton::AppendEnforcers(CMemoryPool *mp,
CExpressionHandle &, / exprhdl
CReqdPropPlan *
#ifdef GPOS_DEBUG
prpp
#endif / GPOS_DEBUG
,
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(EopttraceDisableMotionRandom))
{
/ random Motion is disabled
return;
}
/ add a random distribution enforcer
CDistributionSpecStrictRandom *pdsrandom =
GPOS_NEW(mp) CDistributionSpecStrictRandom();
pexpr->AddRef();
CExpression *pexprMotion = GPOS_NEW(mp) CExpression(
mp, GPOS_NEW(mp) CPhysicalMotionRandom(mp, pdsrandom), pexpr);
pdrgpexpr->Append(pexprMotion);
}
/---------------------------------------------------------------------------
/ @function:
/ CDistributionSpecNonSingleton::OsPrint
/
/ @doc:
/ Print function
/
/---------------------------------------------------------------------------
IOstream &
CDistributionSpecNonSingleton::OsPrint(IOstream &os) const
{
os << "NON-SINGLETON ";
if (!m_fAllowReplicated)
{
os << " (NON-REPLICATED)";
}
return os;
}
/ EOF
相关信息
相关文章
greenplumn CColConstraintsArrayMapper 源码