external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add guc variable for shard count

pull/867/head
Metin Doslu 2016-10-05 17:11:55 +03:00
parent 98e0648d40
commit d04f4f5935
3 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/backend/distributed/master/master_node_protocol.c
View File

@ -55,6 +55,7 @@
/* Shard related configuration */ /* Shard related configuration */
int ShardCount = 32;
int ShardReplicationFactor = 2; /* desired replication factor for shards */ int ShardReplicationFactor = 2; /* desired replication factor for shards */
int ShardMaxSize = 1048576; /* maximum size in KB one shard can grow to */ int ShardMaxSize = 1048576; /* maximum size in KB one shard can grow to */
int ShardPlacementPolicy = SHARD_PLACEMENT_ROUND_ROBIN; int ShardPlacementPolicy = SHARD_PLACEMENT_ROUND_ROBIN;

11
src/backend/distributed/shared_library_init.c
View File

@ -332,6 +332,17 @@ RegisterCitusConfigVariables(void)
0, 0,
NULL, NULL, NULL); NULL, NULL, NULL);
DefineCustomIntVariable(
"citus.shard_count",
gettext_noop("Sets the number of shards for a new hash-partitioned table"
"created with create_distributed_table()."),
NULL,
&ShardCount,
32, 1, 64000,
PGC_USERSET,
0,
NULL, NULL, NULL);
DefineCustomIntVariable( DefineCustomIntVariable(
"citus.shard_replication_factor", "citus.shard_replication_factor",
gettext_noop("Sets the replication factor for shards."), gettext_noop("Sets the replication factor for shards."),

1
src/include/distributed/master_protocol.h
View File

@ -82,6 +82,7 @@ typedef enum
/* Config variables managed via guc.c */ /* Config variables managed via guc.c */
extern int ShardCount;
extern int ShardReplicationFactor; extern int ShardReplicationFactor;
extern int ShardMaxSize; extern int ShardMaxSize;
extern int ShardPlacementPolicy; extern int ShardPlacementPolicy;