diff --git a/EdgeManager/EDataCapture/ENodeConfigure.php b/EdgeManager/EDataCapture/ENodeConfigure.php index e2c6257..be6e2da 100644 --- a/EdgeManager/EDataCapture/ENodeConfigure.php +++ b/EdgeManager/EDataCapture/ENodeConfigure.php @@ -68,9 +68,9 @@ class ENodeConfigure { $res[] = pg_query($this -> dbconn, sprintf("SELECT create_hypertable('\"%s\"', 'capture_time')", $table_name)); } else { $res[] = pg_query($this -> dbconn, sprintf("SELECT create_distributed_hypertable('\"%s\"', 'capture_time', 'code')", $table_name)); - $res[] = pg_query($this -> dbconn, sprintf("add_dimension('\"%s\"', 'device_code', number_partitions => %s)", $node_count)); - $res[] = pg_query($this -> dbconn, sprintf("add_dimension('\"%s\"', 'parent_device_code', number_partitions => %s)", $node_count)); - $res[] = pg_query($this -> dbconn, sprintf("add_dimension('\"%s\"', 'batch', number_partitions => %s)", $node_count)); + $res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'device_code', number_partitions => %s)", $node_count)); + $res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'parent_device_code', number_partitions => %s)", $node_count)); + $res[] = pg_query($this -> dbconn, sprintf("SELECT add_dimension('\"%s\"', 'batch', number_partitions => %s)", $node_count)); } $res[] = pg_query($this -> dbconn, sprintf(