greenplumn CFilterCardinalityTest 源码

greenplumn CFilterCardinalityTest 代码

文件路径：/src/backend/gporca/server/include/unittest/dxl/statistics/CFilterCardinalityTest.h

//---------------------------------------------------------------------------
//	Greenplum Database
//	Copyright (C) 2018 VMware, Inc. or its affiliates.
//
//	@filename:
//		CFilterCardinalityTest.h
//
//	@doc:
//		Test for filter cardinality estimation
//---------------------------------------------------------------------------
#ifndef GPNAUCRATES_CFilterCardinalityTest_H
#define GPNAUCRATES_CFilterCardinalityTest_H

#include "gpos/base.h"

#include "naucrates/dxl/CDXLUtils.h"
#include "naucrates/statistics/CBucket.h"
#include "naucrates/statistics/CHistogram.h"
#include "naucrates/statistics/CPoint.h"
#include "naucrates/statistics/CStatistics.h"
#include "naucrates/statistics/CStatsPredDisj.h"

namespace gpnaucrates
{
using namespace gpos;

//---------------------------------------------------------------------------
//	@class:
//		CFilterCardinalityTest
//
//	@doc:
//		Static unit tests for join cardinality estimation
//
//---------------------------------------------------------------------------
class CFilterCardinalityTest
{
	// shorthand for functions for generating the disjunctive filter predicates
	typedef CStatsPred *(FnPstatspredDisj)(CMemoryPool *mp);

private:
	// triplet consisting of comparison type, double value and its byte array representation
	struct SStatsCmpValElem
	{
		CStatsPred::EStatsCmpType m_stats_cmp_type;	 // comparison operator
		const WCHAR *m_wsz;	 // byte array representation
		CDouble m_value;	 // double value
	};						 // SStatsCmpValElem

	// test case for disjunctive filter evaluation
	struct SStatsFilterSTestCase
	{
		// input stats dxl file
		const CHAR *m_szInputFile;

		// output stats dxl file
		const CHAR *m_szOutputFile;

		// filter predicate generation function pointer
		FnPstatspredDisj *m_pf;
	};	// SStatsFilterSTestCase

	// helper method to iterate over an array generated filter predicates for stats evaluation
	static GPOS_RESULT EresUnittest_CStatistics(
		SStatsFilterSTestCase rgstatsdisjtc[], ULONG ulTestCases);

	// disjunction filters
	static CStatsPred *PstatspredDisj1(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj2(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj3(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj4(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj5(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj6(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj7(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj8(CMemoryPool *mp);

	// disjunction filters
	static CStatsPred *PstatspredDisj9(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredNestedPredDiffCol1(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredNestedPredDiffCol2(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredNestedPredCommonCol1(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredNestedPredCommonCol2(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredNestedSharedCol(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredDisjOverConjSameCol1(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredDisjOverConjSameCol2(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredDisjOverConjSameCol3(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredDisjOverConjSameCol4(CMemoryPool *mp);

	// nested AND and OR predicates
	static CStatsPred *PstatspredDisjOverConjDifferentCol1(CMemoryPool *mp);

	static CStatsPred *PstatspredDisjOverConjMultipleIdenticalCols(
		CMemoryPool *mp);

	static CStatsPred *PstatspredArrayCmpAnySimple(CMemoryPool *mp);

	static CStatsPred *PstatspredArrayCmpAnyDuplicate(CMemoryPool *mp);


	// conjunctive predicates
	static CStatsPred *PstatspredConj(CMemoryPool *mp);

	// generate an array of filter given a column identifier, comparison type, and array of integer point
	static CStatsPredPtrArry *PdrgpstatspredInteger(
		CMemoryPool *mp, ULONG colid, CStatsPred::EStatsCmpType stats_cmp_type,
		INT *piVals, ULONG ulVals);

	// create a numeric predicate on a particular column
	static CStatsPredPtrArry *PdrgppredfilterNumeric(
		CMemoryPool *mp, ULONG colid, SStatsCmpValElem statsCmpValElem);

	// create a filter on a column with null values
	static CStatsPred *PstatspredNullableCols(CMemoryPool *mp);

	// create a point filter where the constant is null
	static CStatsPred *PstatspredWithNullConstant(CMemoryPool *mp);

	// create a 'is not null' point filter
	static CStatsPred *PstatspredNotNull(CMemoryPool *mp);

	// compare the derived statistics with the statistics in the outputfile
	static GPOS_RESULT EresUnittest_CStatisticsCompare(
		CMemoryPool *mp, CMDAccessor *md_accessor,
		CStatisticsArray *pdrgpstatBefore, CStatsPred *pred_stats,
		const CHAR *szDXLOutput, BOOL fApplyTwice = false);

public:
	// unittests
	static GPOS_RESULT EresUnittest();

	// testing select predicates
	static GPOS_RESULT EresUnittest_CStatisticsFilter();

	// testing ArryCmpAny predicates
	static GPOS_RESULT EresUnittest_CStatisticsFilterArrayCmpAny();

	// testing nested AND / OR predicates
	static GPOS_RESULT EresUnittest_CStatisticsNestedPred();

	// test disjunctive filter
	static GPOS_RESULT EresUnittest_CStatisticsFilterDisj();

	// test conjunctive filter
	static GPOS_RESULT EresUnittest_CStatisticsFilterConj();

	// DXL based test on numeric data types
	static GPOS_RESULT EresUnittest_CStatisticsBasicsFromDXLNumeric();

	// basic statistics parsing
	static GPOS_RESULT EresUnittest_CStatisticsBasicsFromDXL();

	// test for accumulating cardinality in disjunctive and conjunctive predicates
	static GPOS_RESULT EresUnittest_CStatisticsAccumulateCard();

};	// class CFilterCardinalityTest
}  // namespace gpnaucrates

#endif	// !GPNAUCRATES_CFilterCardinalityTest_H


// EOF

相关信息

greenplumn 源码目录

相关文章

greenplumn CBucketTest 源码

greenplumn CCardinalityTestUtils 源码

greenplumn CHistogramTest 源码

greenplumn CJoinCardinalityTest 源码

greenplumn CMCVTest 源码

greenplumn CPointTest 源码

greenplumn CStatisticsTest 源码