You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2021/06/15 08:30:59 UTC
[iotdb] branch ChunkCacheCaffeine updated (03cd911 -> 72f5d89)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ChunkCacheCaffeine
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 03cd911 add license binary
add 8d3819f update test and doc and fix small bug (#3281)
add 363bda9 Fix TotalSeriesNumber in MManager counted twice when recovering (#3276)
add beefb2e do not select unseq files when there are unmerged old unseq files (#3273)
add 8b1ee93 Fix typo (#3287)
add 084c3b8 [IOTDB-3268] Add the Chinese version of TSDB-Comparison document (#3274)
add 5ea3c2e fix import csv split by comma bug (#3253)
add 275918e jdbc - get col type bug (#3220)
add 1aaf21d Enable sonar-coveralls for pr from fork repos (#3293)
add 915fb43 Enable sonar-coveralls for pr from fork repos (#3293)
add d381f97 Skip testContainer in unix and sonar workflow to accelerate CI (#3272)
add e19ad05 [IOTDB-1412] Unclear exception message thrown when executing empty InsertTabletPlan (#3296)
add 622a9c4 [IOTDB-1403] Dictionary encoding for TEXT (#3218)
add bc6fc68 Fix `Could not find ref: master in refs/heads` in sonar github action workflow(#3301)
add 5e199b5 Revert "Fix `Could not find ref: master in refs/heads` in sonar github action workflow(#3301)" (#3302)
add 92aedfe [IOTDB-1411] thriftMaxFrameSize and thriftDefaultBufferSize does not in effect (#3295)
add a99bf9c Enable sonar-coveralls for pr from fork repos (#3293)
add 91d3690 [IOTDB-1414]NPE occurred when call getStorageGroupNodeByPath() method using not exist path
add 4bfac46 [ISSUE-3309] Fix InsertRecordsOfOneDevice runs too slow (#3310)
add 1616737 Enable sonar-coveralls for pr from fork repos (#3293)
add 22086d3 Bug Fix: Overlapped data should be consumed first (#3270)
add 9883106 Fix group by data inconsistence bug (#3317)
add 17f10e3 add query last data interface (#3219)
add fdbf23d Disable pull_request_target for sonar check since it cannot load any PR revision information (#3314)
add d06988e Add comments for JMX_LOCAL (#3323)
add 41fbd19 [IOTDB-1391] Add a new Aggregation function ext (#3289)
add 4f7f6d0 Fix TsFileV3 doc figure in SystemDesign\TsFile\Format.md (#3327)
add 245f188 enable the client library test for all changes (#3328)
add 6c4b801 [IOTDB-1400] Support arithmetic operations in SELECT clauses (#3288)
add f9d9cba [ISSUE-3335] Fix the bug of start-cli.sh -e mode can't work with wildcard * (#3336)
add 22d8e0d Fix bug in disable align it (#3333)
add d55a204 Try to fix sg dead lock (#3340)
add e700129 [ISSUE-3132]modify pom to avoid download moquette-broker from Bintary (#3345)
add 4bb101c upgrade netty and claim exclusion for enforcer check (#3347)
add 52f7248 fix file name format issue in tests (#3351)
add 73d37e6 [WIP] Fix dictionary encoding test bug (#3357)
add ce3f42b Enable coveralls check for the commit pushed into master branch (#3360)
add 11c942a [IOTDB-1405] Refactor MManager for new vector interfaces (#3300)
add 28cccc6 [IOTDB-1422] Support partial insert for new vector interfaces (#3361)
add 6e80aa0 Session example create time series method use attributes (#3363)
add dc3fc32 move pull schema methods from CMManagercode to MetaPuller (#3325)
add f059700 [IOTDB-1396] Restructure logical query operator (#3267)
add 80f5aff Fix compaction lock with query (#3365)
add 66918f3 Remove the broken cached leader connection & optimize the insertRecords method in session (#3364)
add 82755b3 [IOTDB-1430] Ensure only one vector in one MetadataIndexTree (#3375)
add 06001d1 [IOTDB-1426] Restructure physicalGenerator (#3369)
add 30c37cf Revert "fix import csv split by comma bug (#3253)"
add f6c4162 Update some English system design documents (#3379)
add fe983ed [IOTDB-1429]fix failsafe-plugin not report failures issue (#3374)
add 1b15d1e fix iotdb-env.bat not working (#3382)
add 8c518ae Fix throw exception, easy to find bugs.
add 80850fb [IOTDB-1420] Fix compaction ttl bug (#3385)
add ff645f6 Change PPMC to PMC; Update PMC and Committer Information (#3390)
add 03e920e [IOTDB-1433] Fix bug in getMetadataAndEndOffset when querying non-exist device (#3391)
add 03f534d [IOTDB-1432] fix level compaction loss data (#3396)
add b472b3a Change the default primitive array size to 32 (#3398)
add e728789 Add java doc (#3401)
add ec12bb0 [IOTDB-1439] Update user guide documents according to the new interfaces (#3402)
add 6384f07 [IOTDB-1437]Fix the tsfile sketch tool NPE (#3397)
add 72f5d89 fix conflicts
No new revisions were added by this update.
Summary of changes:
.github/workflows/client.yml | 15 +-
.github/workflows/e2e.yml | 2 +-
.github/workflows/main-unix.yml | 2 +-
.github/workflows/sonar-coveralls.yml | 20 +-
LICENSE-binary | 22 +-
README.md | 2 +-
README_ZH.md | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 12 +-
cli/pom.xml | 1 +
cli/src/assembly/resources/sbin/start-cli.sh | 1 +
client-cpp/src/main/Session.cpp | 8 +-
client-cpp/src/main/Session.h | 4 +-
client-py/iotdb/utils/IoTDBConstants.py | 3 +-
cluster/pom.xml | 14 +-
.../iotdb/cluster/coordinator/Coordinator.java | 2 +
.../cluster/log/applier/AsyncDataLogApplier.java | 2 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 8 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 4 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 229 +-----
.../apache/iotdb/cluster/metadata/MetaPuller.java | 173 +++++
.../cluster/query/ClusterPhysicalGenerator.java | 15 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 13 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 16 +
.../cluster/server/member/DataGroupMember.java | 4 +
.../iotdb/cluster/utils/ClusterQueryUtils.java | 5 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 2 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 2 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 6 +-
.../cluster/log/applier/DataLogApplierTest.java | 8 +-
.../cluster/log/logtypes/SerializeLogTest.java | 2 +-
.../query/ClusterPhysicalGeneratorTest.java | 20 +-
.../query/groupby/MergeGroupByExecutorTest.java | 10 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 11 +-
.../cluster/server/member/DataGroupMemberTest.java | 12 +-
.../cluster/server/member/MetaGroupMemberTest.java | 6 +-
cross-tests/pom.xml | 1 +
distribution/pom.xml | 13 -
docker/src/main/Dockerfile-cluster | 5 +-
docker/src/main/Dockerfile-single | 5 +-
docs/SystemDesign/DataQuery/QueryFundamentals.md | 16 +-
.../QueryEngine/ResultSetConstruction.md | 12 +-
docs/SystemDesign/SchemaManager/SchemaManager.md | 8 +-
docs/SystemDesign/StorageEngine/DataPartition.md | 2 +-
docs/SystemDesign/StorageEngine/FlushManager.md | 2 +-
docs/SystemDesign/StorageEngine/MergeManager.md | 11 +-
docs/SystemDesign/StorageEngine/StorageEngine.md | 6 +-
docs/SystemDesign/StorageEngine/WAL.md | 4 +-
docs/SystemDesign/TsFile/Format.md | 25 +-
docs/SystemDesign/TsFile/Read.md | 16 +-
docs/SystemDesign/TsFile/Write.md | 16 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 15 +-
docs/UserGuide/Appendix/SQL-Reference.md | 27 +-
docs/UserGuide/Comparison/TSDB-Comparison.md | 135 ++--
docs/UserGuide/Data-Concept/Encoding.md | 7 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DDL-Data-Definition-Language.md | 25 -
.../DML-Data-Manipulation-Language.md | 53 +-
docs/zh/SystemDesign/TsFile/Format.md | 5 +-
.../UserGuide/API/Programming-Java-Native-API.md | 21 +-
docs/zh/UserGuide/Appendix/SQL-Reference.md | 20 +-
docs/zh/UserGuide/Comparison/TSDB-Comparison.md | 403 ++++++++++
docs/zh/UserGuide/Data-Concept/Encoding.md | 8 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 2 +-
.../DDL-Data-Definition-Language.md | 25 -
.../DML-Data-Manipulation-Language.md | 55 +-
...e.java => AlignedTimeseriesSessionExample.java} | 110 ++-
.../main/java/org/apache/iotdb/SessionExample.java | 17 +-
grafana/pom.xml | 1 +
hadoop/pom.xml | 19 +
hive-connector/pom.xml | 4 +
jdbc/pom.xml | 1 +
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 4 +-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 3 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 3 +
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 8 +-
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 2 +-
pom.xml | 9 +-
server/pom.xml | 22 +-
.../resources/conf/iotdb-engine.properties | 2 +-
server/src/assembly/resources/conf/iotdb-env.bat | 28 +-
server/src/assembly/resources/conf/iotdb-env.sh | 1 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 33 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 5 +
.../db/engine/cache/TimeSeriesMetadataCache.java | 39 +
.../db/engine/compaction/TsFileManagement.java | 8 +-
.../level/LevelCompactionTsFileManagement.java | 7 +
.../engine/compaction/utils/CompactionUtils.java | 285 +++----
.../apache/iotdb/db/engine/flush/FlushManager.java | 7 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 9 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 37 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 14 +-
.../merge/selector/MaxFileMergeFileSelector.java | 9 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 1 +
.../db/engine/querycontext/QueryDataSource.java | 5 +
.../db/engine/querycontext/ReadOnlyMemChunk.java | 4 +
.../engine/storagegroup/StorageGroupProcessor.java | 207 +++--
.../db/engine/storagegroup/TsFileProcessor.java | 61 +-
.../db/engine/storagegroup/TsFileResource.java | 43 +-
.../storagegroup/timeindex/TimeIndexLevel.java | 3 +
.../virtualSg/HashVirtualPartitioner.java | 1 +
.../virtualSg/VirtualStorageGroupManager.java | 16 +-
.../version/SimpleFileVersionController.java | 1 +
.../exception/query/LogicalOptimizeException.java | 7 +-
.../apache/iotdb/db/metadata/MLogTxtWriter.java | 2 +-
.../org/apache/iotdb/db/metadata/MManager.java | 206 +++--
.../java/org/apache/iotdb/db/metadata/MTree.java | 132 ++--
.../org/apache/iotdb/db/metadata/MetaUtils.java | 15 +-
.../iotdb/db/metadata/VectorPartialPath.java | 6 +
.../iotdb/db/metadata/logfile/MLogWriter.java | 8 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 32 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 19 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 26 +-
.../iotdb/db/metadata/template/Template.java | 65 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 7 +-
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 2 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 23 +-
.../iotdb/db/qp/constant/FilterConstant.java | 95 +++
.../apache/iotdb/db/qp/constant/SQLConstant.java | 75 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 111 +--
.../org/apache/iotdb/db/qp/logical/Operator.java | 115 +--
.../apache/iotdb/db/qp/logical/RootOperator.java | 30 -
.../qp/logical/crud/AggregationQueryOperator.java | 130 ++++
.../db/qp/logical/crud/BasicFunctionOperator.java | 26 +-
.../db/qp/logical/crud/BasicOperatorType.java | 24 +-
.../db/qp/logical/crud/DeleteDataOperator.java | 10 +
.../crud/FillClauseComponent.java} | 15 +-
.../db/qp/logical/crud/FillQueryOperator.java | 77 ++
.../iotdb/db/qp/logical/crud/FilterOperator.java | 81 +-
.../crud/{FromOperator.java => FromComponent.java} | 12 +-
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 7 +-
.../crud/GroupByClauseComponent.java} | 63 +-
.../crud/GroupByFillClauseComponent.java} | 15 +-
.../qp/logical/crud/GroupByFillQueryOperator.java | 72 ++
.../db/qp/logical/crud/GroupByQueryOperator.java | 68 ++
.../iotdb/db/qp/logical/crud/InOperator.java | 16 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 41 +
.../db/qp/logical/crud/LastQueryOperator.java | 64 ++
.../iotdb/db/qp/logical/crud/QueryOperator.java | 658 ++++++++++------
.../{SelectOperator.java => SelectComponent.java} | 17 +-
.../db/qp/logical/crud/SpecialClauseComponent.java | 129 ++++
.../logical/crud/UDFQueryOperator.java} | 36 +-
.../iotdb/db/qp/logical/crud/WhereComponent.java | 24 +-
.../db/qp/logical/sys/AlterTimeSeriesOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 20 +-
.../db/qp/logical/sys/ClearCacheOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/CountOperator.java | 27 +
.../db/qp/logical/sys/CreateFunctionOperator.java | 14 +-
.../db/qp/logical/sys/CreateIndexOperator.java | 10 +
.../db/qp/logical/sys/CreateSnapshotOperator.java | 14 +-
.../qp/logical/sys/CreateTimeSeriesOperator.java | 23 +-
.../db/qp/logical/sys/CreateTriggerOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/DataAuthOperator.java | 12 +-
.../db/qp/logical/sys/DeletePartitionOperator.java | 14 +-
.../qp/logical/sys/DeleteStorageGroupOperator.java | 12 +-
.../qp/logical/sys/DeleteTimeSeriesOperator.java | 12 +-
.../db/qp/logical/sys/DropFunctionOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/DropIndexOperator.java | 10 +
.../db/qp/logical/sys/DropTriggerOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/FlushOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/KillQueryOperator.java | 14 +-
.../qp/logical/sys/LoadConfigurationOperator.java | 13 +-
.../iotdb/db/qp/logical/sys/LoadDataOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/MergeOperator.java | 19 +-
.../iotdb/db/qp/logical/sys/MoveFileOperator.java | 14 +-
.../db/qp/logical/sys/RemoveFileOperator.java | 14 +-
.../db/qp/logical/sys/SetStorageGroupOperator.java | 12 +-
.../iotdb/db/qp/logical/sys/SetTTLOperator.java | 14 +-
.../db/qp/logical/sys/ShowChildNodesOperator.java | 11 +
.../db/qp/logical/sys/ShowChildPathsOperator.java | 11 +
.../db/qp/logical/sys/ShowDevicesOperator.java | 10 +
.../db/qp/logical/sys/ShowFunctionsOperator.java | 11 +
...odesOperator.java => ShowLockInfoOperator.java} | 6 +-
.../db/qp/logical/sys/ShowMergeStatusOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/ShowOperator.java | 28 +-
.../qp/logical/sys/ShowStorageGroupOperator.java | 11 +
.../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 8 +
.../db/qp/logical/sys/ShowTimeSeriesOperator.java | 15 +
.../db/qp/logical/sys/ShowTriggersOperator.java | 11 +
.../db/qp/logical/sys/StartTriggerOperator.java | 14 +-
.../db/qp/logical/sys/StopTriggerOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/TracingOperator.java | 14 +-
.../{SetTTLOperator.java => UnSetTTLOperator.java} | 21 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 8 -
.../db/qp/physical/crud/AlignByDevicePlan.java | 2 +-
.../db/qp/physical/crud/CreateTemplatePlan.java | 32 +-
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 9 -
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 4 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 51 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 95 ++-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 15 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 2 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 45 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 5 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 23 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 68 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 28 +-
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 4 +-
...StorageGroupPlan.java => ShowLockInfoPlan.java} | 6 +-
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 6 +-
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 4 +-
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 4 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 356 +++++----
.../iotdb/db/qp/strategy/LogicalChecker.java | 80 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 54 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 836 +--------------------
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 38 +-
.../qp/strategy/optimizer/DnfFilterOptimizer.java | 22 +-
.../optimizer/MergeSingleFilterOptimizer.java | 4 +-
.../qp/strategy/optimizer/RemoveNotOptimizer.java | 21 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 28 +-
.../db/query/aggregation/AggregationType.java | 8 +-
.../db/query/aggregation/impl/CountAggrResult.java | 24 +-
...ValueAggrResult.java => ExtremeAggrResult.java} | 111 ++-
.../db/query/dataset/AlignByDeviceDataSet.java | 6 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 160 ++--
.../iotdb/db/query/executor/LastQueryExecutor.java | 4 +-
.../db/query/executor/fill/LastPointReader.java | 1 +
.../iotdb/db/query/expression/Expression.java | 5 -
.../query/expression/binary/BinaryExpression.java | 18 +-
.../query/expression/unary/FunctionExpression.java | 20 -
...inusExpression.java => NegationExpression.java} | 14 +-
.../query/expression/unary/TimeSeriesOperand.java | 10 -
.../db/query/factory/AggregateResultFactory.java | 20 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 32 +-
.../transformer/ArithmeticAdditionTransformer.java | 30 +-
.../transformer/ArithmeticBinaryTransformer.java | 110 +++
.../transformer/ArithmeticDivisionTransformer.java | 30 +-
.../transformer/ArithmeticModuloTransformer.java} | 20 +-
.../ArithmeticMultiplicationTransformer.java | 30 +-
...mer.java => ArithmeticNegationTransformer.java} | 22 +-
.../ArithmeticSubtractionTransformer.java | 30 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 81 +-
.../iotdb/db/sink/local/LocalIoTDBHandler.java | 2 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 15 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 19 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 +
.../iotdb/db/writelog/recover/LogReplayer.java | 16 +-
.../org/apache/iotdb/db/constant/TestConstant.java | 4 +
.../compaction/LevelCompactionMergeTest.java | 68 ++
.../db/engine/compaction/LevelCompactionTest.java | 59 ++
.../db/engine/memtable/MemTableTestUtils.java | 6 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 9 +-
.../engine/merge/MaxFileMergeFileSelectorTest.java | 73 ++
.../iotdb/db/engine/merge/MergeTaskTest.java | 4 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 9 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 4 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 4 +-
.../db/integration/IOTDBInsertAlignedValuesIT.java | 4 +
...iltinFunctionIT.java => IoTDBArithmeticIT.java} | 214 +++---
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 21 +-
.../iotdb/db/integration/IoTDBEncodingIT.java | 56 ++
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 6 +-
.../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 103 ++-
.../db/integration/IoTDBOverlappedPageIT.java | 86 ++-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 39 +
.../db/integration/IoTDBUDTFHybridQueryIT.java | 2 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 4 +-
.../aggregation/IoTDBAggregationIT.java | 61 ++
.../aggregation/IoTDBAggregationLargeDataIT.java | 64 ++
.../aggregation/IoTDBAggregationSmallDataIT.java | 80 ++
.../iotdb/db/metadata/MManagerBasicTest.java | 361 +++++----
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 18 +-
.../iotdb/db/qp/logical/IndexLogicalPlanTest.java | 14 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 121 ++-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 50 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 38 +-
.../db/query/aggregation/AggregateResultTest.java | 25 +
.../iotdb/db/tools/TsFileSketchToolTest.java | 49 +-
service-rpc/pom.xml | 1 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 8 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +-
session/pom.xml | 1 +
.../java/org/apache/iotdb/session/Session.java | 240 ++++--
.../apache/iotdb/session/SessionConnection.java | 69 +-
.../org/apache/iotdb/session/SessionDataSet.java | 2 +-
.../iotdb/session/pool/SessionDataSetWrapper.java | 3 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 33 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 33 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 438 ++++++++++-
.../java/org/apache/iotdb/session/SessionUT.java | 17 +-
site/src/main/.vuepress/config.js | 6 +
.../theme/global-components/Contributor.vue | 53 +-
spark-iotdb-connector/pom.xml | 26 +
testcontainer/pom.xml | 1 +
.../test/java/org/apache/iotdb/db/sql/Cases.java | 225 ++++--
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 2 +
thrift/src/main/thrift/rpc.thrift | 36 +-
tsfile/pom.xml | 1 +
.../iotdb/tsfile/encoding/decoder/Decoder.java | 2 +
.../tsfile/encoding/decoder/DictionaryDecoder.java | 86 +++
.../tsfile/encoding/encoder/DictionaryEncoder.java | 115 +++
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 18 +
.../iotdb/tsfile/file/header/ChunkHeader.java | 3 +
.../file/metadata/MetadataIndexConstructor.java | 14 +-
.../tsfile/file/metadata/VectorChunkMetadata.java | 2 +
.../file/metadata/VectorTimeSeriesMetadata.java | 14 +
.../tsfile/file/metadata/enums/TSEncoding.java | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../read/reader/chunk/VectorChunkReader.java | 20 +-
.../tsfile/read/reader/page/ValuePageReader.java | 8 +
.../tsfile/read/reader/page/VectorChunkReader.java | 21 -
.../tsfile/read/reader/page/VectorPageReader.java | 7 +
.../apache/iotdb/tsfile/write/TsFileWriter.java | 12 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 74 +-
.../write/schema/VectorMeasurementSchema.java | 93 +--
.../encoding/decoder/DictionaryDecoderTest.java | 85 +++
.../iotdb/tsfile/file/metadata/utils/Utils.java | 73 --
...easurementChunkMetadataListMapIteratorTest.java | 5 +
zeppelin-interpreter/pom.xml | 6 +
315 files changed, 7672 insertions(+), 4328 deletions(-)
create mode 100644 docs/zh/UserGuide/Comparison/TSDB-Comparison.md
rename example/session/src/main/java/org/apache/iotdb/{VectorSessionExample.java => AlignedTimeseriesSessionExample.java} (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/constant/FilterConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/RootOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/AggregationQueryOperator.java
copy server/src/main/java/org/apache/iotdb/db/qp/{physical/crud/GroupByTimeFillPlan.java => logical/crud/FillClauseComponent.java} (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/FillQueryOperator.java
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{FromOperator.java => FromComponent.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/qp/{physical/crud/GroupByTimePlan.java => logical/crud/GroupByClauseComponent.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/qp/{physical/crud/GroupByTimeFillPlan.java => logical/crud/GroupByFillClauseComponent.java} (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByFillQueryOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByQueryOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/LastQueryOperator.java
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{SelectOperator.java => SelectComponent.java} (90%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SpecialClauseComponent.java
copy server/src/main/java/org/apache/iotdb/db/{query/udf/core/transformer/UDFQueryRowTransformer.java => qp/logical/crud/UDFQueryOperator.java} (53%)
copy hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java => server/src/main/java/org/apache/iotdb/db/qp/logical/crud/WhereComponent.java (66%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{ShowChildNodesOperator.java => ShowLockInfoOperator.java} (86%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/sys/{SetTTLOperator.java => UnSetTTLOperator.java} (69%)
copy server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{ShowStorageGroupPlan.java => ShowLockInfoPlan.java} (86%)
copy server/src/main/java/org/apache/iotdb/db/query/aggregation/impl/{LastValueAggrResult.java => ExtremeAggrResult.java} (50%)
rename server/src/main/java/org/apache/iotdb/db/query/expression/unary/{MinusExpression.java => NegationExpression.java} (82%)
copy grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java => server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticAdditionTransformer.java (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticBinaryTransformer.java
copy grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java => server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticDivisionTransformer.java (63%)
copy server/src/main/java/org/apache/iotdb/db/{qp/physical/sys/ShowChildNodesPlan.java => query/udf/core/transformer/ArithmeticModuloTransformer.java} (63%)
copy grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java => server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticMultiplicationTransformer.java (63%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{RawQueryPointTransformer.java => ArithmeticNegationTransformer.java} (71%)
copy grafana/src/main/java/org/apache/iotdb/web/grafana/bean/TimeValues.java => server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticSubtractionTransformer.java (63%)
copy server/src/test/java/org/apache/iotdb/db/integration/{IoTDBUDTFBuiltinFunctionIT.java => IoTDBArithmeticIT.java} (51%)
copy example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteWithTablet.java => server/src/test/java/org/apache/iotdb/db/tools/TsFileSketchToolTest.java (78%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/decoder/DictionaryDecoder.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/DictionaryEncoder.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/page/VectorChunkReader.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/decoder/DictionaryDecoderTest.java