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

Remove AutoConvertedViaCatalog

talha_tes1
Ahmet Gedemenli 2021-10-19 11:24:42 +03:00
parent 21a184f2e7
commit 91bc5158a4
2 changed files with 0 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/backend/distributed/metadata/metadata_cache.c
View File

@ -517,44 +517,6 @@ PartitionMethodViaCatalog(Oid relationId)
}
/*
* AutoConvertedViaCatalog gets a relationId and returns the auto converted
* column from pg_dist_partition via reading from catalog.
*/
bool
AutoConvertedViaCatalog(Oid relationId)
{
HeapTuple partitionTuple = PgDistPartitionTupleViaCatalog(relationId);
if (!HeapTupleIsValid(partitionTuple))
{
ereport(ERROR, (errmsg("relation not found with oid: %u", relationId)));
}
Datum datumArray[Natts_pg_dist_partition];
bool isNullArray[Natts_pg_dist_partition];
Relation pgDistPartition = table_open(DistPartitionRelationId(), AccessShareLock);
TupleDesc tupleDescriptor = RelationGetDescr(pgDistPartition);
heap_deform_tuple(partitionTuple, tupleDescriptor, datumArray, isNullArray);
if (isNullArray[Anum_pg_dist_partition_autoconverted - 1])
{
heap_freetuple(partitionTuple);
table_close(pgDistPartition, NoLock);
return false;
}
Datum autoConvertedDatum = datumArray[Anum_pg_dist_partition_autoconverted - 1];
bool autoConvertedBool = DatumGetBool(autoConvertedDatum);
heap_freetuple(partitionTuple);
table_close(pgDistPartition, NoLock);
return autoConvertedBool;
}
/*
* PgDistPartitionTupleViaCatalog is a helper function that searches
* pg_dist_partition for the given relationId. The caller is responsible

1
src/include/distributed/metadata_cache.h
View File

@ -147,7 +147,6 @@ extern bool IsCitusTable(Oid relationId);
extern char PgDistPartitionViaCatalog(Oid relationId);
extern List * LookupDistShardTuples(Oid relationId);
extern char PartitionMethodViaCatalog(Oid relationId);
extern bool AutoConvertedViaCatalog(Oid relationId);
extern bool IsCitusLocalTableByDistParams(char partitionMethod, char replicationModel);
extern List * CitusTableList(void);
extern ShardInterval * LoadShardInterval(uint64 shardId);