greenplumn CScalarSubqueryQuantified 源码
greenplumn CScalarSubqueryQuantified 代码
文件路径:/src/backend/gporca/libgpopt/src/operators/CScalarSubqueryQuantified.cpp
//---------------------------------------------------------------------------
// Greenplum Database
// Copyright (C) 2011 EMC Corp.
//
// @filename:
// CScalarSubqueryQuantified.cpp
//
// @doc:
// Implementation of quantified subquery operator
//---------------------------------------------------------------------------
#include "gpopt/operators/CScalarSubqueryQuantified.h"
#include "gpos/base.h"
#include "gpopt/base/CColRefSet.h"
#include "gpopt/base/CDrvdPropScalar.h"
#include "gpopt/base/COptCtxt.h"
#include "gpopt/operators/CExpressionHandle.h"
#include "gpopt/xforms/CSubqueryHandler.h"
#include "naucrates/md/IMDScalarOp.h"
#include "naucrates/md/IMDTypeBool.h"
using namespace gpopt;
using namespace gpmd;
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::CScalarSubqueryQuantified
//
// @doc:
// Ctor
//
//---------------------------------------------------------------------------
CScalarSubqueryQuantified::CScalarSubqueryQuantified(
CMemoryPool *mp, IMDId *scalar_op_mdid, const CWStringConst *pstrScalarOp,
const CColRef *colref)
: CScalar(mp),
m_scalar_op_mdid(scalar_op_mdid),
m_pstrScalarOp(pstrScalarOp),
m_pcr(colref)
{
GPOS_ASSERT(scalar_op_mdid->IsValid());
GPOS_ASSERT(nullptr != pstrScalarOp);
GPOS_ASSERT(nullptr != colref);
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::~CScalarSubqueryQuantified
//
// @doc:
// Dtor
//
//---------------------------------------------------------------------------
CScalarSubqueryQuantified::~CScalarSubqueryQuantified()
{
m_scalar_op_mdid->Release();
GPOS_DELETE(m_pstrScalarOp);
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::PstrOp
//
// @doc:
// Operator name
//
//---------------------------------------------------------------------------
const CWStringConst *
CScalarSubqueryQuantified::PstrOp() const
{
return m_pstrScalarOp;
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::MdIdOp
//
// @doc:
// Scalar operator metadata id
//
//---------------------------------------------------------------------------
IMDId *
CScalarSubqueryQuantified::MdIdOp() const
{
return m_scalar_op_mdid;
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::MdidType
//
// @doc:
// Type of scalar's value
//
//---------------------------------------------------------------------------
IMDId *
CScalarSubqueryQuantified::MdidType() const
{
CMDAccessor *md_accessor = COptCtxt::PoctxtFromTLS()->Pmda();
IMDId *mdid_type =
md_accessor->RetrieveScOp(m_scalar_op_mdid)->GetResultTypeMdid();
GPOS_ASSERT(
md_accessor->PtMDType<IMDTypeBool>()->MDId()->Equals(mdid_type));
return mdid_type;
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::HashValue
//
// @doc:
// Operator specific hash function
//
//---------------------------------------------------------------------------
ULONG
CScalarSubqueryQuantified::HashValue() const
{
return gpos::CombineHashes(
COperator::HashValue(),
gpos::CombineHashes(m_scalar_op_mdid->HashValue(),
gpos::HashPtr<CColRef>(m_pcr)));
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::Matches
//
// @doc:
// Match function on operator level
//
//---------------------------------------------------------------------------
BOOL
CScalarSubqueryQuantified::Matches(COperator *pop) const
{
if (pop->Eopid() != Eopid())
{
return false;
}
// match if contents are identical
CScalarSubqueryQuantified *popSsq =
CScalarSubqueryQuantified::PopConvert(pop);
return popSsq->Pcr() == m_pcr && popSsq->MdIdOp()->Equals(m_scalar_op_mdid);
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::PcrsUsed
//
// @doc:
// Locally used columns
//
//---------------------------------------------------------------------------
CColRefSet *
CScalarSubqueryQuantified::PcrsUsed(CMemoryPool *mp, CExpressionHandle &exprhdl)
{
// used columns is an empty set unless subquery column is an outer reference
CColRefSet *pcrs = GPOS_NEW(mp) CColRefSet(mp);
CColRefSet *pcrsChildOutput =
exprhdl.DeriveOutputColumns(0 /* child_index */);
if (!pcrsChildOutput->FMember(m_pcr))
{
// subquery column is not produced by relational child, add it to used columns
pcrs->Include(m_pcr);
}
return pcrs;
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::DerivePartitionInfo
//
// @doc:
// Derive partition consumers
//
//---------------------------------------------------------------------------
CPartInfo *
CScalarSubqueryQuantified::PpartinfoDerive(CMemoryPool *, // mp,
CExpressionHandle &exprhdl) const
{
CPartInfo *ppartinfoChild = exprhdl.DerivePartitionInfo(0);
GPOS_ASSERT(nullptr != ppartinfoChild);
ppartinfoChild->AddRef();
return ppartinfoChild;
}
//---------------------------------------------------------------------------
// @function:
// CScalarSubqueryQuantified::OsPrint
//
// @doc:
// Debug print
//
//---------------------------------------------------------------------------
IOstream &
CScalarSubqueryQuantified::OsPrint(IOstream &os) const
{
os << SzId();
os << "(" << PstrOp()->GetBuffer() << ")";
os << "[";
m_pcr->OsPrint(os);
os << "]";
return os;
}
// EOF
相关信息
相关文章
greenplumn CExpressionFactorizer 源码
greenplumn CExpressionHandle 源码
greenplumn CExpressionPreprocessor 源码
greenplumn CExpressionUtils 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
7、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦