This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch last_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ad4343e8e5c fix it
add 0c29fe5a0c0 Revert "Load: Parallelly load files into different target
data partitions (#13893)" (#13905)
add e5d7d558981 Add try_cast function
add ad97746cddf Pipe: Fix mode.snapshot configuration not taking effect
(#13899)
add 77a2dd7232d Support distinguish of DB model && Fixed the table
detection bug when indexOutOfRange && Fixed the bug that conflict databases may
be saved in cache
add 53741294f06 Fix compaction cached time chunk flip twice (#13903)
add 7ed70ecefdf Support mode, stddev and variance function for grouped
aggregation (#13911)
new 4bb2d27f7de Merge branch 'master' into last_cache
new 6479ad912d3 fix it
The 2 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:
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 20 +-
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 87 +++-
.../scalar/IoTDBCastFunctionTableIT.java | 552 +++++++++++++++++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 17 +
.../relational/it/schema/IoTDBDatabaseIT.java | 22 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../iotdb/confignode/manager/ConfigManager.java | 40 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../manager/schema/ClusterSchemaManager.java | 15 +-
.../persistence/partition/PartitionInfo.java | 18 +-
.../persistence/schema/ClusterSchemaInfo.java | 29 +-
.../confignode/persistence/schema/ConfigMTree.java | 90 ++--
.../persistence/schema/mnode/IConfigMNode.java | 1 +
.../schema/mnode/impl/ConfigDatabaseMNode.java | 5 +-
.../schema/mnode/impl/ConfigTableNode.java | 4 +-
.../impl/schema/SetTemplateProcedure.java | 148 +++---
.../persistence/schema/ConfigMTreeTest.java | 38 +-
.../metadata/DatabaseConflictException.java | 2 +-
...sException.java => DatabaseModelException.java} | 10 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 42 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 31 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 2 +-
.../common/header/ColumnHeaderConstant.java | 12 +-
.../common/header/DatasetHeaderFactory.java | 6 +-
.../TableAggregationTableScanOperator.java | 117 ++---
.../relational/aggregation/AccumulatorFactory.java | 18 +
.../aggregation/TableModeAccumulator.java | 147 ++++--
.../source/relational/aggregation/Utils.java | 2 +-
.../grouped/GroupedModeAccumulator.java | 452 +++++++++++++++++
.../GroupedVarianceAccumulator.java} | 140 +++---
.../{BinaryBigArray.java => MapBigArray.java} | 37 +-
.../relational/ColumnTransformerBuilder.java | 6 +-
.../plan/analyze/ClusterPartitionFetcher.java | 185 +++----
.../analyze/cache/partition/PartitionCache.java | 144 +++---
.../execution/config/TableConfigTaskVisitor.java | 3 +-
.../config/executor/ClusterConfigTaskExecutor.java | 42 +-
.../config/metadata/DatabaseSchemaTask.java | 5 +-
.../config/metadata/ShowDatabaseTask.java | 4 +-
.../config/metadata/relational/ShowDBTask.java | 60 ++-
.../plan/planner/TableOperatorGenerator.java | 60 +--
.../metadata/TableBuiltinAggregationFunction.java | 43 +-
.../fetcher/TableHeaderSchemaValidator.java | 10 +-
.../relational/planner/optimizations/Util.java | 18 +-
.../plan/relational/sql/ast/ShowDB.java | 16 +-
.../plan/relational/sql/parser/AstBuilder.java | 11 +-
.../statement/metadata/ShowDatabaseStatement.java | 23 +-
... => AbstractCastFunctionColumnTransformer.java} | 78 +--
.../scalar/CastFunctionColumnTransformer.java | 320 +-----------
.../scalar/TryCastFunctionColumnTransformer.java | 75 +++
.../db/schemaengine/table/DataNodeTableCache.java | 2 +
.../metrics/IoTDBInternalLocalReporter.java | 7 +-
.../executor/batch/utils/BatchCompactionPlan.java | 17 +-
.../estimator/AbstractCompactionEstimator.java | 2 +-
.../db/storageengine/load/LoadTsFileManager.java | 57 +--
.../plan/analyze/cache/PartitionCacheTest.java | 8 +-
...atchedAlignedSeriesFastInnerCompactionTest.java | 37 ++
.../db/relational/grammar/sql/RelationalSql.g4 | 3 +-
.../src/main/thrift/confignode.thrift | 2 +
58 files changed, 2221 insertions(+), 1124 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/metadata/{AlignedTimeseriesException.java
=> DatabaseModelException.java} (76%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedModeAccumulator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{TableVarianceAccumulator.java
=> grouped/GroupedVarianceAccumulator.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/{BinaryBigArray.java
=> MapBigArray.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/{CastFunctionColumnTransformer.java
=> AbstractCastFunctionColumnTransformer.java} (82%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TryCastFunctionColumnTransformer.java
