You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2021/12/28 03:32:07 UTC
[iotdb] branch alignbydevice updated (b89eb81 -> 51663a0)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch alignbydevice
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from b89eb81 Fix CI
add e6d7c8f [IOTDB-2077] Unexpected exception when executing raw data query without VF with limit clause (#4507)
add 99f06aa [IOTDB-2017][metric] Add a new gauge implement (#4506)
add e78f1b6 [IOTDB-2088] Fix IndexOutOfBound exception in AggregationPlan.groupAggResultByLevel (#4518)
add 2c30d33 update user guide for cpp-api & disable compiling nodejs (#4515)
add 7eca660 [IOTDB-2024] Add annotation to compaction (#4523)
add d514e00 fix priority of cross space task (#4524)
add febdcb8 [IOTDB-2074] Fix NullPointerException when recovering compaction in MacOS (#4519)
add fd4c14b [IOTDB-1773] Aligned timeseries support group by query with value filter for standalone mode (#4511)
add 08e0833 [IOTDB-1952] Add IT about group by level and multi level query for new vector (#4522)
add 31548f4 [IOTDB-1852] Accelerate queryies by using statistics (#4260)
add 45a6658 [IoTDB-1989] IoTDB support insert data from Spark (#4477)
add a583ead [IOTDB-1901] Compatibility of Apache IoTDB with InfluxDB - Server-side InfluxDB Metadata Manager (#4460)
add 88f9a6b memory leak fix: replace RandomDeleteCache with LoadingCache as its size can't limit in … (#4526)
add 7aabea4 [IOTDB-2102] Push down limit to ReadTask in RawDataSetWithoutValueFilter (#4534)
add e066317 [IoTDB-2119] IoTDB CSV export tools add timestamp accuracy setting function (#4531)
add d2116cc [IOTDB-2124] the filtering condition does not take efffect for last query in cluster (#4539)
add 25c1918 [IOTDB-2072] Remove TVListAllocator to reduce the TVList mem cost (#4540)
add 4d869fe Fix all client connections are stuck bug caused by logback bug (#4545)
add 9db966c [IOTDB-1968] Mount the Metric Service as a Built-in IService (#4527)
add 64f9662 [IOTDB-2123] Accelerate recovery process (#4533)
add 1217c70 [IOTDB-1969] Remove old metric framework from iotdb-server (#4547)
add 9dd7ab2 [IOTDB-2102] Push down limit to ReadTask supporting UDF (#4548)
add 64f1e72 Bump jackson.version from 2.10.0 to 2.10.5 (#4504)
add 9d5f4bc [IOTDB-1969] Remove statistic resources of old metric framework from iotdb-server (#4551)
add 207b3e4 Fix deploying site fail caused by CI (#4553)
add 76a4fa5 [IOTDB-2129] Wrong result returned when querying by nested expressions with aliases (#4552)
add 45e4faf [IOTDB-2130] IT fails on MQTTSinkTest.onEventUsingMultiSensorsHandler (#4554)
add eaeaa52 [IOTDB-1970] Migrate the org.apache.iotdb.db.cost.statistic module to the new metric framework (#4556)
add 5483abf [IOTDB-2092] Basic support aggregation query with UDF nested (#4517)
add 9d241c7 [IOTDB-2131] Change the fill syntax (#4550)
add 9d2df64 [IOTDB-1973] Supports aggregate queries, constants, and arithmetic nested expressions in SELECT clauses (#4453)
add d6394ad [IOTDB-2135] Add configuration for influx DB RPC service (#4558)
add dd1ea14 [IOTDB-2137] Fix incorrect column num in UDTFDataSet (#4562)
add 2f12b9f Fix IT framework disable Influx DB RPC service to avoid port conflict (#4565)
add a67f1e4 [IOTDB-2139] Move example udfs to src/java package to pass cluster IT (#4569)
add ae1938e Fix connection refused using session when users forget to set client ip (#4567)
add f9e8315 [IOTDB-2122] Migrate MQTT and REST modules to `org.apache.iotdb.db.protocol` (#4564)
add 8779a95 [IOTDB-2151] Fix extreme() not supported in nested expression query (#4574)
add ff669ed [IOTDB-2152] PyClient: Override __eq__() of TSDataType, TSEncoding and Compressor to avoid unexpected comparation behaviour (#4576)
add 5d9beb4 [IOTDB-2039] Fix data redundant after too many open files exception occurs during compaction (#4498)
add 78b1ba9 [IOTDB-2136] Fix timeseries deletion issue (#4559)
add 288d8e5 rethrow other exceptions in query main thread (#4579)
add 93a2f40 [IOTDB-2141] Fix some issues in cluster test (#4571)
add 5274c99 [IOTDB-2160] Fix cluster groupby memory leak (#4582)
add 6c2c2f8 [DOC] Update TSDB-Comparison (#4588)
add 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 51663a0 Fix conflicts
No new revisions were added by this update.
Summary of changes:
.github/workflows/grafana-plugin.yml | 47 +
Jenkinsfile | 42 +-
LICENSE-binary | 4 +-
README_ZH.md | 2 +-
RELEASE_NOTES.md | 2 +-
.../protocol/influxdb}/input/InfluxLineProtocol.g4 | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 10 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 18 +-
client-py/iotdb/utils/IoTDBConstants.py | 15 +
cluster/src/assembly/cluster.xml | 4 +
cluster/src/assembly/resources/sbin/start-node.bat | 21 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 6 +
.../cluster/client/sync/SyncClientAdaptor.java | 5 +-
.../log/manage/PartitionedSnapshotLogManager.java | 15 +
.../apache/iotdb/cluster/metadata/CMManager.java | 14 +-
.../cluster/query/ClusterDataQueryExecutor.java | 6 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 7 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 19 -
.../iotdb/cluster/query/LocalQueryExecutor.java | 28 +-
.../cluster/query/aggregate/ClusterAggregator.java | 9 +-
.../ClusterGroupByFillNoVFilterDataSet.java | 54 -
.../groupby/ClusterGroupByFillVFilterDataSet.java | 67 -
.../groupby/ClusterGroupByVFilterDataSet.java | 10 +-
.../query/last/ClusterLastQueryExecutor.java | 29 +-
.../cluster/query/reader/ClusterReaderFactory.java | 13 +-
.../iotdb/cluster/server/ClusterRPCService.java | 10 +-
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 7 +-
.../server/handlers/caller/ElectionHandler.java | 17 +
.../handlers/caller/ShowTimeSeriesHandler.java | 20 +-
.../cluster/server/service/DataSyncService.java | 11 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +
.../apache/iotdb/cluster/utils/StatusUtils.java | 2 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 83 +
.../cluster/client/sync/SyncClientAdaptorTest.java | 1 +
.../iotdb/cluster/common/TestAsyncDataClient.java | 11 +
.../query/last/ClusterLastQueryExecutorTest.java | 95 +
.../iotdb/cluster/server/member/BaseMember.java | 2 +
.../resources/node1conf/iotdb-engine.properties | 1 +
.../src/test/resources/node1conf/iotdb-metric.yml | 3 +-
.../resources/node2conf/iotdb-engine.properties | 1 +
.../src/test/resources/node2conf/iotdb-metric.yml | 3 +-
.../resources/node3conf/iotdb-engine.properties | 1 +
.../src/test/resources/node3conf/iotdb-metric.yml | 3 +-
compile-tools/thrift/pom.xml | 2 +
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 | 3 +-
docker/src/main/Dockerfile-single | 1 +
docs/Download/README.md | 45 +-
docs/SystemDesign/TsFile/Format.md | 1 -
docs/UserGuide/API/Programming-Cpp-Native-API.md | 19 +-
.../Advanced-Features/Continuous-Query.md | 2 +-
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 2 +-
.../Programming-MQTT.md | 55 +-
docs/UserGuide/Comparison/TSDB-Comparison.md | 4 +-
.../{Grafana.md => Grafana Connector.md} | 22 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 53 +-
.../DML-Data-Manipulation-Language.md | 382 +-
docs/UserGuide/System-Tools/Metric-Tool.md | 310 +
docs/zh/Download/README.md | 45 +-
docs/zh/SystemDesign/TsFile/Format.md | 1 -
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 18 +-
.../Advanced-Features/Continuous-Query.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 2 +-
.../Programming-MQTT.md | 55 +-
docs/zh/UserGuide/Comparison/TSDB-Comparison.md | 4 +-
.../{Grafana.md => Grafana Connector.md} | 20 +-
.../Ecosystem Integration/Grafana Plugin.md | 236 +
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 58 +-
.../DML-Data-Manipulation-Language.md | 375 +-
docs/zh/UserGuide/System-Tools/Metric-Tool.md | 306 +
.../server/CustomizedJsonPayloadFormatter.java | 4 +-
...apache.iotdb.db.protocol.mqtt.PayloadFormatter} | 0
.../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 +
.../User.java => grafana-plugin/.prettierrc.js | 24 +-
.../CHANGELOG.md | 10 +-
LICENSE-binary => grafana-plugin/LICENSE | 105 +-
grafana-plugin/README.md | 63 +
.../User.java => grafana-plugin/jest.config.js | 26 +-
grafana-plugin/package.json | 31 +
grafana-plugin/pom.xml | 96 +
grafana-plugin/src/ConfigEditor.tsx | 101 +
grafana-plugin/src/QueryEditor.tsx | 101 +
.../src/componments/Form.tsx | 39 +-
grafana-plugin/src/componments/FromValue.tsx | 110 +
grafana-plugin/src/componments/SelectValue.tsx | 109 +
.../src/componments/WhereValue.tsx | 41 +-
grafana-plugin/src/datasource.ts | 156 +
.../User.java => grafana-plugin/src/functions.ts | 23 +-
grafana-plugin/src/img/logo.svg | 271 +
.../User.java => grafana-plugin/src/module.ts | 29 +-
grafana-plugin/src/plugin.json | 47 +
.../User.java => grafana-plugin/src/types.ts | 41 +-
grafana-plugin/tsconfig.json | 9 +
grafana-plugin/yarn.lock | 14427 +++++++++++++++++++
influxdb-protocol/pom.xml | 85 +-
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 87 +-
.../iotdb/influxdb/IoTDBInfluxDBFactory.java | 2 +-
.../iotdb/influxdb/example/InfluxDBExample.java | 36 +-
.../protocol/constant/InfluxDBConstant.java | 2 -
.../iotdb/influxdb/protocol/dto/IoTDBPoint.java | 65 -
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 52 +-
.../protocol/impl/IoTDBInfluxDBService.java | 131 +-
.../influxdb/protocol/meta/MetaManagerHolder.java | 54 -
.../influxdb/protocol/util/DataTypeUtils.java | 86 -
.../iotdb/influxdb/session/InfluxDBSession.java | 242 +
.../influxdb/integration/IoTDBInfluxDBIT.java | 94 +-
.../iotdb/db/query/udf/example/Accumulator.java | 30 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 0
.../apache/iotdb/db/query/udf/example/Counter.java | 39 +-
.../db/query/udf/example/ExampleUDFConstant.java | 24 +-
.../org/apache/iotdb/db/query/udf/example/Max.java | 0
.../iotdb/db/query/udf/example/Multiplier.java | 0
.../SlidingSizeWindowConstructorTester0.java | 0
.../SlidingSizeWindowConstructorTester1.java | 0
.../SlidingTimeWindowConstructionTester.java | 4 +-
.../db/query/udf/example/TerminateTester.java | 0
.../iotdb/db/query/udf/example/ValidateTester.java | 0
.../iotdb/integration/env/ClusterEnvBase.java | 17 +-
.../iotdb/integration/env/ClusterEnvConfig.java | 62 +-
.../apache/iotdb/integration/env/ClusterNode.java | 7 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 16 +-
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 37 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 261 +-
.../db/integration/IoTDBFlushQueryMergeIT.java | 14 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 453 +-
.../db/integration/IoTDBGroupByFillMixPathsIT.java | 160 +-
.../integration/IoTDBGroupByFillWithRangeIT.java | 14 +-
.../db/integration/IoTDBGroupByMonthFillIT.java | 55 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 28 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 54 +-
.../db/integration/IoTDBPartialInsertionIT.java | 69 +
.../IoTDBSetSystemReadOnlyWritableIT.java | 6 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 32 -
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 6 +-
.../db/integration/IoTDBUDFWindowQueryIT.java | 34 +-
.../db/integration/IoTDBUDTFHybridQueryIT.java | 12 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 78 +-
.../aggregation/IoTDBAggregationLargeDataIT.java | 81 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 48 +-
.../aggregation/IoTDBUDFNestAggregationIT.java | 550 +
.../IoTDBUserDefinedAggregationFunctionIT.java | 725 +
.../db/integration/aligned/AlignedWriteUtil.java | 7 +
.../aligned/IoTDBAggregationGroupByLevelIT.java | 303 +
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 192 +
.../aligned/IoTDBGroupByFillQueryIT.java | 989 ++
.../IoTDBGroupByQueryWithValueFilter2IT.java | 65 +
.../IoTDBGroupByQueryWithValueFilterIT.java | 1094 ++
...GroupByQueryWithValueFilterWithDeletion2IT.java | 76 +
...BGroupByQueryWithValueFilterWithDeletionIT.java | 826 ++
.../db/integration/env/StandaloneEnvConfig.java | 5 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 5 +-
integration/src/test/resources/logback.xml | 2 +-
metrics/ReadMe.md | 2 +-
.../dropwizard/DropwizardMetricManager.java | 22 +
.../dropwizard/reporter/DropwizardJmxReporter.java | 2 +
.../reporter/DropwizardPrometheusReporter.java | 2 +-
...opwizardGauge.java => DropwizardAutoGauge.java} | 46 +-
.../metrics/dropwizard/type/DropwizardGauge.java | 10 +
.../dropwizard/DropwizardMetricManagerTest.java | 19 +
.../main/assembly/resources/conf/iotdb-metric.yml | 4 +-
.../org/apache/iotdb/metrics/MetricManager.java | 13 +
.../org/apache/iotdb/metrics/MetricService.java | 6 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 9 +-
.../metrics/config/MetricConfigDescriptor.java | 12 +-
.../apache/iotdb/metrics/impl/DoNothingGauge.java | 6 +
.../iotdb/metrics/impl/DoNothingMetricManager.java | 13 +-
.../java/org/apache/iotdb/metrics/type/Gauge.java | 4 +
.../iotdb/metrics/utils/PredefinedMetric.java | 3 +-
.../micrometer/MicrometerMetricManager.java | 55 +-
.../micrometer/reporter/IoTDBJmxConfig.java} | 15 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 8 +-
.../reporter/MicrometerPrometheusReporter.java | 30 +-
...crometerGauge.java => MicrometerAutoGauge.java} | 39 +-
.../metrics/micrometer/type/MicrometerGauge.java | 10 +
.../micrometer/MicrometerMetricManagerTest.java | 26 +-
.../src/test/resources/iotdb-metric.yml | 2 +-
openapi/pom.xml | 6 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 59 +
pom.xml | 9 +-
server/pom.xml | 15 +
.../resources/conf/iotdb-engine.properties | 55 +-
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 | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 115 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 52 +-
.../db/cost/statistic/ConcurrentCircularArray.java | 67 -
.../iotdb/db/cost/statistic/Measurement.java | 423 -
.../iotdb/db/cost/statistic/MeasurementMBean.java | 60 -
.../apache/iotdb/db/engine/cache/ChunkCache.java | 16 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 46 +-
.../db/engine/compaction/CompactionScheduler.java | 3 +
.../compaction/CompactionTaskComparator.java | 2 +-
.../engine/compaction/CompactionTaskManager.java | 67 +-
.../db/engine/compaction/TsFileIdentifier.java | 12 +
.../inplace/InplaceCompactionRecoverTask.java | 11 +-
.../cross/inplace/InplaceCompactionSelector.java | 8 +
.../inplace/manage/CrossSpaceMergeResource.java | 25 +-
.../inplace/selector/MaxFileMergeFileSelector.java | 20 +
.../task/CleanLastCrossSpaceCompactionTask.java | 67 +
.../cross/inplace/task/CrossSpaceMergeTask.java | 19 +-
.../cross/inplace/task/MergeMultiChunkTask.java | 46 +-
.../cross/inplace/task/RecoverCrossMergeTask.java | 305 -
.../inner/AbstractInnerSpaceCompactionTask.java | 4 -
.../InnerSpaceCompactionExceptionHandler.java | 249 +
.../SizeTieredCompactionRecoverTask.java | 206 +-
.../sizetiered/SizeTieredCompactionSelector.java | 23 +-
.../inner/sizetiered/SizeTieredCompactionTask.java | 174 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 136 +-
.../compaction/task/AbstractCompactionTask.java | 18 +
.../apache/iotdb/db/engine/flush/FlushManager.java | 28 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 16 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 43 +-
.../engine/memtable/AlignedWritableMemChunk.java | 5 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 5 +-
.../engine/storagegroup/StorageGroupProcessor.java | 30 +-
.../db/engine/storagegroup/TsFileManager.java | 10 +
.../engine/storagegroup/TsFileNameGenerator.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 22 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 23 +
.../db/engine/storagegroup/TsFileResource.java | 26 +-
.../db/engine/storagegroup/TsFileResourceList.java | 59 +
.../exception/StorageEngineReadonlyException.java | 14 +-
.../org/apache/iotdb/db/metadata/MManager.java | 154 +-
.../apache/iotdb/db/metrics/server/JettyUtil.java | 107 -
.../iotdb/db/metrics/server/MetricsSystem.java | 82 -
.../iotdb/db/metrics/server/QueryServlet.java | 56 -
.../iotdb/db/metrics/server/ServerArgument.java | 328 -
.../iotdb/db/metrics/server/SqlArgument.java | 84 -
.../apache/iotdb/db/metrics/sink/ConsoleSink.java | 54 -
.../iotdb/db/metrics/sink/MetricsServletSink.java | 53 -
.../apache/iotdb/db/metrics/source/JvmSource.java | 50 -
.../iotdb/db/metrics/source/MetricsSource.java | 134 -
.../apache/iotdb/db/metrics/ui/MetricsPage.java | 187 -
.../apache/iotdb/db/metrics/ui/MetricsWebUI.java | 68 -
.../influxdb/constant/InfluxDBConstant.java} | 6 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 128 +-
.../protocol/influxdb}/input/InfluxLineParser.java | 21 +-
.../db/protocol/influxdb}/meta/MetaManager.java | 127 +-
.../db/protocol/influxdb}/meta/TagInfoRecords.java | 30 +-
.../{ => protocol}/mqtt/BrokerAuthenticator.java | 2 +-
.../{ => protocol}/mqtt/JSONPayloadFormatter.java | 2 +-
.../iotdb/db/{ => protocol}/mqtt/Message.java | 2 +-
.../{ => protocol}/mqtt/PayloadFormatManager.java | 2 +-
.../db/{ => protocol}/mqtt/PayloadFormatter.java | 2 +-
.../db/{ => protocol}/mqtt/PublishHandler.java | 2 +-
.../iotdb/db/{ => protocol}/rest/RestService.java | 6 +-
.../rest/filter/ApiOriginFilter.java | 2 +-
.../rest/filter/AuthorizationFilter.java | 4 +-
.../rest/filter/BasicSecurityContext.java | 2 +-
.../iotdb/db/{ => protocol}/rest/filter/User.java | 2 +-
.../db/{ => protocol}/rest/filter/UserCache.java | 2 +-
.../rest/handler/AuthorizationHandler.java | 9 +-
.../rest/handler/ExceptionHandler.java | 4 +-
.../handler/PhysicalPlanConstructionHandler.java | 4 +-
.../rest/handler/QueryDataSetHandler.java | 42 +-
.../rest/handler/RequestValidationHandler.java | 15 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 166 +
.../rest/impl/PingApiServiceImpl.java | 7 +-
.../rest/impl/RestApiServiceImpl.java | 70 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 86 +-
.../qp/logical/crud/AggregationQueryOperator.java | 38 +-
.../db/qp/logical/crud/FillClauseComponent.java | 9 +
.../db/qp/logical/crud/FillQueryOperator.java | 4 +-
.../logical/crud/GroupByFillClauseComponent.java | 9 +
.../qp/logical/crud/GroupByFillQueryOperator.java | 2 +
.../iotdb/db/qp/logical/crud/QueryOperator.java | 31 +-
.../iotdb/db/qp/logical/crud/SelectComponent.java | 29 +-
.../db/qp/logical/crud/UDAFQueryOperator.java | 179 +
...DFQueryOperator.java => UDTFQueryOperator.java} | 6 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 52 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 42 +
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 9 +
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 68 +
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 26 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 64 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 22 +-
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 12 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 60 +-
.../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 81 +
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 30 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 143 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 83 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 13 +-
...{UDFInputDataSet.java => IUDFInputDataSet.java} | 10 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 2 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 98 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 13 +
.../iotdb/db/query/dataset/UDFInputDataSet.java | 42 +-
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 67 +
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 184 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 21 +-
.../db/query/dataset/UDTFNonAlignDataSet.java | 2 +-
.../dataset/groupby/GroupByEngineDataSet.java | 5 +-
.../query/dataset/groupby/GroupByFillDataSet.java | 328 +
.../dataset/groupby/GroupByFillEngineDataSet.java | 412 -
.../groupby/GroupByFillWithValueFilterDataSet.java | 438 -
.../GroupByFillWithoutValueFilterDataSet.java | 255 -
.../groupby/GroupByWithValueFilterDataSet.java | 127 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 19 -
.../db/query/executor/AggregationExecutor.java | 28 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 20 +-
.../iotdb/db/query/executor/IQueryRouter.java | 6 +
.../iotdb/db/query/executor/QueryRouter.java | 77 +-
.../db/query/executor/RawDataQueryExecutor.java | 6 +-
...DTFQueryExecutor.java => UDFQueryExecutor.java} | 16 +-
.../apache/iotdb/db/query/executor/fill/IFill.java | 22 +-
.../iotdb/db/query/executor/fill/ValueFill.java | 44 +-
.../iotdb/db/query/expression/Expression.java | 48 +-
.../iotdb/db/query/expression/ResultColumn.java | 17 +
.../query/expression/binary/BinaryExpression.java | 24 +-
.../db/query/expression/unary/ConstantOperand.java | 6 +
.../query/expression/unary/FunctionExpression.java | 72 +-
.../query/expression/unary/NegationExpression.java | 14 +-
.../query/expression/unary/TimeSeriesOperand.java | 8 +-
.../iotdb/db/query/pool/QueryTaskPoolManager.java | 28 +
.../iotdb/db/query/reader/series/SeriesReader.java | 37 +-
.../db/query/udf/core/executor/UDTFExecutor.java | 13 +-
.../udf/core/layer/InputRowUtils.java} | 36 +-
.../db/query/udf/core/layer/LayerCacheUtils.java | 53 +-
.../layer/MultiInputColumnIntermediateLayer.java | 65 +-
.../query/udf/core/layer/RawQueryInputLayer.java | 36 +-
...InputColumnMultiReferenceIntermediateLayer.java | 10 +
...nputColumnSingleReferenceIntermediateLayer.java | 11 +-
.../udf/core/reader/ConstantLayerPointReader.java | 5 +
.../db/query/udf/core/reader/LayerPointReader.java | 2 +
.../db/query/udf/core/reader/LayerRowReader.java | 3 +
.../transformer/ArithmeticBinaryTransformer.java | 12 +-
.../transformer/ArithmeticNegationTransformer.java | 36 +-
.../db/query/udf/core/transformer/Transformer.java | 10 +-
.../core/transformer/TransparentTransformer.java | 93 +
.../core/transformer/UDFQueryRowTransformer.java | 5 +-
.../udf/core/transformer/UDFQueryTransformer.java | 14 +-
.../row/ElasticSerializableRowRecordList.java | 30 +-
.../row/SerializableRowRecordList.java | 3 +-
.../tv/ElasticSerializableBinaryTVList.java | 8 +-
.../tv/ElasticSerializableTVList.java | 47 +
.../datastructure/tv/SerializableBinaryTVList.java | 5 +-
.../tv/SerializableBooleanTVList.java | 5 +-
.../datastructure/tv/SerializableDoubleTVList.java | 5 +-
.../datastructure/tv/SerializableFloatTVList.java | 5 +-
.../datastructure/tv/SerializableIntTVList.java | 3 +-
.../datastructure/tv/SerializableLongTVList.java | 5 +-
.../apache/iotdb/db/rescon/TVListAllocator.java | 98 -
.../{RPCService.java => InfluxDBRPCService.java} | 46 +-
.../InfluxDBRPCServiceMBean.java} | 7 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 13 +-
.../org/apache/iotdb/db/service/MQTTService.java | 4 +-
.../apache/iotdb/db/service/MetricsService.java | 210 -
.../org/apache/iotdb/db/service/RPCService.java | 10 +-
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../org/apache/iotdb/db/service/StaticResps.java | 4 +-
.../db/service/basic/BasicServiceProvider.java | 16 +-
.../apache/iotdb/db/service/metrics/Metric.java | 25 +-
.../iotdb/db/service/metrics/MetricsService.java | 278 +
.../service/{ => metrics}/MetricsServiceMBean.java | 4 +-
.../statistic => service/metrics}/Operation.java | 2 +-
.../sink/Sink.java => service/metrics/Tag.java} | 15 +-
.../db/service/thrift/ProcessorWithMetrics.java | 70 +
.../handler/InfluxDBServiceThriftHandler.java | 59 +
.../handler}/RPCServiceThriftHandler.java | 4 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 155 +
.../service/{ => thrift/impl}/TSServiceImpl.java | 220 +-
.../iotdb/db/utils/AlignedValueIterator.java | 5 +-
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 149 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 9 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +
.../java/org/apache/iotdb/db/utils/FileUtils.java | 24 +
.../org/apache/iotdb/db/utils/ParameterUtils.java | 21 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 21 +
.../apache/iotdb/db/utils/RandomDeleteCache.java | 76 -
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 1 +
.../db/utils/datastructure/AlignedTVList.java | 21 +-
.../iotdb/db/utils/datastructure/TVList.java | 17 +-
.../writelog/recover/TsFileRecoverPerformer.java | 26 +-
...apache.iotdb.db.protocol.mqtt.PayloadFormatter} | 2 +-
.../src/main/resources/iotdb/ui/static/index.html | 79 -
.../main/resources/iotdb/ui/static/iotdb-logo.png | Bin 1187 -> 0 bytes
.../src/main/resources/iotdb/ui/static/webui.css | 194 -
.../db/cost/statistic/PerformanceStatTest.java | 105 -
.../compaction/CompactionTaskComparatorTest.java | 3 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 295 +
.../compaction/inner/InnerSeqCompactionTest.java | 15 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 434 +
.../inner/InnerSpaceCompactionUtilsTest.java | 3 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 4 +-
.../SizeTieredCompactionHandleExceptionTest.java | 197 +
.../SizeTieredCompactionRecoverTest.java | 694 +-
.../recover/SizeTieredCompactionRecoverTest.java | 68 +-
.../utils/CompactionFileGeneratorUtils.java | 2 +-
.../storagegroup/TsFileResourceListTest.java | 30 +
.../iotdb/db/metadata/MManagerBasicTest.java | 18 +
.../influxdb}/input/InfluxLineParserTest.java | 3 +-
.../mqtt/BrokerAuthenticatorTest.java | 2 +-
.../mqtt/JSONPayloadFormatterTest.java | 2 +-
.../mqtt/PayloadFormatManagerTest.java | 2 +-
.../db/{ => protocol}/mqtt/PublishHandlerTest.java | 2 +-
.../db/{ => protocol}/rest/IoTDBRestServiceIT.java | 2 +-
.../db/qp/physical/InsertTabletMultiPlanTest.java | 94 +
.../db/query/dataset/ShowTimeSeriesResultTest.java | 2 +
.../ElasticSerializableRowRecordListTest.java | 127 +-
.../ElasticSerializableTVListTest.java | 175 +-
.../valuefilter/RawQueryWithValueFilterTest.java | 145 +
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 18 +-
.../recover/RecoverResourceFromReaderTest.java | 54 +-
server/src/test/resources/logback.xml | 2 +-
service-rpc/pom.xml | 5 +
.../iotdb/rpc/InfluxDBSynchronizedHandler.java | 56 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 38 +
.../iotdb/rpc/StatementExecutionException.java | 7 +
.../java/org/apache/iotdb/session/Session.java | 120 +-
.../apache/iotdb/session/SessionConnection.java | 4 +
.../apache/iotdb/session/util/SessionUtils.java | 90 +
site/src/main/.vuepress/config.js | 9 +-
.../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 +-
spark-iotdb-connector/pom.xml | 36 +-
.../org/apache/iotdb/spark/db/Converter.scala | 6 +-
.../org/apache/iotdb/spark/db/DefaultSource.scala | 30 +-
.../org/apache/iotdb/spark/db/IoTDBOptions.scala | 2 +-
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 7 +-
.../iotdb/spark/db/tools/DataFrameTools.java | 162 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 2 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 32 +-
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 117 +
.../test/java/org/apache/iotdb/db/sql/Cases.java | 5 +-
.../README.md | 15 +-
{service-rpc => thrift-influxdb}/pom.xml | 90 +-
thrift-influxdb/src/main/thrift/influxdb.thrift | 92 +
.../write/UnSupportedDataTypeException.java | 2 +-
.../tsfile/read/filter/factory/FilterFactory.java | 4 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 21 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 85 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 3 +-
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 34 +-
.../tsfile/read/filter/FilterSerializeTest.java | 1 +
.../apache/iotdb/tsfile/utils/TsFileUtilsTest.java | 72 +
460 files changed, 32476 insertions(+), 8353 deletions(-)
create mode 100644 .github/workflows/grafana-plugin.yml
rename {influxdb-protocol/src/main/antlr4/org/apache/iotdb/influxdb/protocol => antlr/src/main/antlr4/org/apache/iotdb/db/protocol/influxdb}/input/InfluxLineProtocol.g4 (99%)
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
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/last/ClusterLastQueryExecutorTest.java
copy server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter => cluster/src/test/resources/node1conf/iotdb-metric.yml (94%)
copy server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter => cluster/src/test/resources/node2conf/iotdb-metric.yml (94%)
copy server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter => cluster/src/test/resources/node3conf/iotdb-metric.yml (94%)
copy distribution/src/assembly/{grafana.xml => grafana-connector.xml} (86%)
rename distribution/src/assembly/{grafana.xml => grafana-plugin.xml} (59%)
rename docs/UserGuide/Ecosystem Integration/{Grafana.md => Grafana Connector.md} (86%)
create mode 100644 docs/UserGuide/System-Tools/Metric-Tool.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/System-Tools/Metric-Tool.md
rename example/mqtt-customize/src/main/resources/META-INF/services/{org.apache.iotdb.db.mqtt.PayloadFormatter => org.apache.iotdb.db.org.apache.iotdb.db.protocol.mqtt.PayloadFormatter} (100%)
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%)
copy {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%)
rename {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/rest/filter/User.java => grafana-plugin/.prettierrc.js (67%)
rename docs/zh/UserGuide/System-Tools/Query-History-Visualization-Tool.md => grafana-plugin/CHANGELOG.md (52%)
copy LICENSE-binary => grafana-plugin/LICENSE (77%)
create mode 100644 grafana-plugin/README.md
copy server/src/main/java/org/apache/iotdb/db/rest/filter/User.java => grafana-plugin/jest.config.js (67%)
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/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/rest/filter/User.java => grafana-plugin/src/componments/WhereValue.tsx (60%)
create mode 100644 grafana-plugin/src/datasource.ts
copy server/src/main/java/org/apache/iotdb/db/rest/filter/User.java => grafana-plugin/src/functions.ts (67%)
create mode 100644 grafana-plugin/src/img/logo.svg
copy server/src/main/java/org/apache/iotdb/db/rest/filter/User.java => grafana-plugin/src/module.ts (67%)
create mode 100644 grafana-plugin/src/plugin.json
copy server/src/main/java/org/apache/iotdb/db/rest/filter/User.java => grafana-plugin/src/types.ts (57%)
create mode 100644 grafana-plugin/tsconfig.json
create mode 100644 grafana-plugin/yarn.lock
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/dto/IoTDBPoint.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/meta/MetaManagerHolder.java
delete mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/util/DataTypeUtils.java
create mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/session/InfluxDBSession.java
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/Accumulator.java (71%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/Adder.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/Counter.java (61%)
rename grafana/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java => integration/src/main/java/org/apache/iotdb/db/query/udf/example/ExampleUDFConstant.java (56%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/Max.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/Multiplier.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester0.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/SlidingSizeWindowConstructorTester1.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/SlidingTimeWindowConstructionTester.java (94%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/TerminateTester.java (100%)
rename integration/src/{test => main}/java/org/apache/iotdb/db/query/udf/example/ValidateTester.java (100%)
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/aggregation/IoTDBUDFNestAggregationIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aggregation/IoTDBUserDefinedAggregationFunctionIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationGroupByLevelIT.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 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilter2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterIT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterWithDeletion2IT.java
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithValueFilterWithDeletionIT.java
copy metrics/dropwizard-metrics/src/main/java/org/apache/iotdb/metrics/dropwizard/type/{DropwizardGauge.java => DropwizardAutoGauge.java} (52%)
copy metrics/{interface/src/main/java/org/apache/iotdb/metrics/impl/DoNothingGauge.java => micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBJmxConfig.java} (77%)
copy metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/{MicrometerGauge.java => MicrometerAutoGauge.java} (50%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/cost/statistic/ConcurrentCircularArray.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/cost/statistic/Measurement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/cost/statistic/MeasurementMBean.java
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/InnerSpaceCompactionExceptionHandler.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/write/UnSupportedDataTypeException.java => server/src/main/java/org/apache/iotdb/db/exception/StorageEngineReadonlyException.java (64%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/server/JettyUtil.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/server/MetricsSystem.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/server/QueryServlet.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/server/ServerArgument.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/server/SqlArgument.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/sink/ConsoleSink.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/sink/MetricsServletSink.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/source/JvmSource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/source/MetricsSource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/ui/MetricsPage.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metrics/ui/MetricsWebUI.java
rename server/src/main/java/org/apache/iotdb/db/{rescon/TVListAllocatorMBean.java => protocol/influxdb/constant/InfluxDBConstant.java} (85%)
copy influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/impl/IoTDBInfluxDBService.java => server/src/main/java/org/apache/iotdb/db/protocol/influxdb/dto/IoTDBPoint.java (54%)
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol => server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/input/InfluxLineParser.java (87%)
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol => server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/meta/MetaManager.java (55%)
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol => server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/meta/TagInfoRecords.java (71%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/mqtt/BrokerAuthenticator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/mqtt/JSONPayloadFormatter.java (98%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/mqtt/Message.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/mqtt/PayloadFormatManager.java (97%)
copy server/src/main/java/org/apache/iotdb/db/{ => protocol}/mqtt/PayloadFormatter.java (96%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/mqtt/PublishHandler.java (99%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/RestService.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/filter/ApiOriginFilter.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/filter/AuthorizationFilter.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/filter/BasicSecurityContext.java (96%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/filter/User.java (95%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/filter/UserCache.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/handler/AuthorizationHandler.java (90%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/handler/ExceptionHandler.java (96%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/handler/PhysicalPlanConstructionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/handler/QueryDataSetHandler.java (71%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/handler/RequestValidationHandler.java (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/protocol/rest/impl/GrafanaApiServiceImpl.java
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/impl/PingApiServiceImpl.java (88%)
rename server/src/main/java/org/apache/iotdb/db/{ => protocol}/rest/impl/RestApiServiceImpl.java (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/UDAFQueryOperator.java
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{UDFQueryOperator.java => UDTFQueryOperator.java} (91%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UDAFPlan.java
copy server/src/main/java/org/apache/iotdb/db/query/dataset/{UDFInputDataSet.java => IUDFInputDataSet.java} (77%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/dataset/UDFRawQueryInputDataSetWithoutValueFilter.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/executor/{UDTFQueryExecutor.java => UDFQueryExecutor.java} (86%)
copy server/src/main/java/org/apache/iotdb/db/{cost/statistic/Operation.java => query/udf/core/layer/InputRowUtils.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/TransparentTransformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/rescon/TVListAllocator.java
copy server/src/main/java/org/apache/iotdb/db/service/{RPCService.java => InfluxDBRPCService.java} (68%)
rename server/src/main/java/org/apache/iotdb/db/{metrics/source/Source.java => service/InfluxDBRPCServiceMBean.java} (88%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/MetricsService.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%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/MetricsService.java
rename server/src/main/java/org/apache/iotdb/db/service/{ => metrics}/MetricsServiceMBean.java (94%)
rename server/src/main/java/org/apache/iotdb/db/{cost/statistic => service/metrics}/Operation.java (96%)
rename server/src/main/java/org/apache/iotdb/db/{metrics/sink/Sink.java => service/metrics/Tag.java} (82%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/ProcessorWithMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/handler/InfluxDBServiceThriftHandler.java
rename server/src/main/java/org/apache/iotdb/db/service/{ => thrift/handler}/RPCServiceThriftHandler.java (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InfluxDBServiceImpl.java
rename server/src/main/java/org/apache/iotdb/db/service/{ => thrift/impl}/TSServiceImpl.java (90%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/utils/DataTypeUtils.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/write/UnSupportedDataTypeException.java => server/src/main/java/org/apache/iotdb/db/utils/ParameterUtils.java (62%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/RandomDeleteCache.java
rename server/src/main/resources/META-INF/services/{org.apache.iotdb.db.mqtt.PayloadFormatter => org.apache.iotdb.db.protocol.mqtt.PayloadFormatter} (93%)
delete mode 100644 server/src/main/resources/iotdb/ui/static/index.html
delete mode 100644 server/src/main/resources/iotdb/ui/static/iotdb-logo.png
delete mode 100644 server/src/main/resources/iotdb/ui/static/webui.css
delete mode 100644 server/src/test/java/org/apache/iotdb/db/cost/statistic/PerformanceStatTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionExceptionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionHandleExceptionTest.java
rename {influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/protocol => server/src/test/java/org/apache/iotdb/db/protocol/influxdb}/input/InfluxLineParserTest.java (97%)
rename server/src/test/java/org/apache/iotdb/db/{ => protocol}/mqtt/BrokerAuthenticatorTest.java (97%)
rename server/src/test/java/org/apache/iotdb/db/{ => protocol}/mqtt/JSONPayloadFormatterTest.java (98%)
rename server/src/test/java/org/apache/iotdb/db/{ => protocol}/mqtt/PayloadFormatManagerTest.java (96%)
rename server/src/test/java/org/apache/iotdb/db/{ => protocol}/mqtt/PublishHandlerTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/{ => protocol}/rest/IoTDBRestServiceIT.java (99%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/query/valuefilter/RawQueryWithValueFilterTest.java
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/InfluxDBSynchronizedHandler.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 spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/tools/DataFrameTools.java
create mode 100644 spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/IoTDBWriteTest.scala
rename docs/UserGuide/System-Tools/Query-History-Visualization-Tool.md => thrift-influxdb/README.md (50%)
copy {service-rpc => thrift-influxdb}/pom.xml (52%)
create mode 100644 thrift-influxdb/src/main/thrift/influxdb.thrift
rename server/src/main/java/org/apache/iotdb/db/mqtt/PayloadFormatter.java => tsfile/src/main/java/org/apache/iotdb/tsfile/utils/TsFileUtils.java (59%)
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/utils/TsFileUtilsTest.java