greenplumn CFilterStatsProcessor 源码

greenplumn CFilterStatsProcessor 代码

文件路径：/src/backend/gporca/libnaucrates/include/naucrates/statistics/CFilterStatsProcessor.h

//---------------------------------------------------------------------------
//	Greenplum Database
//	Copyright (C) 2018 VMware, Inc. or its affiliates.
//
//	@filename:
//		CFilterStatsProcessor.h
//
//	@doc:
//		Compute statistics for filter operation
//---------------------------------------------------------------------------
#ifndef GPNAUCRATES_CFilterStatsProcessor_H
#define GPNAUCRATES_CFilterStatsProcessor_H

#include "gpos/base.h"

#include "gpopt/optimizer/COptimizerConfig.h"
#include "naucrates/statistics/CJoinStatsProcessor.h"
#include "naucrates/statistics/CScaleFactorUtils.h"
#include "naucrates/statistics/CStatistics.h"
#include "naucrates/statistics/CStatisticsUtils.h"

namespace gpnaucrates
{
class CFilterStatsProcessor
{
private:
	// create a new histogram after applying the filter that is not an AND/OR predicate
	static CHistogram *MakeHistSimpleFilter(CMemoryPool *mp,
											CStatsPred *pred_stats,
											CBitSet *filter_colids,
											CHistogram *hist_before,
											CDouble *last_scale_factor,
											ULONG *target_last_colid);

	// create a new histogram after applying a point filter
	static CHistogram *MakeHistPointFilter(CStatsPredPoint *pred_stats,
										   CBitSet *filter_colids,
										   CHistogram *hist_before,
										   CDouble *last_scale_factor,
										   ULONG *target_last_colid);

	// create a new histogram after applying a LIKE filter
	static CHistogram *MakeHistLikeFilter(CStatsPredLike *pred_stats,
										  CBitSet *filter_colids,
										  CHistogram *hist_before,
										  CDouble *last_scale_factor,
										  ULONG *target_last_colid);

	// create a new histogram for an unsupported predicate
	static CHistogram *MakeHistUnsupportedPred(
		CStatsPredUnsupported *pred_stats, CBitSet *filter_colids,
		CHistogram *hist_before, CDouble *last_scale_factor,
		ULONG *target_last_colid);

	// create a new histogram after applying a pred op ANY(ARRAY[...]) filter
	static CHistogram *MakeHistArrayCmpAnyFilter(CMemoryPool *mp,
												 CStatsPredArrayCmp *pred_stats,
												 CBitSet *filter_colids,
												 CHistogram *hist_before,
												 CDouble *last_scale_factor,
												 ULONG *target_last_colid);

	// create a new hash map of histograms after applying a conjunctive or disjunctive filter
	static UlongToHistogramMap *MakeHistHashMapConjOrDisjFilter(
		CMemoryPool *mp, const CStatisticsConfig *stats_config,
		UlongToHistogramMap *input_histograms, CDouble input_rows,
		CStatsPred *pred_stats, CDouble *scale_factor);

	// create new hash map of histograms after applying the conjunction predicate
	static UlongToHistogramMap *MakeHistHashMapConjFilter(
		CMemoryPool *mp, const CStatisticsConfig *stats_config,
		UlongToHistogramMap *intermediate_histograms, CDouble input_rows,
		CStatsPredConj *conjunctive_pred_stats, CDouble *scale_factor);

	// create new hash map of histograms after applying the disjunctive predicate
	static UlongToHistogramMap *MakeHistHashMapDisjFilter(
		CMemoryPool *mp, const CStatisticsConfig *stats_config,
		UlongToHistogramMap *input_histograms, CDouble input_rows,
		CStatsPredDisj *pred_stats, CDouble *scale_factor);

	// check if the column is a new column for statistic calculation
	static BOOL IsNewStatsColumn(ULONG colid, ULONG last_colid);

public:
	// filter
	static CStatistics *MakeStatsFilter(CMemoryPool *mp,
										const CStatistics *input_stats,
										CStatsPred *base_pred_stats,
										BOOL do_cap_NDVs);

	// derive statistics for filter operation based on given scalar expression
	static IStatistics *MakeStatsFilterForScalarExpr(
		CMemoryPool *mp, CExpressionHandle &exprhdl, IStatistics *child_stats,
		CExpression
			*local_scalar_expr,	 // filter expression on local columns only
		CExpression *
			outer_refs_scalar_expr,	 // filter expression involving outer references
		IStatisticsArray *all_outer_stats);

	static CDouble SelectivityOfPredicate(CMemoryPool *mp, CExpression *pred,
										  CTableDescriptor *ptabdesc,
										  CColRefSet *pcrsOuterRefs);
};
}  // namespace gpnaucrates

#endif	// !GPNAUCRATES_CFilterStatsProcessor_H

// EOF

相关信息

greenplumn 源码目录

相关文章

greenplumn CBucket 源码

greenplumn CGroupByStatsProcessor 源码

greenplumn CHistogram 源码

greenplumn CInnerJoinStatsProcessor 源码

greenplumn CJoinStatsProcessor 源码

greenplumn CLeftAntiSemiJoinStatsProcessor 源码

greenplumn CLeftOuterJoinStatsProcessor 源码

greenplumn CLeftSemiJoinStatsProcessor 源码

greenplumn CLimitStatsProcessor 源码

greenplumn CPoint 源码