Searched refs:shardMinValue (Results 1 – 8 of 8) sorted by relevance
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/ |
| H A D | stage_protocol.c | 69 text **shardMinValue, text **shardMaxValue);
74 shardSize, text *shardMinValue,
77 text **shardMinValue, text **shardMaxValue,
952 text *shardMinValue = NULL; in ReceiveAndUpdateShardsSizeAndMinMax() local
976 shardPlacementList, shardSize, shardMinValue, in ReceiveAndUpdateShardsSizeAndMinMax()
993 text **shardMinValue, text **shardMaxValue, uint64 *shardSize) in ProcessShardStatisticsRow() argument
1006 *shardMinValue = cstring_to_text(minValueResult); in ProcessShardStatisticsRow()
1044 InsertShardRow(relationId, shardId, storageType, shardMinValue, in UpdateShardSizeAndMinMax()
1056 uint64 *shardSize, text **shardMinValue, text **shardMaxValue) in WorkerShardStats() argument
1081 *shardMinValue = NULL; in WorkerShardStats()
[all …]
|
| H A D | create_shards.c | 286 int32 shardMinValue = DatumGetInt32(sourceShardInterval->minValue); in CreateColocatedShards() local
288 text *shardMinValueText = IntegerToText(shardMinValue); in CreateColocatedShards()
332 text *shardMinValue = NULL; in CreateReferenceTableShard() local
373 InsertShardRow(distributedTableId, shardId, shardStorageType, shardMinValue, in CreateReferenceTableShard()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
| H A D | shardinterval_utils.c | 217 Datum shardMinValue = shardInterval->minValue; in ShardIndex() local
247 shardIndex = FindShardIntervalIndex(shardMinValue, cacheEntry); in ShardIndex()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
| H A D | metadata_sync.c | 112 text *shardMinValue,
2227 text *shardMinValue = NULL; in citus_internal_add_shard_metadata() local
2230 shardMinValue = PG_GETARG_TEXT_P(3); in citus_internal_add_shard_metadata()
2255 EnsureShardMetadataIsSane(relationId, shardId, storageType, shardMinValue, in citus_internal_add_shard_metadata()
2259 InsertShardRow(relationId, shardId, storageType, shardMinValue, shardMaxValue); in citus_internal_add_shard_metadata()
2293 text *shardMinValue, text *shardMaxValue) in EnsureShardMetadataIsSane() argument
2330 if (shardMinValue != NULL || shardMaxValue != NULL) in EnsureShardMetadataIsSane()
2347 if (shardMinValue == NULL || shardMaxValue == NULL) in EnsureShardMetadataIsSane()
2355 char *shardMinValueString = text_to_cstring(shardMinValue); in EnsureShardMetadataIsSane()
|
| H A D | metadata_utility.c | 1652 text *shardMinValue, text *shardMaxValue) in InsertShardRow() argument
1669 if (shardMinValue != NULL && shardMaxValue != NULL) in InsertShardRow()
1671 values[Anum_pg_dist_shard_shardminvalue - 1] = PointerGetDatum(shardMinValue); in InsertShardRow()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/ |
| H A D | citus_add_local_table_to_metadata.c | 1001 text *shardMinValue = NULL; in InsertMetadataForCitusLocalTable() local
1004 shardMinValue, shardMaxValue); in InsertMetadataForCitusLocalTable()
|
| /dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
| H A D | metadata_utility.h | 230 text *shardMinValue, text *shardMaxValue);
|
| /dports/databases/pg_citus/citus-10.2.3/src/test/regress/expected/ |
| H A D | metadata_sync_helpers.out | 528 -- shardMinValue should be smaller than shardMaxValue
541 ERROR: shardMinValue=-1610612737 is greater than shardMaxValue=-2147483648 for table "test_2", whi…
|