This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-1620
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from fd8331b fix IoTDBTriggerManagementIT
new 23e505f ...
add 109e8c0 [IOTDB-1428] Ask query threads to quit if query is timeout
(#4071)
add f79a31b [IOTDB-1793] Support insert Tablet with null value in python
client (#4080)
add a85decf [DOCUMENTATION] Add little note to clarify result of last
point query (#4082)
add bb8c7fa fix inline code format in Measurement-Template.md (#4088)
add 726f259 [IOTDB-1797][IOTDB-1799] Compatibility of Apache IoTDB with
InfluxDB - Intergration Framework (#4081)
add fd301c3 [DOCUMENTATION] fix bold syntax error (#4092)
add 8bd13e5 CI failed because of setStorageGroup in selectIntoIT (#4086)
add 25a8e98 [IOTDB-1742] Fix test bug caused by restart error of virtual
storage groups (#4083)
add 96ee5a8 [IOTDB-1372]Enhance management of TsFileResource (#4003)
add 2cb9336 fix ci (#4094)
add c179fb9 [IOTDB-1758] sync-tool, empty uuid file cause tool can not
auto-recovery (#4054)
add ed159df [IOTDB-1798] Compatibility of Apache IoTDB with InfluxDB -
`flush` / `ping` / `version` (#4091)
add c1e43e2 [IOTDB-1778] Support nullable fields in insertTablet
(cluster) (#4093)
add 2e926ab [DOCUMENTATION] fix bold syntax error (#4096)
add 5ab9e4a [IOTDB-1818] Activate dependabot on IoTDB codebase (#4097)
add 855db65 [IOTDB-1635] settle TsFiles and mods (#4024)
add a6fc68e [IOTDB-1726] Wrong hashCode() and equals() method in
ChunkMetadata (#4084)
add 3da5c6d [IOTDB-1792] Remove tomcat-embed dependency and make all
transitive dependencies versions consistent (#4077)
add 07f3912 check whether bitmap is null before spliting (#4102)
add 40397fd init dummyIndex after restart cluster (#3939)
add d1beffc [IOTDB-1818] Activate dependabot on rel/0.12 (#4105)
add bc4f548 Bump org.slf4j.version from 1.7.30 to 1.7.32 (#4100)
add edbb361 Bump maven-compiler-plugin from 3.3 to 3.8.1 (#4101)
add 4bae008 Update spark doc (#4119)
add 51a02f7 [IOTDB-1821] IT fails on IoTDBContinuousQueryIT caused by
connection broken (#4118)
add 6cf3565 Bump flink.version from 1.11.1 to 1.14.0 (#4112)
add df3c3f5 fix NPE when header node is non-existent. (#4089)
add 5011596 [IOTDB-1818] Automatically label the branch name for
dependabot's PR (#4125)
add f2d9363 Bump extra-enforcer-rules from 1.2 to 1.4 (#4122)
add e65c367 Bump metrics.version from 3.2.6 to 4.2.4 (#4123)
add a0cf15d Bump jaxb-api from 2.4.0-b180725.0427 to 2.4.0-b180830.0359
(#4113)
add 51a3049 Bump progressbar from 0.7.3 to 0.9.2 (#4115)
add 322f234 Bump powermock-api-mockito2 from 2.0.2 to 2.0.9 (#4126)
add da26938 Bump download-maven-plugin from 1.3.0 to 1.6.7 (#4127)
add d72743f [IOTDB-1825] IT fails on IoTDBTriggerExecutionIT caused by
connection broken (#4135)
add 2288b83 Bump avro from 1.7.7 to 1.10.2 (#4139)
add e1a7e13 Bump testcontainers from 1.15.2 to 1.16.0 (#4136)
add c662a3e [IOTDB-1821][IOTDB-1825] IT fails on IoTDBTriggerExecutionIT
& IoTDBContinuousQueryIT caused by connection broken (#4143)
add cbd1317 [IOTDB-1607] Optimize Tracing (#4018)
add 5935515 [IOTDB-1836] Fix Query Exception Bug after deleting all sgs
(#4159)
add 2f21431 overload SessionPool.executeQueryStatement and make it
support querying with timeout (#4150)
add 14bf48c [ISSUE-4072] Parallel insert records in Session (#4073)
add ffab5bd [IOTDB-1845] Make the test results in IoTDBTriggerExecutionIT
& IoTDBContinuousQueryIT deterministic (#4161)
add 8c97f2b [IOTDB-1848] Failed to initialize pool: Does not support
setReadOnly (#4162)
add 871d90e Revert "Bump testcontainers from 1.15.2 to 1.16.0 (#4136)"
(#4168)
add 30a8626 [IOTDB-1837] Fix tagIndex rebuild failure after upgrade mlog
from mlog.txt to mlog.bin (#4160)
add ea15331 [IOTDB-1342] modify error message about LIMIT and OFFSET used
in conjunction with the FILL clause (#4149)
add c85989c [IOTDB-1810] Compatibility of Apache IoTDB with InfluxDB -
Compatibility Scheme (#4090)
add 0c39ef6 [IOTDB-1853] Fix bug about more than one TimeseriesMetadata
in TsFile (#4170)
add 803b88d [IOTDB-1846]Fix the error when count the total number of
devices in cluster mode (#4171)
add 65c840b Bump commons-io from 2.5 to 2.11.0 (#4164)
add 7f29869 [IOTDB-1823] Support group by multi level (#4132)
add e4b7f64 [IOTDB-1857] Remove useless handle logic for CountPlan in
executeNonQuery in cluster module
add b807e4a fix compaction writer write after close (#4186)
add 1ba6410 fix doc Programming-Java-Native-API.md error (#4184)
add 2b70e2a [IOTDB-1280] Rewrite the Antlr grammar file (#4134)
add b6eb283 [IOTDB-1846] Optimize device count for rpc (#4187)
add cae2691 [IOTDB-1862] Optimize dependabot strategy (#4183)
add 516bf65 [IOTDB-1361] Support delete an aligned timeseries (#4166)
add 1dcc82a [IOTDB-1764] Support vector timeseries in raw data query in
cluster (#4182)
add 46da51d cherry-pick docker for grafana-connector from rel/0.12 (#4207)
add 181e835 [IOTDB-1844] Query support timeseries suffix matching (#4199)
add d2e4d73 [IOTDB-1747] Support for automatically creating schemas for
aligned time series in cluster module (#4218)
add cc359f5 [IOTDB-1806] Compatibility of Apache IoTDB with InfluxDB -
Data Point Insertion (#4172)
add 6359640 [ISSUE-3445] New compaction strategy and compaction
scheduling strategy (#3447)
add 955278a [IOTDB-1875] Fix the cast exception on invalid nested
aggregation (#4216)
add 890020d Add javadoc for UDF framework (#4225)
add a8d9e4b ustzh complete session unsetSchemaTemplate method (#4220)
new d116a21 merge master and fix conflits
new a03924a mvn spotless:apply
new 7090f17 g4
new 0f029b0 visitor
new 60e96af visitor
new 852705d add items into .gitignore
new 478e88d Syntax-Conventions CN
The 8 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:
.asf.yaml | 2 +-
.github/dependabot.yml | 71 +
.github/workflows/influxdb-protocol.yml | 64 +
.github/workflows/main-unix.yml | 3 +-
.github/workflows/main-win.yml | 31 +-
.github/workflows/sonar-coveralls.yml | 2 +-
.gitignore | 5 +
.mvn/wrapper/MavenWrapperDownloader.java | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4 | 951 ++++++
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 852 +++++
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 1532 ---------
cli/pom.xml | 2 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 67 +
client-cpp/pom.xml | 2 +-
client-py/SessionExample.py | 13 +
client-py/SessionTest.py | 63 +-
client-py/iotdb/Session.py | 2 +-
.asf.yaml => client-py/iotdb/utils/BitMap.py | 26 +-
client-py/iotdb/utils/Tablet.py | 87 +-
.../cluster/client/sync/SyncClientAdaptor.java | 10 +
.../iotdb/cluster/log/StableEntryManager.java | 6 +
.../cluster/log/manage/CommittedEntryManager.java | 12 +
.../manage/FilePartitionedSnapshotLogManager.java | 12 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 6 +-
.../serializable/SyncLogDequeSerializer.java | 25 +
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 13 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 85 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 138 +
.../iotdb/cluster/query/ClusterPlanRouter.java | 60 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 59 +-
.../iotdb/cluster/query/RemoteQueryContext.java | 5 +-
.../cluster/query/filter/SlotTsFileFilter.java | 5 +-
.../cluster/query/reader/ClusterReaderFactory.java | 24 +-
.../apache/iotdb/cluster/server/ClientServer.java | 6 +-
.../iotdb/cluster/server/DataClusterServer.java | 15 +
.../cluster/server/member/DataGroupMember.java | 2 +-
.../cluster/server/service/DataAsyncService.java | 12 +
.../cluster/server/service/DataSyncService.java | 9 +
.../iotdb/cluster/utils/ClusterQueryUtils.java | 43 +
.../apache/iotdb/cluster/utils/PartitionUtils.java | 5 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 14 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 2 +-
.../iotdb/cluster/integration/SingleNodeTest.java | 2 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 13 +-
.../cluster/partition/SlotPartitionTableTest.java | 37 -
.../apache/iotdb/cluster/query/BaseQueryTest.java | 9 +-
.../cluster/server/member/DataGroupMemberTest.java | 11 +-
compile-tools/thrift/pom.xml | 2 +-
docker/ReadMe.md | 44 +
.../main/DockerCompose/docker-compose-grafana.yml | 50 +
docker/src/main/Dockerfile-0.12.2-grafana | 41 +
docs/SystemDesign/StorageEngine/MergeManager.md | 6 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 10 +
.../Administration-Management/Administration.md | 8 +-
docs/UserGuide/Advanced-Features/Triggers.md | 12 +-
.../Advanced-Features/UDF-User-Defined-Function.md | 6 +-
docs/UserGuide/Appendix/SQL-Reference.md | 24 +-
docs/UserGuide/Data-Concept/Data-Type.md | 12 +-
docs/UserGuide/Data-Concept/Encoding.md | 4 +-
.../UserGuide/Data-Concept/Measurement-Template.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 18 +-
.../DML-Data-Manipulation-Language.md | 34 +-
.../IoTDB-SQL-Language/Maintenance-Command.md | 4 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 38 +-
.../System-Tools/Monitor-and-Log-Tools.md | 6 +-
.../System-Tools/Performance-Tracing-Tool.md | 56 +-
docs/UserGuide/System-Tools/Watermark-Tool.md | 2 +-
docs/zh/SystemDesign/StorageEngine/MergeManager.md | 6 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 249 ++
.../UserGuide/API/Programming-Java-Native-API.md | 16 +-
.../Administration-Management/Administration.md | 8 +-
docs/zh/UserGuide/Advanced-Features/Triggers.md | 14 +-
.../Advanced-Features/UDF-User-Defined-Function.md | 6 +-
docs/zh/UserGuide/Appendix/Config-Manual.md | 18 -
docs/zh/UserGuide/Appendix/SQL-Reference.md | 24 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 8 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 14 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 4 +-
.../UserGuide/Data-Concept/Measurement-Template.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 18 +-
.../DML-Data-Manipulation-Language.md | 28 +-
.../IoTDB-SQL-Language/Maintenance-Command.md | 3 +-
.../IoTDB-SQL-Language/Syntax-Conventions.md | 115 +
.../UserGuide/System-Tools/Load-External-Tsfile.md | 38 +-
.../System-Tools/Monitor-and-Log-Tools.md | 4 +-
.../System-Tools/Performance-Tracing-Tool.md | 58 +-
docs/zh/UserGuide/System-Tools/Watermark-Tool.md | 2 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 6 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
.../flink/tsfile/RowTsFileInputFormatTest.java | 14 +-
hive-connector/pom.xml | 4 +-
influxdb-protocol/pom.xml | 162 +
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 422 +++
.../iotdb/influxdb/IoTDBInfluxDBFactory.java | 70 +
.../iotdb/influxdb/example/InfluxDBExample.java | 102 +
.../protocol/constant/InfluxDBConstant.java | 14 +-
.../iotdb/influxdb/protocol/dto/IoTDBPoint.java | 55 +-
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 47 +-
.../protocol/impl/IoTDBInfluxDBService.java | 148 +
.../iotdb/influxdb/protocol/meta/MetaManager.java | 181 +
.../influxdb/protocol/meta/MetaManagerHolder.java | 54 +
.../influxdb/protocol/meta/TagInfoRecords.java | 85 +
.../influxdb/protocol/util/DataTypeUtils.java | 86 +
.../influxdb/protocol/util/ParameterUtils.java | 27 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 244 ++
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 22 +
.../main/java/org/apache/iotdb/jdbc/Constant.java | 12 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 6 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 25 +
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 11 +
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 6 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 16 +-
.../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 103 +
jenkins.pom | 2 +-
pom.xml | 78 +-
server/pom.xml | 3 +-
.../resources/conf/iotdb-engine.properties | 96 +-
server/src/assembly/resources/conf/logback.xml | 20 +
.../resources/tools/tsfileToolSet/settle.bat | 62 +
.../resources/tools/tsfileToolSet/settle.sh | 43 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 285 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 6 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 102 +-
.../iotdb/db/conf/adapter/CompressionRatio.java | 2 +-
.../db/cq/ContinuousQueryTaskPoolManager.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 85 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 15 +-
.../compaction/CompactionMergeTaskPoolManager.java | 195 --
.../CompactionPriority.java} | 11 +-
.../db/engine/compaction/CompactionScheduler.java | 299 ++
.../compaction/CompactionTaskComparator.java | 109 +
.../engine/compaction/CompactionTaskManager.java | 265 ++
.../db/engine/compaction/TsFileManagement.java | 460 ---
.../AbstractCrossSpaceCompactionRecoverTask.java} | 21 +-
.../AbstractCrossSpaceCompactionSelector.java | 51 +
.../cross/AbstractCrossSpaceCompactionTask.java | 96 +
.../compaction/cross/CrossCompactionStrategy.java | 117 +
.../cross/CrossSpaceCompactionTaskFactory.java | 58 +
.../inplace/InplaceCompactionRecoverTask.java | 109 +
.../cross/inplace/InplaceCompactionSelector.java | 152 +
.../cross/inplace/InplaceCompactionTask.java | 251 ++
.../inplace/manage/CrossSpaceMergeContext.java} | 6 +-
.../inplace/manage/CrossSpaceMergeResource.java} | 17 +-
.../cross/inplace}/manage/MergeFuture.java | 10 +-
.../cross/inplace}/manage/MergeManager.java | 66 +-
.../cross/inplace}/manage/MergeManagerMBean.java | 2 +-
.../cross/inplace}/manage/MergeThreadPool.java | 14 +-
.../cross/inplace}/recover/LogAnalyzer.java | 34 +-
.../cross/inplace}/recover/MergeLogger.java | 15 +-
.../selector/ICrossSpaceMergeFileSelector.java} | 4 +-
.../selector/IFileQueryMemMeasurement.java | 2 +-
.../inplace}/selector/IMergePathSelector.java | 2 +-
.../selector/MaxFileMergeFileSelector.java | 25 +-
.../selector/MaxSeriesMergeFileSelector.java | 6 +-
.../cross/inplace}/selector/MergeFileStrategy.java | 2 +-
.../cross/inplace}/selector/NaivePathSelector.java | 2 +-
.../cross/inplace/task/CrossSpaceMergeTask.java} | 40 +-
.../cross/inplace}/task/MergeCallback.java | 2 +-
.../cross/inplace}/task/MergeFileTask.java | 24 +-
.../cross/inplace}/task/MergeMultiChunkTask.java | 43 +-
.../cross/inplace/task/RecoverCrossMergeTask.java} | 24 +-
.../AbstractInnerSpaceCompactionSelector.java | 52 +
.../inner/AbstractInnerSpaceCompactionTask.java | 131 +
.../compaction/inner/InnerCompactionStrategy.java | 108 +
.../inner/InnerSpaceCompactionTaskFactory.java | 51 +
.../SizeTieredCompactionRecoverTask.java | 151 +
.../sizetiered/SizeTieredCompactionSelector.java | 200 ++
.../inner/sizetiered/SizeTieredCompactionTask.java | 239 ++
.../utils/InnerSpaceCompactionUtils.java} | 189 +-
.../utils/SizeTieredCompactionLogAnalyzer.java} | 40 +-
.../utils/SizeTieredCompactionLogger.java} | 19 +-
.../level/LevelCompactionTsFileManagement.java | 884 -----
.../no/NoCompactionTsFileManagement.java | 290 --
.../task/AbstractCompactionSelector.java} | 23 +-
.../compaction/task/AbstractCompactionTask.java | 89 +
.../compaction/task/CompactionRecoverTask.java | 101 +
.../engine/flush/pool/FlushSubTaskPoolManager.java | 1 +
.../db/engine/flush/pool/FlushTaskPoolManager.java | 1 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 16 +-
.../db/engine/modification/ModificationFile.java | 11 +
.../apache/iotdb/db/engine/settle/SettleLog.java | 116 +
.../apache/iotdb/db/engine/settle/SettleTask.java | 108 +
.../engine/storagegroup/StorageGroupProcessor.java | 661 ++--
.../db/engine/storagegroup/TsFileManager.java | 312 ++
.../engine/storagegroup/TsFileNameGenerator.java | 248 ++
.../db/engine/storagegroup/TsFileProcessor.java | 3 +
.../db/engine/storagegroup/TsFileResource.java | 248 +-
.../db/engine/storagegroup/TsFileResourceList.java | 443 +++
.../storagegroup/timeindex/DeviceTimeIndex.java | 70 +-
.../storagegroup/timeindex/FileTimeIndex.java | 24 +-
.../engine/storagegroup/timeindex/ITimeIndex.java | 24 +
.../virtualSg/HashVirtualPartitioner.java | 6 -
.../virtualSg/VirtualStorageGroupManager.java | 33 +-
.../WriteLockFailedException.java} | 9 +-
.../metadata/DifferentTemplateException.java} | 23 +-
.../metadata/NoTemplateOnMNodeException.java} | 15 +-
.../metadata/TemplateIsInUseException.java} | 15 +-
.../query/QueryTimeoutRuntimeException.java | 4 +-
.../org/apache/iotdb/db/metadata/MManager.java | 112 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 18 +-
.../iotdb/db/metadata/logfile/MLogUpgrader.java | 290 ++
.../iotdb/db/metadata/logfile/MLogWriter.java | 205 +-
.../iotdb/db/metadata/mnode/IEntityMNode.java | 19 -
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 4 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 13 -
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 10 +
.../mnode/{IEntityMNode.java => MNodeUtils.java} | 58 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 5 -
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 96 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 11 -
.../org/apache/iotdb/db/monitor/StatMonitor.java | 27 +-
.../iotdb/db/qp/constant/FilterConstant.java | 20 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 113 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 6 +-
.../qp/logical/crud/AggregationQueryOperator.java | 12 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 37 +-
.../db/qp/logical/crud/SpecialClauseComponent.java | 21 +-
.../iotdb/db/qp/logical/sys/SettleOperator.java | 71 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 3 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 81 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 3 +
.../db/qp/physical/crud/InsertTabletPlan.java | 10 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 17 +-
.../qp/physical/crud/UnsetSchemaTemplatePlan.java | 96 +
.../physical/sys/SettlePlan.java} | 56 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3450 ++++++++++----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 12 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 20 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 150 +
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 3 +-
.../iotdb/db/query/context/QueryContext.java | 79 +-
.../iotdb/db/query/control/FileReaderManager.java | 2 -
.../db/query/control/QueryResourceManager.java | 36 +-
.../iotdb/db/query/control/QueryTimeManager.java | 142 +-
.../apache/iotdb/db/query/control/TracingInfo.java | 85 -
.../iotdb/db/query/control/TracingManager.java | 229 --
.../control/tracing/TracingConstant.java} | 21 +-
.../db/query/control/tracing/TracingInfo.java | 156 +
.../db/query/control/tracing/TracingManager.java | 82 +
.../db/query/dataset/AlignByDeviceDataSet.java | 4 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 9 +-
.../dataset/groupby/GroupByEngineDataSet.java | 6 +
...ByTimeDataSet.java => GroupByLevelDataSet.java} | 59 +-
.../groupby/GroupByWithValueFilterDataSet.java | 26 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 25 +-
.../db/query/executor/AggregationExecutor.java | 33 +-
.../iotdb/db/query/executor/QueryRouter.java | 21 +-
.../db/query/executor/RawDataQueryExecutor.java | 1 +
.../query/expression/unary/FunctionExpression.java | 7 +
.../iotdb/db/query/pool/QueryTaskPoolManager.java | 2 +-
.../resource/CachedUnseqResourceMergeReader.java | 1 +
.../iotdb/db/query/reader/series/SeriesReader.java | 36 +-
.../reader/universal/PriorityMergeReader.java | 13 +-
.../iotdb/db/query/udf/core/layer/SafetyLine.java | 3 +
.../row/ElasticSerializableRowRecordList.java | 33 +-
.../row/SerializableRowRecordList.java | 8 +
.../flush/pool => rescon}/AbstractPoolManager.java | 2 +-
.../iotdb/db/rescon/TsFileResourceManager.java | 121 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 11 +-
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../org/apache/iotdb/db/service/SettleService.java | 190 ++
.../org/apache/iotdb/db/service/TSServiceImpl.java | 135 +-
.../receiver/recover/SyncReceiverLogAnalyzer.java | 2 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 2 +-
.../db/sync/sender/manage/SyncFileManager.java | 4 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 34 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 117 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 360 ++
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 73 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 261 --
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 8 +-
.../runtime/WindowEvaluationTaskPoolManager.java | 2 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 1 -
.../db/conf/adapter/CompressionRatioTest.java | 2 +-
.../org/apache/iotdb/db/constant/TestConstant.java | 30 +
.../MergeTest.java => cache/ChunkCacheTest.java} | 193 +-
.../engine/compaction/CompactionSchedulerTest.java | 2093 ++++++++++++
.../compaction/CompactionTaskComparatorTest.java | 313 ++
.../compaction/LevelCompactionMergeTest.java | 375 ---
.../engine/compaction/LevelCompactionModsTest.java | 135 -
.../compaction/LevelCompactionSelectorTest.java | 76 -
.../LevelCompactionTsFileManagementTest.java | 228 --
.../NoCompactionTsFileManagementTest.java | 235 --
.../compaction/cross/CrossSpaceCompactionTest.java | 720 ++++
.../cross}/MaxFileMergeFileSelectorTest.java | 45 +-
.../cross}/MaxSeriesMergeFileSelectorTest.java | 18 +-
.../{merge => compaction/cross}/MergeLogTest.java | 12 +-
.../cross}/MergeManagerTest.java | 40 +-
.../cross}/MergeOverLapTest.java | 67 +-
.../{merge => compaction/cross}/MergePerfTest.java | 12 +-
.../{merge => compaction/cross}/MergeTaskTest.java | 106 +-
.../{merge => compaction/cross}/MergeTest.java | 53 +-
.../cross}/MergeUpgradeTest.java | 8 +-
.../InnerCompactionCacheTest.java} | 71 +-
.../InnerCompactionChunkTest.java} | 66 +-
.../InnerCompactionLogTest.java} | 38 +-
.../InnerCompactionMoreDataTest.java} | 97 +-
.../inner/InnerCompactionSchedulerTest.java | 135 +
.../InnerCompactionTest.java} | 124 +-
.../compaction/inner/InnerSeqCompactionTest.java | 934 ++++++
.../inner/InnerSpaceCompactionUtilsTest.java | 135 +
.../compaction/inner/InnerUnseqCompactionTest.java | 780 +++++
.../SizeTieredCompactionRecoverTest.java} | 608 ++--
.../sizetiered/SizeTieredCompactionTest.java} | 103 +-
.../task/FakedCrossSpaceCompactionTask.java | 71 +
.../task/FakedCrossSpaceCompactionTaskFactory.java | 56 +
.../task/FakedInnerSpaceCompactionTask.java | 90 +
.../task/FakedInnerSpaceCompactionTaskFactory.java | 51 +
.../compaction/utils/CompactionCheckerUtils.java | 472 +++
.../compaction/utils/CompactionClearUtils.java | 59 +
.../utils/CompactionFileGeneratorUtils.java | 246 ++
.../compaction/utils/CompactionOverlapType.java} | 12 +-
.../utils/CompactionTimeseriesType.java} | 11 +-
.../engine/modification/DeletionFileNodeTest.java | 10 -
.../db/engine/modification/DeletionQueryTest.java | 12 -
.../engine/storagegroup/FakedTsFileResource.java | 76 +
.../storagegroup/StorageGroupProcessorTest.java | 49 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 12 -
.../db/engine/storagegroup/TsFileManagerTest.java | 240 ++
.../engine/storagegroup/TsFileProcessorTest.java | 15 +-
.../storagegroup/TsFileResourceListTest.java | 185 ++
.../iotdb/db/integration/IOTDBGroupByIT.java | 7 -
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 8 -
.../iotdb/db/integration/IoTDBCompleteIT.java | 9 +-
.../db/integration/IoTDBContinuousQueryIT.java | 52 +-
.../db/integration/IoTDBDeleteTimeseriesIT.java | 7 -
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 8 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 6 -
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 8 -
.../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 4 -
.../org/apache/iotdb/db/integration/IoTDBInIT.java | 24 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 7 -
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 34 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 72 +-
.../integration/IoTDBManageTsFileResourceIT.java | 292 ++
.../apache/iotdb/db/integration/IoTDBMergeIT.java | 89 +-
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 7 -
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 11 +-
.../db/integration/IoTDBMultiOverlappedPageIT.java | 7 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 7 -
.../db/integration/IoTDBMultiStatementsIT.java | 7 -
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 28 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 51 +-
.../db/integration/IoTDBOverlappedPageIT.java | 11 -
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 20 +-
.../iotdb/db/integration/IoTDBQueryTimeoutIT.java | 4 +-
.../db/integration/IoTDBRemovePartitionIT.java | 4 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 4 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 2 -
.../db/integration/IoTDBSequenceDataQueryIT.java | 20 -
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 30 -
.../IoTDBSetSystemReadOnlyWritableIT.java | 20 +-
.../apache/iotdb/db/integration/IoTDBSettleIT.java | 94 +
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 37 +
...ionIT.java => IoTDBSizeTieredCompactionIT.java} | 498 ++-
.../iotdb/db/integration/IoTDBTracingIT.java | 62 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 166 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 26 +-
.../db/integration/IoTDBUDFWindowQueryIT.java | 20 +-
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 18 +-
.../db/integration/IoTDBUDTFHybridQueryIT.java | 10 +-
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 6 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 218 +-
.../aggregation/IoTDBAggregationIT.java | 7 -
.../aggregation/IoTDBAggregationLargeDataIT.java | 7 -
.../aggregation/IoTDBAggregationSmallDataIT.java | 8 -
.../db/integration/auth/IoTDBAuthorizationIT.java | 106 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 12 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 128 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 18 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 7 +
.../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 104 +
.../iotdb/db/qp/logical/IndexLogicalPlanTest.java | 156 -
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 8 +-
.../physical/IndexSubMatchingPhysicalPlanTest.java | 163 -
.../IndexWholeMatchingPhysicalPlanTest.java | 168 -
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 30 +-
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 12 +-
.../iotdb/db/query/control/TracingManagerTest.java | 115 -
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 8 +-
.../reader/series/SeriesAggregateReaderTest.java | 9 +-
.../reader/series/SeriesReaderByTimestampTest.java | 9 +-
.../db/query/reader/series/SeriesReaderTest.java | 8 +-
.../query/reader/series/SeriesReaderTestUtil.java | 47 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 401 +++
.../db/sync/receiver/load/FileLoaderTest.java | 9 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 2 +-
.../sender/recover/SyncSenderLogAnalyzerTest.java | 2 +-
.../db/sync/sender/transfer/SyncClientTest.java | 2 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 238 ++
.../apache/iotdb/db/utils/EnvironmentUtils.java | 18 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 76 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 10 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../main/java/org/apache/iotdb/session/Config.java | 4 +
.../org/apache/iotdb/session/InsertConsumer.java | 21 +-
.../java/org/apache/iotdb/session/Session.java | 266 +-
.../apache/iotdb/session/SessionConnection.java | 21 +
.../org/apache/iotdb/session/pool/SessionPool.java | 37 +-
.../iotdb/session/{ => util}/SessionUtils.java | 2 +-
.../org/apache/iotdb/session/util/ThreadUtils.java | 45 +
.../iotdb/session/IoTDBSessionComplexIT.java | 4 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 3 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 7 +-
.../session/IoTDBSessionVectorAggregationIT.java | 7 +-
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 7 +-
.../java/org/apache/iotdb/session/SessionTest.java | 94 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 35 +-
.../apache/iotdb/session/util/ThreadUtilsTest.java | 24 +-
site/pom.xml | 12 +-
site/src/main/.vuepress/config.js | 3 +-
spark-iotdb-connector/Readme.md | 168 -
spark-tsfile/README.md | 335 --
.../test/java/org/apache/iotdb/db/sql/Cases.java | 242 +-
thrift-cluster/src/main/thrift/cluster.thrift | 8 +-
thrift/rpc-changelist.md | 22 +
thrift/src/main/thrift/rpc.thrift | 25 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 17 +-
.../read/controller/CachedChunkLoaderImpl.java | 3 +-
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 37 +-
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 126 +
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 2 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 2 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 2 +-
.../tsfile/write/chunk/VectorChunkWriterImpl.java | 3 +-
.../write/writer/RestorableTsFileIOWriter.java | 41 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
.../apache/iotdb/tsfile/constant/TestConstant.java | 4 +
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 7 +-
.../org/apache/iotdb/tsfile/read/ReadTest.java | 3 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 3 +-
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 7 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 7 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 21 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 36 +-
.../iotdb/tsfile}/utils/FilePathUtilsTest.java | 36 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 39 +-
.../tsfile/write/DefaultSchemaTemplateTest.java | 6 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 7 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 142 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 7 +-
.../iotdb/tsfile/write/TsFileWriterTest.java | 17 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 8 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 79 +-
.../write/writer/VectorChunkWriterImplTest.java | 4 +-
zeppelin-interpreter/pom.xml | 2 +-
451 files changed, 26025 insertions(+), 12622 deletions(-)
create mode 100644 .github/dependabot.yml
create mode 100644 .github/workflows/influxdb-protocol.yml
create mode 100644
antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4
create mode 100644
antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4
delete mode 100644 antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4
copy .asf.yaml => client-py/iotdb/utils/BitMap.py (69%)
create mode 100644 docker/src/main/DockerCompose/docker-compose-grafana.yml
create mode 100644 docker/src/main/Dockerfile-0.12.2-grafana
create mode 100644 docs/zh/UserGuide/API/InfluxDB-Protocol.md
create mode 100644 docs/zh/UserGuide/IoTDB-SQL-Language/Syntax-Conventions.md
create mode 100644 influxdb-protocol/pom.xml
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/IoTDBInfluxDB.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/IoTDBInfluxDBFactory.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/example/InfluxDBExample.java
rename server/src/main/java/org/apache/iotdb/db/engine/merge/package-info.java
=>
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/constant/InfluxDBConstant.java
(75%)
copy
server/src/main/java/org/apache/iotdb/db/query/reader/resource/CachedUnseqResourceMergeReader.java
=>
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/dto/IoTDBPoint.java
(51%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionStrategy.java
=>
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/dto/SessionPoint.java
(50%)
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/impl/IoTDBInfluxDBService.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/meta/MetaManager.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/meta/MetaManagerHolder.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/meta/TagInfoRecords.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/util/DataTypeUtils.java
copy
server/src/main/java/org/apache/iotdb/db/engine/merge/selector/IMergeFileSelector.java
=>
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/util/ParameterUtils.java
(61%)
create mode 100644
influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/integration/IoTDBInfluxDBIT.java
create mode 100644
jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBTracingInfo.java
create mode 100644 server/src/assembly/resources/tools/tsfileToolSet/settle.bat
copy .asf.yaml => server/src/assembly/resources/tools/tsfileToolSet/settle.sh
(56%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionMergeTaskPoolManager.java
copy
server/src/main/java/org/apache/iotdb/db/engine/{merge/selector/MergeFileStrategy.java
=> compaction/CompactionPriority.java} (84%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionScheduler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskComparator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/CompactionTaskManager.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/TsFileManagement.java
copy
server/src/main/java/org/apache/iotdb/db/engine/{merge/selector/IFileQueryMemMeasurement.java
=> compaction/cross/AbstractCrossSpaceCompactionRecoverTask.java} (66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/AbstractCrossSpaceCompactionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossCompactionStrategy.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTaskFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionRecoverTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/inplace/InplaceCompactionTask.java
rename
server/src/main/java/org/apache/iotdb/db/engine/{merge/manage/MergeContext.java
=> compaction/cross/inplace/manage/CrossSpaceMergeContext.java} (93%)
rename
server/src/main/java/org/apache/iotdb/db/engine/{merge/manage/MergeResource.java
=> compaction/cross/inplace/manage/CrossSpaceMergeResource.java} (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/manage/MergeFuture.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/manage/MergeManager.java (83%)
copy server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/manage/MergeManagerMBean.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/manage/MergeThreadPool.java (72%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/recover/LogAnalyzer.java (87%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/recover/MergeLogger.java (88%)
copy
server/src/main/java/org/apache/iotdb/db/engine/{merge/selector/IMergeFileSelector.java
=> compaction/cross/inplace/selector/ICrossSpaceMergeFileSelector.java} (90%)
copy server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/selector/IFileQueryMemMeasurement.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/selector/IMergePathSelector.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/selector/MaxFileMergeFileSelector.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/selector/MaxSeriesMergeFileSelector.java (93%)
copy server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/selector/MergeFileStrategy.java (92%)
copy server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/selector/NaivePathSelector.java (95%)
rename
server/src/main/java/org/apache/iotdb/db/engine/{merge/task/MergeTask.java =>
compaction/cross/inplace/task/CrossSpaceMergeTask.java} (84%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/task/MergeCallback.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/task/MergeFileTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross/inplace}/task/MergeMultiChunkTask.java (95%)
rename
server/src/main/java/org/apache/iotdb/db/engine/{merge/task/RecoverMergeTask.java
=> compaction/cross/inplace/task/RecoverCrossMergeTask.java} (92%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/AbstractInnerSpaceCompactionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionStrategy.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionTaskFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionRecoverTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionSelector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/inner/sizetiered/SizeTieredCompactionTask.java
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{utils/CompactionUtils.java
=> inner/utils/InnerSpaceCompactionUtils.java} (73%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{utils/CompactionLogAnalyzer.java
=> inner/utils/SizeTieredCompactionLogAnalyzer.java} (61%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{utils/CompactionLogger.java
=> inner/utils/SizeTieredCompactionLogger.java} (82%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/level/LevelCompactionTsFileManagement.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/no/NoCompactionTsFileManagement.java
copy
server/src/main/java/org/apache/iotdb/db/engine/{merge/selector/IFileQueryMemMeasurement.java
=> compaction/task/AbstractCompactionSelector.java} (59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/AbstractCompactionTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/task/CompactionRecoverTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/settle/SettleLog.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/settle/SettleTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileNameGenerator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileResourceList.java
copy
server/src/main/java/org/apache/iotdb/db/{engine/merge/manage/MergeManagerMBean.java
=> exception/WriteLockFailedException.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/merge/selector/IFileQueryMemMeasurement.java
=> exception/metadata/DifferentTemplateException.java} (66%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/merge/manage/MergeManagerMBean.java
=> exception/metadata/NoTemplateOnMNodeException.java} (69%)
rename
server/src/main/java/org/apache/iotdb/db/{engine/merge/manage/MergeManagerMBean.java
=> exception/metadata/TemplateIsInUseException.java} (69%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogUpgrader.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{IEntityMNode.java =>
MNodeUtils.java} (50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/sys/SettleOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/UnsetSchemaTemplatePlan.java
rename
server/src/main/java/org/apache/iotdb/db/{engine/merge/selector/NaivePathSelector.java
=> qp/physical/sys/SettlePlan.java} (50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/utils/GroupByLevelController.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/TracingInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/TracingManager.java
copy
server/src/main/java/org/apache/iotdb/db/{engine/merge/selector/IMergeFileSelector.java
=> query/control/tracing/TracingConstant.java} (61%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/tracing/TracingManager.java
rename
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/{GroupByTimeDataSet.java
=> GroupByLevelDataSet.java} (60%)
rename server/src/main/java/org/apache/iotdb/db/{engine/flush/pool =>
rescon}/AbstractPoolManager.java (98%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/rescon/TsFileResourceManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/SettleService.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/tools/settle/TsFileAndModSettleTool.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/FilePathUtils.java
copy server/src/test/java/org/apache/iotdb/db/engine/{merge/MergeTest.java =>
cache/ChunkCacheTest.java} (59%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionSchedulerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/CompactionTaskComparatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionMergeTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionModsTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionSelectorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/LevelCompactionTsFileManagementTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/NoCompactionTsFileManagementTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/cross/CrossSpaceCompactionTest.java
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MaxFileMergeFileSelectorTest.java (85%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MaxSeriesMergeFileSelectorTest.java (83%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeLogTest.java (87%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeManagerTest.java (75%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeOverLapTest.java (78%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergePerfTest.java (89%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeTaskTest.java (87%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeTest.java (84%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeUpgradeTest.java (95%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionCacheTest.java
=> inner/InnerCompactionCacheTest.java} (62%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{CompactionChunkTest.java
=> inner/InnerCompactionChunkTest.java} (84%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionLogTest.java
=> inner/InnerCompactionLogTest.java} (61%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionMoreDataTest.java
=> inner/InnerCompactionMoreDataTest.java} (74%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionSchedulerTest.java
copy
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionTest.java
=> inner/InnerCompactionTest.java} (75%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSeqCompactionTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerSpaceCompactionUtilsTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerUnseqCompactionTest.java
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionRecoverTest.java
=> inner/sizetiered/SizeTieredCompactionRecoverTest.java} (52%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionTest.java
=> inner/sizetiered/SizeTieredCompactionTest.java} (79%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTask.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedCrossSpaceCompactionTaskFactory.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedInnerSpaceCompactionTask.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/task/FakedInnerSpaceCompactionTaskFactory.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/CompactionCheckerUtils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/CompactionClearUtils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/CompactionFileGeneratorUtils.java
copy
server/src/{main/java/org/apache/iotdb/db/engine/merge/selector/MergeFileStrategy.java
=>
test/java/org/apache/iotdb/db/engine/compaction/utils/CompactionOverlapType.java}
(81%)
rename
server/src/{main/java/org/apache/iotdb/db/engine/merge/selector/MergeFileStrategy.java
=>
test/java/org/apache/iotdb/db/engine/compaction/utils/CompactionTimeseriesType.java}
(84%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/storagegroup/FakedTsFileResource.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileResourceListTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBManageTsFileResourceIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBSettleIT.java
rename
server/src/test/java/org/apache/iotdb/db/integration/{IoTDBLevelCompactionIT.java
=> IoTDBSizeTieredCompactionIT.java} (72%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/mlog/MLogUpgraderTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/qp/logical/IndexLogicalPlanTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/qp/physical/IndexSubMatchingPhysicalPlanTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/qp/physical/IndexWholeMatchingPhysicalPlanTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/query/control/TracingManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/rescon/ResourceManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/tools/TsFileAndModSettleToolTest.java
rename
server/src/main/java/org/apache/iotdb/db/engine/merge/selector/IFileQueryMemMeasurement.java
=> session/src/main/java/org/apache/iotdb/session/InsertConsumer.java (68%)
rename session/src/main/java/org/apache/iotdb/session/{ =>
util}/SessionUtils.java (99%)
create mode 100644
session/src/main/java/org/apache/iotdb/session/util/ThreadUtils.java
rename
server/src/main/java/org/apache/iotdb/db/engine/merge/selector/IMergeFileSelector.java
=> session/src/test/java/org/apache/iotdb/session/util/ThreadUtilsTest.java
(62%)
delete mode 100644 spark-iotdb-connector/Readme.md
delete mode 100644 spark-tsfile/README.md
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/FilePathUtils.java
rename {server/src/test/java/org/apache/iotdb/db =>
tsfile/src/test/java/org/apache/iotdb/tsfile}/utils/FilePathUtilsTest.java (72%)
