This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch tvf_handler
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 21be7390051 remove arguments
add fcb2ab352fe Pipe: switch to IdentityHashMap backed set to avoid
infinite loop in table tsfile builder (#15371)
add 8fff9f22677 Pipe: fix potential ClassCastException when casting
LocalDate[] in PipeTreeModelTsFileBuilderV2 (#15375)
add 41c55ad7599 Fix python client pom error (#15381)
add 8f29bcd8578 Load: Do not clear schema cache when last cache is
disabled (#15380)
add aaff44910bd Pipe: aggregate tablets with different measurements under
the same table before write into tsfile (#15372)
add 74827521421 Subscription: obtain database name for message payload
subscribed by table model consumer (#15374)
add 2cfd029f214 Pipe: use mem table to batch write table data into tsfile
(#15373)
add 3215a4f4782 Fix error code when Row appears in query
add 571dcbe19c9 [RTO/RPO] Coordinator/Session Failover Retry (#15269)
add b20ab8accf2 Subscription: implemented runtime permission check (#15376)
add 5fae88dd6a6 feat: disabled history for -e sql (#15389)
add ede9b7430b6 Fixed the issue where the code returned when executing
drop user root SQL is different from the CLI (#15387)
add 699487f7f12 Adapt TIMESTAMP type when import data (#15378)
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 28fab87d5ad Merge branch 'master' into tvf_handler
add 467768eb5c9 compile error
No new revisions were added by this update.
Summary of changes:
.../TableModelSubscriptionSessionExample.java | 19 +-
.../org/apache/iotdb/udf/table/RepeatExample.java | 4 +-
.../udf/example/relational/MySelectColumn.java | 12 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 54 ++++
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 -
.../org/apache/iotdb/db/it/utils/TestUtils.java | 8 -
.../manual/basic/IoTDBPipeWithLoadIT.java | 131 ++++++++
.../relational/it/db/it/IoTDBWindowTVFIT.java | 23 +-
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 16 +
.../it/query/recent/IoTDBTableAggregationIT.java | 8 +
.../it/local/IoTDBSubscriptionPermissionIT.java | 339 +++++++++++++++++++++
.../table/argument/ScalarArgumentChecker.java | 16 +-
.../processor/TableFunctionDataProcessor.java | 12 +-
.../ScalarParameterSpecification.java | 23 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 1 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 12 +
.../org/apache/iotdb/tool/data/ImportDataTree.java | 57 +++-
.../subscription/SubscriptionTableTsFile.java | 2 +-
iotdb-client/client-cpp/src/main/Session.cpp | 2 +-
.../client-cpp/src/main/SessionConnection.h | 2 +-
iotdb-client/client-py/pom.xml | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 134 ++++----
.../rpc/subscription/annotation/TableModel.java | 12 +-
.../rpc/subscription/config/ConsumerConfig.java | 8 +
.../subscription/payload/poll/FileSealPayload.java | 27 +-
.../subscription/payload/poll/TabletsPayload.java | 41 ++-
.../response/PipeSubscribeHeartbeatResp.java | 48 ++-
.../apache/iotdb/session/SessionConnection.java | 148 +++++++--
.../SubscriptionSessionConnection.java | 32 --
.../base/AbstractSubscriptionConsumer.java | 26 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 20 --
.../base/AbstractSubscriptionProvider.java | 13 +-
.../base/AbstractSubscriptionProviders.java | 6 +-
.../SubscriptionTablePullConsumerBuilder.java | 3 +-
.../SubscriptionTablePushConsumerBuilder.java | 3 +-
.../tree/SubscriptionTreePullConsumerBuilder.java | 3 +-
.../tree/SubscriptionTreePushConsumerBuilder.java | 3 +-
.../payload/SubscriptionFileHandler.java | 7 -
.../subscription/payload/SubscriptionMessage.java | 29 +-
.../payload/SubscriptionMessageHandler.java | 7 +-
.../payload/SubscriptionSessionDataSet.java | 97 +++++-
.../SubscriptionSessionDataSetsHandler.java | 56 ++--
.../payload/SubscriptionTsFileHandler.java | 14 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 6 +-
.../persistence/schema/ClusterSchemaInfo.java | 15 +-
.../consumer/CreateConsumerProcedure.java | 4 +-
.../subscription/CreateSubscriptionProcedure.java | 21 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 51 +++-
.../subtask/connector/PipeConnectorSubtask.java | 13 +-
.../batch/PipeTabletEventTsFileBatch.java | 9 +-
.../batch/PipeTransferBatchReqBuilder.java | 41 ++-
.../PipeConsensusTransferBatchReqBuilder.java | 19 +-
...ilder.java => PipeTableModelTsFileBuilder.java} | 116 +++++--
...rV2.java => PipeTableModelTsFileBuilderV2.java} | 137 ++++++---
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 4 +-
.../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 +-
.../rest/table/v1/handler/ExceptionHandler.java | 4 +
.../protocol/rest/v1/handler/ExceptionHandler.java | 4 +
.../protocol/rest/v2/handler/ExceptionHandler.java | 4 +
.../execution/executor/RegionReadExecutor.java | 17 +-
.../process/function/TableFunctionOperator.java | 18 +-
.../relational/ColumnTransformerBuilder.java | 2 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 4 -
.../plan/analyze/load/LoadTsFileAnalyzer.java | 66 +---
.../analyze/load/LoadTsFileTableSchemaCache.java | 78 ++++-
.../analyze/schema/AutoCreateSchemaExecutor.java | 14 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 9 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 1 -
.../config/executor/ClusterConfigTaskExecutor.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 3 +
.../queryengine/plan/planner/TreeModelPlanner.java | 2 -
.../plan/node/metadata/write/MeasurementGroup.java | 25 +-
.../relational/analyzer/StatementAnalyzer.java | 8 +
.../plan/relational/planner/TableModelPlanner.java | 9 -
.../plan/relational/sql/ast/Expression.java | 3 +
.../plan/relational/sql/ast/LoadTsFile.java | 10 +-
.../queryengine/plan/relational/sql/ast/Row.java | 33 ++
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 21 +-
.../plan/scheduler/ClusterScheduler.java | 5 -
....java => FailedFragmentInstanceWithStatus.java} | 22 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 248 ++++++++-------
.../db/schemaengine/table/DataNodeTableCache.java | 18 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 3 +
.../db/subscription/event/SubscriptionEvent.java | 4 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 27 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 5 +-
.../response/SubscriptionEventTabletResponse.java | 20 +-
.../response/SubscriptionEventTsFileResponse.java | 9 +-
.../receiver/SubscriptionReceiverV1.java | 47 ++-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 23 +-
.../iotdb/db/queryengine/plan/function/Repeat.java | 4 +-
...n.java => QuerySchemaFetchFailedException.java} | 10 +-
.../agent/task/progress/PipeEventCommitter.java | 28 +-
.../config/constant/PipeConnectorConstant.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 10 +
.../meta/consumer/ConsumerGroupMeta.java | 49 +++
.../subscription/meta/consumer/ConsumerMeta.java | 12 +
.../commons/subscription/meta/topic/TopicMeta.java | 9 +-
.../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 | 2 +-
113 files changed, 2183 insertions(+), 752 deletions(-)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/function/Exclude.java
=>
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/MySelectColumn.java
(90%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionPermissionIT.java
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%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/SchemaRegion.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/annotation/TableModel.java
(76%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/{PipeTableModeTsFileBuilder.java
=> PipeTableModelTsFileBuilder.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/{PipeTreeModelTsFileBuilderV2.java
=> PipeTableModelTsFileBuilderV2.java} (54%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/{FragInstanceDispatchResult.java
=> FailedFragmentInstanceWithStatus.java} (69%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{RpcThrottlingException.java
=> QuerySchemaFetchFailedException.java} (72%)
