Home
last modified time | relevance | path

Searched defs:shardInterval (Results 1 – 25 of 47) sorted by relevance

12

/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/operations/
H A Drepair_shards.c156 ShardInterval *shardInterval = LoadShardInterval(shardId); in citus_copy_shard_placement() local
313 ShardInterval *shardInterval = LoadShardInterval(shardId); in citus_move_shard_placement() local
659 ShardInterval *shardInterval = LoadShardInterval(shardId); in RepairShardPlacement() local
777 ShardInterval *shardInterval = LoadShardInterval(shardId); in ReplicateColocatedShardPlacement() local
941 ShardInterval *shardInterval = NULL; in CopyShardTablesViaBlockWrites() local
1208 CopyShardCommandList(ShardInterval *shardInterval, const char *sourceNodeName, in CopyShardCommandList()
1231 RecreateShardDDLCommandList(ShardInterval *shardInterval, const char *sourceNodeName, in RecreateShardDDLCommandList()
1287 CopyShardForeignConstraintCommandList(ShardInterval *shardInterval) in CopyShardForeignConstraintCommandList()
1309 CopyShardForeignConstraintCommandListGrouped(ShardInterval *shardInterval, in CopyShardForeignConstraintCommandListGrouped()
1426 ConstructQualifiedShardName(ShardInterval *shardInterval) in ConstructQualifiedShardName()
[all …]
H A Dstage_protocol.c254 ShardInterval *shardInterval = LoadShardInterval(shardId); in master_append_table_to_shard() local
585 ShardInterval *shardInterval = LoadShardInterval(shardId); in CreateShardsOnWorkers() local
646 RelationShardListForShardCreate(ShardInterval *shardInterval) in RelationShardListForShardCreate()
816 ShardInterval *shardInterval = LoadShardInterval(shardId); in WorkerCreateShardCommandList() local
833 ShardInterval *shardInterval = LoadShardInterval(shardId); in UpdateShardStatistics() local
971 ShardInterval *shardInterval = LoadShardInterval(shardId); in ReceiveAndUpdateShardsSizeAndMinMax() local
1020 UpdateShardSizeAndMinMax(uint64 shardId, ShardInterval *shardInterval, Oid relationId, in UpdateShardSizeAndMinMax()
H A Dshard_cleaner.c252 ShardInterval *shardInterval = LoadShardInterval(shardPlacement->shardId); in TryDropShard() local
H A Ddelete_protocol.c459 ShardInterval *shardInterval = NULL; in DropTaskList() local
693 ShardInterval *shardInterval = NULL; in ShardsMatchingDeleteCriteria() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/
H A Dreference_table_utils.c129 ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); in EnsureReferenceTablesExistOnAllNodesExtended() local
338 ReplicateShardToNode(ShardInterval *shardInterval, char *nodeName, int nodePort) in ReplicateShardToNode()
546 ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); in ReplicateAllReferenceTablesToNode() local
557 ShardInterval *shardInterval = NULL; in ReplicateAllReferenceTablesToNode() local
H A Dresource_lock.c256 ShardInterval *shardInterval = NULL; in LockShardListResourcesOnFirstWorker() local
345 ShardInterval *shardInterval = NULL; in LockShardListMetadataOnWorkers() local
445 ShardInterval *shardInterval = LoadShardInterval(shardId); in SetLocktagForShardDistributionMetadata() local
516 ShardInterval *shardInterval = NULL; in LockReferencedReferenceShardDistributionMetadata() local
670 ShardInterval *shardInterval = NULL; in LockShardListMetadata() local
752 ShardInterval *shardInterval = NULL; in LockShardListResources() local
793 ShardInterval *shardInterval = LoadShardInterval(shardId); in LockParentShardResourceIfPartition() local
H A Dshard_utils.c59 ShardInterval *shardInterval = LoadShardIntervalWithLongestShardName(citusTableOid); in GetLongestShardName() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/
H A Dfunction_call_delegation.c394 ShardInterval *shardInterval = FindShardInterval(partitionValueDatum, cacheEntry); in ShardPlacementForFunctionColocatedWithDistTable() local
424 const ShardInterval *shardInterval = cacheEntry->sortedShardIntervalArray[0]; in ShardPlacementForFunctionColocatedWithReferenceTable() local
H A Dmulti_router_planner.c311 ShardIntervalOpExpressions(ShardInterval *shardInterval, Index rteIndex) in ShardIntervalOpExpressions()
857 ShardInterval *shardInterval = linitial(shardIntervalList); in IsLocallyAccessibleCitusLocalTable() local
2544 ShardInterval *shardInterval = (ShardInterval *) lfirst(shardIntervalCell); in RelationShardListForShardIntervalList() local
2584 ShardInterval *shardInterval = linitial(prunedShardIntervalList); in GetAnchorShardId() local
2652 ShardInterval *shardInterval = CopyShardInterval(cachedShardInterval); in TargetShardIntervalForFastPathQuery() local
2858 ShardInterval *shardInterval = (ShardInterval *) linitial(shardIntervalList); in PlacementsForWorkersContainingAllShards() local
2931 ShardInterval *shardInterval = linitial(shardIntervalList); in BuildRoutesForInsert() local
3025 ShardInterval *shardInterval = FindShardInterval(partitionValue, cacheEntry); in BuildRoutesForInsert() local
/dports/biology/gatk/gatk-4.2.0.0/src/test/java/org/broadinstitute/hellbender/tools/walkers/haplotypecaller/
H A DHaplotypeCallerEngineUnitTest.java34 final SimpleInterval shardInterval = new SimpleInterval("20", 10000000, 10001000); in testIsActive() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/test/
H A Ddistribution_metadata.c73 ShardInterval *shardInterval = NULL; in load_shard_id_array() local
100 ShardInterval *shardInterval = LoadShardInterval(shardId); in load_shard_interval_array() local
H A Dcolocation_utils.c116 ShardInterval *shardInterval = LoadShardInterval(shardId); in find_shard_interval_index() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/commands/
H A Dindex.c406 ShardInterval *shardInterval = LoadShardIntervalWithLongestShardName( in GenerateLongestShardPartitionIndexName() local
853 ShardInterval *shardInterval = NULL; in CreateIndexTaskList() local
897 ShardInterval *shardInterval = NULL; in CreateReindexTaskList() local
1184 ShardInterval *shardInterval = NULL; in DropIndexTaskList() local
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/
H A Ddistributed_execution_locks.c348 ShardInterval *shardInterval = LoadShardInterval(shardId); in AcquireExecutorShardLockForRowModify() local
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/cloudflare/cfssl/cfssl-2001f384ec4f/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/google/certificate-transparency-go/client/
H A Dmultilog.go200 func shardInterval(cfg *configpb.LogShardConfig) (interval, error) { func
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/metadata/
H A Dmetadata_utility.c731 ShardInterval *shardInterval = CopyShardInterval(cachedShardInterval); in ShardIntervalsOnWorkerGroup() local
761 ShardInterval *shardInterval = NULL; in GenerateSizeQueryOnMultiplePlacements() local
941 ShardInterval *shardInterval = NULL; in GenerateShardStatisticsQueryForShardList() local
975 ShardInterval *shardInterval, char *shardName, in AppendShardSizeMinMaxQuery()
1009 AppendShardSizeQuery(StringInfo selectQuery, ShardInterval *shardInterval, in AppendShardSizeQuery()
1101 ShardInterval *shardInterval = NULL; in TableShardReplicationFactor() local
2009 ShardInterval *shardInterval = LoadShardInterval(shardPlacement->shardId); in MarkShardPlacementInactive() local

12