wyw/EdgeManager
1
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

perf(distributed_stable):副本数3，v_bool也作为dimension

Browse Source
This commit is contained in:
Yu Sun
2022-10-08 14:43:30 +08:00
parent c45cfba0be
commit a481e56dbc
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
EdgeManager/EDataCapture/ENodeConfigure.php
View File

@@ -67,10 +67,11 @@ class ENodeConfigure {
if ($node_count === 0) { if ($node_count === 0) {
$res[] = pg_query($this -> dbconn, sprintf("SELECT create_hypertable('\"%s\"', 'capture_time')", $table_name)); $res[] = pg_query($this -> dbconn, sprintf("SELECT create_hypertable('\"%s\"', 'capture_time')", $table_name));
} else { } else {
$res[] = pg_query($this -> dbconn, sprintf("SELECT create_distributed_hypertable('\"%s\"', 'capture_time', 'code')", $table_name)); $res[] = pg_query($this -> dbconn, sprintf("SELECT create_distributed_hypertable('\"%s\"', 'capture_time', 'code', replication_factor => 3)", $table_name));
$res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'device_code', number_partitions => %s)", $table_name, $node_count)); $res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'device_code', number_partitions => %s)", $table_name, $node_count));
$res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'parent_device_code', number_partitions => %s)", $table_name, $node_count)); $res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'parent_device_code', number_partitions => %s)", $table_name, $node_count));
$res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'batch', number_partitions => %s)", $table_name, $node_count)); $res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'batch', number_partitions => %s)", $table_name, $node_count));
$res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'v_bool', number_partitions => 2)", $table_name));
} }
$res[] = pg_query($this -> dbconn, sprintf( $res[] = pg_query($this -> dbconn, sprintf(