greenplumn CPhysicalDynamicScan 源码
greenplumn CPhysicalDynamicScan 代码
文件路径:/src/backend/gporca/libgpopt/include/gpopt/operators/CPhysicalDynamicScan.h
//---------------------------------------------------------------------------
// Greenplum Database
// Copyright (C) 2015 VMware, Inc. or its affiliates.
//
// @filename:
// CPhysicalDynamicScan.h
//
// @doc:
// Base class for physical dynamic scan operators
//
// @owner:
//
//
// @test:
//
//---------------------------------------------------------------------------
#ifndef GPOPT_CPhysicalDynamicScan_H
#define GPOPT_CPhysicalDynamicScan_H
#include "gpos/base.h"
#include "gpopt/operators/CPhysicalScan.h"
namespace gpopt
{
// fwd declarations
class CTableDescriptor;
class CName;
class CPartConstraint;
//---------------------------------------------------------------------------
// @class:
// CPhysicalDynamicScan
//
// @doc:
// Base class for physical dynamic scan operators
//
//---------------------------------------------------------------------------
class CPhysicalDynamicScan : public CPhysicalScan
{
private:
// origin operator id -- gpos::ulong_max if operator was not generated via a transformation
ULONG m_ulOriginOpId;
// id of the dynamic scan
ULONG m_scan_id;
// partition keys
CColRef2dArray *m_pdrgpdrgpcrPart;
// child partitions
IMdIdArray *m_partition_mdids;
// Map of Root colref -> col index in child tabledesc
// per child partition in m_partition_mdid
ColRefToUlongMapArray *m_root_col_mapping_per_part = nullptr;
public:
CPhysicalDynamicScan(const CPhysicalDynamicScan &) = delete;
// ctor
CPhysicalDynamicScan(CMemoryPool *mp, CTableDescriptor *ptabdesc,
ULONG ulOriginOpId, const CName *pnameAlias,
ULONG scan_id, CColRefArray *pdrgpcrOutput,
CColRef2dArray *pdrgpdrgpcrParts,
IMdIdArray *partition_mdids,
ColRefToUlongMapArray *root_col_mapping_per_part);
// dtor
~CPhysicalDynamicScan() override;
// origin operator id -- gpos::ulong_max if operator was not generated via a transformation
ULONG
UlOriginOpId() const
{
return m_ulOriginOpId;
}
// return scan id
ULONG
ScanId() const
{
return m_scan_id;
}
// partition keys
CColRef2dArray *
PdrgpdrgpcrPart() const
{
return m_pdrgpdrgpcrPart;
}
// sensitivity to order of inputs
BOOL
FInputOrderSensitive() const override
{
return true;
}
// operator specific hash function
ULONG HashValue() const override;
// return true if operator is dynamic scan
BOOL
FDynamicScan() const override
{
return true;
}
IMdIdArray *
GetPartitionMdids() const
{
return m_partition_mdids;
}
ColRefToUlongMapArray *
GetRootColMappingPerPart() const
{
return m_root_col_mapping_per_part;
}
// debug print
IOstream &OsPrint(IOstream &) const override;
// conversion function
static CPhysicalDynamicScan *PopConvert(COperator *pop);
};
} // namespace gpopt
#endif // !GPOPT_CPhysicalDynamicScan_H
// EOF
相关信息
相关文章
greenplumn CExpressionFactorizer 源码
greenplumn CExpressionHandle 源码
greenplumn CExpressionPreprocessor 源码
greenplumn CExpressionUtils 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
7、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦