diff --git a/src/backend/columnar/columnar_customscan.c b/src/backend/columnar/columnar_customscan.c index 75df14bb5..f7d8c2b45 100644 --- a/src/backend/columnar/columnar_customscan.c +++ b/src/backend/columnar/columnar_customscan.c @@ -821,11 +821,11 @@ static void ColumnarScan_ExplainCustomScan(CustomScanState *node, List *ancestors, ExplainState *es) { - TableScanDesc scanDesc = node->ss.ss_currentScanDesc; + ColumnarScanDesc columnarScanDesc = (ColumnarScanDesc) node->ss.ss_currentScanDesc; - if (scanDesc != NULL) + if (columnarScanDesc != NULL) { - int64 chunkGroupsFiltered = ColumnarScanChunkGroupsFiltered(scanDesc); + int64 chunkGroupsFiltered = ColumnarScanChunkGroupsFiltered(columnarScanDesc); ExplainPropertyInteger("Columnar Chunk Groups Removed by Filter", NULL, chunkGroupsFiltered, es); } diff --git a/src/backend/columnar/columnar_tableam.c b/src/backend/columnar/columnar_tableam.c index 36222fc48..4b908f244 100644 --- a/src/backend/columnar/columnar_tableam.c +++ b/src/backend/columnar/columnar_tableam.c @@ -1843,9 +1843,8 @@ columnar_tableam_finish() * Get the number of chunks filtered out during the given scan. */ int64 -ColumnarScanChunkGroupsFiltered(TableScanDesc scanDesc) +ColumnarScanChunkGroupsFiltered(ColumnarScanDesc columnarScanDesc) { - ColumnarScanDesc columnarScanDesc = (ColumnarScanDesc) scanDesc; ColumnarReadState *readState = columnarScanDesc->cs_readState; /* readState is initialized lazily */ diff --git a/src/include/columnar/columnar_tableam.h b/src/include/columnar/columnar_tableam.h index adb819f1f..f0014a84f 100644 --- a/src/include/columnar/columnar_tableam.h +++ b/src/include/columnar/columnar_tableam.h @@ -42,6 +42,10 @@ #define VALID_BLOCKNUMBERS ((uint64) (MaxBlockNumber + 1)) +struct ColumnarScanDescData; +typedef struct ColumnarScanDescData *ColumnarScanDesc; + + const TableAmRoutine * GetColumnarTableAmRoutine(void); extern void columnar_tableam_init(void); extern void columnar_tableam_finish(void); @@ -51,7 +55,7 @@ extern TableScanDesc columnar_beginscan_extended(Relation relation, Snapshot sna ParallelTableScanDesc parallel_scan, uint32 flags, Bitmapset *attr_needed, List *scanQual); -extern int64 ColumnarScanChunkGroupsFiltered(TableScanDesc scanDesc); +extern int64 ColumnarScanChunkGroupsFiltered(ColumnarScanDesc columnarScanDesc); extern bool ColumnarSupportsIndexAM(char *indexAMName); extern bool IsColumnarTableAmTable(Oid relationId); extern TableDDLCommand * ColumnarGetTableOptionsDDL(Oid relationId);