Home
last modified time | relevance | path

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 Ddistributed_intermediate_results.c101 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 Dpartitioned_intermediate_results.c318 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 Dshardinterval_utils.c35 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 Ddistribution_metadata.c101 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 Dprune_shard_list.c246 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 Dmetadata_cache.h176 extern bool HasUniformHashDistribution(ShardInterval **shardIntervalArray,
180 extern bool HasOverlappingShardInterval(ShardInterval **shardIntervalArray,
H A Dshardinterval_utils.h38 extern ShardInterval ** SortShardIntervalArray(ShardInterval **shardIntervalArray, int
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/
H A Dmetadata_cache.c1403 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 Dmulti_physical_planner.c160 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()