You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2023/12/26 11:41:13 UTC
(iotdb) branch beyyes/template_value_filter updated (08b775fbf1f -> a495a0741b9)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/template_value_filter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 08b775fbf1f remove devicePathNodes in FilterNode
add 571ea729702 Bump org.apache.tomcat.embed:tomcat-embed-core from 9.0.58 to 9.0.83 (#11766)
add d406f40f768 [IOTDB-6276] Load IT: Add ConnectionTimeoutMs for IOTDBLoadTsFileIT.testLoadWithMods (#11764)
add 7507f4b7b4f Pipe: Ignore ConcurrentModificationException caused by PipeWALResourceManager#ttlCheck() & PipeTsFileResourceManager#ttlCheck() (#11761)
add f2a63b0cdcf Fix TsFile with TimeseriesMetadata over 2GB cannot be read (#11739)
add 057f307a740 Bump org.apache.zookeeper:zookeeper from 3.6.3 to 3.7.2 (#11767)
add 75fb67cf80e Bump org.apache.avro:avro from 1.8.2 to 1.11.3 (#11768)
add a0bf520a3b8 Fix UT DataRegion.testMerge (#11771)
add 331946821b0 Try to fix CQ IT
add 315eacb5c3b Show regionId supports SQL queries by time range. (#11747)
add ef3ab7b378b Update example/client-cpp-example/README.md (#11730)
add 0300a8a8ef6 Compaction rate limiter parameter supports negative value (#11774)
add 5d900ab1680 Enhance IoTDBClusterRestartIT (#11775)
add 6954461c799 Fix bug using null as measurement name (#11742)
add 9ceba0f95c4 PBTree: Fix NPE in SchemaFile conccurency control (#11770)
add fb46c9165e5 [IOTDB-6277] Support using view & ORDER BY clause in GROUP BY LEVEL query (#11776)
add cc06298b333 Fix no file error when release new version (#11778)
add 4023934e9af dev (#11762)
add 2f2505ce9c4 [IOTDB-6199] Support automatically fetch available DN list in Session & SessionPool
add b6939f3306d Pipe: add flag for memtable to avoid retransmission of tsfile generated by forwarded insertion (#11779)
add 71a03063427 DataRegion should return WRITE_PROCESS_REJECT to Consensus when insert rejected (#11782)
add 5c7fe287fbe [IOTDB-5706] Data inconsistency between IoT protocol replications (#11780)
add acb6b9c309f PBTree: Fix conccurency control with alias read (#11781)
add e1951aad473 Merge branch 'master' into beyyes/template_value_filter
add a495a0741b9 only serialize align by device header info
No new revisions were added by this update.
Summary of changes:
example/client-cpp-example/README.md | 4 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 6 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../it/cluster/IoTDBClusterRestartIT.java | 9 +
.../it/partition/IoTDBPartitionGetterIT.java | 59 +++-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 6 +
.../IoTDBAlignByDeviceWithTemplateIT.java | 16 +
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 60 +++-
.../apache/iotdb/db/it/cq/IoTDBCQExecInNsIT.java | 60 +++-
.../apache/iotdb/db/it/cq/IoTDBCQExecInUsIT.java | 60 +++-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 34 ++
.../org/apache/iotdb/isession/INodeSupplier.java | 11 +-
.../java/org/apache/iotdb/isession/ISession.java | 3 +-
.../org/apache/iotdb/isession/SessionConfig.java | 2 +
.../apache/iotdb/session/DummyNodesSupplier.java | 26 +-
.../org/apache/iotdb/session/NodesSupplier.java | 239 ++++++++++++++
.../java/org/apache/iotdb/session/Session.java | 92 +++++-
.../apache/iotdb/session/SessionConnection.java | 23 +-
.../org/apache/iotdb/session/ThriftConnection.java | 192 +++++++++++
.../org/apache/iotdb/session/pool/SessionPool.java | 96 +++++-
.../iotdb/session/SessionConnectionTest.java | 13 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../request/read/region/GetRegionIdPlan.java | 35 +-
.../manager/partition/PartitionManager.java | 14 +-
.../partition/DatabasePartitionTable.java | 7 +-
.../persistence/partition/PartitionInfo.java | 7 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 -
.../consensus/iot/client/DispatchLogHandler.java | 3 +-
.../dataregion/DataExecutionVisitor.java | 35 +-
.../dataregion/DataRegionStateMachine.java | 13 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 11 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 4 +
.../iotdb/db/queryengine/common/NodeRef.java | 4 +
.../db/queryengine/plan/analyze/Analysis.java | 7 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 365 ++++++++++++---------
.../plan/analyze/ColumnPaginationController.java | 19 +-
.../plan/analyze/ExpressionAnalyzer.java | 15 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 118 ++++---
...evelController.java => GroupByLevelHelper.java} | 97 +++---
.../queryengine/plan/analyze/PredicateUtils.java | 21 ++
.../queryengine/plan/analyze/TemplatedAnalyze.java | 17 +-
.../db/queryengine/plan/analyze/TemplatedInfo.java | 44 ++-
.../config/executor/ClusterConfigTaskExecutor.java | 8 +-
.../visitor/ColumnTransformerVisitor.java | 14 +-
.../ReplaceRawPathWithGroupedPathVisitor.java | 44 ++-
...tor.java => ReplaceSubTreeWithViewVisitor.java} | 31 +-
...dConcatRemoveUnExistentMeasurementVisitor.java} | 39 +--
.../db/queryengine/plan/parser/ASTVisitor.java | 53 ++-
.../plan/parser/StatementGenerator.java | 5 +
.../plan/planner/LogicalPlanBuilder.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 180 ++++++++--
.../plan/planner/TemplatedLogicalPlan.java | 47 ++-
.../statement/component/GroupByLevelComponent.java | 18 -
.../statement/metadata/GetRegionIdStatement.java | 28 +-
.../impl/pbtree/flush/PBTreeFlushExecutor.java | 2 +
.../mtree/impl/pbtree/flush/Scheduler.java | 17 +-
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 78 +++--
.../mtree/impl/pbtree/schemafile/ISchemaPage.java | 4 +
.../mtree/impl/pbtree/schemafile/SchemaPage.java | 10 +
.../schemafile/pagemgr/BTreePageManager.java | 12 +-
.../pbtree/schemafile/pagemgr/PageManager.java | 40 +--
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../compaction/schedule/CompactionTaskManager.java | 2 +-
.../dataregion/flush/NotifyFlushMemTable.java | 7 +
.../dataregion/memtable/AbstractMemTable.java | 13 +
.../dataregion/memtable/IMemTable.java | 4 +
.../dataregion/memtable/TsFileProcessor.java | 13 +-
.../dataregion/tsfile/TsFileManager.java | 13 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 80 ++++-
.../db/metadata/mtree/schemafile/MonitorTest.java | 33 +-
.../storageengine/dataregion/DataRegionTest.java | 14 +-
.../dataregion/LastFlushTimeMapTest.java | 2 +
.../datanode1conf/iotdb-datanode.properties | 2 +-
.../datanode2conf/iotdb-datanode.properties | 2 +-
.../datanode3conf/iotdb-datanode.properties | 2 +-
.../resources/conf/iotdb-common.properties | 1 +
.../commons/partition/DataPartitionTable.java | 16 +-
.../commons/partition/SeriesPartitionTable.java | 26 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 20 ++
.../tsfile/file/metadata/MetadataIndexEntry.java | 7 +
.../tsfile/file/metadata/MetadataIndexNode.java | 13 +
.../tsfile/file/metadata/TimeseriesMetadata.java | 28 ++
.../iotdb/tsfile/read/TsFileSequenceReader.java | 172 ++++++++--
...leSequenceReaderTimeseriesMetadataIterator.java | 29 +-
.../file/metadata/TimeseriesMetadataTest.java | 34 +-
.../tsfile/file/metadata/utils/TestHelper.java | 4 +-
.../src/main/thrift/confignode.thrift | 3 +-
pom.xml | 7 +-
89 files changed, 2384 insertions(+), 665 deletions(-)
copy integration-test/src/main/java/org/apache/iotdb/itbase/env/ConfigNodeConfig.java => iotdb-client/isession/src/main/java/org/apache/iotdb/isession/INodeSupplier.java (78%)
copy iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerEndpointException.java => iotdb-client/session/src/main/java/org/apache/iotdb/session/DummyNodesSupplier.java (64%)
create mode 100644 iotdb-client/session/src/main/java/org/apache/iotdb/session/NodesSupplier.java
create mode 100644 iotdb-client/session/src/main/java/org/apache/iotdb/session/ThriftConnection.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/{GroupByLevelController.java => GroupByLevelHelper.java} (64%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/{ExpressionNormalizeVisitor.java => ReplaceSubTreeWithViewVisitor.java} (66%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/{TemplatedConcatDeviceAndPredicateVisitor.java => TemplatedConcatRemoveUnExistentMeasurementVisitor.java} (52%)