You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/01/10 10:33:26 UTC
[iotdb] branch new_sync updated (5f97089 -> 8a51c42)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch new_sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 5f97089 [IOTDB-2159] Fix wrong status code when inserting data to a read-only cluster (#4586)
add fb7b18e [IOTDB-2164] Fix IoTDBFlushQueryMergeIT (#4590)
add fab1fa5 Update README_ZH.md (#4593)
add 62d9c86 [IOTDB-2168] Fix IoTDBTtlIT (#4592)
add f5a1cf6 [IOTDB-2102] Set rowLimit before init() in RawDataSetWithoutValueFilter (#4591)
add 4c5d4ab [IOTDB-2169] Fix iotdb-env.bat error in Windows platform (#4595)
add a761a7f [IOTDB-2075] Accelerate the process of insertTablets by using thread pool (#4502)
add 6f5106d [IOTDB-2162] Simplify the recovery merge process (#4575)
add 385f34b [IOTDB-2112] Do not use .tsfile when compacting the target file (#4549)
add 583c186 [IOTDB-2173] Update document about group by level clause (#4599)
add d66521a [IOTDB-2174] Fix Regexp filter serializing and deserializing error (#4601)
add 7d8496e [IOTDB-2161] Get timeseries by device in merge process (#4610)
add 58bc3d0 [IOTDB-2154]add TsFileUtils.isTsFileComplete (#4596)
add 3db25ce [IOTDB-2163] Fix unexpected amount of columns in a cluster slimit query (#4587)
add 4be3978 [IOTDB-2183] Fix the config problems in cluster mode (#4614)
add a7063c1 [IOTDB-2166] Avoid TTL deleting source files in running compaction tasks (#4589)
add 47b7e82 [IOTDB-2143] fix wrong precision in cluster mode (#4570)
add 1de3067 [IOTDB-2180] Fix show latest timeseries in cluster (#4611)
add fcd7824 [IOTDB-2144][Metric] Collect IoTDB Runtime Metrics (#4573)
add 93c5659 Site: Update committer info for SteveYurongSu (#4624)
add e8c7dfb [Docs] Correct an error in the TsFile format document (#4628)
add 2b0394f [IOTDB-1960] Fix count timeseries in cluster mode. (#4617)
add ff9f59c [IOTDB-2172] Refactor for IoTDBSimpleQueryIT (#4598)
add 19abdb0 Site: Add new committer ericpai (#4635)
add 608faec Support double star ** in group by level (#4629)
add c9fdcd4 update website download link to v0.12.4 and delete the 0.11.4 download link (#4636)
add 829bfe4 refactor: remove sort param from Session (#4616)
add 53a7ad7 [IOTDB-1860] REST protocol based Grafana plugin (#4585)
add 4abd8aa Add PMC (#4641)
add e4f8e63 [IOTDB-2208] Reconstruct the process of generating resultset header of query (#4640)
add 42b8f60 [IOTDB-1948] [IOTDB-1949] Group by fill supports vector (#4632)
add db24295 [IoTDB-2185] get an exception when parsing the header of CSV (#4620)
add ce31406 [IOTDB-2209] Fix logback CVE-2021-42550 issue (#4643)
add 9af8185 [IOTDB-2208] Reconstruct the process of generating resultset header of query - Part2 (#4642)
add 3c1d485 [IOTDB-1942] Support align by device query in new vector (#4435)
add effef77 update fill doc (#4647)
add 4dbe90a [IOTDB-2193] Reduce unnecessary lock operations of RaftLogManager to improve writing performance (#4638)
add 349a9b4 [IOTDB-2220] Fix unit tests too slow issue caused by the MQTTService (#4649)
add 421ee8b [IOTDB-2206] Rename StorageGroupProcessor to VirtualStorageGroupProcessor (#4646)
add b7028de Optimize the document format (#4658)
add 4e71208 Fix website compile error (#4661)
add 9d9e6b9 [IOTDB-2153][IOTDB-2157] fix incorrect path search space (#4581)
add 063ad74 [IoTDB-2223]Add an example for Cluster setup on 3 nodes (#4655)
add 1c58407 [IOTDB-2224] Accelerate tests by using batch insert (#4657)
add c461f65 [IOTDB-2195] Control the concurrent query execution thread - Part 1 (#4660)
add 8040996 fix jenkins CI disable testcontainer (#4666)
add 1711ab9 Fix jenkins ci
add a2a8ac8 [IOTDB-2217] Provide an iterator to return timeseries Path in dictionary order (#4645)
add 58e8202 [ISSUE-4651][grafana-plugin] Failed to display data when executing aggregation queries on non-existed timeseries (#4663)
add 2d6307f [IOTDB-2083] ID table implementation (#4603)
add dd37e9f Fix CPP client could not be successfully built on windows (#4665)
add 3ef6bab [IOTDB-2233] Grafana plugin: add `control` field for the `expression` panel (#4662)
add ee0570d [IOTDB-2228] Provide an iterator to return devices in dictionary order (#4668)
add 30983cf Update virtual storage group docs (#4677)
add 327240a [IOTDB-2214] InfluxDB-Connect write point time error format (#4671)
add 0ad2f34 library-udf base documents (#4688)
add 131167d [IOTDB-2237] coverage check encludes influxdb target (#4690)
add 3f2a8c0 [IOTDB-2239] Hompage Sidebar Rearrangement (#4692)
add 10e58c2 [IOTDB-2240] Library-UDF Data Quality Docs (#4693)
add 3456e18 Bump jaxb-runtime from 3.0.0 to 3.0.2 (#4686)
add 05afd4f [IOTDB-2237] Coverage check encludes influxdb target (#4694)
add eb42e3d Bump actions/setup-node from 2.1.2 to 2.1.5 (#4682)
add 86a6fcd [IOTDB-2241] Library-UDF Data Repairing Documents (#4696)
add 8759fa4 [IOTDB-2195] Control the concurrent query execution thread - Part 2 (#4664)
add 010af34 Fix error in the test-only constructor of AlignedSeriesReader (#4675)
add fa4fb46 Fix aligned bug of metadata module (#4701)
add 9dca629 Fix Query Deadlock (#4704)
add 99600d2 [IOTDB-2249] Fix query NPE when an aligned column with duplicated time is deleted (#4702)
add de2e626 [IOTDB-2101] Reduce the memory footprint of QueryDataSource (#4654)
add 3cbf9af [Docs] Add doc about insert data into aligned timeseries (#4705)
add 4fd2229 [IOTDB-2259] Fix Error information is incorrect when aligned timeseries Data type mismatch (#4706)
add cbecb86 update CMakeLists.txt (#4707)
add fe5d591 [IOTDB-2265] rename UnaryMeasurementSchema to MeasurementSchema (#4710)
add f061b28 [IOTDB-1802] Add aligned timeseries APIs for C++ client (#4711)
add e7267ff Support grafana-plugin for mac M1 based cpu(darwin-aarch64) (#4714)
add 853ff47 [IOTDB-2290] Incorrect query result in C++ client (#4721)
add 4dcca12 [IOTDB-2291] Conccurent modification exception of memtables's mods (#4724)
add f7affbb fix tag recovery bug after tag upsert (#4718)
add 4df4bcc [IOTDB-2176] Limit target chunk size when performing inner space compaction (#4698)
add 9ea7c43 Updated Notice file to 2022 (#4733)
add 3334c53 [IOTDB-2301] Fix IndexOutOfBoundException when delete aligned values (#4730)
add 2ae5a52 [IOTDB-2266] Romove warning info when CLI runs on mode (#4728)
add 6e5e209 Fix dead lock in setDataTTL method (#4738)
add aa108f3 [IOTDB-2267] UDF: Error code 500 caused by user logic (#4744)
add c295263 [IOTDB-2273] Trigger doc: quotation marks are required on the id (#4746)
add 2a9af0b [IOTDB-2322] Provide a new interface to get AlignedChunkMetadata of device (#4742)
add e3b385b [IOTDB-1297] Refactor the memory control when enabling time partitions (#4743)
add 8a51c42 [IOTDB-2295][IOTDB-2299] Fix Timeseries count group by level Bug & Fix Wrong SQL instance (#4727)
No new revisions were added by this update.
Summary of changes:
.github/workflows/grafana-plugin.yml | 47 +
.gitignore | 1 +
Jenkinsfile | 2 +-
LICENSE-binary | 4 +-
NOTICE | 2 +-
NOTICE-binary | 2 +-
README_ZH.md | 2 +-
RELEASE_NOTES.md | 2 +-
.../org/apache/iotdb/cli/utils/JlineUtils.java | 4 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 18 +-
client-cpp/src/main/CMakeLists.txt | 4 +-
client-cpp/src/main/Session.cpp | 277 +-
client-cpp/src/main/Session.h | 88 +-
client-cpp/src/test/CMakeLists.txt | 2 +-
cluster/src/assembly/cluster.xml | 4 +
cluster/src/assembly/resources/sbin/start-node.bat | 21 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 4 +-
.../iotdb/cluster/ClusterFileFlushPolicy.java | 8 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 2 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 2 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 6 +-
.../log/manage/PartitionedSnapshotLogManager.java | 15 +
.../apache/iotdb/cluster/metadata/CMManager.java | 76 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 4 +-
.../partition/slot/SlotTimePartitionFilter.java | 2 +-
.../cluster/query/ClusterDataQueryExecutor.java | 6 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 30 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 14 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 19 -
.../cluster/query/ClusterUDTFQueryExecutor.java | 4 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 46 +-
.../ClusterGroupByFillNoVFilterDataSet.java | 54 -
.../groupby/ClusterGroupByFillVFilterDataSet.java | 67 -
.../iotdb/cluster/server/ClusterRPCService.java | 8 +-
.../server/handlers/caller/ElectionHandler.java | 17 +
.../caller/PullMeasurementSchemaHandler.java | 4 +-
.../handlers/caller/ShowTimeSeriesHandler.java | 20 +-
.../cluster/server/member/DataGroupMember.java | 2 +-
.../iotdb/cluster/server/member/RaftMember.java | 101 +-
.../cluster/server/service/DataAsyncService.java | 2 +-
.../cluster/server/service/DataSyncService.java | 2 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 5 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 83 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 4 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 7 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 12 +-
.../cluster/log/applier/DataLogApplierTest.java | 26 +-
.../cluster/log/logtypes/SerializeLogTest.java | 3 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 14 +-
.../log/snapshot/PartitionedSnapshotTest.java | 4 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 87 +
.../mult/AssignPathManagedMergeReaderTest.java | 3 +-
.../reader/mult/RemoteMultSeriesReaderTest.java | 3 +-
.../iotdb/cluster/server/member/BaseMember.java | 2 +
.../cluster/server/member/DataGroupMemberTest.java | 19 +-
.../cluster/server/member/MetaGroupMemberTest.java | 10 +-
.../resources/node1conf/iotdb-engine.properties | 1 +
.../src/test/resources/node1conf}/iotdb-metric.yml | 22 +-
.../resources/node2conf/iotdb-engine.properties | 1 +
.../src/test/resources/node2conf}/iotdb-metric.yml | 22 +-
.../resources/node3conf/iotdb-engine.properties | 1 +
.../src/test/resources/node3conf}/iotdb-metric.yml | 22 +-
code-coverage/pom.xml | 1 +
compile-tools/thrift/pom.xml | 33 -
distribution/pom.xml | 14 +-
distribution/src/assembly/all.xml | 4 +-
.../{grafana.xml => grafana-connector.xml} | 8 +-
.../assembly/{grafana.xml => grafana-plugin.xml} | 26 +-
docker/ReadMe.md | 2 +-
docs/Download/README.md | 45 +-
docs/SystemDesign/StorageEngine/Recover.md | 2 +-
docs/SystemDesign/StorageEngine/StorageEngine.md | 2 +-
docs/SystemDesign/TsFile/Format.md | 1 -
docs/UserGuide/API/Programming-Cpp-Native-API.md | 62 +-
.../Advanced-Features/Continuous-Query.md | 2 +-
docs/UserGuide/Advanced-Features/Triggers.md | 10 +-
docs/UserGuide/Appendix/Config-Manual.md | 38 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 107 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 4 +-
.../UserGuide/Data-Concept/Auto-Create-MetaData.md | 14 +-
docs/UserGuide/Data-Concept/Compression.md | 95 +-
.../Data-Concept/Data-Model-and-Terminology.md | 37 +-
docs/UserGuide/Data-Concept/Data-Type.md | 14 +-
docs/UserGuide/Data-Concept/Encoding.md | 13 +-
docs/UserGuide/Data-Concept/SDT.md | 111 -
docs/UserGuide/Data-Concept/Schema-Template.md | 8 +-
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 55 +
.../{Grafana.md => Grafana Connector.md} | 22 +-
.../DML-Data-Manipulation-Language.md | 640 +-
docs/UserGuide/Library-UDF/Data-Quality.md | 520 +
docs/UserGuide/Library-UDF/Data-Repair.md | 349 +
docs/UserGuide/Library-UDF/Get-Started.md | 61 +
docs/UserGuide/System-Tools/Metric-Tool.md | 288 +-
docs/zh/Download/README.md | 45 +-
docs/zh/SystemDesign/StorageEngine/Recover.md | 4 +-
.../zh/SystemDesign/StorageEngine/StorageEngine.md | 2 +-
docs/zh/SystemDesign/TsFile/Format.md | 1 -
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 80 +-
.../Advanced-Features/Continuous-Query.md | 2 +-
docs/zh/UserGuide/Advanced-Features/Triggers.md | 10 +-
docs/zh/UserGuide/Appendix/Config-Manual.md | 37 +
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 108 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 4 +-
.../UserGuide/Data-Concept/Auto-Create-MetaData.md | 14 +-
docs/zh/UserGuide/Data-Concept/Compression.md | 90 +-
.../Data-Concept/Data-Model-and-Terminology.md | 34 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 18 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 7 +-
docs/zh/UserGuide/Data-Concept/SDT.md | 106 -
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 32 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 8 +-
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 53 +
.../{Grafana.md => Grafana Connector.md} | 20 +-
.../Ecosystem Integration/Grafana Plugin.md | 250 +
.../DML-Data-Manipulation-Language.md | 624 +-
docs/zh/UserGuide/Library-UDF/Data-Quality.md | 509 +
docs/zh/UserGuide/Library-UDF/Data-Repair.md | 341 +
docs/zh/UserGuide/Library-UDF/Get-Started.md | 58 +
docs/zh/UserGuide/System-Tools/Metric-Tool.md | 280 +-
example/client-cpp-example/pom.xml | 4 +
.../src/AlignedTimeseriesSessionExample.cpp | 279 +
example/client-cpp-example/src/CMakeLists.txt | 8 +-
example/client-cpp-example/src/SessionExample.cpp | 198 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 11 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 11 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 9 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 6 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 13 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 8 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 39 +-
.../org/apache/iotdb/DataMigrationExample.java | 7 +-
.../iotdb/HybridTimeseriesSessionExample.java | 9 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 11 +-
.../main/java/org/apache/iotdb/SessionExample.java | 27 +-
.../main/java/org/apache/iotdb/TabletExample.java | 7 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 14 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 10 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 25 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 10 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 15 +-
.../java/org/apache/iotdb/udf/UDTFExample.java | 19 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 10 +-
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 18 +-
.../img/add_data_source.png | Bin
{grafana => grafana-connector}/img/add_graph.png | Bin
.../img/edit_data_source.png | Bin
{grafana => grafana-connector}/pom.xml | 4 +-
{grafana => grafana-connector}/readme.md | 22 +-
{grafana => grafana-connector}/readme_zh.md | 20 +-
.../web/grafana/TsfileWebDemoApplication.java | 0
.../apache/iotdb/web/grafana/bean/TimeValues.java | 0
.../iotdb/web/grafana/conf/MyConfiguration.java | 0
.../controller/DatabaseConnectController.java | 0
.../org/apache/iotdb/web/grafana/dao/BasicDao.java | 0
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 0
.../grafana/service/DatabaseConnectService.java | 0
.../service/impl/DatabaseConnectServiceImpl.java | 0
.../src/main/resources/application.properties | 0
.../web/grafana/dao/impl/BasicDaoImplTest.java | 0
grafana-plugin/.gitignore | 32 +
.../.prettierrc.js | 23 +-
grafana-plugin/CHANGELOG.md | 24 +
LICENSE-binary => grafana-plugin/LICENSE | 105 +-
grafana-plugin/README.md | 63 +
.../jest.config.js | 25 +-
grafana-plugin/package.json | 32 +
grafana-plugin/pom.xml | 96 +
grafana-plugin/src/ConfigEditor.tsx | 101 +
grafana-plugin/src/QueryEditor.tsx | 114 +
.../src/componments/ControlValue.tsx | 40 +-
.../src/componments/Form.tsx | 39 +-
grafana-plugin/src/componments/FromValue.tsx | 110 +
grafana-plugin/src/componments/SelectValue.tsx | 109 +
.../src/componments/WhereValue.tsx | 40 +-
grafana-plugin/src/datasource.ts | 164 +
.../src/functions.ts | 22 +-
grafana-plugin/src/img/logo.svg | 271 +
.../src/module.ts | 28 +-
grafana-plugin/src/plugin.json | 47 +
.../src/types.ts | 41 +-
grafana-plugin/tsconfig.json | 9 +
grafana-plugin/yarn.lock | 14317 +++++++++++++++++++
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 9 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 9 +-
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 18 +-
.../iotdb/integration/env/ClusterEnvBase.java | 6 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 72 +-
.../apache/iotdb/integration/env/ClusterNode.java | 6 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 24 +-
.../integration/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 5 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 33 +-
.../db/integration/IoTDBFlushQueryMergeIT.java | 14 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 275 +-
.../db/integration/IoTDBGroupByFillMixPathsIT.java | 759 +-
.../integration/IoTDBGroupByFillWithRangeIT.java | 14 +-
.../db/integration/IoTDBGroupByMonthFillIT.java | 55 +-
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBMergeIT.java | 18 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 128 +-
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 75 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 6 +-
.../db/integration/IoTDBPartialInsertionIT.java | 69 +
.../IoTDBQueryWithComplexValueFilterIT.java | 122 +
.../db/integration/IoTDBQueryWithIDTableIT.java | 289 +
.../iotdb/db/integration/IoTDBRestartIT.java | 55 -
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 38 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 4 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 12 +-
.../{ => aligned}/IOTDBInsertAlignedValuesIT.java | 57 +-
.../aligned/IoTDBAggregationGroupByLevelIT.java | 12 +-
.../IoTDBAggregationWithoutValueFilterIT.java | 18 +-
.../integration/aligned/IoTDBAlignByDevice2IT.java | 68 +
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1349 ++
.../db/integration/aligned/IoTDBDeletionIT.java | 150 +-
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 192 +
.../aligned/IoTDBGroupByFillQueryIT.java | 989 ++
.../db/integration/env/StandaloneEnvConfig.java | 17 +
.../iotdb/session/IoTDBSessionComplexIT.java | 27 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 65 +-
library-udf/pom.xml | 159 +
.../dropwizard/DropwizardMetricManagerTest.java | 1 +
.../main/assembly/resources/conf/iotdb-metric.yml | 1 +
.../org/apache/iotdb/metrics/MetricService.java | 6 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 3 +-
.../metrics/config/MetricConfigDescriptor.java | 12 +-
.../iotdb/metrics/utils/PredefinedMetric.java | 3 +-
.../micrometer/MicrometerMetricManager.java | 11 +
.../reporter/MicrometerPrometheusReporter.java | 27 +-
.../micrometer/MicrometerMetricManagerTest.java | 1 +
openapi/src/main/openapi3/iotdb-rest.yaml | 61 +
pom.xml | 9 +-
.../resources/conf/iotdb-engine.properties | 73 +-
server/src/assembly/resources/conf/iotdb-env.bat | 2 +-
.../src/assembly/resources/sbin/start-server.bat | 10 +-
.../db/concurrent/IoTDBThreadPoolFactory.java | 10 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 2 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 194 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 79 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 247 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 16 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 46 +-
.../compaction/CompactionTaskComparator.java | 14 +-
.../engine/compaction/CompactionTaskManager.java | 61 +
.../db/engine/compaction/TsFileIdentifier.java | 12 +
.../inplace/InplaceCompactionRecoverTask.java | 11 +-
.../inplace/manage/CrossSpaceMergeResource.java | 25 +-
.../task/CleanLastCrossSpaceCompactionTask.java | 67 +
.../cross/inplace/task/CrossSpaceMergeTask.java | 19 +-
.../cross/inplace/task/MergeMultiChunkTask.java | 46 +-
.../cross/inplace/task/RecoverCrossMergeTask.java | 305 -
.../InnerSpaceCompactionExceptionHandler.java | 69 +-
.../SizeTieredCompactionRecoverTask.java | 212 +-
.../sizetiered/SizeTieredCompactionSelector.java | 6 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 139 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 573 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 251 +
.../utils/SingleSeriesCompactionExecutor.java | 328 +
.../compaction/task/AbstractCompactionTask.java | 18 +
.../compaction/task/CompactionRecoverTask.java | 2 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 28 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 21 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 11 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 120 +-
.../engine/memtable/AlignedWritableMemChunk.java | 12 +-
.../memtable/AlignedWritableMemChunkGroup.java | 7 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 17 +-
.../db/engine/memtable/PrimitiveMemTable.java | 6 +-
.../db/engine/querycontext/QueryDataSource.java | 45 +
.../engine/storagegroup/ILastFlushTimeManager.java | 89 +
.../engine/storagegroup/LastFlushTimeManager.java | 268 +
.../db/engine/storagegroup/StorageGroupInfo.java | 18 +-
.../engine/storagegroup/TsFileNameGenerator.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 159 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 23 +
.../db/engine/storagegroup/TsFileResource.java | 214 +-
...ssor.java => VirtualStorageGroupProcessor.java} | 341 +-
...eGroupManager.java => StorageGroupManager.java} | 167 +-
.../service/TriggerRegistrationService.java | 29 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 2 +-
.../org/apache/iotdb/db/metadata/MManager.java | 142 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 163 +
.../apache/iotdb/db/metadata/idtable/IDTable.java | 181 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 463 +
.../iotdb/db/metadata/idtable/IDTableManager.java | 105 +
.../db/metadata/idtable/IDiskSchemaManager.java | 45 +-
.../db/metadata/idtable/entry/DeviceEntry.java | 81 +
.../db/metadata/idtable/entry/DeviceIDFactory.java | 87 +
.../db/metadata/idtable/entry/DiskSchemaEntry.java | 107 +
.../iotdb/db/metadata/idtable/entry/IDeviceID.java | 15 +-
.../idtable/entry/InsertMeasurementMNode.java | 267 +
.../idtable/entry/PlainDeviceID.java} | 41 +-
.../db/metadata/idtable/entry/SHA256DeviceID.java | 148 +
.../db/metadata/idtable/entry/SchemaEntry.java | 193 +
.../idtable/entry/TimeseriesID.java} | 36 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 4 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 46 +-
.../counter/MeasurementGroupByLevelCounter.java | 74 +
.../apache/iotdb/db/metadata/path/AlignedPath.java | 16 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 24 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 120 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 35 +-
.../iotdb/db/metadata/template/Template.java | 13 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 8 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 26 +-
.../protocol/influxdb/input/InfluxLineParser.java | 6 +
.../rest/handler/AuthorizationHandler.java | 5 +-
.../protocol/rest/handler/QueryDataSetHandler.java | 36 +-
.../rest/handler/RequestValidationHandler.java | 9 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 169 +
.../db/protocol/rest/impl/PingApiServiceImpl.java | 1 +
.../db/protocol/rest/impl/RestApiServiceImpl.java | 50 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 126 +-
.../qp/logical/crud/GroupByFillQueryOperator.java | 2 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 151 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 13 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 50 +
.../db/qp/physical/crud/AlignByDevicePlan.java | 140 +-
.../db/qp/physical/crud/DeletePartitionPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 8 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 59 +
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 26 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 64 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 43 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 40 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 18 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 4 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 20 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 18 +
.../iotdb/db/qp/physical/crud/MeasurementInfo.java | 37 +-
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 12 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 77 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 8 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 4 +-
.../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 13 +
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 13 +
.../db/qp/physical/sys/ActivateTemplatePlan.java | 4 +-
.../db/qp/physical/sys/AlterTimeSeriesPlan.java | 4 +-
.../db/qp/physical/sys/AppendTemplatePlan.java | 6 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 4 +-
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 8 +-
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 4 +-
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 4 +-
.../qp/physical/sys/CreateContinuousQueryPlan.java | 7 +-
.../db/qp/physical/sys/CreateFunctionPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 4 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 2 +-
.../db/qp/physical/sys/CreateTemplatePlan.java | 6 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 4 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 4 +-
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 4 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 6 +-
.../qp/physical/sys/DropContinuousQueryPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/DropIndexPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 4 +-
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/KillQueryPlan.java | 2 +-
.../db/qp/physical/sys/LoadConfigurationPlan.java | 6 +-
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/LogPlan.java | 6 +-
.../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 12 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 8 +-
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 4 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 6 +-
.../db/qp/physical/sys/PruneTemplatePlan.java | 4 +-
.../db/qp/physical/sys/SetStorageGroupPlan.java | 4 +-
.../db/qp/physical/sys/SetSystemModePlan.java | 4 +-
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 4 +-
.../iotdb/db/qp/physical/sys/SettlePlan.java | 4 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 4 +-
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 4 +-
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 4 +-
.../iotdb/db/qp/physical/sys/TracingPlan.java | 2 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 4 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 4 +
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 19 +
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 13 +-
.../iotdb/db/query/context/QueryContext.java | 9 +
.../db/query/control/QueryResourceManager.java | 110 +-
.../db/query/control/tracing/TracingInfo.java | 8 +
.../db/query/control/tracing/TracingManager.java | 8 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 121 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 4 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 53 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 13 +
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 11 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 6 +-
.../dataset/groupby/GroupByEngineDataSet.java | 2 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 328 +
.../dataset/groupby/GroupByFillEngineDataSet.java | 424 -
.../groupby/GroupByFillWithValueFilterDataSet.java | 451 -
.../GroupByFillWithoutValueFilterDataSet.java | 267 -
.../groupby/GroupByWithValueFilterDataSet.java | 32 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 26 +-
.../dataset/groupby/LocalGroupByExecutor.java | 5 +-
.../db/query/executor/AggregationExecutor.java | 51 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 115 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 76 +-
.../iotdb/db/query/executor/QueryRouter.java | 44 +-
.../db/query/executor/RawDataQueryExecutor.java | 54 +-
.../iotdb/db/query/executor/UDFQueryExecutor.java | 4 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 22 +-
.../db/query/executor/fill/LastPointReader.java | 3 +-
.../query/expression/unary/FunctionExpression.java | 3 +-
...yTaskPoolManager.java => QueryTaskManager.java} | 18 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 120 +
.../metadata/MemAlignedChunkMetadataLoader.java | 4 +-
.../chunk/metadata/MemChunkMetadataLoader.java | 4 +-
.../query/reader/series/SeriesAggregateReader.java | 27 +
.../reader/series/SeriesRawDataBatchReader.java | 1 -
.../iotdb/db/query/reader/series/SeriesReader.java | 217 +-
.../reader/series/SeriesReaderByTimestamp.java | 27 +
.../query/timegenerator/ServerTimeGenerator.java | 62 +-
.../query/udf/core/layer/RawQueryInputLayer.java | 9 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 10 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +-
.../org/apache/iotdb/db/service/RPCService.java | 8 +-
.../db/service/basic/BasicServiceProvider.java | 4 +
.../apache/iotdb/db/service/metrics/Metric.java | 25 +-
.../iotdb/db/service/metrics/MetricsService.java | 112 +-
.../org/apache/iotdb/db/service/metrics/Tag.java | 15 +-
.../db/service/thrift/ProcessorWithMetrics.java | 70 +
.../service/thrift/impl/InfluxDBServiceImpl.java | 3 +-
.../db/service/thrift/impl/TSServiceImpl.java | 630 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 18 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 10 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 16 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 47 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 5 +-
.../java/org/apache/iotdb/db/utils/FileUtils.java | 24 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 26 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 15 +-
.../db/utils/datastructure/AlignedTVList.java | 51 +-
.../writelog/manager/MultiFileLogNodeManager.java | 38 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 44 +-
.../writelog/recover/TsFileRecoverPerformer.java | 8 +-
.../db/engine/cache/BloomFilterCacheTest.java | 13 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 12 +-
.../engine/compaction/CompactionSchedulerTest.java | 3035 ++--
.../compaction/CompactionTaskComparatorTest.java | 4 +-
.../engine/compaction/cross/MergeOverLapTest.java | 4 +-
.../db/engine/compaction/cross/MergeTaskTest.java | 4 +-
.../db/engine/compaction/cross/MergeTest.java | 12 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 11 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 52 +-
.../compaction/inner/InnerCompactionChunkTest.java | 246 -
.../inner/InnerCompactionMoreDataTest.java | 10 +-
.../compaction/inner/InnerCompactionTest.java | 12 +-
.../compaction/inner/InnerSeqCompactionTest.java | 988 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 9 +-
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 827 ++
....java => InnerSpaceCompactionUtilsOldTest.java} | 14 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 7 +-
.../SizeTieredCompactionHandleExceptionTest.java | 192 +-
.../SizeTieredCompactionRecoverTest.java | 448 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 12 +-
.../recover/SizeTieredCompactionRecoverTest.java | 97 +-
.../compaction/utils/CompactionCheckerUtils.java | 76 +-
.../compaction/utils/CompactionClearUtils.java | 16 +-
.../utils/CompactionFileGeneratorUtils.java | 8 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 3 +-
.../db/engine/memtable/MemTableTestUtils.java | 19 +-
.../db/engine/memtable/MemtableBenchmark.java | 11 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 81 +-
.../engine/modification/DeletionFileNodeTest.java | 50 +-
.../storagegroup/FileNodeManagerBenchmark.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 94 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 91 +-
.../engine/storagegroup/TsFileProcessorTest.java | 50 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 116 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 73 +
.../apache/iotdb/db/metadata/PartialPathTest.java | 55 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 6 +-
.../db/metadata/idtable/IDTableLogFileTest.java | 160 +
.../idtable/IDTableResourceControlTest.java | 167 +
.../db/metadata/idtable/IDTableRestartTest.java | 205 +
.../iotdb/db/metadata/idtable/IDTableTest.java | 666 +
.../db/metadata/idtable/InsertWithIDTableTest.java | 758 +
.../db/metadata/idtable/LastQueryWithIDTable.java | 180 +
.../QueryAlignedTimeseriesWithIDTableTest.java | 373 +
.../db/metadata/idtable/QueryWithIDTableTest.java | 370 +
.../db/metadata/idtable/entry/DeviceIDTest.java} | 44 +-
.../db/metadata/idtable/entry/SchemaEntryTest.java | 74 +
.../metadata/idtable/trigger_example/Counter.java | 96 +
.../db/protocol/influxdb/dto/IoTDBPointTest.java | 39 +-
.../db/protocol/rest/GrafanaApiServiceIT.java | 293 +
.../db/qp/physical/InsertTabletMultiPlanTest.java | 193 +
.../db/query/dataset/ShowTimeSeriesResultTest.java | 2 +
.../reader/series/SeriesAggregateReaderTest.java | 10 +-
.../reader/series/SeriesReaderByTimestampTest.java | 10 +-
.../db/query/reader/series/SeriesReaderTest.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 21 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 14 +-
.../db/sync/receiver/load/FileLoaderTest.java | 12 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 4 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 5 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 15 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 10 +-
.../db/writelog/recover/DeviceStringTest.java | 8 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 9 +-
.../recover/RecoverResourceFromReaderTest.java | 14 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 18 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 14 +-
.../java/org/apache/iotdb/session/Session.java | 31 +-
.../apache/iotdb/session/util/SessionUtils.java | 4 +-
.../session/IoTDBSessionDisableMemControlIT.java | 19 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 27 +-
.../session/IoTDBSessionVectorAggregationIT.java | 9 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 21 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 27 +-
.../java/org/apache/iotdb/session/SessionTest.java | 17 +-
site/src/main/.vuepress/config.js | 31 +-
.../public/img/contributor-avatar/ericpai.jpg | Bin 0 -> 265364 bytes
.../public/img/contributor-avatar/qhl.jpg | Bin 0 -> 365541 bytes
.../theme/global-components/Contributor.vue | 15 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 6 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 6 +-
.../org/apache/iotdb/spark/tool/TsFileExample.java | 10 +-
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 22 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 57 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 73 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 263 +-
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 2 +-
.../tsfile/read/filter/factory/FilterFactory.java | 4 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 21 +-
.../read/query/timegenerator/TimeGenerator.java | 3 +
.../query/timegenerator/TsFileTimeGenerator.java | 6 +
.../iotdb/tsfile/utils/MeasurementGroup.java | 15 +-
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 38 +
.../apache/iotdb/tsfile/write/TsFileWriter.java | 30 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 10 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 6 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 7 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 20 +-
...asurementSchema.java => MeasurementSchema.java} | 32 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 6 +-
.../tsfile/encoding/decoder/IntRleDecoderTest.java | 7 +-
.../regular/RegularDataEncoderLongTest.java | 4 +-
.../tsfile/file/metadata/utils/TestHelper.java | 6 +-
.../iotdb/tsfile/read/GetAllDevicesTest.java | 2 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 44 +-
.../tsfile/read/filter/FilterSerializeTest.java | 1 +
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 8 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 6 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 26 +-
.../tsfile/read/reader/FakedTimeGenerator.java | 6 +
.../apache/iotdb/tsfile/utils/FileGenerator.java | 60 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 18 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 64 +-
.../apache/iotdb/tsfile/utils/TsFileUtilsTest.java | 72 +
.../tsfile/write/DefaultSchemaTemplateTest.java | 13 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 74 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 24 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 26 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 12 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 12 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 8 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 40 +-
.../iotdb/tsfile/write/TsFileWriterTest.java | 44 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 16 +-
.../write/schema/converter/SchemaBuilderTest.java | 20 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 10 +-
.../writer/MeasurementSchemaSerializeTest.java | 14 +-
.../iotdb/tsfile/write/writer/PageWriterTest.java | 14 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 52 +-
579 files changed, 42664 insertions(+), 10390 deletions(-)
create mode 100644 .github/workflows/grafana-plugin.yml
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByFillNoVFilterDataSet.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByFillVFilterDataSet.java
copy {metrics/interface/src/main/assembly/resources/conf => cluster/src/test/resources/node1conf}/iotdb-metric.yml (53%)
copy {metrics/interface/src/main/assembly/resources/conf => cluster/src/test/resources/node2conf}/iotdb-metric.yml (53%)
copy {metrics/interface/src/main/assembly/resources/conf => cluster/src/test/resources/node3conf}/iotdb-metric.yml (53%)
copy distribution/src/assembly/{grafana.xml => grafana-connector.xml} (86%)
rename distribution/src/assembly/{grafana.xml => grafana-plugin.xml} (59%)
delete mode 100644 docs/UserGuide/Data-Concept/SDT.md
create mode 100644 docs/UserGuide/Data-Modeling/VirtualStorageGroup.md
rename docs/UserGuide/Ecosystem Integration/{Grafana.md => Grafana Connector.md} (86%)
create mode 100644 docs/UserGuide/Library-UDF/Data-Quality.md
create mode 100644 docs/UserGuide/Library-UDF/Data-Repair.md
create mode 100644 docs/UserGuide/Library-UDF/Get-Started.md
delete mode 100644 docs/zh/UserGuide/Data-Concept/SDT.md
create mode 100644 docs/zh/UserGuide/Data-Modeling/VirtualStorageGroup.md
rename docs/zh/UserGuide/Ecosystem Integration/{Grafana.md => Grafana Connector.md} (89%)
create mode 100644 docs/zh/UserGuide/Ecosystem Integration/Grafana Plugin.md
create mode 100644 docs/zh/UserGuide/Library-UDF/Data-Quality.md
create mode 100644 docs/zh/UserGuide/Library-UDF/Data-Repair.md
create mode 100644 docs/zh/UserGuide/Library-UDF/Get-Started.md
create mode 100644 example/client-cpp-example/src/AlignedTimeseriesSessionExample.cpp
rename {grafana => grafana-connector}/img/add_data_source.png (100%)
rename {grafana => grafana-connector}/img/add_graph.png (100%)
rename {grafana => grafana-connector}/img/edit_data_source.png (100%)
rename {grafana => grafana-connector}/pom.xml (99%)
rename {grafana => grafana-connector}/readme.md (93%)
rename {grafana => grafana-connector}/readme_zh.md (91%)
copy {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java (100%)
copy {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java (100%)
rename {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/conf/MyConfiguration.java (100%)
rename {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/controller/DatabaseConnectController.java (100%)
rename {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java (100%)
rename {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImpl.java (100%)
rename {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/service/DatabaseConnectService.java (100%)
rename {grafana => grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/service/impl/DatabaseConnectServiceImpl.java (100%)
rename {grafana => grafana-connector}/src/main/resources/application.properties (100%)
copy {grafana => grafana-connector}/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java (100%)
create mode 100644 grafana-plugin/.gitignore
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/.prettierrc.js (55%)
create mode 100644 grafana-plugin/CHANGELOG.md
copy LICENSE-binary => grafana-plugin/LICENSE (77%)
create mode 100644 grafana-plugin/README.md
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/jest.config.js (55%)
create mode 100644 grafana-plugin/package.json
create mode 100644 grafana-plugin/pom.xml
create mode 100644 grafana-plugin/src/ConfigEditor.tsx
create mode 100644 grafana-plugin/src/QueryEditor.tsx
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/src/componments/ControlValue.tsx (55%)
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/src/componments/Form.tsx (54%)
create mode 100644 grafana-plugin/src/componments/FromValue.tsx
create mode 100644 grafana-plugin/src/componments/SelectValue.tsx
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/src/componments/WhereValue.tsx (55%)
create mode 100644 grafana-plugin/src/datasource.ts
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/src/functions.ts (55%)
create mode 100644 grafana-plugin/src/img/logo.svg
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/src/module.ts (55%)
create mode 100644 grafana-plugin/src/plugin.json
copy server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/PingApiServiceImpl.java => grafana-plugin/src/types.ts (55%)
create mode 100644 grafana-plugin/tsconfig.json
create mode 100644 grafana-plugin/yarn.lock
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBPartialInsertionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithComplexValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryWithIDTableIT.java
rename integration/src/test/java/org/apache/iotdb/db/integration/{ => aligned}/IOTDBInsertAlignedValuesIT.java (73%)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDevice2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDeviceIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByFillQueryBigDataIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByFillQueryIT.java
create mode 100644 library-udf/pom.xml
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/task/CleanLastCrossSpaceCompactionTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/task/RecoverCrossMergeTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/MultiTsFileDeviceIterator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/utils/SingleSeriesCompactionExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/ILastFlushTimeManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/LastFlushTimeManager.java
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{StorageGroupProcessor.java => VirtualStorageGroupProcessor.java} (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/virtualSg/{VirtualStorageGroupManager.java => StorageGroupManager.java} (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/AppendOnlyDiskSchemaManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/IDTable.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/IDTableHashmapImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/IDTableManager.java
rename grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java => server/src/main/java/org/apache/iotdb/db/metadata/idtable/IDiskSchemaManager.java (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/DeviceEntry.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/DeviceIDFactory.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/DiskSchemaEntry.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/PredefinedMetric.java => server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/IDeviceID.java (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/InsertMeasurementMNode.java
copy server/src/main/java/org/apache/iotdb/db/{engine/memtable/PrimitiveMemTable.java => metadata/idtable/entry/PlainDeviceID.java} (56%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/SHA256DeviceID.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/SchemaEntry.java
copy server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/KillQueryPlan.java => metadata/idtable/entry/TimeseriesID.java} (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MeasurementGroupByLevelCounter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/GrafanaApiServiceImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillEngineDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillWithValueFilterDataSet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByFillWithoutValueFilterDataSet.java
rename server/src/main/java/org/apache/iotdb/db/query/pool/{QueryTaskPoolManager.java => QueryTaskManager.java} (82%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/pool/RawQueryReadTaskPoolManager.java
rename grafana/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java => server/src/main/java/org/apache/iotdb/db/service/metrics/Metric.java (70%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/PredefinedMetric.java => server/src/main/java/org/apache/iotdb/db/service/metrics/Tag.java (77%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/ProcessorWithMetrics.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionChunkTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsNoAlignedTest.java
rename server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/{InnerSpaceCompactionUtilsTest.java => InnerSpaceCompactionUtilsOldTest.java} (88%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableLogFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableResourceControlTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableRestartTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/InsertWithIDTableTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/LastQueryWithIDTable.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/QueryAlignedTimeseriesWithIDTableTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/QueryWithIDTableTest.java
copy server/src/{main/java/org/apache/iotdb/db/qp/physical/sys/ClearCachePlan.java => test/java/org/apache/iotdb/db/metadata/idtable/entry/DeviceIDTest.java} (51%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/entry/SchemaEntryTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/trigger_example/Counter.java
rename grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java => server/src/test/java/org/apache/iotdb/db/protocol/influxdb/dto/IoTDBPointTest.java (53%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/protocol/rest/GrafanaApiServiceIT.java
create mode 100644 site/src/main/.vuepress/public/img/contributor-avatar/ericpai.jpg
create mode 100644 site/src/main/.vuepress/public/img/contributor-avatar/qhl.jpg
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileDeviceIterator.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/utils/TsFileUtils.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/{UnaryMeasurementSchema.java => MeasurementSchema.java} (91%)
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/utils/TsFileUtilsTest.java