greenplumn CStatsPredPoint 源码
greenplumn CStatsPredPoint 代码
文件路径：/src/backend/gporca/libnaucrates/src/statistics/CStatsPredPoint.cpp
//---------------------------------------------------------------------------
// Greenplum Database
// Copyright (C) 2013 EMC Corp.
//
// @filename:
// CStatsPredPoint.cpp
//
// @doc:
// Implementation of statistics filter that compares a column to a constant
//---------------------------------------------------------------------------
#include "naucrates/statistics/CStatsPredPoint.h"
#include "gpopt/base/CColRef.h"
#include "gpopt/base/CColRefTable.h"
#include "naucrates/md/CMDIdGPDB.h"
using namespace gpnaucrates;
using namespace gpopt;
using namespace gpmd;
//---------------------------------------------------------------------------
// @function:
// CStatsPredPoint::CStatisticsFilterPoint
//
// @doc:
// Ctor
//
//---------------------------------------------------------------------------
CStatsPredPoint::CStatsPredPoint(ULONG colid,
CStatsPred::EStatsCmpType stats_cmp_type,
CPoint *point)
: CStatsPred(colid), m_stats_cmp_type(stats_cmp_type), m_pred_point(point)
{
GPOS_ASSERT(nullptr != point);
}
//---------------------------------------------------------------------------
// @function:
// CStatsPredPoint::CStatisticsFilterPoint
//
// @doc:
// Ctor
//
//---------------------------------------------------------------------------
CStatsPredPoint::CStatsPredPoint(CMemoryPool *mp, const CColRef *colref,
CStatsPred::EStatsCmpType stats_cmp_type,
IDatum *datum)
: CStatsPred(gpos::ulong_max),
m_stats_cmp_type(stats_cmp_type),
m_pred_point(nullptr)
{
GPOS_ASSERT(nullptr != colref);
GPOS_ASSERT(nullptr != datum);
m_colid = colref->Id();
IDatum *padded_datum = PreprocessDatum(mp, colref, datum);
m_pred_point = GPOS_NEW(mp) CPoint(padded_datum);
}
//---------------------------------------------------------------------------
// CStatsPredPoint::PreprocessDatum
//
// @doc:
// Add padding to datums when needed
//---------------------------------------------------------------------------
IDatum *
CStatsPredPoint::PreprocessDatum(CMemoryPool *mp, const CColRef *colref,
IDatum *datum)
{
GPOS_ASSERT(nullptr != colref);
GPOS_ASSERT(nullptr != datum);
if (!datum->NeedsPadding() || CColRef::EcrtTable != colref->Ecrt() ||
datum->IsNull())
{
// we do not pad datum for comparison against computed columns
datum->AddRef();
return datum;
}
const CColRefTable *colref_table =
CColRefTable::PcrConvert(const_cast<CColRef *>(colref));
return datum->MakePaddedDatum(mp, colref_table->Width());
}
// EOF
相关信息
相关文章
greenplumn CFilterStatsProcessor 源码
greenplumn CGroupByStatsProcessor 源码
greenplumn CInnerJoinStatsProcessor 源码
greenplumn CJoinStatsProcessor 源码
greenplumn CLeftAntiSemiJoinStatsProcessor 源码
greenplumn CLeftOuterJoinStatsProcessor 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
7、 openharmony