This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch builtin-udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from bc3fed49a2b Merge branch 'udtf-optimize' into builtin-udtf
new b6bda6d986e save
new 9dc0c9d0b6a save
new 1496caa6ac8 save
add f44fd70bf18 Save
add 07e0d21478a [opt](query) Improve the logic to calculate
TRegionReplicaSets for devices (#15102)
add 98acf8e5090 Optimized the query logic to make schema or weak data
query read from local first & random if without local (#15106)
add a637327f31d fix create region group (#15108)
add 19067243d0c Subscription IT: fix
IoTDBConsumer2With1TopicShareProcessTsfileIT (#15110)
add 010843f8933 Optimized the show/query devices logic to only return
required attributes & Reduced unnecessary CPU usage in schema tsBlock building
(#15109)
add ec06abee8fc Fix template extension with null value (#15103)
add 35377c69004 Make error msg be semantic when the functionality is not
supported
add 385d0df5f9f Enhance remove unexisted confignode error message #15117
add c09bb166883 Optimize query execution in easy count(*) cases
add 5ab0c1adbfd Try to compatiable with 1.3.X view
add c6d1f493b0d Fix the wrong time index type check in
CrossSpaceCompaction (#15095)
add 93197a426ea fix mods file metrics (#15107)
add 93ec99d7ad0 Make removed confignode can rejoin cluster without
deleting data dir (#15118)
add 411f45f99a2 feat: move costTime to execute finished
add 8e650cbb1e1 Pipe: Reduced the log of epoch switching & Optimized the
memory calculation of insertion event & Refactor & Optimized the memory
reservation logic of tsFile parser provider & Added the missing parsing logic +
Fixed the wrong listening types to table meta sync & Skipped the file parsing
in privilege for empty file and root user & Subscription IT: assertGte for
received tsfile count (#15068)
add 0e395feb01c Pipe: Added memory control for receiver insert statements
(#15046)
add ab784fbfabb Revert "Optimized the query logic to make schema or weak
data query read from local first & random if without local (#15106)" (#15127)
add 50a48ce42b3 Load & Region Migrate: Notify all DNs before and after RM
(#15032)
add db614fb8eda IoTConsensusV2: Fix concurrency bug when client traffic is
extremely high (#15129)
add 893d9ffa8f7 Resolve conflict
new 8630cb6fabd Save
new c3c3e39e322 save
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:
.../it/cluster/IoTDBClusterNodeGetterIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 7 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 16 +-
.../IoTDBCorrelatedExistsSubqueryIT.java | 24 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 14 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 10 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 10 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 8 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 22 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../confignode/client/CnToCnNodeRequestType.java | 2 +-
.../client/async/CnToDnAsyncRequestType.java | 1 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 6 +-
.../write/pipe/payload/PipeDeleteDevicesPlan.java | 44 +--
.../request/write/table/AbstractTablePlan.java | 15 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../extractor/ConfigRegionListeningFilter.java | 3 +-
...ConfigPhysicalPlanTablePatternParseVisitor.java | 62 ++--
...nfigPhysicalPlanTablePrivilegeParseVisitor.java | 82 +++---
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 37 +--
.../procedure/env/ConfigNodeProcedureEnv.java | 20 +-
.../impl/node/RemoveConfigNodeProcedure.java | 8 +-
.../impl/region/CreateRegionGroupsProcedure.java | 35 ++-
.../region/NotifyRegionMigrationProcedure.java | 137 +++++++++
.../impl/region/RegionMigrateProcedure.java | 2 +
...eState.java => NotifyRegionMigrationState.java} | 5 +-
.../procedure/state/RemoveConfigNodeState.java | 2 +-
.../procedure/store/ProcedureFactory.java | 7 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 10 +-
...igPhysicalPlanTablePatternParseVisitorTest.java | 9 +
.../protocol/opcda/OpcDaServerHandle.java | 4 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 4 +-
.../async/IoTDBDataRegionAsyncConnector.java | 21 --
.../db/pipe/event/common/PipeInsertionEvent.java | 13 -
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 9 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 15 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 70 +++--
.../parser/TsFileInsertionEventParserProvider.java | 19 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 12 +-
.../pipeconsensus/PipeConsensusReceiver.java | 17 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 52 +++-
.../resource/memory/InsertNodeMemoryEstimator.java | 319 ++++-----------------
.../pipe/resource/tsfile/PipeTsFileResource.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 22 +-
.../fragment/FragmentInstanceContext.java | 38 ++-
.../schema/source/DeviceAttributeUpdater.java | 10 +-
.../schema/source/DeviceBlackListConstructor.java | 11 +-
.../schema/source/DevicePredicateFilter.java | 13 +-
.../schema/source/DevicePredicateHandler.java | 22 +-
.../operator/schema/source/DeviceUpdater.java | 13 +-
.../schema/source/SchemaSourceFactory.java | 4 +-
.../schema/source/TableDeviceQuerySource.java | 21 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 11 +-
.../config/executor/ClusterConfigTaskExecutor.java | 8 +-
.../plan/planner/TableOperatorGenerator.java | 37 ++-
.../plan/planner/plan/node/PlanGraphPrinter.java | 15 +-
.../plan/relational/analyzer/Analysis.java | 17 --
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 5 +
.../relational/planner/TableLogicalPlanner.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 224 +++++++--------
.../plan/relational/planner/node/GroupNode.java | 47 +--
.../planner/optimizations/ParallelizeGrouping.java | 130 +++++----
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../optimizations/UnaliasSymbolReferences.java | 3 -
.../sql/ast/AbstractQueryDeviceWithCache.java | 33 ++-
.../relational/sql/ast/AbstractTraverseDevice.java | 9 +-
.../plan/relational/sql/ast/DeleteDevice.java | 19 +-
.../plan/relational/sql/ast/ShowDevice.java | 10 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 10 +
.../plan/statement/crud/InsertBaseStatement.java | 46 ++-
.../crud/InsertMultiTabletsStatement.java | 16 ++
.../plan/statement/crud/InsertRowStatement.java | 13 +
.../crud/InsertRowsOfOneDeviceStatement.java | 16 ++
.../plan/statement/crud/InsertRowsStatement.java | 16 ++
.../plan/statement/crud/InsertTabletStatement.java | 18 ++
.../attribute/update/UpdateDetailContainer.java | 2 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 29 +-
.../iotdb/db/service/RegionMigrateService.java | 18 ++
.../buffer/TimeSeriesMetadataCache.java | 3 +-
.../db/storageengine/dataregion/DataRegion.java | 7 +-
.../dataregion/VirtualDataRegion.java | 2 +-
.../writer/AbstractCrossCompactionWriter.java | 25 +-
.../utils/writer/FastCrossCompactionWriter.java | 12 +
.../dataregion/tsfile/TsFileResource.java | 50 ++--
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 12 +-
.../process/tvf/TableFunctionOperatorTest.java | 4 +-
.../plan/relational/analyzer/AnalyzerTest.java | 10 +-
.../relational/analyzer/TableFunctionTest.java | 1 -
.../FastCrossCompactionPerformerTest.java | 78 +++++
.../apache/iotdb/commons/conf/CommonConfig.java | 12 +-
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../consensus/index/impl/HybridProgressIndex.java | 4 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../commons/schema/view/LogicalViewSchema.java | 13 +-
.../multi/FunctionViewExpression.java | 14 +
.../viewExpression/unary/LikeViewExpression.java | 39 ++-
.../relational/TableBuiltinTableFunction.java | 8 +-
...bleFunction.java => CapacityTableFunction.java} | 9 +-
.../relational/tvf/SessionTableFunction.java | 6 +-
.../relational/tvf/VariationTableFunction.java | 6 +-
.../iotdb/commons/utils/TimePartitionUtils.java | 7 +-
.../schema/LikeViewExpreesionSerDeTest.java | 48 ++++
.../src/main/thrift/confignode.thrift | 4 +-
.../src/main/thrift/datanode.thrift | 10 +
110 files changed, 1450 insertions(+), 1036 deletions(-)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RemoveAINodeState.java
=> NotifyRegionMigrationState.java} (93%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/{NumberTableFunction.java
=> CapacityTableFunction.java} (93%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/LikeViewExpreesionSerDeTest.java
