external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Get rid of EndStripeRead, since we anyway reset mem cxt

pull/5058/head
Onur Tirtir 2021-07-05 12:45:40 +03:00
parent 83f5d42365
commit 327ae43b83
1 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/backend/columnar/columnar_reader.c
View File

@ -103,7 +103,6 @@ static StripeReadState * BeginStripeRead(StripeMetadata *stripeMetadata, Relatio
TupleDesc tupleDesc, List *projectedColumnList, TupleDesc tupleDesc, List *projectedColumnList,
List *whereClauseList, List *whereClauseVars, List *whereClauseList, List *whereClauseVars,
MemoryContext stripeReadContext); MemoryContext stripeReadContext);
static void EndStripeRead(StripeReadState *stripeReadState);
static void AdvanceStripeRead(ColumnarReadState *readState); static void AdvanceStripeRead(ColumnarReadState *readState);
static bool ReadStripeNextRow(StripeReadState *stripeReadState, Datum *columnValues, static bool ReadStripeNextRow(StripeReadState *stripeReadState, Datum *columnValues,
bool *columnNulls); bool *columnNulls);
@ -512,16 +511,6 @@ BeginStripeRead(StripeMetadata *stripeMetadata, Relation rel, TupleDesc tupleDes
} }
/*
* EndStripeRead finishes a stripe read.
*/
static void
EndStripeRead(StripeReadState *stripeReadState)
{
pfree(stripeReadState);
}
/* /*
* AdvanceStripeRead updates chunkGroupsFiltered and sets * AdvanceStripeRead updates chunkGroupsFiltered and sets
* currentStripeMetadata for next stripe read. * currentStripeMetadata for next stripe read.
@ -534,9 +523,6 @@ AdvanceStripeRead(ColumnarReadState *readState)
uint64 lastReadRowNumber = uint64 lastReadRowNumber =
StripeGetHighestRowNumber(readState->currentStripeMetadata); StripeGetHighestRowNumber(readState->currentStripeMetadata);
EndStripeRead(readState->stripeReadState);
readState->currentStripeMetadata = FindNextStripeByRowNumber(readState->relation, readState->currentStripeMetadata = FindNextStripeByRowNumber(readState->relation,
lastReadRowNumber, lastReadRowNumber,
GetTransactionSnapshot()); GetTransactionSnapshot());