This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch udtf-optimize
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 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
No new revisions were added by this update.
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 | 23 +-
.../plan/relational/analyzer/Analysis.java | 17 --
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 5 +
.../relational/planner/TableLogicalPlanner.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 124 +++++---
.../optimizations/PushPredicateIntoTableScan.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 +-
.../plan/relational/analyzer/AnalyzerTest.java | 10 +-
.../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 ++-
.../iotdb/commons/utils/TimePartitionUtils.java | 7 +-
.../schema/LikeViewExpreesionSerDeTest.java | 48 ++++
.../src/main/thrift/confignode.thrift | 4 +-
.../src/main/thrift/datanode.thrift | 10 +
100 files changed, 1308 insertions(+), 835 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%)
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/LikeViewExpreesionSerDeTest.java
