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

columnar_tuple_satisfies_snapshot, columnar_index_delete_tuples, columnar_tuple_insert, columnar_multi_insert

pull/5712/head
yxu2162 2022-02-15 13:21:19 -08:00
parent 76985eeafd
commit 8fc364d2ae
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/columnar/columnar_tableam.c
View File

@ -659,7 +659,7 @@ static bool
columnar_tuple_satisfies_snapshot(Relation rel, TupleTableSlot *slot, columnar_tuple_satisfies_snapshot(Relation rel, TupleTableSlot *slot,
Snapshot snapshot) Snapshot snapshot)
{ {
CheckCitusVersion(ERROR); CheckExtensionVersion(ERROR);
uint64 rowNumber = tid_to_row_number(slot->tts_tid); uint64 rowNumber = tid_to_row_number(slot->tts_tid);
StripeMetadata *stripeMetadata = FindStripeByRowNumber(rel, rowNumber, snapshot); StripeMetadata *stripeMetadata = FindStripeByRowNumber(rel, rowNumber, snapshot);
@ -672,7 +672,7 @@ static TransactionId
columnar_index_delete_tuples(Relation rel, columnar_index_delete_tuples(Relation rel,
TM_IndexDeleteOp *delstate) TM_IndexDeleteOp *delstate)
{ {
CheckCitusVersion(ERROR); CheckExtensionVersion(ERROR);
/* /*
* XXX: We didn't bother implementing index_delete_tuple for neither of * XXX: We didn't bother implementing index_delete_tuple for neither of
@ -733,7 +733,7 @@ static void
columnar_tuple_insert(Relation relation, TupleTableSlot *slot, CommandId cid, columnar_tuple_insert(Relation relation, TupleTableSlot *slot, CommandId cid,
int options, BulkInsertState bistate) int options, BulkInsertState bistate)
{ {
CheckCitusVersion(ERROR); CheckExtensionVersion(ERROR);
/* /*
* columnar_init_write_state allocates the write state in a longer * columnar_init_write_state allocates the write state in a longer
@ -781,7 +781,7 @@ static void
columnar_multi_insert(Relation relation, TupleTableSlot **slots, int ntuples, columnar_multi_insert(Relation relation, TupleTableSlot **slots, int ntuples,
CommandId cid, int options, BulkInsertState bistate) CommandId cid, int options, BulkInsertState bistate)
{ {
CheckCitusVersion(ERROR); CheckExtensionVersion(ERROR);
ColumnarWriteState *writeState = columnar_init_write_state(relation, ColumnarWriteState *writeState = columnar_init_write_state(relation,
RelationGetDescr(relation), RelationGetDescr(relation),