This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a change to branch tsfile_v4
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 613c583 Init commit
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 0f333db Merge master
add c61d67a Fix output
add 57438a2 Fix more tests
add 60da0c3 Merge remote-tracking branch 'origin/tsfile_v4' into tsfile_v4
No new revisions were added by this update.
Summary of changes:
.github/workflows/grafana-plugin.yml | 47 +
Jenkinsfile | 2 +-
LICENSE-binary | 4 +-
RELEASE_NOTES.md | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 18 +-
.../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 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 62 +-
.../partition/slot/SlotTimePartitionFilter.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 30 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 14 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 19 -
.../ClusterGroupByFillNoVFilterDataSet.java | 54 -
.../groupby/ClusterGroupByFillVFilterDataSet.java | 67 -
.../cluster/server/member/DataGroupMember.java | 2 +-
.../iotdb/cluster/server/member/RaftMember.java | 101 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 2 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 4 +-
.../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 +-
.../mult/AssignPathManagedMergeReaderTest.java | 3 +-
.../reader/mult/RemoteMultSeriesReaderTest.java | 3 +-
.../cluster/server/member/DataGroupMemberTest.java | 19 +-
.../cluster/server/member/MetaGroupMemberTest.java | 10 +-
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/UserGuide/API/Programming-Cpp-Native-API.md | 62 +-
docs/UserGuide/Appendix/Config-Manual.md | 38 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 107 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 4 +-
docs/UserGuide/Data-Concept/Encoding.md | 4 +-
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 55 +
.../{Grafana.md => Grafana Connector.md} | 22 +-
.../DML-Data-Manipulation-Language.md | 492 +-
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/zh/Download/README.md | 45 +-
docs/zh/SystemDesign/StorageEngine/Recover.md | 4 +-
.../zh/SystemDesign/StorageEngine/StorageEngine.md | 2 +-
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 80 +-
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 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 3 +-
.../UserGuide/Data-Modeling/VirtualStorageGroup.md | 53 +
.../{Grafana.md => Grafana Connector.md} | 20 +-
.../Ecosystem Integration/Grafana Plugin.md | 250 +
.../DML-Data-Manipulation-Language.md | 494 +-
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 +
.../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 | 31 +
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 | 14427 +++++++++++++++++++
.../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 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 5 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 6 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 275 +-
.../db/integration/IoTDBGroupByFillMixPathsIT.java | 759 +-
.../integration/IoTDBGroupByFillWithRangeIT.java | 14 +-
.../db/integration/IoTDBGroupByMonthFillIT.java | 55 +-
.../apache/iotdb/db/integration/IoTDBMergeIT.java | 24 +-
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 75 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 6 +-
.../db/integration/IoTDBPartialInsertionIT.java | 69 +
.../db/integration/IoTDBQueryWithIDTableIT.java | 289 +
.../iotdb/db/integration/IoTDBRestartIT.java | 55 -
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 38 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 12 +-
.../aligned/IoTDBAggregationGroupByLevelIT.java | 12 +-
.../IoTDBAggregationWithoutValueFilterIT.java | 18 +-
.../integration/aligned/IoTDBAlignByDevice2IT.java | 68 +
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1349 ++
.../db/integration/aligned/IoTDBDeletionIT.java | 88 +-
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 192 +
.../aligned/IoTDBGroupByFillQueryIT.java | 989 ++
.../db/integration/env/StandaloneEnvConfig.java | 17 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 2 +-
library-udf/pom.xml | 163 +
openapi/src/main/openapi3/iotdb-rest.yaml | 61 +
pom.xml | 9 +-
.../resources/conf/iotdb-engine.properties | 31 +-
.../org/apache/iotdb/db/concurrent/ThreadName.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 76 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 35 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 218 +-
.../compaction/task/CompactionRecoverTask.java | 2 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 5 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 11 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 86 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 17 +-
.../db/engine/memtable/PrimitiveMemTable.java | 6 +-
.../engine/storagegroup/ILastFlushTimeManager.java | 89 +
.../engine/storagegroup/LastFlushTimeManager.java | 268 +
.../db/engine/storagegroup/StorageGroupInfo.java | 18 +-
.../db/engine/storagegroup/TsFileProcessor.java | 82 +-
.../db/engine/storagegroup/TsFileResource.java | 4 +-
...ssor.java => VirtualStorageGroupProcessor.java} | 241 +-
...eGroupManager.java => StorageGroupManager.java} | 167 +-
.../service/TriggerRegistrationService.java | 29 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 2 +-
.../org/apache/iotdb/db/metadata/MManager.java | 26 +-
.../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 +
.../idtable/IDiskSchemaManager.java} | 43 +-
.../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 | 14 +-
.../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 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 7 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 10 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 13 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 113 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 4 +-
.../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 | 33 +-
.../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 | 14 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 43 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 36 +-
.../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 | 4 +-
.../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/utils/DatetimeUtils.java | 19 +
.../db/query/control/tracing/TracingManager.java | 4 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 121 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 4 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 9 +-
.../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 | 4 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 4 +-
.../db/query/executor/AggregationExecutor.java | 6 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 4 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 64 +-
.../iotdb/db/query/executor/QueryRouter.java | 44 +-
.../db/query/executor/RawDataQueryExecutor.java | 14 +-
.../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} | 46 +-
...nager.java => RawQueryReadTaskPoolManager.java} | 34 +-
.../reader/series/SeriesRawDataBatchReader.java | 1 -
.../iotdb/db/query/reader/series/SeriesReader.java | 32 +-
.../query/timegenerator/ServerTimeGenerator.java | 4 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 10 +-
.../db/service/basic/BasicServiceProvider.java | 4 +
.../service/thrift/impl/InfluxDBServiceImpl.java | 3 +-
.../db/service/thrift/impl/TSServiceImpl.java | 621 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 16 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 11 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 44 +-
.../writelog/recover/TsFileRecoverPerformer.java | 8 +-
.../recover/SizeTieredCompactionRecoverTest.java | 4 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 3 +-
.../db/engine/memtable/MemTableTestUtils.java | 6 +-
.../db/engine/memtable/MemtableBenchmark.java | 7 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 31 +-
.../engine/modification/DeletionFileNodeTest.java | 10 +-
.../storagegroup/FileNodeManagerBenchmark.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 4 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 56 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 55 +-
.../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/sync/receiver/load/FileLoaderTest.java | 12 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 3 +-
.../recover/RecoverResourceFromReaderTest.java | 2 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 6 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 2 +-
.../java/org/apache/iotdb/session/Session.java | 27 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 27 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 4 -
site/src/main/.vuepress/config.js | 21 +-
.../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 | 11 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../iotdb/tsfile/file/metadata/TsFileMetadata.java | 2 +-
.../metadataIndex/MetadataIndexConstructor.java | 21 +-
.../metadata/metadataIndex/MetadataIndexType.java | 2 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 319 +-
.../read/controller/MetadataQuerierByFileImpl.java | 17 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 21 +-
.../tsfile/encoding/decoder/IntRleDecoderTest.java | 7 +-
.../regular/RegularDataEncoderLongTest.java | 4 +-
.../iotdb/tsfile/read/GetAllDevicesTest.java | 2 +-
.../tsfile/read/TsFileRestorableReaderTest.java | 2 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 16 +-
.../write/BPlusTreeIndexConstructorTest.java | 4 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 46 +-
338 files changed, 31777 insertions(+), 5020 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 distribution/src/assembly/{grafana.xml => grafana-connector.xml} (86%)
rename distribution/src/assembly/{grafana.xml => grafana-plugin.xml} (59%)
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
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
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%)
rename {grafana =>
grafana-connector}/src/main/java/org/apache/iotdb/web/grafana/TsfileWebDemoApplication.java
(100%)
rename {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/IoTDBQueryWithIDTableIT.java
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/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} (93%)
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
copy
server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/KillQueryPlan.java =>
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
tsfile/src/main/java/org/apache/iotdb/tsfile/file/metadata/metadataIndex/MetadataIndexType.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/IDeviceID.java
(79%)
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/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
copy
server/src/main/java/org/apache/iotdb/db/query/pool/{QueryTaskPoolManager.java
=> QueryTaskManager.java} (60%)
rename
server/src/main/java/org/apache/iotdb/db/query/pool/{QueryTaskPoolManager.java
=> RawQueryReadTaskPoolManager.java} (73%)
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
