greenplumn CPhysicalHashAggDeduplicate 代码
文件路径：/src/backend/gporca/libgpopt/src/operators/CPhysicalHashAggDeduplicate.cpp
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2013 VMware, Inc. or its affiliates.
/
/ @filename:
/ CPhysicalHashAggDeduplicate.cpp
/
/ @doc:
/ Implementation of Hash Aggregate operator for deduplicating join outputs
/---------------------------------------------------------------------------
#include "gpopt/operators/CPhysicalHashAggDeduplicate.h"
#include "gpos/base.h"
#include "gpopt/base/CDistributionSpecAny.h"
#include "gpopt/base/CDistributionSpecRandom.h"
#include "gpopt/operators/CExpressionHandle.h"
#include "gpopt/operators/CLogicalGbAgg.h"
using namespace gpopt;
/---------------------------------------------------------------------------
/ @function:
/ CPhysicalHashAggDeduplicate::CPhysicalHashAggDeduplicate
/
/ @doc:
/ Ctor
/
/---------------------------------------------------------------------------
CPhysicalHashAggDeduplicate::CPhysicalHashAggDeduplicate(
CMemoryPool *mp, CColRefArray *colref_array, CColRefArray *pdrgpcrMinimal,
COperator::EGbAggType egbaggtype, CColRefArray *pdrgpcrKeys,
BOOL fGeneratesDuplicates, BOOL fMultiStage, BOOL isAggFromSplitDQA,
CLogicalGbAgg::EAggStage aggStage, BOOL should_enforce_distribution)
: CPhysicalHashAgg(mp, colref_array, pdrgpcrMinimal, egbaggtype,
fGeneratesDuplicates, nullptr /*pdrgpcrGbMinusDistinct*/,
fMultiStage, isAggFromSplitDQA, aggStage,
should_enforce_distribution),
m_pdrgpcrKeys(pdrgpcrKeys)
{
GPOS_ASSERT(nullptr != pdrgpcrKeys);
}
/---------------------------------------------------------------------------
/ @function:
/ CPhysicalHashAggDeduplicate::~CPhysicalHashAggDeduplicate
/
/ @doc:
/ Dtor
/
/---------------------------------------------------------------------------
CPhysicalHashAggDeduplicate::~CPhysicalHashAggDeduplicate()
{
m_pdrgpcrKeys->Release();
}
/---------------------------------------------------------------------------
/ @function:
/ CPhysicalHashAggDeduplicate::OsPrint
/
/ @doc:
/ Debug print
/
/---------------------------------------------------------------------------
IOstream &
CPhysicalHashAggDeduplicate::OsPrint(IOstream &os) const
{
if (m_fPattern)
{
return COperator::OsPrint(os);
}
os << SzId() << "( ";
CLogicalGbAgg::OsPrintGbAggType(os, Egbaggtype());
os << " )"
<< " Grp Cols: [";
CUtils::OsPrintDrgPcr(os, PdrgpcrGroupingCols());
os << "]"
<< ", Key Cols:[";
CUtils::OsPrintDrgPcr(os, m_pdrgpcrKeys);
os << "]";
os << ", Generates Duplicates :[ " << FGeneratesDuplicates() << " ] ";
return os;
}
/ EOF
/ EOF
相关信息
相关文章
greenplumn CExpressionFactorizer 源码
greenplumn CExpressionHandle 源码
greenplumn CExpressionPreprocessor 源码
greenplumn CExpressionUtils 源码