This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch cluster-
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 50fb186 [cluster-refactor] fix UT cases in: DataGroupMemberTest,
MetaGroupMem… (#4181)
add cbd1317 [IOTDB-1607] Optimize Tracing (#4018)
add 5935515 [IOTDB-1836] Fix Query Exception Bug after deleting all sgs
(#4159)
add 2f21431 overload SessionPool.executeQueryStatement and make it
support querying with timeout (#4150)
add 14bf48c [ISSUE-4072] Parallel insert records in Session (#4073)
add ffab5bd [IOTDB-1845] Make the test results in IoTDBTriggerExecutionIT
& IoTDBContinuousQueryIT deterministic (#4161)
add 8c97f2b [IOTDB-1848] Failed to initialize pool: Does not support
setReadOnly (#4162)
add 871d90e Revert "Bump testcontainers from 1.15.2 to 1.16.0 (#4136)"
(#4168)
add 30a8626 [IOTDB-1837] Fix tagIndex rebuild failure after upgrade mlog
from mlog.txt to mlog.bin (#4160)
add ea15331 [IOTDB-1342] modify error message about LIMIT and OFFSET used
in conjunction with the FILL clause (#4149)
add c85989c [IOTDB-1810] Compatibility of Apache IoTDB with InfluxDB -
Compatibility Scheme (#4090)
add 0c39ef6 [IOTDB-1853] Fix bug about more than one TimeseriesMetadata
in TsFile (#4170)
add 803b88d [IOTDB-1846]Fix the error when count the total number of
devices in cluster mode (#4171)
add 65c840b Bump commons-io from 2.5 to 2.11.0 (#4164)
add 7f29869 [IOTDB-1823] Support group by multi level (#4132)
add e4b7f64 [IOTDB-1857] Remove useless handle logic for CountPlan in
executeNonQuery in cluster module
add 0d399ce Merge branch 'master' into cluster-
No new revisions were added by this update.
Summary of changes:
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 12 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 67 +++++
.../iotdb/cluster/query/ClusterPlanExecutor.java | 139 ++++++++++
.../iotdb/cluster/query/ClusterPlanRouter.java | 50 ----
.../cluster/partition/SlotPartitionTableTest.java | 37 ---
.../DML-Data-Manipulation-Language.md | 6 +-
.../System-Tools/Performance-Tracing-Tool.md | 56 ++--
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 216 ++++++++++++++-
docs/zh/UserGuide/Appendix/Config-Manual.md | 18 --
.../DML-Data-Manipulation-Language.md | 6 +-
.../System-Tools/Performance-Tracing-Tool.md | 58 ++---
.../main/java/org/apache/iotdb/JDBCExample.java | 6 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 2 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 22 ++
.../main/java/org/apache/iotdb/jdbc/Constant.java | 12 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 6 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 25 ++
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 11 +
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 6 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 4 +
.../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 103 ++++++++
pom.xml | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 -
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 -
.../org/apache/iotdb/db/engine/StorageEngine.java | 2 +-
.../engine/storagegroup/StorageGroupProcessor.java | 1 -
.../virtualSg/VirtualStorageGroupManager.java | 2 +-
.../iotdb/db/metadata/logfile/MLogUpgrader.java | 290 +++++++++++++++++++++
.../iotdb/db/metadata/logfile/MLogWriter.java | 200 +-------------
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 18 +-
.../qp/logical/crud/AggregationQueryOperator.java | 3 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 35 ++-
.../db/qp/logical/crud/SpecialClauseComponent.java | 21 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 81 +++---
.../iotdb/db/qp/physical/crud/QueryPlan.java | 17 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 50 +++-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 18 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 150 +++++++++++
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 1 -
.../iotdb/db/query/context/QueryContext.java | 9 +
.../db/query/control/QueryResourceManager.java | 34 +--
.../apache/iotdb/db/query/control/TracingInfo.java | 85 ------
.../iotdb/db/query/control/TracingManager.java | 222 ----------------
.../db/query/control/tracing/TracingConstant.java | 17 +-
.../db/query/control/tracing/TracingInfo.java | 156 +++++++++++
.../db/query/control/tracing/TracingManager.java | 82 ++++++
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../dataset/groupby/GroupByEngineDataSet.java | 6 +
...ByTimeDataSet.java => GroupByLevelDataSet.java} | 59 ++---
.../groupby/GroupByWithValueFilterDataSet.java | 26 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 25 +-
.../db/query/executor/AggregationExecutor.java | 33 +--
.../iotdb/db/query/executor/QueryRouter.java | 21 +-
.../db/query/executor/RawDataQueryExecutor.java | 1 +
.../query/expression/unary/FunctionExpression.java | 7 +
.../iotdb/db/query/reader/series/SeriesReader.java | 24 +-
.../reader/universal/PriorityMergeReader.java | 13 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 12 -
.../org/apache/iotdb/db/service/TSServiceImpl.java | 82 ++++--
.../org/apache/iotdb/db/utils/AggregateUtils.java | 169 ------------
.../db/integration/IoTDBContinuousQueryIT.java | 20 +-
.../db/integration/IoTDBRemovePartitionIT.java | 4 +-
.../iotdb/db/integration/IoTDBTracingIT.java | 61 +++--
.../db/integration/IoTDBTriggerExecutionIT.java | 53 ++--
.../aggregation/IoTDBAggregationByLevelIT.java | 218 ++++++++++++++--
.../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 104 ++++++++
.../iotdb/db/query/control/TracingManagerTest.java | 112 --------
.../apache/iotdb/db/utils/EnvironmentUtils.java | 7 +-
.../main/java/org/apache/iotdb/session/Config.java | 4 +
.../org/apache/iotdb/session/InsertConsumer.java | 16 +-
.../java/org/apache/iotdb/session/Session.java | 237 +++++++++--------
.../apache/iotdb/session/SessionConnection.java | 1 +
.../org/apache/iotdb/session/pool/SessionPool.java | 37 ++-
.../iotdb/session/{ => util}/SessionUtils.java | 2 +-
.../org/apache/iotdb/session/util/ThreadUtils.java | 35 +--
.../apache/iotdb/session/pool/SessionPoolTest.java | 27 +-
.../apache/iotdb/session/util/ThreadUtilsTest.java | 17 +-
site/src/main/.vuepress/config.js | 2 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 9 +
thrift/rpc-changelist.md | 22 ++
thrift/src/main/thrift/rpc.thrift | 15 ++
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 142 ++++++++--
84 files changed, 2473 insertions(+), 1539 deletions(-)
create mode 100644
jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBTracingInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogUpgrader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/utils/GroupByLevelController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/TracingInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/TracingManager.java
copy cluster/src/main/java/org/apache/iotdb/cluster/ClusterIoTDBMBean.java =>
server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingConstant.java
(61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingManager.java
rename
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/{GroupByTimeDataSet.java
=> GroupByLevelDataSet.java} (59%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/AggregateUtils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/mlog/MLogUpgraderTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java
copy
server/src/main/java/org/apache/iotdb/db/utils/windowing/api/Evaluator.java =>
session/src/main/java/org/apache/iotdb/session/InsertConsumer.java (69%)
rename session/src/main/java/org/apache/iotdb/session/{ =>
util}/SessionUtils.java (99%)
copy server/src/main/java/org/apache/iotdb/db/exception/ShutdownException.java
=> session/src/main/java/org/apache/iotdb/session/util/ThreadUtils.java (50%)
copy tsfile/src/test/java/org/apache/iotdb/tsfile/read/common/FieldTest.java
=> session/src/test/java/org/apache/iotdb/session/util/ThreadUtilsTest.java
(68%)
