Searched defs:distributedTableId (Results 1 – 12 of 12) sorted by relevance
63 Oid distributedTableId = PG_GETARG_OID(0); in prune_using_no_values() local79 Oid distributedTableId = PG_GETARG_OID(0); in prune_using_single_value() local97 Oid distributedTableId = PG_GETARG_OID(0); in prune_using_either_value() local118 Oid distributedTableId = PG_GETARG_OID(0); in prune_using_both_values() local139 Oid distributedTableId = PG_GETARG_OID(0); in debug_equality_expression() local155 Oid distributedTableId = PG_GETARG_OID(0); in print_sorted_shard_intervals() local168 MakeTextPartitionExpression(Oid distributedTableId, text *value) in MakeTextPartitionExpression()208 PrunedShardIdsForTable(Oid distributedTableId, List *whereClauseList) in PrunedShardIdsForTable()241 SortedShardIntervalArray(Oid distributedTableId) in SortedShardIntervalArray()
64 Oid distributedTableId = PG_GETARG_OID(0); in load_shard_id_array() local170 Oid distributedTableId = PG_GETARG_OID(0); in partition_column_id() local186 Oid distributedTableId = PG_GETARG_OID(0); in partition_type() local200 Oid distributedTableId = PG_GETARG_OID(0); in is_distributed_table() local215 Oid distributedTableId = PG_GETARG_OID(0); in create_monolithic_shard_row() local
36 Oid distributedTableId = PG_GETARG_OID(0); in get_table_colocation_id() local84 Oid distributedTableId = PG_GETARG_OID(0); in get_colocated_table_array() local
75 Oid distributedTableId = ResolveRelationId(tableNameText, false); in master_create_worker_shards() local108 CreateShardsWithRoundRobinPolicy(Oid distributedTableId, int32 shardCount, in CreateShardsWithRoundRobinPolicy()329 CreateReferenceTableShard(Oid distributedTableId) in CreateReferenceTableShard()391 CheckHashPartitionedTable(Oid distributedTableId) in CheckHashPartitionedTable()
314 Oid distributedTableId = shardInterval->relationId; in citus_move_shard_placement() local660 Oid distributedTableId = shardInterval->relationId; in RepairShardPlacement() local778 Oid distributedTableId = shardInterval->relationId; in ReplicateColocatedShardPlacement() local1031 Oid distributedTableId = shardInterval->relationId; in CopyPartitionShardsCommandList() local
381 Oid distributedTableId = PG_GETARG_OID(0); in citus_update_table_statistics() local
889 Oid distributedTableId = InvalidOid; in ModifyQuerySupported() local1142 Oid distributedTableId = ExtractFirstCitusTableId(queryTree); in ErrorIfOnConflictNotSupported() local1657 Oid distributedTableId = cacheEntry->relationId; in ErrorIfNoShardsExist() local1680 Oid distributedTableId = ExtractFirstCitusTableId(query); in RouterInsertTaskList() local1760 Oid distributedTableId = InvalidOid; in ExtractFirstCitusTableId() local2904 Oid distributedTableId = ExtractFirstCitusTableId(query); in BuildRoutesForInsert() local3449 Oid distributedTableId = ExtractFirstCitusTableId(query); in ExtractInsertPartitionKeyValue() local3581 Oid distributedTableId = rte->relid; in DeferErrorIfUnsupportedRouterPlannableSelectQuery() local3745 Oid distributedTableId = InvalidOid; in ErrorIfQueryHasUnroutableModifyingCTE() local
200 Oid distributedTableId = rangeTableEntry->relid; in FastPathRouterQuery() local
692 Oid distributedTableId = shardInterval->relationId; in RouterModifyTaskForShardInterval() local
824 TableColocationId(Oid distributedTableId) in TableColocationId()890 ColocatedTableList(Oid distributedTableId) in ColocatedTableList()986 Oid distributedTableId = shardInterval->relationId; in ColocatedShardIntervalList() local1047 Oid distributedTableId = shardInterval->relationId; in ColocatedNonPartitionShardIntervalList() local
81 Oid distributedTableId = PG_GETARG_OID(0); in column_name_to_column_id() local
216 Oid distributedTableId = shardInterval->relationId; in ShardIndex() local