This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch cluster-
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 12ad291 [cluster-refactor]split DataGroupServiceImpls into engine and
impls (#4062)
add 2d86da2 Merge remote-tracking branch 'origin/master'
add 1c6af88 Merge remote-tracking branch 'origin/master'
add 15a5e68 [IOTDB-1647] Nested Expressions in `SELECT` clauses (#4012)
add ffadb30 improve TagLogFile force flush (#4020)
add ceafab1 [IOTDB-1694] change name for loading dir and add an IT for
loading dir (#3985)
add 84a018d [IOTDB-1636]change sync version check to major version (#3984)
add 9c3da93 [IOTDB-1578] Set unsequnce when loading TsFile with the same
establish time (#4021)
add 9dd88f0 [IOTDB-1581] Consider deletions when recovering
tsFileResource of incomplete tsfile (#3804)
add 10aea61 [IOTDB-1719] client-cpp should firstly use thrift head files
in thrift src (#4009)
add c8d0da8 [IOTDB-1720] client-cpp: enhance Session codes (#4010)
add 07abef0 [IOTDB-1718] correct the position of "chmod + cmake" (#4007)
add 45248d4 Merge remote-tracking branch 'origin/master'
add f864bc6 [INFRA-22355] Enable GitHub wiki (#4023)
add 69ce3e5 Merge remote-tracking branch 'origin/master'
add 6cda81b enable github issue
add 1b7add1 enable github issues
add 5c7eb25 [IOTDB-1733] Fix dropping built-in function (#4026)
add 96b5269 [IOTDB-1730] client-cpp, enhance session::insertTablet()
etc.'s performance (#4022)
add 31c8b07 UserGuideReadme.md: fix "In Progress Version" link (#4029)
add 8ce16e9 Improve ContributeGuide.md and HowToCommit.md (#4030)
add a9f582e [IOTDB-1634][IOTDB-1571] Extend more aligned timeseries
insert APIs && Fix aligned timeseries wal cannot recover (#3917)
add bc3b736 [IOTDB-1026] Support wildcard ** in Path And Replace
PrefixPath usage with PathPattern in IOTDB-SQL (#3918)
add 8996333 [IOTDB-1736] Fix error code is not printed in TSServiceImpl's
log (#4035)
add 87e1ae4 fix template doc display (#4038)
add a10a170 [IOTDB-1739] Constant timeseries generating functions (const,
pi and e) (#4033)
add 33d5c0f [ISSUE-3891]: Fix typo in sync_storage_groups use doc (#4046)
add 8e5519d [ISSUE-4047]: Generic type in Statistics extend Serializable
(#4048)
add 05b9b0e [IOTDB-1037] set rpc_compression as a parameter in JDBC URL
(#3988)
add 30e8a07 [IOTDB-1738] Cache paths list in batched insert plan (#4034)
add 1e12e65 Fix typo in jdbc/IoTDBStatement.java (#4051)
add 8e54838 [IOTDB-1638] Support vector in aggregation query (#4005)
add 5a1b4c0 [IOTDB-1514] Support null in insertTablet (#3995)
add 0163d3a [IOTDB-1749] sync-tool's lockInstance() dose not take effect
(#4052)
add 4b34a9c [ISSUE-4059]: IoTDBSqlVisitor#visitTopClause add top range
restriction (#4060)
add 01b8d0f fix usage of removeNode (#4061)
add bd8ac6e Update user manual configuration information (#4013)
add a931968 [ISSUE-4069] update sql reference link in README.md and
README_ZH.md (#4070)
add 6d1fd1f [IOTDB-1675][IOTDB-1785] Introduce UnaryMeasurementMNode and
MultiMeasurementMNode (#4056)
add d4babb2 [ISSUE-4065] Reduce JSONPayloadFormatter#format deserialize
measurements times (#4066)
add cbbdc6c fix cpp client ci on macos (#4074)
new 5f98024 merge with master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 5 +-
.github/workflows/client.yml | 1 +
README.md | 2 +-
README_ZH.md | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 13 +-
client-cpp/src/main/CMakeLists.txt | 5 +-
client-cpp/src/main/Session.cpp | 413 ++--
client-cpp/src/main/Session.h | 313 ++--
.../java/org/apache/iotdb/cluster/ClientMain.java | 6 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 2 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 8 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 6 +-
.../log/manage/PartitionedSnapshotLogManager.java | 11 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 118 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 32 +-
.../iotdb/cluster/partition/PartitionTable.java | 4 +-
.../cluster/query/ClusterPhysicalGenerator.java | 7 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 19 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 15 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 5 +-
.../cluster/query/ClusterUDTFQueryExecutor.java | 31 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 4 +-
.../query/aggregate/ClusterAggregateExecutor.java | 30 +-
.../caller/PullMeasurementSchemaHandler.java | 4 +-
.../cluster/server/member/MetaGroupMember.java | 2 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 4 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 8 +-
.../query/ClusterAggregateExecutorTest.java | 8 +-
.../cluster/server/member/DataGroupMemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 2 +-
compile-tools/thrift/pom.xml | 38 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 8 +-
docs/Development/ContributeGuide.md | 12 +-
docs/Development/HowToCommit.md | 18 +
docs/SystemDesign/SchemaManager/SchemaManager.md | 2 +-
docs/UserGuide/API/Programming-JDBC.md | 2 +
docs/UserGuide/Advanced-Features/Select-Into.md | 8 +
.../Advanced-Features/UDF-User-Defined-Function.md | 12 +-
docs/UserGuide/Appendix/SQL-Reference.md | 121 +-
.../Collaboration-of-Edge-and-Cloud/Sync-Tool.md | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 23 +-
.../DDL-Data-Definition-Language.md | 69 +-
.../DML-Data-Manipulation-Language.md | 793 ++++----
docs/UserGuide/UserGuideReadme.md | 2 +-
docs/zh/Development/ContributeGuide.md | 10 +
docs/zh/Development/HowToCommit.md | 18 +
.../zh/SystemDesign/SchemaManager/SchemaManager.md | 2 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +
docs/zh/UserGuide/Advanced-Features/Select-Into.md | 8 +
.../Advanced-Features/UDF-User-Defined-Function.md | 10 +-
docs/zh/UserGuide/Appendix/Config-Manual.md | 1494 +++++++++++----
docs/zh/UserGuide/Appendix/SQL-Reference.md | 127 +-
.../Data-Concept/Data-Model-and-Terminology.md | 28 +-
.../DDL-Data-Definition-Language.md | 72 +-
.../DML-Data-Manipulation-Language.md | 1617 ++++++++--------
example/client-cpp-example/src/SessionExample.cpp | 3 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 11 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 11 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 9 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 6 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 8 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 8 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 245 ++-
.../org/apache/iotdb/DataMigrationExample.java | 4 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 8 +-
.../main/java/org/apache/iotdb/SessionExample.java | 97 +-
.../main/java/org/apache/iotdb/TabletExample.java | 4 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 14 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 8 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 8 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 10 +-
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 18 +-
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 6 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 6 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 5 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 47 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 12 +
.../resources/conf/iotdb-engine.properties | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 10 +
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 7 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 7 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 18 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 6 +-
.../level/LevelCompactionTsFileManagement.java | 2 +-
.../engine/compaction/utils/CompactionUtils.java | 7 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 8 +-
.../db/engine/memtable/IWritableMemChunk.java | 21 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 56 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 20 +-
.../engine/storagegroup/StorageGroupProcessor.java | 164 +-
.../db/engine/storagegroup/TsFileProcessor.java | 7 +-
.../db/engine/storagegroup/TsFileResource.java | 5 +-
.../service/TriggerRegistrationService.java | 4 +-
...eption.java => MNodeTypeMismatchException.java} | 13 +-
.../metadata/StorageGroupAlreadySetException.java | 11 +-
.../org/apache/iotdb/db/metadata/MManager.java | 1207 ++++++------
.../java/org/apache/iotdb/db/metadata/MTree.java | 1963 --------------------
.../apache/iotdb/db/metadata/MetadataConstant.java | 27 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 47 +-
.../iotdb/db/metadata/VectorPartialPath.java | 6 +
.../db/metadata/lastCache/LastCacheManager.java | 82 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 4 +-
.../iotdb/db/metadata/mnode/IEntityMNode.java | 2 +-
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 9 +-
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 10 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 30 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 35 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 161 +-
.../db/metadata/mnode/MultiMeasurementMNode.java | 65 +
.../db/metadata/mnode/UnaryMeasurementMNode.java | 63 +
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 1371 ++++++++++++++
.../mtree/traverser/PathGrouperByStorageGroup.java | 103 +
.../db/metadata/mtree/traverser/Traverser.java | 247 +++
.../collector/BelongedEntityPathCollector.java | 83 +
.../traverser/collector/CollectorTraverser.java | 93 +
.../traverser/collector/EntityPathCollector.java | 66 +
.../collector/FlatMeasurementCollector.java | 138 ++
.../collector/FlatMeasurementPathCollector.java | 60 +
.../collector/FlatMeasurementSchemaCollector.java | 117 ++
.../mtree/traverser/collector/MNodeCollector.java | 76 +
.../traverser/collector/MeasurementCollector.java | 58 +
.../collector/StorageGroupPathCollector.java | 65 +
.../mtree/traverser/counter/CounterTraverser.java} | 25 +-
.../mtree/traverser/counter/EntityCounter.java} | 31 +-
.../traverser/counter/FlatMeasurementCounter.java | 78 +
.../traverser/counter/MNodeLevelCounter.java} | 42 +-
.../traverser/counter/MeasurementCounter.java} | 40 +-
.../traverser/counter/StorageGroupCounter.java} | 38 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 85 +-
.../iotdb/db/metadata/template/Template.java | 10 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 9 +-
.../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 51 +-
.../org/apache/iotdb/db/mqtt/PayloadFormatter.java | 8 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 79 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 35 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 5 -
.../db/qp/physical/crud/AlignByDevicePlan.java | 5 +
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 5 -
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 17 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 108 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 41 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 32 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 60 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 5 -
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 5 -
.../iotdb/db/qp/physical/crud/QueryPlan.java | 10 -
.../db/qp/physical/crud/RawDataQueryPlan.java | 32 +-
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 5 -
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 98 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 15 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 4 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 75 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 7 +-
.../db/query/aggregation/AggregateResult.java | 10 +-
.../db/query/aggregation/impl/AvgAggrResult.java | 17 +-
.../db/query/aggregation/impl/CountAggrResult.java | 15 +-
.../query/aggregation/impl/ExtremeAggrResult.java | 19 +-
.../aggregation/impl/FirstValueAggrResult.java | 25 +-
.../aggregation/impl/FirstValueDescAggrResult.java | 17 +-
.../aggregation/impl/LastValueAggrResult.java | 21 +-
.../aggregation/impl/LastValueDescAggrResult.java | 17 +-
.../query/aggregation/impl/MaxTimeAggrResult.java | 19 +-
.../aggregation/impl/MaxTimeDescAggrResult.java | 13 +-
.../query/aggregation/impl/MaxValueAggrResult.java | 21 +-
.../query/aggregation/impl/MinTimeAggrResult.java | 17 +-
.../aggregation/impl/MinTimeDescAggrResult.java | 11 +-
.../query/aggregation/impl/MinValueAggrResult.java | 19 +-
.../db/query/aggregation/impl/SumAggrResult.java | 17 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 19 +-
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 3 +-
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 24 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 180 +-
.../db/query/dataset/UDTFNonAlignDataSet.java | 22 +-
.../dataset/groupby/LocalGroupByExecutor.java | 14 +-
.../db/query/executor/AggregationExecutor.java | 377 +++-
.../iotdb/db/query/executor/LastQueryExecutor.java | 27 +-
.../iotdb/db/query/executor/QueryRouter.java | 11 +-
.../iotdb/db/query/executor/UDTFQueryExecutor.java | 30 +-
.../iotdb/db/query/expression/Expression.java | 64 +-
.../iotdb/db/query/expression/ResultColumn.java | 13 +-
.../expression/binary/AdditionExpression.java | 10 +
.../query/expression/binary/BinaryExpression.java | 82 +-
.../expression/binary/DivisionExpression.java | 10 +
.../query/expression/binary/ModuloExpression.java | 9 +
.../binary/MultiplicationExpression.java | 10 +
.../expression/binary/SubtractionExpression.java | 10 +
.../query/expression/unary/FunctionExpression.java | 143 +-
.../query/expression/unary/NegationExpression.java | 64 +-
.../query/expression/unary/TimeSeriesOperand.java | 53 +-
.../db/query/reader/series/IAggregateReader.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 38 +
...eader.java => VectorSeriesAggregateReader.java} | 50 +-
.../reader/universal/DescPriorityMergeReader.java | 9 +-
.../apache/iotdb/db/query/udf/api/access/Row.java | 18 +-
.../api/customizer/parameter/UDFParameters.java | 49 +-
.../db/query/udf/builtin/BuiltinFunction.java | 3 +
.../iotdb/db/query/udf/builtin/UDTFConst.java | 123 ++
.../{UDTFTimeDifference.java => UDTFConstE.java} | 22 +-
.../{UDTFTimeDifference.java => UDTFConstPi.java} | 22 +-
.../iotdb/db/query/udf/builtin/UDTFSelectK.java | 2 +-
.../iotdb/db/query/udf/builtin/UDTFValueTrend.java | 3 +-
...alizableRowRecordListBackedMultiColumnRow.java} | 38 +-
...zableRowRecordListBackedMultiColumnWindow.java} | 58 +-
...RecordListBackedMultiColumnWindowIterator.java} | 28 +-
...ticSerializableTVListBackedSingleColumnRow.java | 99 +
...SerializableTVListBackedSingleColumnWindow.java | 83 +
...bleTVListBackedSingleColumnWindowIterator.java} | 32 +-
.../LayerPointReaderBackedSingleColumnRow.java | 91 +
.../db/query/udf/core/executor/UDTFExecutor.java | 12 +-
.../iotdb/db/query/udf/core/input/InputLayer.java | 571 ------
.../iotdb/db/query/udf/core/layer/DAGBuilder.java | 106 ++
.../db/query/udf/core/layer/IntermediateLayer.java | 80 +
.../db/query/udf/core/layer/LayerCacheUtils.java | 104 ++
.../query/udf/core/layer/LayerMemoryAssigner.java | 69 +
.../layer/MultiInputColumnIntermediateLayer.java | 342 ++++
.../query/udf/core/layer/RawQueryInputLayer.java | 197 ++
.../udf/core/{input => layer}/SafetyLine.java | 2 +-
...InputColumnMultiReferenceIntermediateLayer.java | 336 ++++
...nputColumnSingleReferenceIntermediateLayer.java | 250 +++
.../db/query/udf/core/reader/LayerRowReader.java | 2 +-
.../core/transformer/RawQueryPointTransformer.java | 73 -
.../udf/core/transformer/UDFQueryTransformer.java | 2 +-
.../primitive/ElasticSerializableIntList.java | 99 -
.../query/udf/datastructure/primitive/IntList.java | 33 -
.../primitive/SerializableIntList.java | 133 --
.../datastructure/primitive/WrappedIntArray.java | 51 -
.../row/ElasticSerializableRowRecordList.java | 9 +-
.../tv/ElasticSerializableTVList.java | 4 +-
.../query/udf/service/UDFRegistrationService.java | 4 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 66 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 4 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 17 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 14 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 8 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 2 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 59 +-
.../db/utils/datastructure/BooleanTVList.java | 59 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 59 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 59 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 59 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 69 +-
.../iotdb/db/utils/datastructure/TVList.java | 16 +-
.../iotdb/db/utils/datastructure/VectorTVList.java | 82 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 73 +-
.../writelog/recover/TsFileRecoverPerformer.java | 58 +-
.../compaction/LevelCompactionMoreDataTest.java | 10 +-
.../db/engine/compaction/LevelCompactionTest.java | 12 +-
.../db/engine/memtable/MemTableTestUtils.java | 13 +-
.../db/engine/memtable/MemtableBenchmark.java | 4 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 20 +-
.../iotdb/db/engine/merge/MergeOverLapTest.java | 4 +-
.../iotdb/db/engine/merge/MergeTaskTest.java | 4 +-
.../apache/iotdb/db/engine/merge/MergeTest.java | 12 +-
.../iotdb/db/engine/merge/MergeUpgradeTest.java | 10 +-
.../storagegroup/StorageGroupProcessorTest.java | 36 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 16 +-
.../engine/storagegroup/TsFileProcessorTest.java | 22 +-
.../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 249 ---
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 27 +-
.../db/integration/IoTDBAutoCreateSchemaIT.java | 50 -
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 2 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 26 +-
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 2 +-
.../db/integration/IoTDBDeleteStorageGroupIT.java | 2 +-
.../db/integration/IoTDBDeleteTimeseriesIT.java | 4 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 6 +-
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 6 +-
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 4 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 4 +-
.../db/integration/IoTDBFlushQueryMergeIT.java | 2 +-
.../db/integration/IoTDBInsertWithQueryIT.java | 4 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 2 +-
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 141 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 31 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 10 +-
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 14 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 7 +-
.../db/integration/IoTDBMultiStatementsIT.java | 3 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 388 ++++
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 13 +-
.../db/integration/IoTDBQueryMemoryControlIT.java | 6 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 4 +-
.../db/integration/IoTDBRpcCompressionIT.java | 6 +-
.../IoTDBSameMeasurementsDifferentTypesIT.java | 3 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 33 +-
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 4 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 2 +-
.../IoTDBSetSystemReadOnlyWritableIT.java | 2 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 26 +-
.../apache/iotdb/db/integration/IoTDBTagIT.java | 9 +-
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 4 +-
.../db/integration/IoTDBTriggerManagementIT.java | 2 +-
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 21 +
.../db/integration/IoTDBUDFWindowQueryIT.java | 8 +-
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 6 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 79 +-
.../db/integration/IoTDBUDTFHybridQueryIT.java | 2 -
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 6 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 6 +-
.../db/integration/auth/IoTDBAuthorizationIT.java | 6 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 32 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 162 +-
.../iotdb/db/metadata/MManagerImproveTest.java | 2 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 276 ++-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 11 +
.../apache/iotdb/db/metadata/PartialPathTest.java | 8 +
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 2 +-
...rmatTest.java => JSONPayloadFormatterTest.java} | 2 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 3 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 6 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 2 +
.../db/qp/physical/InsertTabletMultiPlanTest.java | 3 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 112 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 2 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 2 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 18 +-
.../reader/series/SeriesAggregateReaderTest.java | 14 +-
.../reader/series/SeriesReaderByTimestampTest.java | 4 +-
.../db/query/reader/series/SeriesReaderTest.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 19 +-
.../ElasticSerializableTVListTest.java | 2 +-
.../iotdb/db/query/udf/example/Accumulator.java | 12 +-
.../apache/iotdb/db/query/udf/example/Adder.java | 4 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 24 +-
.../org/apache/iotdb/db/query/udf/example/Max.java | 2 +-
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 4 +-
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 4 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 18 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 8 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 8 +-
.../db/utils/datastructure/BinaryTVListTest.java | 59 +-
.../db/utils/datastructure/BooleanTVListTest.java | 63 +-
.../db/utils/datastructure/DoubleTVListTest.java | 63 +-
.../db/utils/datastructure/FloatTVListTest.java | 63 +-
.../db/utils/datastructure/IntTVListTest.java | 63 +-
.../db/utils/datastructure/LongTVListTest.java | 62 +-
.../db/utils/datastructure/PrecisionTest.java | 8 +-
.../db/utils/datastructure/VectorTVListTest.java | 40 +-
.../db/writelog/recover/DeviceStringTest.java | 8 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 12 +-
.../recover/RecoverResourceFromReaderTest.java | 12 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 257 ++-
.../writelog/recover/UnseqTsFileRecoverTest.java | 12 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 20 +
.../org/apache/iotdb/rpc/TSStatusCodeTest.java | 10 +-
.../java/org/apache/iotdb/session/Session.java | 334 +++-
.../apache/iotdb/session/SessionConnection.java | 6 +-
.../org/apache/iotdb/session/SessionUtils.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 189 ++
.../iotdb/session/IoTDBSessionComplexIT.java | 26 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 81 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 231 +++
.../session/IoTDBSessionVectorAggregationIT.java | 266 +++
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 192 ++
.../apache/iotdb/session/IoTDBSessionVectorIT.java | 212 ---
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 449 +++++
.../apache/iotdb/session/SessionCacheLeaderUT.java | 30 +-
.../java/org/apache/iotdb/session/SessionTest.java | 12 +-
site/src/main/.vuepress/config.js | 16 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 14 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 4 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 4 +-
.../org/apache/iotdb/spark/tool/TsFileExample.java | 10 +-
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 22 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 14 +-
thrift/src/main/thrift/rpc.thrift | 15 +-
.../iotdb/tsfile/file/header/PageHeader.java | 15 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 13 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 3 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 9 +-
.../tsfile/file/metadata/VectorChunkMetadata.java | 4 +
.../file/metadata/VectorTimeSeriesMetadata.java | 4 +
.../file/metadata/statistics/BinaryStatistics.java | 2 +-
.../metadata/statistics/BooleanStatistics.java | 2 +-
.../file/metadata/statistics/DoubleStatistics.java | 2 +-
.../file/metadata/statistics/FloatStatistics.java | 2 +-
.../metadata/statistics/IntegerStatistics.java | 2 +-
.../file/metadata/statistics/LongStatistics.java | 2 +-
.../file/metadata/statistics/Statistics.java | 29 +-
.../file/metadata/statistics/TimeStatistics.java | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 8 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 84 +-
.../tsfile/read/common/DescReadWriteBatchData.java | 42 +
.../tsfile/read/common/IBatchDataIterator.java | 17 +-
.../tsfile/read/reader/BatchDataIterator.java | 54 -
.../tsfile/read/reader/page/VectorPageReader.java | 6 +-
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 22 +
.../iotdb/tsfile/v2/file/header/PageHeaderV2.java | 5 +-
.../tsfile/v2/file/metadata/ChunkMetadataV2.java | 3 +-
.../v2/file/metadata/statistics/StatisticsV2.java | 14 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 4 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 7 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 3 +-
.../apache/iotdb/tsfile/write/page/PageWriter.java | 5 +-
.../iotdb/tsfile/write/page/ValuePageWriter.java | 5 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 13 +-
...mentSchema.java => UnaryMeasurementSchema.java} | 32 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 3 +-
.../tsfile/file/metadata/utils/TestHelper.java | 14 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 5 +-
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 6 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 6 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 27 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 27 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 19 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 26 +-
.../tsfile/write/DefaultSchemaTemplateTest.java | 8 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 4 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 24 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 26 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 12 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 4 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 8 +-
.../iotdb/tsfile/write/TsFileWriterTest.java | 22 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 16 +-
.../write/schema/converter/SchemaBuilderTest.java | 16 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 10 +-
.../writer/MeasurementSchemaSerializeTest.java | 14 +-
.../iotdb/tsfile/write/writer/PageWriterTest.java | 14 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 52 +-
431 files changed, 16038 insertions(+), 8972 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{UndefinedTemplateException.java
=> MNodeTypeMismatchException.java} (74%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/MTree.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/MultiMeasurementMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/UnaryMeasurementMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/MTree.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/PathGrouperByStorageGroup.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/Traverser.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/BelongedEntityPathCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/CollectorTraverser.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/EntityPathCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/FlatMeasurementCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/FlatMeasurementPathCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/FlatMeasurementSchemaCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/MNodeCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/MeasurementCollector.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/StorageGroupPathCollector.java
copy
server/src/main/java/org/apache/iotdb/db/{qp/logical/crud/FromComponent.java =>
metadata/mtree/traverser/counter/CounterTraverser.java} (62%)
copy
server/src/main/java/org/apache/iotdb/db/{query/expression/Expression.java =>
metadata/mtree/traverser/counter/EntityCounter.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/FlatMeasurementCounter.java
copy
server/src/main/java/org/apache/iotdb/db/{engine/merge/selector/NaivePathSelector.java
=> metadata/mtree/traverser/counter/MNodeLevelCounter.java} (53%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/merge/selector/NaivePathSelector.java
=> metadata/mtree/traverser/counter/MeasurementCounter.java} (54%)
copy
server/src/main/java/org/apache/iotdb/db/{query/dataset/SingleDataSet.java =>
metadata/mtree/traverser/counter/StorageGroupCounter.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/query/reader/series/{SeriesAggregateReader.java
=> VectorSeriesAggregateReader.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFConst.java
copy
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/{UDTFTimeDifference.java
=> UDTFConstE.java} (77%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/builtin/{UDTFTimeDifference.java
=> UDTFConstPi.java} (77%)
rename
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/{RowImpl.java =>
ElasticSerializableRowRecordListBackedMultiColumnRow.java} (69%)
rename
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/{RowWindowImpl.java
=> ElasticSerializableRowRecordListBackedMultiColumnWindow.java} (59%)
copy
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/{RowIteratorImpl.java
=> ElasticSerializableRowRecordListBackedMultiColumnWindowIterator.java} (67%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/ElasticSerializableTVListBackedSingleColumnRow.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/ElasticSerializableTVListBackedSingleColumnWindow.java
rename
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/{RowIteratorImpl.java
=> ElasticSerializableTVListBackedSingleColumnWindowIterator.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/access/LayerPointReaderBackedSingleColumnRow.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/input/InputLayer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/DAGBuilder.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/IntermediateLayer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/LayerCacheUtils.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/LayerMemoryAssigner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/MultiInputColumnIntermediateLayer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/RawQueryInputLayer.java
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/{input =>
layer}/SafetyLine.java (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputColumnMultiReferenceIntermediateLayer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/SingleInputColumnSingleReferenceIntermediateLayer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/RawQueryPointTransformer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/ElasticSerializableIntList.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/IntList.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/SerializableIntList.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/datastructure/primitive/WrappedIntArray.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBAddSubDeviceIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBNestedQueryIT.java
rename
server/src/test/java/org/apache/iotdb/db/mqtt/{JSONPayloadFormatTest.java =>
JSONPayloadFormatterTest.java} (98%)
copy
server/src/test/java/org/apache/iotdb/db/query/control/QueryResourceManagerTest.java
=> service-rpc/src/test/java/org/apache/iotdb/rpc/TSStatusCodeTest.java (80%)
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionVectorABDeviceIT.java
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionVectorAggregationIT.java
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionVectorAggregationWithUnSeqIT.java
delete mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionVectorIT.java
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionVectorInsertIT.java
copy server/src/main/java/org/apache/iotdb/db/metrics/sink/Sink.java =>
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/IBatchDataIterator.java
(79%)
delete mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/BatchDataIterator.java
rename
tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/{MeasurementSchema.java
=> UnaryMeasurementSchema.java} (91%)
