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 74cfc17 add a feature of merging schema result for those slots which
are in state of PULLING due to add/remove node
add 9b06cae [IOTDB-1303] Group by without aggregation function used in
select clause (#3011)
add 7be35d6 [IOTDB-1317] Log CatchUp always failed du to not check the
follower's match index (#3029)
add 3c64ed9 update config.js (#3039)
add aaa8fec [IOTDB-1199] Support aligned timeseries and device template
(#2802)
add 05c5b7b rethrow RTE (#3042)
add 6d338c4 [IOTDB-1301] snappy compatible arm64 (#3006)
add 9766836 [IOTDB-1319] Trigger module: sink utility (#3038)
add 79f4b4b Fix CI failed caused by updating unnecessary vector last
cache (#3044)
add de51269 change version to 0.13.0-SNAPSHOT (#3045)
add 42a04ac Fix CI Bug
add f2e53d7 Fix query one sensor in a vector from memtable (#3056)
add 7458f4d [IOTDB-1310] Enable docker, docker-compose and testcontainer
for End to end test (#3024)
add 4867912 [IOTDB-924] Support insert multi rows (#2956)
add 56bed8c [IOTDB-1326] make config files and IoTDBConfig consistent
(#3071)
add f585d02 [IOTDB-1220] MQTT example may have timestamp precision issue
(#3074)
add 1dd10ca Fix Delete vector data bug (#3076)
add 7148f15 [IOTDB-1132] username, password and rolename shouldn't
contains spaces (#3069)
add 7ecccf5 [IOTDB-1293] Message of enable_partition cannot be modified
after iotdb started should be more clear (#3075)
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)
new 2c7f2a1 merge master and fix all conflicts
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/client-go.yml | 3 +
.github/workflows/client.yml | 5 +-
.github/workflows/e2e.yml | 11 +-
.github/workflows/main-unix.yml | 5 +
.github/workflows/main-win.yml | 3 +
.github/workflows/sonar-coveralls.yml | 3 +
Code Summary.md | 59 ++
README.md | 2 +-
antlr/pom.xml | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 30 +-
cli/pom.xml | 5 +-
.../org/apache/iotdb/tool/AbstractCsvTool.java | 1 +
client-cpp/pom.xml | 2 +-
client-cpp/src/main/Session.cpp | 11 +-
client-cpp/src/main/Session.h | 16 +-
client-py/README.md | 2 +-
client-py/pom.xml | 2 +-
cluster/pom.xml | 15 +-
.../resources/conf/iotdb-cluster.properties | 8 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 5 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 5 +-
.../cluster/client/sync/SyncClientAdaptor.java | 6 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 37 +-
.../iotdb/cluster/coordinator/Coordinator.java | 79 ++-
.../iotdb/cluster/log/applier/BaseApplier.java | 4 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 48 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 198 +++++-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 21 +-
.../cluster/partition/slot/SlotPartitionTable.java | 5 +-
.../cluster/query/ClusterPhysicalGenerator.java | 7 +
.../iotdb/cluster/query/ClusterPlanRouter.java | 11 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 22 +-
.../cluster/query/reader/ClusterReaderFactory.java | 16 +-
.../apache/iotdb/cluster/server/ClientServer.java | 1 +
.../caller/PullMeasurementSchemaHandler.java | 13 +-
.../cluster/server/member/DataGroupMember.java | 41 +-
.../cluster/server/member/MetaGroupMember.java | 17 +-
.../iotdb/cluster/server/member/RaftMember.java | 31 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 8 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 3 +-
.../cluster/client/async/AsyncClientPoolTest.java | 10 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 7 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 6 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 9 +-
.../query/ClusterAggregateExecutorTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 10 +-
.../cluster/query/ClusterFillExecutorTest.java | 4 +-
.../cluster/query/ClusterPlanExecutorTest.java | 2 +-
.../cluster/query/ClusterQueryRouterTest.java | 12 +-
.../ClusterGroupByNoVFilterDataSetTest.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 2 +-
.../caller/PullMeasurementSchemaHandlerTest.java | 12 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 14 +-
cluster/src/test/resources/logback.xml | 2 +-
.../resources/node1conf/iotdb-cluster.properties | 2 +-
.../resources/node2conf/iotdb-cluster.properties | 2 +-
.../resources/node3conf/iotdb-cluster.properties | 2 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 10 +-
compile-tools/thrift/pom.xml | 2 +-
cross-tests/pom.xml | 3 +-
distribution/pom.xml | 2 +-
docker/src/main/{Dockerfile => Dockerfile-cluster} | 4 +-
docker/src/main/{Dockerfile => Dockerfile-single} | 2 +-
docs/Development/VoteRelease.md | 8 +-
docs/SystemDesign/TsFile/Format.md | 12 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 61 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
docs/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/UserGuide/Advanced-Features/Alerting.md | 385 ++++++++++++
docs/UserGuide/Advanced-Features/Triggers.md | 390 +++++++++++-
.../Advanced-Features/UDF-User-Defined-Function.md | 8 +-
docs/UserGuide/Appendix/SQL-Reference.md | 30 +-
docs/UserGuide/CLI/Command-Line-Interface.md | 69 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 8 +-
.../Data-Concept/Data-Model-and-Terminology.md | 24 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 8 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DDL-Data-Definition-Language.md | 42 +-
.../DML-Data-Manipulation-Language.md | 19 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
docs/zh/Development/VoteRelease.md | 8 +-
docs/zh/SystemDesign/TsFile/Format.md | 12 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +-
.../UserGuide/API/Programming-Java-Native-API.md | 41 +-
.../UserGuide/API/Programming-Python-Native-API.md | 2 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +-
docs/zh/UserGuide/Advanced-Features/Alerting.md | 385 ++++++++++++
docs/zh/UserGuide/Advanced-Features/Triggers.md | 389 +++++++++++-
.../Advanced-Features/UDF-User-Defined-Function.md | 8 +-
docs/zh/UserGuide/Appendix/SQL-Reference.md | 30 +-
docs/zh/UserGuide/CLI/Command-Line-Interface.md | 75 ++-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 8 +-
.../Data-Concept/Data-Model-and-Terminology.md | 24 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 8 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DDL-Data-Definition-Language.md | 39 ++
.../DML-Data-Manipulation-Language.md | 21 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 2 +-
example/client-cpp-example/pom.xml | 2 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 5 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 5 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 4 +-
example/kafka/readme.md | 4 +-
example/mqtt/pom.xml | 2 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 1 +
example/pom.xml | 3 +-
example/pulsar/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
.../org/apache/iotdb/DataMigrationExample.java | 3 +-
.../main/java/org/apache/iotdb/SessionExample.java | 6 +-
.../org/apache/iotdb/VectorSessionExample.java | 337 ++++++++++
example/{udf => trigger}/pom.xml | 6 +-
.../org/apache/iotdb/trigger/AlertingExample.java | 107 ++++
.../org/apache/iotdb/trigger/TriggerExample.java | 127 ++++
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 5 +-
example/udf/pom.xml | 4 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana/pom.xml | 3 +-
hadoop/README.md | 2 +-
hadoop/pom.xml | 5 +-
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 3 +-
hive-connector/pom.xml | 7 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 3 +-
jdbc/README.md | 4 +-
jdbc/pom.xml | 3 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 14 +-
pom.xml | 61 +-
server/pom.xml | 13 +-
.../resources/conf/iotdb-engine.properties | 153 ++++-
server/src/assembly/resources/conf/logback.xml | 24 +-
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 3 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 58 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 4 +
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 48 +-
.../db/engine/cache/CacheHitRatioMonitor.java | 28 +
.../engine/cache/CacheHitRatioMonitorMXBean.java | 10 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../compaction/CompactionMergeTaskPoolManager.java | 38 +-
.../db/engine/compaction/TsFileManagement.java | 19 +-
.../level/LevelCompactionTsFileManagement.java | 274 ++++----
.../no/NoCompactionTsFileManagement.java | 132 ++--
.../iotdb/db/engine/flush/MemTableFlushTask.java | 119 +++-
.../iotdb/db/engine/flush/NotifyFlushMemTable.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 193 ++++--
.../apache/iotdb/db/engine/memtable/IMemTable.java | 19 +-
.../db/engine/memtable/IWritableMemChunk.java | 43 +-
.../db/engine/memtable/PrimitiveMemTable.java | 9 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 87 ++-
.../db/engine/merge/manage/MergeResource.java | 14 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 17 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 6 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 5 +-
.../db/engine/querycontext/QueryDataSource.java | 12 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 145 ++++-
.../db/engine/storagegroup/StorageGroupInfo.java | 6 +-
.../engine/storagegroup/StorageGroupProcessor.java | 183 +++---
.../db/engine/storagegroup/TsFileProcessor.java | 214 +++++--
.../engine/storagegroup/TsFileProcessorInfo.java | 6 +-
.../db/engine/storagegroup/TsFileResource.java | 152 +++--
.../storagegroup/timeindex/DeviceTimeIndex.java | 18 -
.../storagegroup/timeindex/FileTimeIndex.java | 5 -
.../engine/storagegroup/timeindex/ITimeIndex.java | 8 -
...eption.java => AlignedTimeseriesException.java} | 19 +-
.../metadata/DuplicatedTemplateException.java} | 17 +-
.../metadata/StorageGroupNotSetException.java | 4 +
.../metadata/UndefinedTemplateException.java} | 17 +-
.../apache/iotdb/db/metadata/MLogTxtWriter.java | 36 +-
.../org/apache/iotdb/db/metadata/MManager.java | 640 ++++++++++++++++---
.../java/org/apache/iotdb/db/metadata/MTree.java | 389 ++++++++++--
.../apache/iotdb/db/metadata/MeasurementMeta.java | 14 +-
.../org/apache/iotdb/db/metadata/MetaUtils.java | 24 +
.../iotdb/db/metadata/MetadataOperationType.java | 2 +
.../org/apache/iotdb/db/metadata/PartialPath.java | 6 +-
.../iotdb/db/metadata/VectorPartialPath.java | 68 ++
.../iotdb/db/metadata/logfile/MLogWriter.java | 38 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 98 +++
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 20 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 26 +-
.../iotdb/db/metadata/template/Template.java | 170 +++++
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 142 ++++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 7 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 10 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 25 +
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 5 +
.../db/qp/physical/crud/CreateTemplatePlan.java | 240 +++++++
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 5 +
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 110 ++--
.../db/qp/physical/crud/InsertTabletPlan.java | 70 ++-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 5 +
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 5 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 14 +
.../db/qp/physical/crud/RawDataQueryPlan.java | 63 +-
.../db/qp/physical/crud/SetDeviceTemplatePlan.java | 94 +++
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 5 +
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 87 +++
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 259 ++++++++
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 7 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 9 +-
.../physical/sys/SetUsingDeviceTemplatePlan.java | 83 +++
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 36 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 48 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 115 +++-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 9 +
.../iotdb/db/query/context/QueryContext.java | 4 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 25 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 8 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 143 ++++-
.../iotdb/db/query/executor/LastQueryExecutor.java | 41 +-
.../iotdb/db/query/executor/QueryRouter.java | 16 +-
.../db/query/executor/fill/LastPointReader.java | 34 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 19 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 17 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 15 +-
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../reader/series/SeriesRawDataBatchReader.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 129 ++--
.../reader/series/SeriesReaderByTimestamp.java | 4 +-
.../query/reader/series/SeriesReaderFactory.java | 94 +++
.../db/query/reader/series/VectorSeriesReader.java | 144 +++++
.../query/timegenerator/ServerTimeGenerator.java | 7 +
.../iotdb/db/rescon/PrimitiveArrayManager.java | 7 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 244 +++----
.../apache/iotdb/db/rescon/TVListAllocator.java | 15 +-
.../org/apache/iotdb/db/service/ServiceType.java | 3 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 163 ++++-
.../alertmanager/AlertManagerConfiguration.java} | 17 +-
.../db/sink/alertmanager/AlertManagerEvent.java | 123 ++++
.../db/sink/alertmanager/AlertManagerHandler.java | 83 +++
.../Evaluator.java => sink/api/Configuration.java} | 14 +-
.../api/Evaluator.java => sink/api/Event.java} | 14 +-
.../api/Evaluator.java => sink/api/Handler.java} | 16 +-
.../exception/SinkException.java} | 15 +-
.../db/sink/local/LocalIoTDBConfiguration.java | 51 ++
.../local/LocalIoTDBEvent.java} | 23 +-
.../iotdb/db/sink/local/LocalIoTDBHandler.java | 104 +++
.../iotdb/db/sink/mqtt/MQTTConfiguration.java | 74 +++
.../org/apache/iotdb/db/sink/mqtt/MQTTEvent.java | 51 +-
.../org/apache/iotdb/db/sink/mqtt/MQTTHandler.java | 85 +++
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 54 +-
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 4 +
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 31 +-
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 9 +
.../org/apache/iotdb/db/utils/CommonUtils.java | 3 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 36 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 119 ++--
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 31 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 19 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 8 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 74 +++
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +
.../iotdb/db/utils/datastructure/TVList.java | 88 ++-
.../iotdb/db/utils/datastructure/VectorTVList.java | 698 +++++++++++++++++++++
.../iotdb/db/utils/windowing/api/Evaluator.java | 3 +-
.../windowing/runtime/WindowEvaluationTask.java | 2 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 27 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 6 +
.../db/auth/user/LocalFileUserManagerTest.java | 16 +
.../compaction/LevelCompactionCacheTest.java | 2 +-
.../engine/compaction/LevelCompactionLogTest.java | 2 +-
.../compaction/LevelCompactionMergeTest.java | 6 +-
.../compaction/LevelCompactionMoreDataTest.java | 2 +-
.../LevelCompactionTsFileManagementTest.java | 69 ++
.../NoCompactionTsFileManagementTest.java | 71 ++-
.../db/engine/memtable/MemTableFlushTaskTest.java | 57 ++
.../db/engine/memtable/MemTableTestUtils.java | 81 ++-
.../db/engine/memtable/MemtableBenchmark.java | 1 -
.../db/engine/memtable/PrimitiveMemTableTest.java | 130 +++-
.../iotdb/db/engine/merge/MergeTaskTest.java | 75 +++
.../db/engine/modification/DeletionQueryTest.java | 10 +-
.../storagegroup/StorageGroupProcessorTest.java | 28 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 6 +-
.../engine/storagegroup/TsFileProcessorTest.java | 84 ++-
.../iotdb/db/integration/IOTDBGroupByIT.java | 19 +
.../db/integration/IOTDBInsertAlignedValuesIT.java | 215 +++++++
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 2 +-
.../iotdb/db/integration/IoTDBCompressTypeIT.java | 5 -
.../iotdb/db/integration/IoTDBDeletionIT.java | 12 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 6 +-
.../db/integration/IoTDBFlushQueryMergeIT.java | 4 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 97 ++-
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 70 ++-
...TDBInsertIT.java => IoTDBInsertMultiRowIT.java} | 31 +-
...oTDBLoadExternalTsFileWithTimePartitionIT.java} | 44 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 6 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 8 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 4 +
.../apache/iotdb/db/integration/IoTDBTagIT.java | 40 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 16 +
.../aggregation/IoTDBAggregationByLevelIT.java | 21 +
.../db/integration/auth/IoTDBAuthorizationIT.java | 108 +++-
.../iotdb/db/metadata/MManagerBasicTest.java | 589 ++++++++++++++++-
.../iotdb/db/metadata/MManagerImproveTest.java | 17 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 246 ++++++++
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 264 ++++++++
.../db/qp/physical/PhysicalPlanSerializeTest.java | 44 ++
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 15 +
.../reader/series/SeriesAggregateReaderTest.java | 6 +-
.../reader/series/SeriesReaderByTimestampTest.java | 6 +-
.../query/reader/series/SeriesReaderTestUtil.java | 3 +-
.../org/apache/iotdb/db/sink/AlertManagerTest.java | 328 ++++++++++
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 217 +++++++
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 204 ++++++
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 2 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 57 ++
.../db/utils/datastructure/VectorTVListTest.java | 143 +++++
.../iotdb/db/writelog/recover/LogReplayerTest.java | 22 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 3 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 5 +-
.../src/test/resources/testcontainers.properties | 17 +
service-rpc/pom.xml | 3 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 10 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 4 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 20 +-
session/pom.xml | 3 +-
.../java/org/apache/iotdb/session/Session.java | 174 ++++-
.../apache/iotdb/session/SessionConnection.java | 60 ++
.../org/apache/iotdb/session/SessionUtils.java | 133 ++--
.../iotdb/session/IoTDBSessionComplexIT.java | 7 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 57 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 5 +-
.../java/org/apache/iotdb/session/SessionUT.java | 52 +-
site/pom.xml | 2 +-
site/src/main/.vuepress/config.js | 12 +-
spark-iotdb-connector/Readme.md | 8 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/README.md | 6 +-
spark-tsfile/pom.xml | 4 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 4 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 5 +-
test/e2e/base/docker-compose.yaml | 4 +-
test/e2e/cases/cli/cleanup.sh | 0
test/e2e/cases/cli/run.sh | 0
testcontainer/Readme.md | 66 ++
testcontainer/pom.xml | 159 +++++
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 122 ++++
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 122 ++++
.../NoProjectNameDockerComposeContainer.java | 24 +-
.../src/test/resources/1node}/docker-compose.yaml | 31 +-
.../test/resources/1node}/iotdb-cluster.properties | 7 +-
.../src/test/resources/3nodes}/docker-compose.yaml | 31 +-
.../resources/3nodes}/iotdb-cluster.properties | 5 +-
.../src/test/resources/5nodes}/docker-compose.yaml | 32 +-
.../resources/5nodes}/iotdb-cluster.properties | 5 +-
.../src/test/resources/iotdb-engine.properties | 24 +
.../src/test/resources/logback-container.xml | 10 +-
.../src/test/resources/logback.xml | 23 +-
thrift-cluster/pom.xml | 2 +-
thrift-sync/pom.xml | 2 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/rpc.thrift | 31 +
tsfile/README.md | 2 +-
tsfile/pom.xml | 3 +-
.../iotdb/tsfile/encoding/decoder/Decoder.java | 4 +
.../iotdb/tsfile/file/header/ChunkHeader.java | 15 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 22 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 74 +++
.../metadata/ITimeSeriesMetadata.java} | 23 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 23 +-
.../tsfile/file/metadata/VectorChunkMetadata.java | 178 ++++++
.../file/metadata/VectorTimeSeriesMetadata.java | 97 +++
.../tsfile/file/metadata/enums/TSDataType.java | 8 +-
.../file/metadata/statistics/Statistics.java | 96 +--
.../file/metadata/statistics/TimeStatistics.java | 161 +++++
.../iotdb/tsfile/read/TsFileSequenceReader.java | 59 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 60 ++
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 5 +-
.../read/controller/IChunkMetadataLoader.java | 8 +-
.../tsfile/read/controller/IMetadataQuerier.java | 6 +-
.../read/controller/MetadataQuerierByFileImpl.java | 13 +-
.../expression/impl/SingleSeriesExpression.java | 4 +
.../tsfile/read/filter/GroupByMonthFilter.java | 17 +-
.../iotdb/tsfile/read/filter/ValueFilter.java | 106 ++++
.../iotdb/tsfile/read/filter/operator/In.java | 6 +-
.../query/executor/ExecutorWithTimeGenerator.java | 4 +-
.../tsfile/read/query/executor/TsFileExecutor.java | 4 +-
.../query/timegenerator/TsFileTimeGenerator.java | 4 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 8 +-
.../read/reader/chunk/VectorChunkReader.java | 262 ++++++++
.../tsfile/read/reader/page/TimePageReader.java | 92 +++
.../tsfile/read/reader/page/ValuePageReader.java | 218 +++++++
.../tsfile/read/reader/page/VectorChunkReader.java | 15 +-
.../tsfile/read/reader/page/VectorPageReader.java | 122 ++++
.../reader/series/AbstractFileSeriesReader.java | 14 +-
.../read/reader/series/EmptyFileSeriesReader.java | 6 +-
.../read/reader/series/FileSeriesReader.java | 9 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 13 +-
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 2 +
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 121 ++++
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 4 +
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 88 +++
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 6 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 13 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 6 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 32 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 4 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 15 +-
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 255 ++++++++
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 252 ++++++++
.../tsfile/write/chunk/VectorChunkWriterImpl.java | 202 ++++++
.../apache/iotdb/tsfile/write/page/PageWriter.java | 6 +-
.../iotdb/tsfile/write/page/TimePageWriter.java | 177 ++++++
.../page/{PageWriter.java => ValuePageWriter.java} | 160 ++---
.../apache/iotdb/tsfile/write/record/Tablet.java | 251 +++++---
.../write/record/datapoint/BooleanDataPoint.java | 2 +-
.../write/record/datapoint/DoubleDataPoint.java | 2 +-
.../write/record/datapoint/FloatDataPoint.java | 2 +-
.../write/record/datapoint/IntDataPoint.java | 2 +-
.../write/record/datapoint/LongDataPoint.java | 2 +-
.../write/record/datapoint/StringDataPoint.java | 2 +-
.../tsfile/write/schema/IMeasurementSchema.java | 77 +++
.../tsfile/write/schema/MeasurementSchema.java | 89 ++-
.../apache/iotdb/tsfile/write/schema/Schema.java | 25 +-
.../write/schema/VectorMeasurementSchema.java | 370 +++++++++++
.../write/writer/RestorableTsFileIOWriter.java | 17 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 39 +-
...easurementChunkMetadataListMapIteratorTest.java | 13 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 7 +-
.../query/timegenerator/ReaderByTimestampTest.java | 4 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 6 +-
.../org/apache/iotdb/tsfile/utils/BitMapTest.java | 67 ++
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 4 +-
.../tsfile/write/DefaultDeviceTemplateTest.java | 5 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 3 +-
.../write/schema/converter/SchemaBuilderTest.java | 17 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 5 +-
.../tsfile/write/writer/TestTsFileOutput.java} | 49 +-
.../tsfile/write/writer/TimeChunkWriterTest.java | 111 ++++
.../tsfile/write/writer/TimePageWriterTest.java | 171 +++++
.../tsfile/write/writer/ValueChunkWriterTest.java | 109 ++++
.../tsfile/write/writer/ValuePageWriterTest.java | 291 +++++++++
.../write/writer/VectorChunkWriterImplTest.java | 178 ++++++
.../write/writer/VectorMeasurementSchemaStub.java | 128 ++++
zeppelin-interpreter/pom.xml | 2 +-
454 files changed, 19263 insertions(+), 2662 deletions(-)
create mode 100644 Code Summary.md
copy docker/src/main/{Dockerfile => Dockerfile-cluster} (92%)
rename docker/src/main/{Dockerfile => Dockerfile-single} (95%)
create mode 100644 docs/UserGuide/Advanced-Features/Alerting.md
create mode 100644 docs/zh/UserGuide/Advanced-Features/Alerting.md
create mode 100644
example/session/src/main/java/org/apache/iotdb/VectorSessionExample.java
copy example/{udf => trigger}/pom.xml (97%)
create mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/AlertingExample.java
create mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/TriggerExample.java
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{StorageGroupNotSetException.java
=> AlignedTimeseriesException.java} (63%)
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
exception/metadata/DuplicatedTemplateException.java} (68%)
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
exception/metadata/UndefinedTemplateException.java} (70%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/VectorPartialPath.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/Template.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/CreateTemplatePlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/SetDeviceTemplatePlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/AutoCreateDeviceMNodePlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/CreateAlignedTimeSeriesPlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/SetUsingDeviceTemplatePlan.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReaderFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/VectorSeriesReader.java
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
sink/alertmanager/AlertManagerConfiguration.java} (70%)
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
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
sink/api/Configuration.java} (74%)
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
sink/api/Event.java} (74%)
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
sink/api/Handler.java} (69%)
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
sink/exception/SinkException.java} (74%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/local/LocalIoTDBConfiguration.java
copy
server/src/main/java/org/apache/iotdb/db/{utils/windowing/api/Evaluator.java =>
sink/local/LocalIoTDBEvent.java} (65%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/local/LocalIoTDBHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/mqtt/MQTTConfiguration.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/series/EmptyFileSeriesReader.java
=> server/src/main/java/org/apache/iotdb/db/sink/mqtt/MQTTEvent.java (52%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sink/mqtt/MQTTHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/datastructure/VectorTVList.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IOTDBInsertAlignedValuesIT.java
copy server/src/test/java/org/apache/iotdb/db/integration/{IOTDBInsertIT.java
=> IoTDBInsertMultiRowIT.java} (80%)
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/qp/physical/InsertRowPlanTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sink/AlertManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sink/LocalIoTDBSinkTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sink/MQTTSinkTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/VectorTVListTest.java
create mode 100644 server/src/test/resources/testcontainers.properties
mode change 100644 => 100755 test/e2e/cases/cli/cleanup.sh
mode change 100644 => 100755 test/e2e/cases/cli/run.sh
create mode 100644 testcontainer/Readme.md
create mode 100644 testcontainer/pom.xml
create mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/ClusterIT.java
create mode 100644
testcontainer/src/test/java/org/apache/iotdb/db/sql/SingleNodeIT.java
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/StorageGroupNotSetException.java
=>
testcontainer/src/test/java/org/testcontainers/containers/NoProjectNameDockerComposeContainer.java
(58%)
copy {test/e2e/base =>
testcontainer/src/test/resources/1node}/docker-compose.yaml (68%)
copy {cluster/src/test/resources/node1conf =>
testcontainer/src/test/resources/1node}/iotdb-cluster.properties (92%)
copy {test/e2e/base =>
testcontainer/src/test/resources/3nodes}/docker-compose.yaml (68%)
copy {cluster/src/test/resources/node1conf =>
testcontainer/src/test/resources/3nodes}/iotdb-cluster.properties (93%)
copy {test/e2e/base =>
testcontainer/src/test/resources/5nodes}/docker-compose.yaml (68%)
copy {cluster/src/test/resources/node1conf =>
testcontainer/src/test/resources/5nodes}/iotdb-cluster.properties (89%)
create mode 100644 testcontainer/src/test/resources/iotdb-engine.properties
copy cluster/src/test/resources/logback.xml =>
testcontainer/src/test/resources/logback-container.xml (68%)
copy {cluster => testcontainer}/src/test/resources/logback.xml (68%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/IChunkMetadata.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/{read/controller/IChunkMetadataLoader.java
=> file/metadata/ITimeSeriesMetadata.java} (67%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/VectorChunkMetadata.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/VectorTimeSeriesMetadata.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/statistics/TimeStatistics.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/VectorChunkReader.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/TimePageReader.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/ValuePageReader.java
copy
server/src/main/java/org/apache/iotdb/db/utils/windowing/api/Evaluator.java =>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/VectorChunkReader.java
(73%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/VectorPageReader.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitMap.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/TimeChunkWriter.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/ValueChunkWriter.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/chunk/VectorChunkWriterImpl.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/TimePageWriter.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/write/page/{PageWriter.java
=> ValuePageWriter.java} (69%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/IMeasurementSchema.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/VectorMeasurementSchema.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/utils/BitMapTest.java
copy
tsfile/src/{main/java/org/apache/iotdb/tsfile/read/reader/series/EmptyFileSeriesReader.java
=> test/java/org/apache/iotdb/tsfile/write/writer/TestTsFileOutput.java} (50%)
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TimeChunkWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TimePageWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/ValueChunkWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/ValuePageWriterTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/VectorChunkWriterImplTest.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/VectorMeasurementSchemaStub.java
