This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch expr
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from abcf608 add logs
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)
new 1a4365c Merge branch 'master' into expr
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/grafana-plugin.yml | 47 +
Jenkinsfile | 2 +-
LICENSE-binary | 4 +-
RELEASE_NOTES.md | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 18 +-
cluster/src/assembly/cluster.xml | 4 +
.../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 +
.../log/sequencing/SynchronousSequencer.java | 8 +
.../apache/iotdb/cluster/metadata/CMManager.java | 76 +-
.../partition/slot/SlotTimePartitionFilter.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 30 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 14 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 19 -
.../iotdb/cluster/query/LocalQueryExecutor.java | 26 +-
.../ClusterGroupByFillNoVFilterDataSet.java | 54 -
.../groupby/ClusterGroupByFillVFilterDataSet.java | 67 -
.../iotdb/cluster/server/ClusterRPCService.java | 8 +-
.../server/handlers/caller/ElectionHandler.java | 17 +
.../handlers/caller/ShowTimeSeriesHandler.java | 20 +-
.../cluster/server/member/DataGroupMember.java | 2 +-
.../iotdb/cluster/server/member/RaftMember.java | 12 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 83 +
.../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 +-
.../iotdb/cluster/server/member/BaseMember.java | 2 +
.../cluster/server/member/DataGroupMemberTest.java | 19 +-
.../cluster/server/member/MetaGroupMemberTest.java | 5 +-
.../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 +-
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/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 +-
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 +
docs/zh/UserGuide/System-Tools/Metric-Tool.md | 280 +-
.../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 | 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 | 31 +-
.../db/concurrent/IoTDBThreadPoolFactory.java | 10 +-
.../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 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 16 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 46 +-
.../engine/compaction/CompactionTaskManager.java | 51 +
.../inplace/manage/CrossSpaceMergeResource.java | 25 +-
.../cross/inplace/task/CrossSpaceMergeTask.java | 19 +-
.../cross/inplace/task/MergeMultiChunkTask.java | 46 +-
.../InnerSpaceCompactionExceptionHandler.java | 6 +-
.../SizeTieredCompactionRecoverTask.java | 2 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 80 +-
.../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 +-
.../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 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 23 +
.../db/engine/storagegroup/TsFileResource.java | 4 +-
...ssor.java => VirtualStorageGroupProcessor.java} | 262 +-
...eGroupManager.java => StorageGroupManager.java} | 167 +-
.../service/TriggerRegistrationService.java | 29 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 2 +-
.../org/apache/iotdb/db/metadata/MManager.java | 104 +-
.../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 | 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 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 7 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 10 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 12 +-
.../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 | 17 +-
.../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/DummyPlan.java | 2 +-
.../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 +
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 13 +-
.../db/query/control/tracing/TracingManager.java | 4 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 121 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 4 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 9 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 13 +
.../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} | 18 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 120 +
.../iotdb/db/query/reader/series/SeriesReader.java | 5 +-
.../query/timegenerator/ServerTimeGenerator.java | 4 +-
.../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 | 629 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 16 +
.../java/org/apache/iotdb/db/utils/FileUtils.java | 24 +
.../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/query/dataset/ShowTimeSeriesResultTest.java | 2 +
.../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 | 15 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 172 +-
.../tsfile/read/filter/factory/FilterFactory.java | 4 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 21 +-
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 38 +
.../tsfile/encoding/decoder/IntRleDecoderTest.java | 7 +-
.../regular/RegularDataEncoderLongTest.java | 4 +-
.../iotdb/tsfile/read/GetAllDevicesTest.java | 2 +-
.../tsfile/read/filter/FilterSerializeTest.java | 1 +
.../apache/iotdb/tsfile/utils/FileGenerator.java | 32 +-
.../apache/iotdb/tsfile/utils/TsFileUtilsTest.java | 72 +
.../tsfile/write/MetadataIndexConstructorTest.java | 61 +-
385 files changed, 33273 insertions(+), 5119 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%)
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%)
copy {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
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/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
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/utils/TsFileUtils.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/utils/TsFileUtilsTest.java
