You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ej...@apache.org on 2021/05/30 09:13:48 UTC
[iotdb] branch hitter_compaction_mto_master updated (cd3d8c1 ->
770b402)
This is an automated email from the ASF dual-hosted git repository.
ejttianyu pushed a change to branch hitter_compaction_mto_master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from cd3d8c1 finish hitter merge
add faed0d8 Fix group by month StackOverflow bug (#3070)
add ae77977 fix some spell mistake for iotdb-engine conf (#3077)
add 308e39d JDBC bug - check authority for execute batch (#3059)
add 0452bc3 Improve openid user manual (#3062)
add f4ed918 Fix AuthorizationIT failed caused by #3069 (#3085)
add 5c026bc Fix query multiple subSensors for multiple device timeout bug in cluster (#3087)
add a6401e4 [IOTDB-1319] Trigger module: alert manager sink (#3057)
add ce6945f [IOTDB-1339] optimize TimeoutChangeableTSnappyFramedTransport (#3086)
add 6aa58c1 Print too many useless logs when snapshot occurred loading one tsfile (#3095)
add b98b453 line separator (#3097)
add 13f846a fix some config inconsistent (#3082)
add 9ba36a3 [IOTDB-1306] New memory control strategy (#3060)
add 8cb33d7 Only print last query details while debuging (#3094)
add 8c5bef7 Fixed openid bug (#3073)
add 06ba8b3 Fix for issue # 1804 (Opened by me) (#2278)
add 3f55841 [IOTDB-1344] Deleting Storage Group does not clear the count of time series (#3104)
add 17a2872 [IOTDB-1330]fix the load tsfile bug when the cross multi partition's tsfile only have one page (#3080)
add 05bdd1c Add TsFileSequenceReader getChunkMetadataList method return empty if path not exists (#3109)
add 077bb3c [IOTDB-1212] The given error message is not right when executing `select sin(non_existence) from root.sg1.d1` (#3101)
add c17cfa2 [IOTDB-1345] AlertManagerTest: Bind Address already in use (#3110)
add 4cabbfa [GITHUB-3121] add maven http parameter to avoid maven downloading dependencies timeout in github actions (#3122)
add e43aea6 Fix reduce frequent log printing. (#3114)
add c45fa84 fix link for CSV tool
add 126ebc0 [IOTDB-1345] reuse server in AlertManagerTest (#3124)
add f34cfb3 [IOTDB-1355] Support updating aligned timeseries values when insert partially (#3128)
add 925a2b4 [ISSUE-3132] Replace Bintray repository with JFrog
add 421d35c [IOTDB-1350]Change the log packing time from one hour to one day(#3120)
add 6e88ad7 [IOTDB-1315] ExportCsvTool should support timestamp `yyyy-MM-dd'T'HH:mm:ss.SSSZ` (#3115)
add ca36589 [IOTDB-1286] fix 4 C++ mem-leak points (#2976)
add db71701 [IoTDB-1331] Add transformPath for CMManger (#3105)
add 1594797 Update LICENCE-binary (#3140)
add 8907772 [IOTDB-1348] Last plan not work in cluster mode (#3118)
add e9ada63 [IOTDB-1232][IOTDB-1313] Fix lossing time precision when import csv with unsupported timestamp format (#3142)
add 7a77b3f [IOTDB-1316] The importCsv tool should continue inserting if a part of insertion failed (#3131)
add f4db723 [ISSUE-3089] make it possible for storage groups to have name with hyphen (#3151)
add 1a6118a Fix `merge` command cannot execute compaction task bug (#3152)
add 819b195 Add continuous compaction in level compaction strategy (#2080)
add 19cfcd5 [IOTDB-1352][IOTDB-1353] Rafactor E2E test, add ClusterInfo thrift based API (#3143)
add 215199f Fix code format error
add 7151b7d fix cluster_info_public_port parameter not set in cluster/src/test/resources/ (#3156)
add d6fe7b0 [IOTDB-1366] Refactor MetadataIndex in TsFile for Vector (#3081)
add 55d9260 [IOTDB-1266]SHOW TIMESERIES will only display 2000 timeseries (#2958)
add e4a3e74 Increase the time of timeout in Jenkinsfile to fix website build failed (#3165)
add 0050262 [IOTDB-1357] Compaction use append chunk merge strategy when chunk is already large (#3159)
add 9e56152 [IOTDB-1356] Separate unseq_file_num_in_each_level from selecting candidate file in unseq compaction (#3160)
add 470ea63 [ISSUE-3166] Privilege `CREATE_TIMESERIES` is not stated in the document (#3168)
add 4852dad [IOTDB-1371] Fix NPE when creating aligned timeseries and inserting with mismatched data type (#3164)
add 0ea44c4 Update some badge in README (#3174)
add 6907e34 [IOTDB-1378] Fix MetadataIndexTree constructs error when existing more than one chunks in vector (#3180)
add f6e636b support (#3172)
add 49cd4d1 Fix align by device query locally bugs in cluster module && Fix concurrent query bugs in cluster module (#3183)
add f7e3590 [IOTDB-1376] BatchProcessException was not correctly handled in BaseApplier (#3173)
add 3bf4114 Cherry pick upgrade bugs fixes PR #3178 #3154 to master (#3182)
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 8d3819f update test and doc and fix small bug (#3281)
add 363bda9 Fix TotalSeriesNumber in MManager counted twice when recovering (#3276)
add beefb2e do not select unseq files when there are unmerged old unseq files (#3273)
add 8b1ee93 Fix typo (#3287)
add 084c3b8 [IOTDB-3268] Add the Chinese version of TSDB-Comparison document (#3274)
add 770b402 merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-go.yml | 3 +
.github/workflows/client.yml | 12 +-
.github/workflows/e2e.yml | 3 +
.github/workflows/main-unix.yml | 5 +-
.github/workflows/main-win.yml | 5 +-
.github/workflows/sonar-coveralls.yml | 3 +
.../ContributeGuide.md => CONTRIBUTING.md | 63 ++-
Code Summary.md | 59 +++
Jenkinsfile | 2 +-
LICENSE-binary | 6 +-
README.md | 33 +-
README_ZH.md | 23 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 156 ++----
cli/pom.xml | 2 +-
.../org/apache/iotdb/tool/AbstractCsvTool.java | 40 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 59 ++-
client-cpp/src/main/CMakeLists.txt | 2 +-
client-cpp/src/main/Session.cpp | 11 +-
client-cpp/src/main/Session.h | 16 +-
client-cpp/src/test/CMakeLists.txt | 2 +-
client-py/README.md | 5 +-
cluster/pom.xml | 14 +-
.../resources/conf/iotdb-cluster.properties | 9 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 13 +
.../cluster/client/async/AsyncDataClient.java | 4 +-
.../client/async/AsyncDataHeartbeatClient.java | 4 +-
.../cluster/client/async/AsyncMetaClient.java | 4 +-
.../client/async/AsyncMetaHeartbeatClient.java | 4 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 2 +
.../client/sync/SyncDataHeartbeatClient.java | 2 +
.../iotdb/cluster/client/sync/SyncMetaClient.java | 2 +
.../client/sync/SyncMetaHeartbeatClient.java | 2 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 17 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 9 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 37 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 47 +-
.../cluster/query/ClusterDataQueryExecutor.java | 5 +-
.../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/last/ClusterLastQueryExecutor.java | 1 +
.../cluster/query/reader/ClusterReaderFactory.java | 12 +-
.../query/reader/mult/RemoteMultSeriesReader.java | 7 +-
.../iotdb/cluster/server/MetaClusterServer.java | 27 +-
.../server/clusterinfo/ClusterInfoServer.java | 65 +--
.../server/clusterinfo/ClusterInfoServerMBean.java | 6 +-
.../server/clusterinfo/ClusterInfoServiceImpl.java | 71 +++
.../ClusterInfoServiceThriftHandler.java | 9 +-
.../cluster/server/member/MetaGroupMember.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 2 +
.../utils/nodetool/ClusterMonitorMBean.java | 2 +-
.../cluster/client/sync/SyncDataClientTest.java | 6 +-
.../cluster/client/sync/SyncMetaClientTest.java | 6 +-
.../cluster/common/TestAsyncClientFactory.java | 4 +-
.../cluster/common/TestSyncClientFactory.java | 13 +
.../cluster/log/applier/DataLogApplierTest.java | 35 ++
.../cluster/log/snapshot/DataSnapshotTest.java | 14 +
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 14 +
.../query/ClusterPhysicalGeneratorTest.java | 10 +-
.../query/groupby/MergeGroupByExecutorTest.java | 23 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 23 +-
.../server/clusterinfo/ClusterInfoServerTest.java | 96 ++++
.../clusterinfo/ClusterInfoServiceImplTest.java | 98 ++++
.../cluster/server/member/DataGroupMemberTest.java | 28 +-
.../cluster/server/member/MetaGroupMemberTest.java | 20 +-
cluster/src/test/resources/logback.xml | 4 -
.../resources/node1conf/iotdb-cluster.properties | 1 +
.../src/test/resources/node1conf}/logback.xml | 48 +-
.../resources/node2conf/iotdb-cluster.properties | 1 +
.../src/test/resources/node2conf}/logback.xml | 48 +-
.../resources/node3conf/iotdb-cluster.properties | 1 +
.../src/test/resources/node3conf}/logback.xml | 48 +-
compile-tools/pom.xml | 8 +-
compile-tools/thrift/pom.xml | 2 +-
docs/Development/ContributeGuide.md | 62 ++-
docs/UserGuide/API/Programming-Java-Native-API.md | 98 ++++
.../Administration-Management/Administration.md | 7 +-
docs/UserGuide/Advanced-Features/Alerting.md | 385 ++++++++++++++
docs/UserGuide/Advanced-Features/Triggers.md | 112 ++++
docs/UserGuide/CLI/Command-Line-Interface.md | 69 ++-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 37 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 11 +-
docs/UserGuide/Comparison/TSDB-Comparison.md | 135 ++---
.../Data-Concept/Data-Model-and-Terminology.md | 4 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 4 +-
.../DDL-Data-Definition-Language.md | 2 +-
.../DML-Data-Manipulation-Language.md | 14 +
docs/zh/Development/ContributeGuide.md | 26 +-
.../UserGuide/API/Programming-Java-Native-API.md | 95 ++++
.../Administration-Management/Administration.md | 5 +-
docs/zh/UserGuide/Advanced-Features/Alerting.md | 385 ++++++++++++++
docs/zh/UserGuide/Advanced-Features/Triggers.md | 110 ++++
docs/zh/UserGuide/CLI/Command-Line-Interface.md | 75 ++-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 37 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 11 +-
docs/zh/UserGuide/Comparison/TSDB-Comparison.md | 403 ++++++++++++++
.../Data-Concept/Data-Model-and-Terminology.md | 4 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 4 +-
.../DDL-Data-Definition-Language.md | 2 +-
.../DML-Data-Manipulation-Language.md | 14 +
example/hadoop/pom.xml | 3 +-
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 ++-
.../org/apache/iotdb/trigger/AlertingExample.java | 107 ++++
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 5 +
example/udf/pom.xml | 68 ++-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 5 +-
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 | 38 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 42 +-
pom.xml | 25 +-
server/pom.xml | 6 +
.../resources/conf/iotdb-engine.properties | 33 +-
server/src/assembly/resources/conf/iotdb-env.bat | 12 +-
server/src/assembly/resources/conf/logback.xml | 24 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +-
.../db/auth/authorizer/LocalFileAuthorizer.java | 3 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 3 +-
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 1 +
.../iotdb/db/auth/user/BasicUserManager.java | 10 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 3 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 60 ++-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 28 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 49 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 41 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 123 ++++-
.../db/engine/compaction/TsFileManagement.java | 23 +-
.../level/LevelCompactionTsFileManagement.java | 57 +-
.../engine/compaction/utils/CompactionUtils.java | 81 ++-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 20 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 11 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 4 +
.../db/engine/merge/manage/MergeResource.java | 2 +-
.../merge/selector/MaxFileMergeFileSelector.java | 9 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 8 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 14 +-
.../db/engine/storagegroup/StorageGroupInfo.java | 6 +-
.../engine/storagegroup/StorageGroupProcessor.java | 73 +--
.../db/engine/storagegroup/TsFileProcessor.java | 54 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 6 +-
.../db/engine/storagegroup/TsFileResource.java | 26 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 18 -
.../storagegroup/timeindex/FileTimeIndex.java | 5 -
.../engine/storagegroup/timeindex/ITimeIndex.java | 8 -
.../org/apache/iotdb/db/metadata/MManager.java | 98 +++-
.../org/apache/iotdb/db/metadata/PartialPath.java | 29 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 4 +
.../iotdb/db/metrics/server/ServerArgument.java | 12 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 186 ++-----
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 15 +-
.../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 +-
.../physical/BatchPlan.java} | 41 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 6 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 6 +
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 39 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 33 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 39 +-
.../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 ++-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 39 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 1 -
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 586 ++++++++++++---------
.../iotdb/db/qp/strategy/LogicalChecker.java | 108 ++++
.../iotdb/db/qp/strategy/LogicalGenerator.java | 63 ++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 208 +++-----
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 397 +++-----------
.../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/ShowDataSet.java | 12 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 2 +-
.../dataset/groupby/LocalGroupByExecutor.java | 3 +
.../iotdb/db/query/executor/LastQueryExecutor.java | 53 +-
.../iotdb/db/query/executor/QueryRouter.java | 6 +-
.../db/query/executor/fill/LastPointReader.java | 51 +-
.../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 +++
.../chunk/metadata/DiskChunkMetadataLoader.java | 2 +-
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../reader/series/SeriesRawDataBatchReader.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 13 +-
.../reader/series/SeriesReaderByTimestamp.java | 2 +-
.../query/reader/series/SeriesReaderFactory.java | 94 ----
.../db/query/reader/series/VectorSeriesReader.java | 144 -----
.../db/query/udf/core/context/UDFContext.java | 142 -----
.../db/query/udf/core/executor/UDTFExecutor.java | 17 +-
.../query/udf/service/UDFRegistrationService.java | 6 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 230 ++++----
.../apache/iotdb/db/service/MetricsService.java | 3 +
.../org/apache/iotdb/db/service/ServiceType.java | 5 +-
.../org/apache/iotdb/db/service/StartupChecks.java | 2 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 61 +--
.../alertmanager/AlertManagerConfiguration.java | 20 +-
.../db/sink/alertmanager/AlertManagerEvent.java | 123 +++++
.../db/sink/alertmanager/AlertManagerHandler.java | 83 +++
.../apache/iotdb/db/sync/conf/SyncConstant.java | 5 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 27 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 15 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 16 +
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 2 -
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 94 +++-
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 4 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 20 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../iotdb/db/utils/datastructure/TVList.java | 31 +-
.../iotdb/db/utils/datastructure/VectorTVList.java | 63 ++-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 2 -
.../auth/authorizer/LocalFileAuthorizerTest.java | 10 +-
.../db/auth/user/LocalFileUserManagerTest.java | 4 +-
.../db/engine/compaction/CompactionChunkTest.java | 4 +-
.../compaction/LevelCompactionCacheTest.java | 3 +-
.../engine/compaction/LevelCompactionLogTest.java | 3 +-
.../compaction/LevelCompactionMergeTest.java | 83 ++-
.../compaction/LevelCompactionMoreDataTest.java | 3 +-
.../NoCompactionTsFileManagementTest.java | 4 +-
.../engine/merge/MaxFileMergeFileSelectorTest.java | 73 +++
.../iotdb/db/engine/merge/MergeTaskTest.java | 86 ++-
.../apache/iotdb/db/engine/merge/MergeTest.java | 9 +-
.../engine/storagegroup/TsFileProcessorTest.java | 12 +-
.../db/integration/IOTDBInsertAlignedValuesIT.java | 78 ++-
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 99 +++-
.../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 136 +++++
...oTDBLoadExternalTsFileWithTimePartitionIT.java} | 44 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 36 ++
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 10 +-
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 16 +
.../db/integration/IoTDBUDTFHybridQueryIT.java | 3 +-
.../db/integration/IoTDBWithoutAllNullIT.java | 264 ++++++++++
.../db/integration/IoTDBWithoutAnyNullIT.java | 221 ++++++++
.../db/integration/auth/IoTDBAuthorizationIT.java | 108 +++-
.../iotdb/db/metadata/MManagerBasicTest.java | 299 +++++++++++
.../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 +-
.../org/apache/iotdb/db/script/EnvScriptIT.java | 6 +-
.../org/apache/iotdb/db/sink/AlertManagerTest.java | 328 ++++++++++++
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 3 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 12 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 57 ++
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 13 +
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 15 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 20 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 13 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 4 +-
.../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 +++
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 20 +-
.../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 | 10 +-
spark-tsfile/pom.xml | 2 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 223 ++++++++
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 116 ++--
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 50 +-
.../iotdb/db/sql/node1/OneNodeClusterIT.java | 54 ++
.../AbstractThreeNodeClusterIT.java} | 63 +--
.../iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java | 10 +-
.../iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java | 16 +-
.../AbstractFiveNodeClusterIT.java} | 89 ++--
.../iotdb/db/sql/nodes5/FiveNodeCluster1IT.java | 10 +-
.../iotdb/db/sql/nodes5/FiveNodeCluster2IT.java | 15 +-
.../iotdb/db/sql/nodes5/FiveNodeCluster4IT.java | 15 +-
.../test/resources/1node/iotdb-cluster.properties | 2 +-
thrift-cluster/src/main/thrift/cluster.thrift | 52 +-
thrift-sync/pom.xml | 5 -
.../tsfile/common/constant/TsFileConstant.java | 3 +
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 16 +
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 6 +
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 3 +
.../file/metadata/MetadataIndexConstructor.java | 54 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 2 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 20 +-
.../tsfile/file/metadata/VectorChunkMetadata.java | 24 +
.../file/metadata/VectorTimeSeriesMetadata.java | 16 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 97 +++-
.../apache/iotdb/tsfile/read/common/RowRecord.java | 43 +-
.../tsfile/read/filter/GroupByMonthFilter.java | 17 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 33 +-
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 1 +
.../tsfile/v2/file/metadata/TsFileMetadataV2.java | 9 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 22 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 3 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 3 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 121 +++--
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 27 +-
329 files changed, 10544 insertions(+), 3527 deletions(-)
copy docs/Development/ContributeGuide.md => CONTRIBUTING.md (74%)
create mode 100644 Code Summary.md
copy server/src/main/java/org/apache/iotdb/db/service/RPCService.java => cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServer.java (55%)
copy server/src/main/java/org/apache/iotdb/db/metrics/source/Source.java => cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java (89%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImpl.java
copy server/src/main/java/org/apache/iotdb/db/sync/receiver/SyncServerThriftHandler.java => cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceThriftHandler.java (84%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceImplTest.java
copy {server/src/assembly/resources/conf => cluster/src/test/resources/node1conf}/logback.xml (85%)
copy {server/src/assembly/resources/conf => cluster/src/test/resources/node2conf}/logback.xml (85%)
copy {server/src/assembly/resources/conf => cluster/src/test/resources/node3conf}/logback.xml (85%)
create mode 100644 docs/UserGuide/Advanced-Features/Alerting.md
create mode 100644 docs/zh/UserGuide/Advanced-Features/Alerting.md
create mode 100644 docs/zh/UserGuide/Comparison/TSDB-Comparison.md
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
create mode 100644 example/trigger/src/main/java/org/apache/iotdb/trigger/AlertingExample.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SFWOperator.java
copy server/src/main/java/org/apache/iotdb/db/{exception/query/QueryTimeoutRuntimeException.java => qp/physical/BatchPlan.java} (55%)
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/reader/series/SeriesReaderFactory.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/series/VectorSeriesReader.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/context/UDFContext.java
copy grafana/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java => server/src/main/java/org/apache/iotdb/db/sink/alertmanager/AlertManagerConfiguration.java (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/sink/alertmanager/AlertManagerEvent.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/sink/alertmanager/AlertManagerHandler.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByUnseqIT.java
rename server/src/test/java/org/apache/iotdb/db/integration/{IoTDBLoadExternalTsfileWithTimePartitionIT.java => IoTDBLoadExternalTsFileWithTimePartitionIT.java} (82%)
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
create mode 100644 server/src/test/java/org/apache/iotdb/db/sink/AlertManagerTest.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%)
create mode 100644 testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java
create mode 100644 testcontainer/src/test/java/org/apache/iotdb/db/sql/node1/OneNodeClusterIT.java
copy testcontainer/src/test/java/org/apache/iotdb/db/sql/{ClusterIT.java => nodes3/AbstractThreeNodeClusterIT.java} (58%)
copy server/src/main/java/org/apache/iotdb/db/engine/merge/selector/MergeFileStrategy.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java (83%)
copy server/src/main/java/org/apache/iotdb/db/exception/UDFRegistrationException.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java (68%)
copy testcontainer/src/test/java/org/apache/iotdb/db/sql/{ClusterIT.java => nodes5/AbstractFiveNodeClusterIT.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/engine/merge/selector/MergeFileStrategy.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster1IT.java (82%)
copy server/src/main/java/org/apache/iotdb/db/exception/LoadFileException.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster2IT.java (67%)
copy server/src/main/java/org/apache/iotdb/db/exception/LoadFileException.java => testcontainer/src/test/java/org/apache/iotdb/db/sql/nodes5/FiveNodeCluster4IT.java (66%)