This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch timeoutQuit
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 19d2355 rerun CI
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)
add 5a26548 Merge branch 'master' into timeoutQuit
No new revisions were added by this update.
Summary of changes:
.github/workflows/client.yml | 1 +
README.md | 2 +-
README_ZH.md | 2 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 4 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 2 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 41 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 19 +-
.../cluster/query/ClusterPhysicalGenerator.java | 7 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 5 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 2 +-
.../query/aggregate/ClusterAggregateExecutor.java | 30 +-
.../caller/PullMeasurementSchemaHandler.java | 4 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 4 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 8 +-
.../query/ClusterAggregateExecutorTest.java | 8 +-
.../cluster/server/member/MetaGroupMemberTest.java | 2 +-
docs/UserGuide/API/Programming-JDBC.md | 2 +
.../Collaboration-of-Edge-and-Cloud/Sync-Tool.md | 2 +-
.../DML-Data-Manipulation-Language.md | 43 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 2 +
docs/zh/UserGuide/Appendix/Config-Manual.md | 1494 +++++++++++++++-----
.../DML-Data-Manipulation-Language.md | 41 +-
.../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 | 7 +
.../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 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 12 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 6 +-
.../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 | 44 +-
.../iotdb/db/engine/merge/task/MergeTask.java | 21 +-
.../engine/storagegroup/StorageGroupProcessor.java | 56 +-
.../db/engine/storagegroup/TsFileProcessor.java | 5 +-
.../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 | 395 +++---
.../apache/iotdb/db/metadata/MetadataConstant.java | 27 +-
.../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 | 6 +
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 10 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 6 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 35 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 155 +-
.../db/metadata/mnode/MultiMeasurementMNode.java | 65 +
.../db/metadata/mnode/UnaryMeasurementMNode.java | 63 +
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 179 ++-
.../db/metadata/mtree/traverser/Traverser.java | 26 +-
...ector.java => BelongedEntityPathCollector.java} | 23 +-
.../traverser/collector/EntityPathCollector.java | 3 +-
...ollector.java => FlatMeasurementCollector.java} | 44 +-
...ctor.java => FlatMeasurementPathCollector.java} | 16 +-
...or.java => FlatMeasurementSchemaCollector.java} | 15 +-
.../traverser/collector/MeasurementCollector.java | 92 +-
...entCounter.java => FlatMeasurementCounter.java} | 35 +-
.../traverser/counter/MeasurementCounter.java | 38 +-
.../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/executor/PlanExecutor.java | 28 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 33 +-
.../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 | 16 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 21 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 32 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 30 +-
.../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/UDTFPlan.java | 5 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 15 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 4 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 6 +-
.../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 +-
.../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 +-
.../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 +-
.../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/sync/sender/transfer/SyncClient.java | 15 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 14 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 8 +-
.../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 | 2 +-
.../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/IoTDBAlignByDeviceIT.java | 18 -
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 4 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 2 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 6 +-
.../db/integration/IoTDBTriggerManagementIT.java | 2 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 79 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 20 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 25 +-
.../iotdb/db/metadata/MManagerImproveTest.java | 2 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 11 +
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 2 +-
...rmatTest.java => JSONPayloadFormatterTest.java} | 2 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 89 +-
.../reader/series/SeriesAggregateReaderTest.java | 14 +-
.../reader/series/SeriesReaderByTimestampTest.java | 4 +-
.../db/query/reader/series/SeriesReaderTest.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 19 +-
.../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/VectorTVListTest.java | 40 +-
.../db/writelog/recover/DeviceStringTest.java | 8 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 10 +-
.../recover/RecoverResourceFromReaderTest.java | 12 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 8 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 12 +-
.../java/org/apache/iotdb/session/Session.java | 4 +-
.../org/apache/iotdb/session/SessionUtils.java | 4 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 20 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 75 +-
.../session/IoTDBSessionVectorABDeviceIT.java | 231 +++
.../session/IoTDBSessionVectorAggregationIT.java | 266 ++++
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 192 +++
...ctorIT.java => IoTDBSessionVectorInsertIT.java} | 15 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 20 +-
.../java/org/apache/iotdb/session/SessionTest.java | 12 +-
.../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 | 10 +-
.../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 | 7 +
.../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 +-
259 files changed, 5736 insertions(+), 2308 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{UndefinedTemplateException.java
=> MNodeTypeMismatchException.java} (74%)
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
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{TSEntityPathCollector.java
=> BelongedEntityPathCollector.java} (74%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{MeasurementCollector.java
=> FlatMeasurementCollector.java} (65%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{MeasurementPathCollector.java
=> FlatMeasurementPathCollector.java} (70%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{MeasurementSchemaCollector.java
=> FlatMeasurementSchemaCollector.java} (86%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{MeasurementCounter.java
=> FlatMeasurementCounter.java} (67%)
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/test/java/org/apache/iotdb/db/mqtt/{JSONPayloadFormatTest.java =>
JSONPayloadFormatterTest.java} (98%)
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
rename
session/src/test/java/org/apache/iotdb/session/{IoTDBSessionVectorIT.java =>
IoTDBSessionVectorInsertIT.java} (98%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/SnapshotFactory.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%)
