This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch expr
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f505f20 before add log sequencer
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)
add 3a6ce23 [IOTDB-1887] Fix importing csv data containing null throws
exception (#4241)
add a5185a0 [IOTDB-1651]add reconnect to solve out of sequence (#4087)
(#4246)
add 5ad6a4b [IOTDB-1880] Compatibility of Apache IoTDB with InfluxDB -
Data Record Insertion (#4231)
add 52869f4 [IOTDB-1731]Fix sync error between different os (#4245)
add 85d2a4a [IOTDB-1884] Distinguish between zero and null values in sum
aggregation (#4233)
add b5ef4d8 [IOTDB-1620] Support backtick (`) character and double quotes
(") to quote identifiers (#4243)
add 461d22b [IOTDB-1280] Solve the performance reduction caused by syntax
error in SLL prediction mode (#4234)
new 918a705 Merge branch 'master' into expr
new 4edae81 add interface
new 6df34d6 add async sequencer
new d2f2645 add sequencer factory
new d1dfe4b5 Merge branch 'extract_sequencer' into expr
new e6c29bc merge sequencer
new 2240029 fix client in LogDispatcher
new f9a5f89 control voting list size
new ba4355a add RESPONSE_OUT_OF_WINDOW
The 9 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 +
.gitignore | 5 +
.mvn/wrapper/MavenWrapperDownloader.java | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4 | 950 ++++++
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 836 +++++
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 1602 ---------
cli/pom.xml | 2 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 67 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 88 +-
client-cpp/pom.xml | 2 +-
.../cluster/client/sync/SyncClientAdaptor.java | 10 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 10 +
.../org/apache/iotdb/cluster/expr/ExprBench.java | 88 +-
.../org/apache/iotdb/cluster/expr/ExprMember.java | 7 +-
.../org/apache/iotdb/cluster/expr/ExprServer.java | 5 +
.../apache/iotdb/cluster/expr/SequencerExpr.java | 339 +-
.../apache/iotdb/cluster/expr/VotingLogList.java | 10 +
.../iotdb/cluster/log/IndirectLogDispatcher.java | 8 +-
.../java/org/apache/iotdb/cluster/log/Log.java | 7 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 97 +-
.../iotdb/cluster/log/StableEntryManager.java | 6 +
.../cluster/log/logtypes/PhysicalPlanLog.java | 14 +-
.../cluster/log/manage/CommittedEntryManager.java | 12 +
.../manage/FilePartitionedSnapshotLogManager.java | 12 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 10 +-
.../serializable/SyncLogDequeSerializer.java | 25 +
.../log/sequencing/AsynchronousSequencer.java | 148 +
.../iotdb/cluster/log/sequencing/LogSequencer.java | 30 +-
.../log/sequencing/LogSequencerFactory.java | 10 +-
.../log/sequencing/SynchronousSequencer.java | 109 +
.../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 | 57 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 53 +-
.../cluster/query/filter/SlotTsFileFilter.java | 5 +-
.../cluster/query/reader/ClusterReaderFactory.java | 24 +-
.../iotdb/cluster/server/DataClusterServer.java | 15 +
.../org/apache/iotdb/cluster/server/Response.java | 1 +
.../handlers/caller/AppendNodeEntryHandler.java | 8 +
.../cluster/server/member/DataGroupMember.java | 10 +-
.../cluster/server/member/MetaGroupMember.java | 10 +-
.../iotdb/cluster/server/member/RaftMember.java | 174 +-
.../apache/iotdb/cluster/server/monitor/Timer.java | 36 +-
.../cluster/server/service/DataAsyncService.java | 12 +
.../cluster/server/service/DataSyncService.java | 9 +
.../iotdb/cluster/utils/ClusterQueryUtils.java | 43 +
.../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 +-
.../cluster/server/member/MetaGroupMemberTest.java | 4 +-
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 +-
.../Data-Concept/Data-Model-and-Terminology.md | 70 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 18 +-
.../DML-Data-Manipulation-Language.md | 12 +-
.../IoTDB-SQL-Language/Syntax-Conventions.md | 115 +
.../UserGuide/System-Tools/Load-External-Tsfile.md | 38 +-
.../System-Tools/Monitor-and-Log-Tools.md | 2 +-
.../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 | 216 +-
.../UserGuide/API/Programming-Java-Native-API.md | 16 +-
.../Administration-Management/Administration.md | 8 +-
docs/zh/UserGuide/Advanced-Features/Triggers.md | 12 +-
.../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 +-
.../Data-Concept/Data-Model-and-Terminology.md | 69 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 18 +-
.../DML-Data-Manipulation-Language.md | 12 +-
.../IoTDB-SQL-Language/Syntax-Conventions.md | 116 +
.../UserGuide/System-Tools/Load-External-Tsfile.md | 38 +-
.../System-Tools/Monitor-and-Log-Tools.md | 10 +-
.../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 | 29 +
.../influxdb/protocol/input/InfluxLineProtocol.g4 | 93 +
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 172 +-
.../iotdb/influxdb/IoTDBInfluxDBFactory.java | 17 +-
.../iotdb/influxdb/example/InfluxDBExample.java | 2 +-
.../protocol/constant/InfluxDBConstant.java | 14 +-
.../iotdb/influxdb/protocol/dto/IoTDBPoint.java | 55 +-
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 47 +-
.../protocol/impl/IoTDBInfluxDBService.java | 148 +
.../influxdb/protocol/input/InfluxLineParser.java | 165 +
.../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 +
.../util/ParameterUtils.java} | 4 +-
.../influxdb/integration/IoTDBInfluxDBIT.java | 136 +-
.../protocol/input/InfluxLineParserTest.java | 55 +
.../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 | 4 +
.../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 103 +
jenkins.pom | 2 +-
pom.xml | 76 +-
server/pom.xml | 3 +-
.../resources/conf/iotdb-engine.properties | 91 +-
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 | 277 +-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 6 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 96 +-
.../iotdb/db/conf/adapter/CompressionRatio.java | 2 +-
.../db/cq/ContinuousQueryTaskPoolManager.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 35 +-
.../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} | 20 +-
.../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 | 899 -----
.../no/NoCompactionTsFileManagement.java | 298 --
.../task/AbstractCompactionSelector.java} | 22 +-
.../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 | 546 ++--
.../db/engine/storagegroup/TsFileManager.java | 312 ++
.../engine/storagegroup/TsFileNameGenerator.java | 248 ++
.../db/engine/storagegroup/TsFileProcessor.java | 3 +
.../db/engine/storagegroup/TsFileResource.java | 246 +-
.../db/engine/storagegroup/TsFileResourceList.java | 443 +++
.../storagegroup/timeindex/DeviceTimeIndex.java | 2 +-
.../storagegroup/timeindex/FileTimeIndex.java | 2 +-
.../virtualSg/VirtualStorageGroupManager.java | 33 +-
.../WriteLockFailedException.java} | 9 +-
.../metadata/DifferentTemplateException.java} | 23 +-
.../metadata/NoTemplateOnMNodeException.java} | 15 +-
.../metadata/TemplateIsInUseException.java} | 15 +-
.../org/apache/iotdb/db/metadata/MManager.java | 110 +-
.../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 +-
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 36 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../iotdb/db/qp/constant/FilterConstant.java | 20 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 96 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 3 +
.../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 +
.../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 | 3435 ++++++++++----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 31 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 20 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 150 +
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 3 +-
.../db/query/aggregation/impl/SumAggrResult.java | 70 +-
.../iotdb/db/query/context/QueryContext.java | 9 +
.../iotdb/db/query/control/FileReaderManager.java | 2 -
.../db/query/control/QueryResourceManager.java | 34 +-
.../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/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 | 24 +-
.../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 +-
.../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 | 106 +-
.../receiver/recover/SyncReceiverLogAnalyzer.java | 2 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 46 +-
.../db/sync/sender/manage/SyncFileManager.java | 4 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 59 +-
.../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} | 196 +-
.../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 | 62 +-
.../{merge => compaction/cross}/MergePerfTest.java | 12 +-
.../{merge => compaction/cross}/MergeTaskTest.java | 79 +-
.../{merge => compaction/cross}/MergeTest.java | 50 +-
.../cross}/MergeUpgradeTest.java | 8 +-
.../InnerCompactionCacheTest.java} | 71 +-
.../InnerCompactionChunkTest.java} | 66 +-
.../InnerCompactionLogTest.java} | 38 +-
.../InnerCompactionMoreDataTest.java} | 102 +-
.../inner/InnerCompactionSchedulerTest.java | 135 +
.../InnerCompactionTest.java} | 121 +-
.../compaction/inner/InnerSeqCompactionTest.java | 934 ++++++
.../inner/InnerSpaceCompactionUtilsTest.java | 135 +
.../compaction/inner/InnerUnseqCompactionTest.java | 780 +++++
.../SizeTieredCompactionRecoverTest.java} | 580 ++--
.../sizetiered/SizeTieredCompactionTest.java} | 100 +-
.../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 | 48 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 9 -
.../db/engine/storagegroup/TsFileManagerTest.java | 240 ++
.../engine/storagegroup/TsFileProcessorTest.java | 15 +-
.../storagegroup/TsFileResourceListTest.java | 185 ++
.../iotdb/db/integration/IOTDBGroupByIT.java | 156 +-
.../integration/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 8 -
.../iotdb/db/integration/IoTDBArithmeticIT.java | 7 +-
.../db/integration/IoTDBContinuousQueryIT.java | 48 +-
.../db/integration/IoTDBCreateStorageGroupIT.java | 2 +-
.../db/integration/IoTDBDeleteTimeseriesIT.java | 7 -
.../iotdb/db/integration/IoTDBDeletionIT.java | 16 +-
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 8 +-
.../apache/iotdb/db/integration/IoTDBFillIT.java | 6 -
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 10 +-
.../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 | 62 +-
.../integration/IoTDBManageTsFileResourceIT.java | 15 +-
.../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/IoTDBQuotedPathIT.java | 35 +-
.../db/integration/IoTDBRemovePartitionIT.java | 4 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 4 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 7 -
.../IoTDBSetSystemReadOnlyWritableIT.java | 20 +-
.../apache/iotdb/db/integration/IoTDBSettleIT.java | 94 +
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 39 +-
...ionIT.java => IoTDBSizeTieredCompactionIT.java} | 498 ++-
.../iotdb/db/integration/IoTDBTracingIT.java | 62 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 314 +-
.../db/integration/IoTDBTriggerManagementIT.java | 172 +-
.../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 | 222 +-
.../aggregation/IoTDBAggregationIT.java | 7 -
.../aggregation/IoTDBAggregationLargeDataIT.java | 7 -
.../aggregation/IoTDBAggregationSmallDataIT.java | 10 +-
.../db/integration/auth/IoTDBAuthorizationIT.java | 118 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 12 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 113 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 18 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 30 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 7 +
.../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 104 +
.../iotdb/db/monitor/IoTDBStatMonitorTest.java | 4 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 4 +-
.../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 | 36 +-
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 12 +-
.../iotdb/db/query/control/TracingManagerTest.java | 115 -
.../iotdb/db/query/dataset/ListDataSetTest.java | 2 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 2 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 8 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 9 +-
.../dataset/groupby/GroupByTimeDataSetTest.java | 9 +-
.../query/reader/series/SeriesReaderTestUtil.java | 47 +-
.../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 | 12 +-
.../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 | 252 +-
.../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 | 12 +-
.../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 | 6 +-
spark-iotdb-connector/Readme.md | 168 -
spark-tsfile/README.md | 335 --
.../test/java/org/apache/iotdb/db/sql/Cases.java | 190 +-
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 +-
.../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 +-
456 files changed, 25177 insertions(+), 13288 deletions(-)
create mode 100644 .github/dependabot.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
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/sequencing/AsynchronousSequencer.java
copy
server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeCallback.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/log/sequencing/LogSequencer.java
(51%)
copy
server/src/main/java/org/apache/iotdb/db/engine/merge/manage/MergeManagerMBean.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/log/sequencing/LogSequencerFactory.java
(74%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/log/sequencing/SynchronousSequencer.java
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/UserGuide/IoTDB-SQL-Language/Syntax-Conventions.md
create mode 100644 docs/zh/UserGuide/IoTDB-SQL-Language/Syntax-Conventions.md
create mode 100644
influxdb-protocol/src/main/antlr4/org/apache/iotdb/influxdb/protocol/input/InfluxLineProtocol.g4
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/input/InfluxLineParser.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
rename
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/{IoTDBInfluxDBUtils.java
=> protocol/util/ParameterUtils.java} (94%)
create mode 100644
influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/protocol/input/InfluxLineParserTest.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/IMergeFileSelector.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/IMergeFileSelector.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/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} (58%)
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 (80%)
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 (89%)
rename server/src/test/java/org/apache/iotdb/db/engine/{merge =>
compaction/cross}/MergeTest.java (85%)
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} (73%)
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} (54%)
rename
server/src/test/java/org/apache/iotdb/db/engine/compaction/{LevelCompactionTest.java
=> inner/sizetiered/SizeTieredCompactionTest.java} (80%)
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/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/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%)
