greenplumn IStatistics 代码
文件路径：/src/backend/gporca/libnaucrates/include/naucrates/statistics/IStatistics.h
/---------------------------------------------------------------------------
/ Greenplum Database
/ Copyright (C) 2018 VMware, Inc. or its affiliates.
/
/ @filename:
/ IStatistics.h
/
/ @doc:
/ Abstract statistics API
/---------------------------------------------------------------------------
#ifndef GPNAUCRATES_IStatistics_H
#define GPNAUCRATES_IStatistics_H
#include "gpos/base.h"
#include "gpos/common/CBitSet.h"
#include "gpos/common/CHashMapIter.h"
#include "gpopt/base/CColRef.h"
#include "naucrates/md/CDXLStatsDerivedRelation.h"
#include "naucrates/statistics/CHistogram.h"
#include "naucrates/statistics/CStatsPred.h"
#include "naucrates/statistics/CStatsPredJoin.h"
#include "naucrates/statistics/CStatsPredPoint.h"
namespace gpopt
{
class CMDAccessor;
class CReqdPropRelational;
class CColRefSet;
} / namespace gpopt
namespace gpnaucrates
{
using namespace gpos;
using namespace gpmd;
using namespace gpopt;
/ fwd declarations
class IStatistics;
/ hash map from column id to a histogram
using UlongToHistogramMap =
CHashMap<ULONG, CHistogram, gpos::HashValue<ULONG>, gpos::Equals<ULONG>,
CleanupDelete<ULONG>, CleanupDelete<CHistogram>>;
/ iterator
using UlongToHistogramMapIter =
CHashMapIter<ULONG, CHistogram, gpos::HashValue<ULONG>, gpos::Equals<ULONG>,
CleanupDelete<ULONG>, CleanupDelete<CHistogram>>;
/ hash map from column ULONG to CDouble
using UlongToDoubleMap =
CHashMap<ULONG, CDouble, gpos::HashValue<ULONG>, gpos::Equals<ULONG>,
CleanupDelete<ULONG>, CleanupDelete<CDouble>>;
/ iterator
using UlongToDoubleMapIter =
CHashMapIter<ULONG, CDouble, gpos::HashValue<ULONG>, gpos::Equals<ULONG>,
CleanupDelete<ULONG>, CleanupDelete<CDouble>>;
using UlongToUlongMap =
CHashMap<ULONG, ULONG, gpos::HashValue<ULONG>, gpos::Equals<ULONG>,
CleanupDelete<ULONG>, CleanupDelete<ULONG>>;
/ hash maps mapping INT -> ULONG
using IntToUlongMap =
CHashMap<INT, ULONG, gpos::HashValue<INT>, gpos::Equals<INT>,
CleanupDelete<INT>, CleanupDelete<ULONG>>;
/---------------------------------------------------------------------------
/ @class:
/ IStatistics
/
/ @doc:
/ Abstract statistics API
/
/---------------------------------------------------------------------------
class IStatistics : public CRefCount
{
private:
public:
IStatistics &operator=(IStatistics &) = delete;
IStatistics(const IStatistics &) = delete;
enum EStatsJoinType
{
EsjtInnerJoin,
EsjtLeftOuterJoin,
EsjtLeftSemiJoin,
EsjtLeftAntiSemiJoin,
EstiSentinel / should be the last in this enum
};
/ ctor
IStatistics() = default;
/ dtor
~IStatistics() override = default;
/ how many rows
virtual CDouble Rows() const = 0;
/ number of blocks in the relation (not always up to-to-date)
virtual ULONG RelPages() const = 0;
/ number of all-visible blocks in the relation (not always up-to-date)
virtual ULONG RelAllVisible() const = 0;
/ is statistics on an empty input
virtual BOOL IsEmpty() const = 0;
/ statistics could be computed using predicates with external parameters (outer references),
/ this is the total number of external parameters' values
virtual CDouble NumRebinds() const = 0;
/ skew estimate for given column
virtual CDouble GetSkew(ULONG colid) const = 0;
/ what is the width in bytes
virtual CDouble Width() const = 0;
/ what is the width in bytes of set of column id's
virtual CDouble Width(ULongPtrArray *colids) const = 0;
/ what is the width in bytes of set of column references
virtual CDouble Width(CMemoryPool *mp, CColRefSet *colrefs) const = 0;
/ the risk of errors in cardinality estimation
virtual ULONG StatsEstimationRisk() const = 0;
/ update the risk of errors in cardinality estimation
virtual void SetStatsEstimationRisk(ULONG risk) = 0;
/ look up the number of distinct values of a particular column
virtual CDouble GetNDVs(const CColRef *colref) = 0;
virtual ULONG GetNumberOfPredicates() const = 0;
/ inner join with another stats structure
virtual IStatistics *CalcInnerJoinStats(
CMemoryPool *mp, const IStatistics *other_stats,
CStatsPredJoinArray *join_preds_stats) const = 0;
/ LOJ with another stats structure
virtual IStatistics *CalcLOJoinStats(
CMemoryPool *mp, const IStatistics *other_stats,
CStatsPredJoinArray *join_preds_stats) const = 0;
/ semi join stats computation
virtual IStatistics *CalcLSJoinStats(
CMemoryPool *mp, const IStatistics *inner_side_stats,
CStatsPredJoinArray *join_preds_stats) const = 0;
/ anti semi join
virtual IStatistics *CalcLASJoinStats(
CMemoryPool *mp, const IStatistics *other_stats,
CStatsPredJoinArray *join_preds_stats,
BOOL DoIgnoreLASJHistComputation) const = 0;
/ return required props associated with stats object
virtual CReqdPropRelational *GetReqdRelationalProps(
CMemoryPool *mp) const = 0;
/ append given stats to current object
virtual void AppendStats(CMemoryPool *mp, IStatistics *stats) = 0;
/ set number of rebinds
virtual void SetRebinds(CDouble num_rebinds) = 0;
/ copy stats
virtual IStatistics *CopyStats(CMemoryPool *mp) const = 0;
/ return a copy of this stats object scaled by a given factor
virtual IStatistics *ScaleStats(CMemoryPool *mp, CDouble factor) const = 0;
/ copy stats with remapped column ids
virtual IStatistics *CopyStatsWithRemap(CMemoryPool *mp,
UlongToColRefMap *colref_mapping,
BOOL must_exist = true) const = 0;
/ return a set of column references we have stats for
virtual CColRefSet *GetColRefSet(CMemoryPool *mp) const = 0;
/ print function
virtual IOstream &OsPrint(IOstream &os) const = 0;
/ generate the DXL representation of the statistics object
virtual CDXLStatsDerivedRelation *GetDxlStatsDrvdRelation(
CMemoryPool *mp, CMDAccessor *md_accessor) const = 0;
/ is the join type either a left semi join or left anti-semi join
static BOOL
IsSemiJoin(IStatistics::EStatsJoinType join_type)
{
return (IStatistics::EsjtLeftAntiSemiJoin == join_type) ||
(IStatistics::EsjtLeftSemiJoin == join_type);
}
}; / class IStatistics
/ shorthand for printing
inline IOstream &
operator<<(IOstream &os, IStatistics &stats)
{
return stats.OsPrint(os);
}
/ dynamic array for derived stats
using IStatisticsArray = CDynamicPtrArray<IStatistics, CleanupRelease>;
} / namespace gpnaucrates
#endif / !GPNAUCRATES_IStatistics_H
/ EOF
相关信息
相关文章
greenplumn CFilterStatsProcessor 源码
greenplumn CGroupByStatsProcessor 源码
greenplumn CInnerJoinStatsProcessor 源码
greenplumn CJoinStatsProcessor 源码
greenplumn CLeftAntiSemiJoinStatsProcessor 源码
greenplumn CLeftOuterJoinStatsProcessor 源码