This is an automated email from the ASF dual-hosted git repository.
critas pushed a change to branch wx_script
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 433c1a9171e fix integration-test build
add 285ee5b5b6b Load: Fixed the bug that an empty table database may not
check privilege for auto-creation (#15366)
add 9e02cbdd371 [RTO/RPO] Add requestor retry for network partition
error #15393
add bac9f664f5f Subscription: unify table and tree consumer builder
interface (#15392)
add b0cfead5f3b Pipe: Fixed the deadlock cause by terminate event
reporting & Added sink.batch.max-delay-ms to enable delicate control over batch
delay & Fixed the bug of premature halt in extractor snapshot mode cause by
real-time-first transfer & Stabilized the trigger of default batch sending &
Added "isNeedToReport" getter in PipeRawTabletInsertionEvent for user-defined
plugins & Reduce logs from PipeEventCommitter (#15377)
add 34795100682 Add ScalarArgumentChecker and auto-built pass through
index for TVF
add 8eb73e0cf1f Load: Enhanced the table auto-creation logic (#15265)
add b1344eefefc Subscription: add more methods for table session dataset
(#15398)
add eb15d9a8367 Subscription: simplify table and tree consumer builder
interface (#15399)
add db62fba21ba Subscription: implemented strict runtime permission check
for consumer group (#15400)
add dd429d9539f Pipe: Fix batch type can not be changed (Introduced in
#15377) & Enhance close() in PipeTsFileResource (#15401)
add a25ce1922fc Load IT: Ignore unstable
testLoadAutoCreateWithoutInsertPermission (#15405)
add aa1bd05234a Fix cpp client compilation (#15403)
add 1f67cf6e7cc update params in ImportSchemaTestIT (#15406)
add 7603c53305c Merge branch 'master' into wx_script
add d853503820c fix schema it
No new revisions were added by this update.
Summary of changes:
.../TableModelSubscriptionSessionExample.java | 18 ++-
.../org/apache/iotdb/udf/table/RepeatExample.java | 4 +-
.../{MyExcludeColumn.java => MySelectColumn.java} | 10 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 54 +++++++++
.../manual/basic/IoTDBPipeWithLoadIT.java | 131 +++++++++++++++++++++
.../relational/it/db/it/IoTDBWindowTVFIT.java | 23 +++-
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 16 +++
.../it/local/IoTDBSubscriptionPermissionIT.java | 115 +++++++++++++++++-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 2 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 14 +--
.../table/argument/ScalarArgumentChecker.java | 16 ++-
.../processor/TableFunctionDataProcessor.java | 12 +-
.../ScalarParameterSpecification.java | 23 +++-
.../subscription/SubscriptionTableTsFile.java | 2 +-
iotdb-client/client-cpp/src/main/Session.cpp | 2 +-
.../client-cpp/src/main/SessionConnection.h | 2 +-
.../rpc/subscription/annotation/TableModel.java | 2 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 20 ----
.../SubscriptionTablePullConsumerBuilder.java | 3 +-
.../SubscriptionTablePushConsumerBuilder.java | 3 +-
.../tree/SubscriptionTreePullConsumerBuilder.java | 3 +-
.../tree/SubscriptionTreePushConsumerBuilder.java | 3 +-
.../payload/SubscriptionSessionDataSet.java | 93 ++++++++++++---
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 15 ++-
.../consumer/CreateConsumerProcedure.java | 4 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 51 ++++++--
.../subtask/connector/PipeConnectorSubtask.java | 13 +-
.../batch/PipeTransferBatchReqBuilder.java | 41 ++++---
.../PipeConsensusTransferBatchReqBuilder.java | 19 ++-
.../common/tablet/PipeRawTabletInsertionEvent.java | 5 +
.../event/common/terminate/PipeTerminateEvent.java | 6 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 30 +----
.../pipe/resource/tsfile/PipeTsFileResource.java | 14 ++-
.../resource/tsfile/PipeTsFileResourceManager.java | 2 +-
.../process/function/TableFunctionOperator.java | 18 ++-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 66 ++---------
.../analyze/load/LoadTsFileTableSchemaCache.java | 78 +++++++++++-
.../plan/planner/TableOperatorGenerator.java | 3 +
.../relational/analyzer/StatementAnalyzer.java | 8 ++
.../plan/relational/sql/ast/LoadTsFile.java | 10 +-
.../db/schemaengine/table/DataNodeTableCache.java | 18 ++-
.../apache/iotdb/db/utils/ModificationUtils.java | 23 ++--
.../iotdb/db/queryengine/plan/function/Repeat.java | 4 +-
.../agent/task/progress/PipeEventCommitter.java | 28 +++--
.../config/constant/PipeConnectorConstant.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 10 ++
.../meta/consumer/ConsumerGroupMeta.java | 28 +++++
.../relational/tvf/CapacityTableFunction.java | 5 +-
.../relational/tvf/CumulateTableFunction.java | 13 +-
.../builtin/relational/tvf/HOPTableFunction.java | 13 +-
.../relational/tvf/SessionTableFunction.java | 5 +-
.../relational/tvf/TumbleTableFunction.java | 7 +-
.../relational/tvf/VariationTableFunction.java | 5 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 1 +
55 files changed, 841 insertions(+), 278 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyExcludeColumn.java
=> MySelectColumn.java} (90%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/table/argument/ScalarArgumentChecker.java
(69%)
