This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch
fix_project_order_in_TableDistributedPlanGenerator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7da7528bcc7 fix
add 9132389e4fd Import/Export schema script adapt table model (#15192)
add e6713d4f029 IoTV2: Clean receiver files when dropping consensus pipe &
Improve robustness when cleaning some dirs. (#15252)
add a4d1a508100 Pipe: Applied the login function to config receiver
(#15258)
add e7ce326ca07 [opt](query) Optimize count(1), count(constant expression)
to count(*)
add d3d0687b3be Reduce default value of rpcMaxConcurrentClientNum (#15260)
add 518126ed7ce Enhance remove confignode robustness by increase waiting
time for new leader #15261
add fac2e6334bd Harmonizing the case of reported error messages for
aggregation (#15251)
add 838dbab4fb5 Made memory not enough exception cause by schema fetching
retry-able for insertion & Refactor & Fixed the database name bug when alter
non-exists database
add 72aeed2591f Pipe: Optimized insert node cache hit possibility & Pipe:
Set thread name for pipe receiver (#15263)
add edf2aa6ee5b fix node ordering
add f8188b47e4b perfect ramBytesUsed method
add bee5bd90379 fix order of project
add fbc019091df fix
add 82be8be5844 Pipe: Added total floating memory usage for mem-ctrl of
linked but deleted tsFile resource and insertNode memory (#15205)
add e4e3c29d274 fix grant all to others.
add b4abdd2bf34 Pipe: Fixed the meta inclusion between SQL dialects
(#15278)
add 961f3581728 Fix the output ordinal of AggTableScanOperator are not
consistent with OutputSymbols of AggTableScanNode when do single input distinct
optimize
add 6ed8366ed81 Merge branch 'master' into
fix_project_order_in_TableDistributedPlanGenerator
add 2814d5833f8 remove TODO
add 24d3329a1c9 Merge branch
'fix_project_order_in_TableDistributedPlanGenerator' of github.com:apache/iotdb
into fix_project_order_in_TableDistributedPlanGenerator
No new revisions were added by this update.
Summary of changes:
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 43 ++
.../manual/enhanced/IoTDBPipeMetaIT.java | 52 ++
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 122 +++-
.../it/query/recent/IoTDBTableAggregationIT.java | 64 +++
.../relational/it/schema/IoTDBDatabaseIT.java | 11 +
.../apache/iotdb/tools/it/ExportDataTestIT.java | 13 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 5 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 8 +-
.../org/apache/iotdb/tool/common/Constants.java | 45 +-
.../org/apache/iotdb/tool/common/OptionsUtil.java | 156 +++++-
.../apache/iotdb/tool/data/AbstractImportData.java | 2 +-
.../org/apache/iotdb/tool/data/ExportData.java | 1 -
.../apache/iotdb/tool/data/ExportDataTable.java | 2 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 2 +-
.../iotdb/tool/schema/AbstractExportSchema.java} | 14 +-
.../iotdb/tool/schema/AbstractImportSchema.java | 94 ++++
.../iotdb/tool/schema/AbstractSchemaTool.java | 120 ++--
.../org/apache/iotdb/tool/schema/ExportSchema.java | 325 +++--------
.../iotdb/tool/schema/ExportSchemaTable.java | 252 +++++++++
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 116 ++++
.../org/apache/iotdb/tool/schema/ImportSchema.java | 613 +++------------------
.../iotdb/tool/schema/ImportSchemaTable.java | 188 +++++++
.../{ImportSchema.java => ImportSchemaTree.java} | 417 ++++----------
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 4 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 12 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 42 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 4 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 3 -
.../deletion/DeletionResourceManager.java | 15 +-
.../parser/TsFileInsertionEventParserProvider.java | 2 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 8 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 2 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 82 +--
.../db/pipe/resource/memory/PipeMemoryManager.java | 45 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 -
.../relational/aggregation/AvgAccumulator.java | 8 +-
.../relational/aggregation/CountAccumulator.java | 4 +-
.../aggregation/CountAllAccumulator.java | 4 +-
.../relational/aggregation/ExtremeAccumulator.java | 2 +-
.../relational/aggregation/FirstAccumulator.java | 12 +-
.../relational/aggregation/FirstByAccumulator.java | 14 +-
.../relational/aggregation/LastAccumulator.java | 12 +-
.../relational/aggregation/LastByAccumulator.java | 17 +-
.../relational/aggregation/MaxAccumulator.java | 12 +-
.../relational/aggregation/MinAccumulator.java | 12 +-
.../relational/aggregation/SumAccumulator.java | 8 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 9 +-
.../aggregation/TableVarianceAccumulator.java | 4 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 6 +-
.../grouped/GroupedExtremeAccumulator.java | 16 +-
.../grouped/GroupedFirstAccumulator.java | 20 +-
.../grouped/GroupedFirstByAccumulator.java | 22 +-
.../grouped/GroupedLastAccumulator.java | 20 +-
.../grouped/GroupedLastByAccumulator.java | 24 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 16 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 34 +-
.../aggregation/grouped/GroupedMinAccumulator.java | 16 +-
.../grouped/GroupedModeAccumulator.java | 6 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 4 +-
.../grouped/GroupedVarianceAccumulator.java | 2 +-
.../plan/analyze/ClusterPartitionFetcher.java | 30 +-
.../analyze/cache/partition/PartitionCache.java | 7 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 14 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 9 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../relational/analyzer/ExpressionAnalyzer.java | 2 +-
.../plan/relational/function/FunctionId.java | 2 +
.../plan/relational/metadata/ResolvedFunction.java | 1 -
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 5 +-
.../plan/relational/planner/SymbolAllocator.java | 4 +
.../plan/relational/planner/ir/IrUtils.java | 7 +
.../iterative/rule/SimplifyCountOverConstant.java | 145 +++++
.../rule/SingleDistinctAggregationToGroupBy.java | 3 +-
.../planner/node/AggregationTableScanNode.java | 11 +-
.../optimizations/LogicalOptimizeFactory.java | 5 +-
...mQuantifiedComparisonApplyToCorrelatedJoin.java | 13 +-
.../relational/planner/optimizations/Util.java | 2 +-
.../relational/security/AccessControlImpl.java | 7 +-
.../dataregion/wal/utils/WALEntryHandler.java | 10 +-
.../dataregion/wal/utils/WALEntryPosition.java | 4 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 6 +
.../broker/SubscriptionPrefetchingQueueStates.java | 2 +-
.../event/cache/SubscriptionPollResponseCache.java | 4 +-
.../plan/relational/analyzer/AggregationTest.java | 45 ++
.../conf/iotdb-system.properties.template | 4 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 13 +
.../iotdb/commons/pipe/config/PipeConfig.java | 5 +
.../options/PipeInclusionOptions.java | 117 ++--
.../commons/pipe/extractor/IoTDBExtractor.java | 15 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 35 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 1 +
98 files changed, 2116 insertions(+), 1630 deletions(-)
copy
iotdb-client/{session/src/main/java/org/apache/iotdb/session/InsertConsumer.java
=> cli/src/main/java/org/apache/iotdb/tool/schema/AbstractExportSchema.java}
(71%)
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/AbstractImportSchema.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/ExportSchemaTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/ExportSchemaTree.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/ImportSchemaTable.java
copy
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/schema/{ImportSchema.java
=> ImportSchemaTree.java} (53%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SimplifyCountOverConstant.java
