This is an automated email from the ASF dual-hosted git repository.
lancelly pushed a change to branch support_correlated_quantified_comparison
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7109ee98c33 add IT
add 29a68365b86 Subscription: tree/table model isolation for
topic/consumer/subscription entities (#15484)
add 8439e547959 Feature/cppclient table redirection (#15439)
add ea6a2d01b19 Support built-in forecast table function for table model
add ccd3060f14a Fixed the reserved word introduced by tree view in tree
model SQL & Enhanced the tree view IT & Handled the cases in field /
measurement names & Temporarily banned source measurements with the same name
(#15475)
add 8ff01204936 Async Load: Set the database name null when appropriate &
Enable auto-creation of the database by reading the isAutoCreateSchemaEnabled
flag from config (#15489)
add d4818124bc1 Use reference time position for PartitionTableAutoCleaner
add b0a69febb9d add it & fix bugs for TreeDeviceViewScan
add 78689179359 [AINode] Support built-in inference of table/tree model
for time_xl
add 25c933f53fc Fixed the issue of abnormal output when the input length
of timerxl is not a multiple of 96 (#15495)
add 21ee53c0f1e docker-compose file:fix a slip of the pen and add the new
way to set memory with environment variables (#15496)
add a63b608394d fix thread leak (#15497)
add a23db285d89 Implememt auto release technique for Blob Allocator
(#15491)
add cdab0f68666 [Table Model Subquery] Support correlated scalar subquery
add bb31262ac5e merge master
No new revisions were added by this update.
Summary of changes:
.../DockerCompose/docker-compose-cluster-1c2d.yml | 3 +
.../DockerCompose/docker-compose-standalone.yml | 2 +-
.../partition/IoTDBPartitionTableAutoCleanIT.java | 7 +-
....java => IoTDBPartitionTableAutoCleanUSIT.java} | 34 +-
.../IoTDBCorrelatedScalarSubqueryIT.java | 2 +-
.../old/IoTDBFilterBetweenTableViewIT.java} | 43 +-
.../old/IoTDBFilterNullTableViewIT.java} | 30 +-
.../old/IoTDBFilterTableViewIT.java} | 112 +-
.../old/IoTDBNestedQueryTableViewIT.java} | 71 +-
.../old/IoTDBSimpleQueryTableViewIT.java} | 516 ++--
.../IoTDBAlignByDeviceTableView2IT.java} | 4 +-
.../IoTDBAlignByDeviceTableView3IT.java} | 6 +-
.../IoTDBAlignByDeviceTableViewIT.java} | 131 +-
...oTDBAlignByDeviceWithTemplateTableView2IT.java} | 5 +-
...IoTDBAlignByDeviceWithTemplateTableViewIT.java} | 40 +-
...derByLimitOffsetAlignByDeviceTableView2IT.java} | 9 +-
...rderByLimitOffsetAlignByDeviceTableViewIT.java} | 47 +-
...IoTDBOrderByWithAlignByDeviceTableView2IT.java} | 5 +-
...IoTDBOrderByWithAlignByDeviceTableView3IT.java} | 5 +-
.../IoTDBOrderByWithAlignByDeviceTableViewIT.java} | 92 +-
...oTDBAlignedOffsetLimitPushDownTableViewIT.java} | 36 +-
.../IoTDBAlignedSeriesQueryTableView2IT.java} | 6 +-
.../IoTDBAlignedSeriesQueryTableView3IT.java} | 7 +-
.../IoTDBAlignedSeriesQueryTableView4IT.java} | 6 +-
.../IoTDBAlignedSeriesQueryTableView5IT.java} | 6 +-
.../IoTDBAlignedSeriesQueryTableViewIT.java} | 8 +-
.../IoTDBPredicatePushDownTableView2IT.java} | 6 +-
.../IoTDBPredicatePushDownTableView3IT.java} | 6 +-
.../IoTDBPredicatePushDownTableView4IT.java} | 6 +-
.../IoTDBPredicatePushDownTableViewIT.java} | 20 +-
.../it/query/view/old/aligned/TableViewUtils.java} | 82 +-
.../old/orderby/IoTDBOrderByTableViewIT.java} | 102 +-
.../old/query/IoTDBArithmeticTableViewIT.java} | 35 +-
.../old/query/IoTDBPaginationTableViewIT.java} | 121 +-
.../recent/IoTDBColumnsMatchTableViewIT.java} | 24 +-
.../view/recent/IoTDBComplexQueryTableViewIT.java | 100 +
.../view/recent/IoTDBDistinctTagTableViewIT.java | 173 ++
.../recent/IoTDBFillTableViewIT.java} | 97 +-
.../recent/IoTDBGapFillTableViewIT.java} | 36 +-
.../recent/IoTDBNullIdQueryTableViewIT.java} | 81 +-
.../recent/IoTDBNullValueTableViewIT.java} | 25 +-
...TDBTableViewAggregationFunctionDistinctIT.java} | 31 +-
.../recent/IoTDBTableViewAggregationIT.java} | 489 ++--
.../IoTDBTableViewAggregationNonStreamIT.java} | 489 ++--
.../query/view/recent/IoTDBTableViewQueryIT.java | 368 +++
.../relational/it/schema/IoTDBDatabaseIT.java | 6 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 98 +-
.../tablemodel/IoTDBSubscriptionIsolationIT.java | 218 ++
.../ScalarParameterSpecification.java | 2 +-
iotdb-client/client-cpp/pom.xml | 12 +
iotdb-client/client-cpp/src/main/Common.cc | 186 ++
iotdb-client/client-cpp/src/main/Common.h | 390 +++
iotdb-client/client-cpp/src/main/DeviceID.h | 161 ++
iotdb-client/client-cpp/src/main/Session.cpp | 2510 ++++++++++----------
iotdb-client/client-cpp/src/main/Session.h | 1174 ++++-----
.../client-cpp/src/main/SessionConnection.cpp | 499 +++-
.../client-cpp/src/main/SessionConnection.h | 298 ++-
iotdb-client/client-cpp/src/main/TableSession.h | 8 +-
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 156 +-
.../src/test/cpp/sessionRelationalIT.cpp | 6 +-
iotdb-client/client-cpp/src/test/main.cpp | 2 +-
.../client-cpp/src/test/main_Relational.cpp | 20 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../rpc/subscription/config/ConsumerConfig.java | 4 +
.../rpc/subscription/config/ConsumerConstant.java | 3 +
.../base/AbstractSubscriptionProvider.java | 1 +
.../ainode/ainode/TimerXL/models/timer_xl.py | 32 +-
iotdb-core/ainode/ainode/core/handler.py | 5 +-
.../ainode/core/manager/inference_manager.py | 329 +--
.../ainode/core/model/built_in_model_factory.py | 22 +-
iotdb-core/ainode/ainode/core/util/serde.py | 413 ----
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 5 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 3 +-
.../subscription/SubscriptionTableResp.java | 29 +-
.../response/subscription/TopicTableResp.java | 25 +-
.../subscription/SubscriptionCoordinator.java | 29 +-
.../iotdb/confignode/persistence/ModelInfo.java | 1 +
.../schema/TreeDeviceViewFieldDetector.java | 96 +-
.../persistence/subscription/SubscriptionInfo.java | 42 +-
.../procedure/PartitionTableAutoCleaner.java | 23 +-
.../schema/table/view/AddViewColumnProcedure.java | 32 +-
.../subscription/CreateSubscriptionProcedure.java | 10 -
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../persistence/schema/ConfigMTreeTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 6 +-
.../schema/table/CreateTableProcedureTest.java | 2 +-
.../schema/table/CreateTableViewProcedureTest.java | 4 +-
.../table/view/CreateTableViewProcedureTest.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 10 +
.../operator/process/ai/InferenceOperator.java | 34 +-
.../process/join/LeftOuterTimeJoinOperator.java | 2 +-
.../schema/source/TableDeviceQuerySource.java | 2 +-
.../InformationSchemaContentSupplierFactory.java | 8 +-
.../execution/config/TableConfigTaskVisitor.java | 14 +-
.../config/executor/ClusterConfigTaskExecutor.java | 5 +-
.../config/sys/subscription/DropTopicTask.java | 1 +
.../sys/subscription/ShowSubscriptionsTask.java | 1 +
.../config/sys/subscription/ShowTopicsTask.java | 1 +
.../db/queryengine/plan/parser/ASTVisitor.java | 22 +-
.../plan/planner/TableOperatorGenerator.java | 122 +-
.../planner/plan/parameter/SeriesScanOptions.java | 9 +-
.../function/TableBuiltinTableFunction.java | 9 +-
.../function/tvf/ForecastTableFunction.java | 45 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 2 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 8 +-
.../distribute/TableDistributedPlanGenerator.java | 17 +-
.../iterative/rule/PruneTableScanColumns.java | 3 +
.../node/AggregationTreeDeviceViewScanNode.java | 2 +-
.../node/TreeAlignedDeviceViewScanNode.java | 2 +-
.../node/TreeNonAlignedDeviceViewScanNode.java | 2 +-
.../relational/sql/ast/ViewFieldDefinition.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 23 +-
.../metadata/subscription/DropTopicStatement.java | 17 +-
.../subscription/ShowSubscriptionsStatement.java | 15 +-
.../metadata/subscription/ShowTopicsStatement.java | 15 +-
.../table/DataNodeTreeViewSchemaUtils.java | 10 +
.../load/active/ActiveLoadTsFileLoader.java | 16 +-
.../receiver/SubscriptionReceiverV1.java | 10 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 29 +-
.../plan/relational/analyzer/TreeViewTest.java | 19 +
.../commons/binaryallocator/BinaryAllocator.java | 66 +-
.../PooledBinaryPhantomReference.java | 31 +-
.../iotdb/commons/binaryallocator/arena/Arena.java | 36 +-
.../binaryallocator/autoreleaser/Releaser.java | 91 +
.../binaryallocator/config/AllocatorConfig.java | 4 +-
.../commons/binaryallocator/evictor/Evictor.java | 25 +-
.../iotdb/commons/client/ainode/AINodeClient.java | 16 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 +
.../datastructure/visibility/VisibilityUtils.java | 10 +
.../iotdb/commons/schema/table/TreeViewSchema.java | 8 +
.../apache/iotdb/commons/schema/table/TsTable.java | 2 +-
.../meta/subscription/SubscriptionMeta.java | 20 +-
.../commons/subscription/meta/topic/TopicMeta.java | 9 +
.../subscription/meta/topic/TopicMetaKeeper.java | 8 +
.../iotdb/commons/utils/TimePartitionUtils.java | 13 -
.../binaryallocator/BinaryAllocatorTest.java | 44 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 7 +-
.../src/main/thrift/confignode.thrift | 5 +
scripts/conf/datanode-env.sh | 2 +-
139 files changed, 6817 insertions(+), 4460 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionTableAutoCleanIT.java
=> IoTDBPartitionTableAutoCleanUSIT.java} (87%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/IoTDBFilterBetweenTableIT.java
=> view/old/IoTDBFilterBetweenTableViewIT.java} (83%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/IoTDBFilterNullTableIT.java
=> view/old/IoTDBFilterNullTableViewIT.java} (76%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/IoTDBFilterTableIT.java
=> view/old/IoTDBFilterTableViewIT.java} (68%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/IoTDBNestedQueryTableIT.java
=> view/old/IoTDBNestedQueryTableViewIT.java} (85%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/IoTDBSimpleQueryTableIT.java
=> view/old/IoTDBSimpleQueryTableViewIT.java} (53%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceTable2IT.java
=> view/old/alignbydevice/IoTDBAlignByDeviceTableView2IT.java} (91%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceTable2IT.java
=> view/old/alignbydevice/IoTDBAlignByDeviceTableView3IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceTableIT.java
=> view/old/alignbydevice/IoTDBAlignByDeviceTableViewIT.java} (81%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceWithTemplateTable2IT.java
=> view/old/alignbydevice/IoTDBAlignByDeviceWithTemplateTableView2IT.java}
(89%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceWithTemplateTableIT.java
=> view/old/alignbydevice/IoTDBAlignByDeviceWithTemplateTableViewIT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceTable2IT.java
=>
view/old/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceTableView2IT.java}
(86%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceTableIT.java
=>
view/old/alignbydevice/IoTDBOrderByLimitOffsetAlignByDeviceTableViewIT.java}
(69%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBOrderByWithAlignByDeviceTable2IT.java
=> view/old/alignbydevice/IoTDBOrderByWithAlignByDeviceTableView2IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBOrderByWithAlignByDeviceTable3IT.java
=> view/old/alignbydevice/IoTDBOrderByWithAlignByDeviceTableView3IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBOrderByWithAlignByDeviceTableIT.java
=> view/old/alignbydevice/IoTDBOrderByWithAlignByDeviceTableViewIT.java} (95%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBAlignedOffsetLimitPushDownTableIT.java
=> view/old/aligned/IoTDBAlignedOffsetLimitPushDownTableViewIT.java} (79%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBAlignedSeriesQueryTable2IT.java
=> view/old/aligned/IoTDBAlignedSeriesQueryTableView2IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTable3IT.java
=> view/old/aligned/IoTDBAlignedSeriesQueryTableView3IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBAlignedSeriesQueryTable4IT.java
=> view/old/aligned/IoTDBAlignedSeriesQueryTableView4IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBAlignedSeriesQueryTable5IT.java
=> view/old/aligned/IoTDBAlignedSeriesQueryTableView5IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBAlignedSeriesQueryTableIT.java
=> view/old/aligned/IoTDBAlignedSeriesQueryTableViewIT.java} (99%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTable2IT.java
=> view/old/aligned/IoTDBPredicatePushDownTableView2IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTable3IT.java
=> view/old/aligned/IoTDBPredicatePushDownTableView3IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTable4IT.java
=> view/old/aligned/IoTDBPredicatePushDownTableView4IT.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTableIT.java
=> view/old/aligned/IoTDBPredicatePushDownTableViewIT.java} (97%)
copy
integration-test/src/test/java/org/apache/iotdb/{db/it/utils/AlignedWriteUtil.java
=> relational/it/query/view/old/aligned/TableViewUtils.java} (77%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/orderBy/IoTDBOrderByTableIT.java
=> view/old/orderby/IoTDBOrderByTableViewIT.java} (91%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/query/IoTDBArithmeticTableIT.java
=> view/old/query/IoTDBArithmeticTableViewIT.java} (87%)
copy
integration-test/src/test/java/org/apache/iotdb/{db/it/query/IoTDBPaginationIT.java
=> relational/it/query/view/old/query/IoTDBPaginationTableViewIT.java} (65%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBColumnsMatchTableIT.java
=> view/recent/IoTDBColumnsMatchTableViewIT.java} (93%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBComplexQueryTableViewIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBDistinctTagTableViewIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBFillTableIT.java
=> view/recent/IoTDBFillTableViewIT.java} (89%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBGapFillTableIT.java
=> view/recent/IoTDBGapFillTableViewIT.java} (93%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBNullIdQueryIT.java
=> view/recent/IoTDBNullIdQueryTableViewIT.java} (88%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBNullValueIT.java
=> view/recent/IoTDBNullValueTableViewIT.java} (77%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBTableAggregationFunctionDistinctIT.java
=> view/recent/IoTDBTableViewAggregationFunctionDistinctIT.java} (88%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBTableAggregationIT.java
=> view/recent/IoTDBTableViewAggregationIT.java} (89%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{recent/IoTDBTableAggregationIT.java
=> view/recent/IoTDBTableViewAggregationNonStreamIT.java} (89%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBTableViewQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/tablemodel/IoTDBSubscriptionIsolationIT.java
create mode 100644 iotdb-client/client-cpp/src/main/Common.cc
create mode 100644 iotdb-client/client-cpp/src/main/Common.h
create mode 100644 iotdb-client/client-cpp/src/main/DeviceID.h
copy
integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteConfigNodeConfig.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/PooledBinaryPhantomReference.java
(56%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/binaryallocator/autoreleaser/Releaser.java
