This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster_scalability
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from fbda1e9 fix sonar issues
add 517e496 [ISSUE-3116] Bug when using natural month unit in time
interval in group by query (#3139)
add 0b964a1 Implement some JDBC methods to support DataGrip (#3181)
add 8992927 Fix import csv throw ArrayOutOfIndexError when the last value
in a line is null (#3185)
add ebf1a73 update force full merge config (#3194)
add 49f8919 Update some out-of-date contents in README and
ContributeGuide (#3196)
add 5fe8c84 [IOTDB-1259] upgrade libthrift from 0.12.0/0.13.0 to 0.14.1
and updated related classes or files (#3163)
add c63bf83 [ISSUE-3176] Support running IoTDB CI on JDK16 (#3177)
add 31f077e [IOTDB-1380] Automatically close the dataset while there is
no more data (#3193)
add 6844ac7 [IOTDB-1321] Filter RowRecord automatically if any column in
it is null or all columns are null (#3153)
add c0ee6cb Fix an invalid link in the Zepplin-IoTDB UserGuide (#3210)
add 725cc68 fix index out of bound when VectorTimeSeriesMetadata is not
find in memory (#3208)
add a41c855 Fix the CI issue introduced by thrift0.14 and the thrift
server is not closed properly in SessionPoolTest. (#3198)
add 222396c add rabbitmq example module. (#3049)
add 38ac322 Fix JDK version missspelling (#3224)
add 53ac9d9 Fix some bugs reported by sonar (#3158)
add 2cfa4d8 Modify the document to ensure that the official website can
be successfully built (#3229)
add 088ac59 Fix session UT (#3227)
add 2147526 update cluster docs (#3238)
add 48328e3 [ISSUE-3232] fix the bug of Memory Information in Windows
host (#3231)
add 076a8ac update cluster docs (#3239)
add c581085 Try to fix website build failed (#3243)
add f7c61aa Pseudo distributed no logs error (#3247)
add bcce61b [IOTDB-1385] Extract the super user and password to the
config (#3244)
add fee62c1 [IOTDB-1387] Fix Without Null ALL doesn't take effect in
align by device clause (#3245)
add 44fdc04 [IOTDB-1384] Fix group by bug (#3251)
add b303d33 Support JDBC placeholder when set sensor or device by set
string (#3249)
add 7c3d432 fix_unseq_compaction_loss_data_bug (#3256)
add 98ba544 Modify the getAggrResult method, don't destroy polymorphism
too early (#3209)
add 95a7405 Try to fix cluster CI failed (#3257)
add 951bf72 support “all” keyword when execute fill query (#3240)
add dae1f15 [IOTDB-1022] ANTLR Grammar & Logical Operator for Arithmetic
Operations and Nested Operations in SELECT Clauses (#3236)
add aca9faa Enable sonar-coveralls for pr from fork repos (#3263)
add bd1d1a6 Revert "Enable sonar-coveralls for pr from fork repos
(#3263)" (#3266)
add 89d0d37 add slack invite link (#3265)
add 5d44f0f merge master
add 57e0875 fix some issues according to pr comments
No new revisions were added by this update.
Summary of changes:
.github/workflows/client.yml | 7 +-
.github/workflows/main-unix.yml | 2 +-
.github/workflows/main-win.yml | 2 +-
.../ContributeGuide.md => CONTRIBUTING.md | 63 +--
LICENSE-binary | 2 +-
README.md | 28 +-
README_ZH.md | 20 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 150 ++-----
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 3 +
client-cpp/src/main/CMakeLists.txt | 2 +-
client-cpp/src/test/CMakeLists.txt | 2 +-
cluster/pom.xml | 2 +-
.../cluster/client/async/AsyncDataClient.java | 4 +-
.../client/async/AsyncDataHeartbeatClient.java | 4 +-
.../cluster/client/async/AsyncMetaClient.java | 4 +-
.../client/async/AsyncMetaHeartbeatClient.java | 4 +-
.../cluster/client/sync/SyncClientAdaptor.java | 10 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 2 +
.../client/sync/SyncDataHeartbeatClient.java | 2 +
.../iotdb/cluster/client/sync/SyncMetaClient.java | 2 +
.../client/sync/SyncMetaHeartbeatClient.java | 2 +
.../iotdb/cluster/coordinator/Coordinator.java | 9 +-
.../cluster/log/snapshot/PullSnapshotTask.java | 11 +-
.../iotdb/cluster/partition/PartitionTable.java | 9 -
.../cluster/partition/slot/SlotPartitionTable.java | 11 +-
.../cluster/query/ClusterPhysicalGenerator.java | 8 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 43 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 58 +--
.../cluster/query/aggregate/ClusterAggregator.java | 10 +-
.../query/groupby/RemoteGroupByExecutor.java | 10 +-
.../cluster/query/reader/ClusterReaderFactory.java | 4 +-
.../server/heartbeat/MetaHeartbeatThread.java | 10 +-
.../cluster/server/member/DataGroupMember.java | 3 +-
.../cluster/server/member/MetaGroupMember.java | 4 +-
.../cluster/client/sync/SyncDataClientTest.java | 6 +-
.../cluster/client/sync/SyncMetaClientTest.java | 6 +-
.../cluster/common/TestAsyncClientFactory.java | 4 +-
.../cluster/common/TestSyncClientFactory.java | 13 +
.../apache/iotdb/cluster/log/LogParserTest.java | 15 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 14 +
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 14 +
.../cluster/partition/SlotPartitionTableTest.java | 16 +-
.../query/ClusterPhysicalGeneratorTest.java | 10 +-
.../server/clusterinfo/ClusterInfoServerTest.java | 33 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 10 -
.../iotdb/cluster/server/member/BaseMember.java | 3 +-
.../cluster/server/member/DataGroupMemberTest.java | 17 +-
.../cluster/server/member/MetaGroupMemberTest.java | 22 +-
.../cluster/server/member/RaftMemberTest.java | 5 +-
cluster/src/test/resources/logback.xml | 4 -
.../src/test/resources/node1conf}/logback.xml | 48 +--
.../src/test/resources/node2conf}/logback.xml | 48 +--
.../src/test/resources/node3conf}/logback.xml | 48 +--
compile-tools/thrift/pom.xml | 2 +-
docs/Development/ContributeGuide.md | 62 +--
docs/UserGuide/Advanced-Features/Triggers.md | 6 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 37 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 2 -
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DML-Data-Manipulation-Language.md | 14 +
docs/zh/Development/ContributeGuide.md | 26 +-
docs/zh/UserGuide/Advanced-Features/Triggers.md | 7 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 37 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 2 -
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DML-Data-Manipulation-Language.md | 14 +
example/pom.xml | 6 +
example/{pulsar => rabbitmq}/pom.xml | 20 +-
example/rabbitmq/readme.md | 63 +++
.../java/org/apache/iotdb/rabbitmq}/Constant.java | 27 +-
.../iotdb/rabbitmq/RabbitMQChannelUtils.java | 50 +++
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 132 ++++++
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 49 +++
example/trigger/pom.xml | 66 +--
example/udf/pom.xml | 66 +--
jdbc/src/main/feature/feature.xml | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 9 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 9 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 24 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 42 +-
pom.xml | 25 +-
.../resources/conf/iotdb-engine.properties | 10 +-
server/src/assembly/resources/conf/iotdb-env.bat | 12 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +-
.../db/auth/authorizer/LocalFileAuthorizer.java | 3 +-
.../iotdb/db/auth/user/BasicUserManager.java | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 30 +-
.../db/engine/compaction/TsFileManagement.java | 4 +-
.../level/LevelCompactionTsFileManagement.java | 6 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 8 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 13 +-
.../engine/storagegroup/StorageGroupProcessor.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../org/apache/iotdb/db/metadata/MManager.java | 3 -
.../org/apache/iotdb/db/metadata/PartialPath.java | 14 -
.../iotdb/db/metrics/server/ServerArgument.java | 12 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 186 ++------
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +
.../org/apache/iotdb/db/qp/logical/Operator.java | 1 -
.../db/qp/logical/crud/DeleteDataOperator.java | 17 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 15 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 66 ++-
.../iotdb/db/qp/logical/crud/SFWOperator.java | 98 -----
.../iotdb/db/qp/logical/crud/SelectOperator.java | 118 ++---
.../db/qp/logical/sys/CreateIndexOperator.java | 17 +-
.../iotdb/db/qp/logical/sys/DropIndexOperator.java | 18 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 6 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 6 +
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 30 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 46 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 67 +++
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 4 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 83 +++-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 475 +++++++++------------
.../iotdb/db/qp/strategy/LogicalChecker.java | 108 +++++
.../iotdb/db/qp/strategy/LogicalGenerator.java | 63 ++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 200 +++------
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 406 ++++--------------
.../qp/strategy/optimizer/ILogicalOptimizer.java | 2 +-
.../qp/strategy/optimizer/RemoveNotOptimizer.java | 7 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 33 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 160 +++++++
.../db/query/dataset/AlignByDeviceDataSet.java | 3 +
.../dataset/RawQueryDataSetWithoutValueFilter.java | 79 +++-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 2 +-
.../dataset/groupby/LocalGroupByExecutor.java | 3 +
.../iotdb/db/query/executor/LastQueryExecutor.java | 12 +-
.../iotdb/db/query/expression/Expression.java | 31 +-
.../iotdb/db/query/expression/ResultColumn.java | 139 ++++++
.../expression/binary/AdditionExpression.java | 18 +-
.../query/expression/binary/BinaryExpression.java | 118 +++++
.../expression/binary/DivisionExpression.java | 18 +-
.../query/expression/binary/ModuloExpression.java | 18 +-
.../binary/MultiplicationExpression.java | 18 +-
.../expression/binary/SubtractionExpression.java | 18 +-
.../query/expression/unary/FunctionExpression.java | 232 ++++++++++
.../db/query/expression/unary/MinusExpression.java | 78 ++++
.../query/expression/unary/TimeSeriesOperand.java | 82 ++++
.../db/query/udf/core/context/UDFContext.java | 142 ------
.../db/query/udf/core/executor/UDTFExecutor.java | 17 +-
.../query/udf/service/UDFRegistrationService.java | 6 +-
.../apache/iotdb/db/service/MetricsService.java | 3 +
.../org/apache/iotdb/db/service/StartupChecks.java | 2 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 46 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 5 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 27 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 20 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 4 +-
.../db/auth/user/LocalFileUserManagerTest.java | 4 +-
.../iotdb/db/engine/merge/MergeTaskTest.java | 7 +-
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 29 ++
.../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 136 ++++++
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 10 +-
.../db/integration/IoTDBUDTFHybridQueryIT.java | 3 +-
.../db/integration/IoTDBWithoutAllNullIT.java | 264 ++++++++++++
.../db/integration/IoTDBWithoutAnyNullIT.java | 221 ++++++++++
.../iotdb/db/metadata/MManagerBasicTest.java | 1 +
.../org/apache/iotdb/db/metadata/MTreeTest.java | 1 +
.../iotdb/db/qp/logical/IndexLogicalPlanTest.java | 48 +--
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 88 ++--
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 28 ++
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 18 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 12 +-
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 13 +
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 15 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 20 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 3 +-
.../rpc/TCompressedElasticFramedTransport.java | 2 +-
...OpenTransport.java => TConfigurationConst.java} | 28 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 20 +-
.../iotdb/rpc/TNonblockingSocketWrapper.java | 60 +++
.../java/org/apache/iotdb/rpc/TSocketWrapper.java | 68 +++
.../apache/iotdb/session/SessionConnection.java | 13 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 81 ++++
.../java/org/apache/iotdb/session/SessionUT.java | 2 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 117 +++--
.../src/test/resources/logback.xml | 3 +-
site/src/main/.vuepress/config.js | 4 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 78 +++-
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 3 +
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 3 +
.../apache/iotdb/tsfile/read/common/RowRecord.java | 43 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 33 +-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 1 +
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 27 +-
189 files changed, 4483 insertions(+), 2211 deletions(-)
copy docs/Development/ContributeGuide.md => CONTRIBUTING.md (74%)
copy {server/src/assembly/resources/conf =>
cluster/src/test/resources/node1conf}/logback.xml (84%)
copy {server/src/assembly/resources/conf =>
cluster/src/test/resources/node2conf}/logback.xml (84%)
copy {server/src/assembly/resources/conf =>
cluster/src/test/resources/node3conf}/logback.xml (84%)
copy example/{pulsar => rabbitmq}/pom.xml (81%)
create mode 100644 example/rabbitmq/readme.md
copy example/{rocketmq/src/main/java/org/apache/iotdb/rocketmq =>
rabbitmq/src/main/java/org/apache/iotdb/rabbitmq}/Constant.java (75%)
create mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQChannelUtils.java
create mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQConsumer.java
create mode 100644
example/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/RabbitMQProducer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SFWOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalChecker.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/utils/WildcardsRemover.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterConcatPathOptimizer.java
=> server/src/main/java/org/apache/iotdb/db/query/expression/Expression.java
(54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/expression/ResultColumn.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
server/src/main/java/org/apache/iotdb/db/query/expression/binary/AdditionExpression.java
(70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/expression/binary/BinaryExpression.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
server/src/main/java/org/apache/iotdb/db/query/expression/binary/DivisionExpression.java
(70%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
server/src/main/java/org/apache/iotdb/db/query/expression/binary/ModuloExpression.java
(70%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
server/src/main/java/org/apache/iotdb/db/query/expression/binary/MultiplicationExpression.java
(70%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
server/src/main/java/org/apache/iotdb/db/query/expression/binary/SubtractionExpression.java
(70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/expression/unary/FunctionExpression.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/expression/unary/MinusExpression.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/expression/unary/TimeSeriesOperand.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/context/UDFContext.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBWithoutAllNullIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBWithoutAnyNullIT.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{NonOpenTransport.java =>
TConfigurationConst.java} (68%)
create mode 100644
service-rpc/src/main/java/org/apache/iotdb/rpc/TNonblockingSocketWrapper.java
create mode 100644
service-rpc/src/main/java/org/apache/iotdb/rpc/TSocketWrapper.java
copy {hive-connector => session}/src/test/resources/logback.xml (94%)
