Searched refs:shardIntervalArray (Results 1 – 9 of 9) sorted by relevance
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
H A D | distributed_intermediate_results.c | 101 static void ShardMinMaxValueArrays(ShardInterval **shardIntervalArray, int shardCount, 213 ShardInterval **shardIntervalArray = targetRelation->sortedShardIntervalArray; in WrapTasksForPartitioning() local 228 ShardMinMaxValueArrays(shardIntervalArray, shardCount, intervalTypeOutFunc, in WrapTasksForPartitioning() 364 ShardMinMaxValueArrays(ShardInterval **shardIntervalArray, int shardCount, in ShardMinMaxValueArrays() argument 374 minValueNulls[shardIndex] = !shardIntervalArray[shardIndex]->minValueExists; in ShardMinMaxValueArrays() 375 maxValueNulls[shardIndex] = !shardIntervalArray[shardIndex]->maxValueExists; in ShardMinMaxValueArrays() 379 Datum minValue = shardIntervalArray[shardIndex]->minValue; in ShardMinMaxValueArrays() 387 Datum maxValue = shardIntervalArray[shardIndex]->maxValue; in ShardMinMaxValueArrays()
|
H A D | partitioned_intermediate_results.c | 318 ShardInterval **shardIntervalArray = palloc0(partitionCount * in QueryTupleShardSearchInfo() local 334 shardIntervalArray[partitionIndex] = in QueryTupleShardSearchInfo() 337 shardIntervalArray[partitionIndex]->shardIndex = partitionIndex; in QueryTupleShardSearchInfo() 347 SortShardIntervalArray(shardIntervalArray, partitionCount, in QueryTupleShardSearchInfo()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
H A D | shardinterval_utils.c | 35 SortShardIntervalArray(ShardInterval **shardIntervalArray, int shardCount, in SortShardIntervalArray() argument 46 return shardIntervalArray; in SortShardIntervalArray() 50 qsort_arg(shardIntervalArray, shardCount, sizeof(ShardInterval *), in SortShardIntervalArray() 53 return shardIntervalArray; in SortShardIntervalArray()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/ |
H A D | distribution_metadata.c | 101 Datum shardIntervalArray[] = { shardInterval->minValue, shardInterval->maxValue }; in load_shard_interval_array() local 105 ArrayType *shardIntervalArrayType = DatumArrayToArrayType(shardIntervalArray, 2, in load_shard_interval_array()
|
H A D | prune_shard_list.c | 246 ShardInterval **shardIntervalArray = cacheEntry->sortedShardIntervalArray; in SortedShardIntervalArray() local 252 ShardInterval *shardId = shardIntervalArray[shardIndex]; in SortedShardIntervalArray()
|
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
H A D | metadata_cache.h | 176 extern bool HasUniformHashDistribution(ShardInterval **shardIntervalArray, 180 extern bool HasOverlappingShardInterval(ShardInterval **shardIntervalArray,
|
H A D | shardinterval_utils.h | 38 extern ShardInterval ** SortShardIntervalArray(ShardInterval **shardIntervalArray, int
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/ |
H A D | metadata_cache.c | 1403 ShardInterval **shardIntervalArray = NULL; in BuildCachedShardList() local 1427 shardIntervalArray = MemoryContextAllocZero(MetadataCacheMemoryContext, in BuildCachedShardList() 1449 shardIntervalArray[arrayIndex] = CopyShardInterval(shardInterval); in BuildCachedShardList() 1511 sortedShardIntervalArray = shardIntervalArray; in BuildCachedShardList() 1516 sortedShardIntervalArray = SortShardIntervalArray(shardIntervalArray, in BuildCachedShardList() 1629 HasUniformHashDistribution(ShardInterval **shardIntervalArray, in HasUniformHashDistribution() argument 1643 ShardInterval *shardInterval = shardIntervalArray[shardIndex]; in HasUniformHashDistribution() 1700 HasOverlappingShardInterval(ShardInterval **shardIntervalArray, in HasOverlappingShardInterval() argument 1714 ShardInterval *lastShardInterval = shardIntervalArray[0]; in HasOverlappingShardInterval() 1717 ShardInterval *curShardInterval = shardIntervalArray[shardIndex]; in HasOverlappingShardInterval()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/ |
H A D | multi_physical_planner.c | 160 static ArrayType * SplitPointObject(ShardInterval **shardIntervalArray, 2059 SplitPointObject(ShardInterval **shardIntervalArray, uint32 shardIntervalCount) in SplitPointObject() argument 2072 ShardInterval *shardInterval = shardIntervalArray[intervalIndex]; in SplitPointObject() 4658 ShardInterval **shardIntervalArray = palloc0(partitionCount * in GenerateSyntheticShardIntervalArray() local 4680 shardIntervalArray[shardIndex] = shardInterval; in GenerateSyntheticShardIntervalArray() 4683 return shardIntervalArray; in GenerateSyntheticShardIntervalArray()
|