This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TYQuery
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from ec70119 format
new 6cd892d add VectorSeriesReader
new b8b9477 format code
new 9e466ca need haonan
new b7fe308 add todo
add 3f6b915 [IOTDB-1225] Support CreateAlignedTimeseriesPlan in MManager
add 96f29bb [To Vector] add VectorPartialPath (#2823)
add 6430a79 [To Vector] Vector TVList Step 1 (#2825)
add b2ee6ca [To Vector] flush vector series (#2826)
add 567491f Merge remote-tracking branch 'origin/Vector' into Vector
add 14f8046 [IOTDB-1227] Support deleting aligned timeseries in MManager
add 19e1aba device template
add 0198f5c Add generated-sources as source folder
add bfa529b (Fix Github Action)Update apt source before installing
libboost
add 19ad435 [IOTDB-1204] set parameter in iotdb-cluster.properties (#2797)
add 1f54e62 Update cpp client build doc (#2796)
add 7d5329f [IOTDB-1192] Fix sql end with semicolon (#2798)
add a857820 Update UDF User Defined Function.md
add aad1bcd [IOTDB-1193] Remove redundant sync meta leader in CManager
for cluster module (#2787)
add 02a4ecf [IOTDB-1208] revise the cluster setup docs (#2807)
add ff3a0f9 Fix compaction with cluster snapshot deletion (#2811)
add 1f98174 [IOTDB-1221] Compaction module: chunk metadata lists returned
by the getMeasurementChunkMetadataListMapIterator method are not
lexicographically ordered by the measurement names (#2817)
add bccb441 check and persist the system properties of the cluster
version (#2816)
add 251c979 Rename timeout parameter (#2824)
add 653841b download calcite-core's dependency penhato from
public.nexus.pentaho.org rather than spring.io
add 1b9d1f2 Merge branch 'master' into Vector
add 6767feb Merge branch 'Vector' of https://github.com/apache/iotdb into
Vector
add 6fed4ed update template
add fb51b68 [To Vector] [IOTDB-1225] Support CreateAlignedTimeseriesPlan
in MManager (#2831)
add a9d6687 [To Vector] change the way of flushing memtable from by
column to by row (#2832)
add 2e667d3 Merge remote-tracking branch 'origin/Vector' into Vector
add b692da0 Skip code coverage and sonar reports in a forked pull request
add 9ef4b81 Merge branch 'Vector' of https://github.com/apache/iotdb into
Vector
add ffeb7fe Merge branch 'Vector' of https://github.com/apache/iotdb into
Vector
add 98fd47c support insert vector with tablet plan
add fe23fad fix write vector bug
add d6d821f add serialize
add 292bc65 update template
add e149592 Merge branch 'Vector' of https://github.com/apache/iotdb into
Vector
add 0867605 Merge branch 'Vector' of https://github.com/apache/iotdb into
Vector
add bbcadd9 Merge remote-tracking branch 'origin/Vector' into Vector
add f39bc42 [IOTDB-1228] Refactor PlanExecutor.insertTablet method to
support aligned timeseries
add 0aa64f5 Device template
add 4d99c0b vector mem control
add 3601d1a [To Vector][IOTDB-1228] Refactor PlanExecutor.insertTablet
method to support aligned timeseries (#2833)
add d9dd825 Merge branch 'Vector' of https://github.com/apache/iotdb into
Vector
add aab52e4 fix write vector bugssss
add fe5a6a2 add .align
add 62a5c31 spotless
add e178a76 add header
add cee50d4 Merge remote-tracking branch 'origin/Vector' into Vector
add 932a408 Quick fix for experiment
new 2617771 fix conflicts and format code
The 5 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:
.github/workflows/client.yml | 30 +-
.github/workflows/sonar-coveralls.yml | 14 +-
antlr/pom.xml | 19 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 2 +-
client-cpp/README.md | 6 +-
.../resources/conf/iotdb-cluster.properties | 10 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 7 +
.../cluster/client/async/AsyncClientPool.java | 10 +-
.../iotdb/cluster/client/sync/SyncClientPool.java | 10 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 15 +
.../iotdb/cluster/config/ClusterDescriptor.java | 11 +
.../iotdb/cluster/coordinator/Coordinator.java | 27 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 40 +-
.../cluster/query/ClusterPhysicalGenerator.java | 20 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 4 +
.../cluster/query/reader/ClusterReaderFactory.java | 3 +-
docs/UserGuide/Operation Manual/Kill Query.md | 2 +-
.../Operation Manual/UDF User Defined Function.md | 2 +-
docs/UserGuide/Server/Cluster Setup.md | 4 +-
docs/zh/UserGuide/Operation Manual/Kill Query.md | 2 +-
.../Operation Manual/UDF User Defined Function.md | 2 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 4 +-
example/client-cpp-example/README.md | 2 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 3 +-
hive-connector/pom.xml | 12 +-
.../resources/conf/iotdb-engine.properties | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 3 +-
.../db/engine/compaction/TsFileManagement.java | 8 +
.../level/LevelCompactionTsFileManagement.java | 31 ++
.../engine/compaction/utils/CompactionUtils.java | 3 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 59 ++-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 52 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 10 +
.../db/engine/memtable/IWritableMemChunk.java | 4 +
.../db/engine/memtable/PrimitiveMemTable.java | 5 +
.../iotdb/db/engine/memtable/WritableMemChunk.java | 17 +
.../db/engine/querycontext/QueryDataSource.java | 12 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 5 +
.../engine/storagegroup/StorageGroupProcessor.java | 34 +-
.../db/engine/storagegroup/TsFileProcessor.java | 142 ++++--
.../db/engine/storagegroup/TsFileResource.java | 10 +-
...eption.java => AlignedTimeseriesException.java} | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 308 ++++++++++--
.../java/org/apache/iotdb/db/metadata/MTree.java | 301 ++++++++++--
.../org/apache/iotdb/db/metadata/MetaUtils.java | 16 +
.../iotdb/db/metadata/logfile/MLogWriter.java | 10 +
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 12 +
.../iotdb/db/metadata/template/Template.java | 95 ++++
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 29 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 4 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 14 +-
.../db/qp/physical/crud/CreateTemplatePlan.java | 239 +++++++++
.../db/qp/physical/crud/InsertTabletPlan.java | 6 +-
.../SetDeviceTemplatePlan.java} | 83 ++--
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 3 -
.../iotdb/db/query/context/QueryContext.java | 4 +-
.../iotdb/db/query/control/QueryTimeManager.java | 2 +-
.../chunk/metadata/DiskChunkMetadataLoader.java | 5 +
.../chunk/metadata/MemChunkMetadataLoader.java | 5 +
.../query/reader/series/SeriesAggregateReader.java | 2 +-
.../reader/series/SeriesRawDataBatchReader.java | 4 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 115 ++---
.../reader/series/SeriesReaderByTimestamp.java | 4 +-
.../query/reader/series/SeriesReaderFactory.java | 91 ++++
.../db/query/reader/series/VectorSeriesReader.java | 140 ++++++
.../iotdb/db/rescon/PrimitiveArrayManager.java | 8 +
.../apache/iotdb/db/rescon/TVListAllocator.java | 13 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 79 ++-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 1 -
.../iotdb/db/utils/datastructure/TVList.java | 27 ++
.../iotdb/db/utils/datastructure/VectorTVList.java | 539 +++++++++++++++++++++
.../db/engine/memtable/MemTableFlushTaskTest.java | 32 +-
.../db/engine/memtable/MemTableTestUtils.java | 58 +++
.../db/engine/memtable/PrimitiveMemTableTest.java | 73 +++
.../storagegroup/StorageGroupProcessorTest.java | 28 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 6 +-
.../engine/storagegroup/TsFileProcessorTest.java | 72 ++-
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 8 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 163 ++++++-
.../iotdb/db/metadata/MManagerImproveTest.java | 2 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 166 +++++++
.../db/qp/physical/PhysicalPlanSerializeTest.java | 20 +-
.../reader/series/SeriesAggregateReaderTest.java | 6 +-
.../reader/series/SeriesReaderByTimestampTest.java | 6 +-
.../db/utils/datastructure/VectorTVListTest.java | 105 ++++
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 54 +++
.../apache/iotdb/session/SessionConnection.java | 40 ++
.../java/org/apache/iotdb/session/SessionUT.java | 47 ++
thrift/pom.xml | 19 +
thrift/src/main/thrift/rpc.thrift | 19 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 4 +
.../file/metadata/VectorTimeSeriesMetadata.java | 29 +-
.../tsfile/file/metadata/enums/TSDataType.java | 3 +-
.../file/metadata/statistics/Statistics.java | 2 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 15 +-
.../read/controller/IChunkMetadataLoader.java | 2 +
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 4 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 3 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 26 +-
.../write/schema/VectorMeasurementSchema.java | 9 +-
...easurementChunkMetadataListMapIteratorTest.java | 65 ++-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 2 +-
105 files changed, 3427 insertions(+), 502 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{IllegalParameterOfPathException.java
=> AlignedTimeseriesException.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/Template.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/CreateTemplatePlan.java
copy server/src/main/java/org/apache/iotdb/db/qp/physical/{sys/SetTTLPlan.java
=> crud/SetDeviceTemplatePlan.java} (50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/SeriesReaderFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/series/VectorSeriesReader.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/datastructure/VectorTVList.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/utils/datastructure/VectorTVListTest.java
