You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2024/10/15 12:44:28 UTC

(iotdb) branch tyAggTest updated (b103d1c208b -> 75d88a129a7)

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a change to branch tyAggTest
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from b103d1c208b Fix some sort orders bug about AggTableScan
     add 757fec48a78 fix ut
     add e022f22b0c8 Implement last cache for table model & Fixed the bug that the table conflict detection when creating timeseries in tree model does not take effect
     add 9c8c1ed5306 Push down completely when group-by Aggregation with only one device entry
     add 75d88a129a7 Merge remote-tracking branch 'origin/master' into tyAggTest

No new revisions were added by this update.

Summary of changes:
 .../apache/iotdb/itbase/constant/TestConstant.java |   2 +-
 .../db/it/aligned/IoTDBAlignedLastQueryIT.java     |  23 +-
 .../it/aligned/IoTDBLastQueryWithDeletionIT.java   |  16 +-
 .../aligned/IoTDBLastQueryWithoutLastCacheIT.java  |  16 +-
 .../db/it/last/IoTDBLastQueryLastCacheIT.java      |  10 +-
 .../protocol/thrift/impl/ClientRPCServiceImpl.java |   5 +-
 .../impl/DataNodeInternalRPCServiceImpl.java       |  19 +-
 .../last/AbstractUpdateLastCacheOperator.java      |  36 +-
 .../last/AlignedUpdateLastCacheOperator.java       |  11 +-
 .../AlignedUpdateViewPathLastCacheOperator.java    |   6 +-
 .../operator/process/last/LastQueryUtil.java       |  45 +-
 .../process/last/UpdateLastCacheOperator.java      |  15 +-
 .../last/UpdateViewPathLastCacheOperator.java      |   6 +-
 .../analyze/cache/schema/DataNodeSchemaCache.java  | 334 ---------------
 .../schema/DeviceUsingTemplateSchemaCache.java     | 235 -----------
 .../cache/schema/TimeSeriesSchemaCache.java        | 436 --------------------
 .../cache/schema/dualkeycache/IDualKeyCache.java   |  71 ++--
 .../dualkeycache/impl/CacheEntryGroupImpl.java     |  16 +-
 .../schema/dualkeycache/impl/DualKeyCacheImpl.java | 423 +++++++++----------
 .../dualkeycache/impl/FIFOCacheEntryManager.java   |  77 ++--
 .../schema/dualkeycache/impl/ICacheEntryGroup.java |   9 +-
 .../dualkeycache/impl/ICacheEntryManager.java      |  13 +-
 .../dualkeycache/impl/LRUCacheEntryManager.java    |  57 ++-
 .../schema/lastcache/DataNodeLastCacheManager.java |  72 ----
 .../schema/lastcache/ILastCacheContainer.java      |  45 --
 .../cache/schema/lastcache/LastCacheContainer.java | 103 -----
 .../schema/lastcache/value/ILastCacheValue.java    |  39 --
 .../schema/lastcache/value/LastCacheValue.java     |  74 ----
 .../plan/analyze/schema/ClusterSchemaFetcher.java  |   5 +-
 .../plan/analyze/schema/NormalSchemaFetcher.java   |   6 +-
 .../plan/analyze/schema/TemplateSchemaFetcher.java |   6 +-
 .../plan/planner/OperatorTreeGenerator.java        | 180 ++++----
 .../plan/planner/plan/node/write/InsertNode.java   |  15 +
 .../planner/plan/node/write/InsertRowNode.java     |  23 +-
 .../planner/plan/node/write/InsertTabletNode.java  |  32 +-
 .../plan/node/write/RelationalInsertRowNode.java   |  13 +
 .../node/write/RelationalInsertTabletNode.java     |  31 ++
 .../metadata/fetcher/TableDeviceSchemaFetcher.java |  55 +--
 .../fetcher/TableDeviceSchemaValidator.java        |  29 +-
 .../cache/IDeviceSchema.java}                      |   8 +-
 .../metadata/fetcher/cache}/SchemaCacheEntry.java  | 115 ++----
 .../fetcher/cache/TableAttributeSchema.java        |  77 ++++
 .../fetcher/cache/TableDeviceCacheEntry.java       | 181 +++++++-
 .../metadata/fetcher/cache/TableDeviceId.java      |  66 ---
 .../fetcher/cache/TableDeviceLastCache.java        | 240 +++++++++++
 .../fetcher/cache/TableDeviceSchemaCache.java      | 453 ++++++++++++++++++--
 .../cache/TableDeviceSchemaCacheMetrics.java}      |  30 +-
 .../relational/metadata/fetcher/cache/TableId.java |  33 +-
 .../fetcher/cache/TreeDeviceNormalSchema.java      | 103 +++++
 .../cache/TreeDeviceSchemaCacheManager.java        | 457 +++++++++++++++++++++
 .../fetcher/cache/TreeDeviceTemplateSchema.java}   |  26 +-
 .../distribute/TableDistributedPlanGenerator.java  |  12 +-
 .../PushAggregationIntoTableScan.java              |  13 +-
 .../schemaregion/impl/SchemaRegionMemoryImpl.java  |  11 +-
 .../db/storageengine/dataregion/DataRegion.java    | 168 ++------
 ....java => TreeDeviceSchemaCacheManagerTest.java} | 228 ++++------
 .../cache/dualkeycache/DualKeyCacheTest.java       | 347 +---------------
 .../plan/relational/analyzer/AggregationTest.java  |  83 ++--
 .../fetcher/cache/TableDeviceSchemaCacheTest.java  | 434 +++++++++++++++++--
 .../pipe/datastructure/pattern/TreePattern.java    |   8 +-
 60 files changed, 2901 insertions(+), 2801 deletions(-)
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/DataNodeSchemaCache.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/DeviceUsingTemplateSchemaCache.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/TimeSeriesSchemaCache.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/DataNodeLastCacheManager.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/ILastCacheContainer.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/LastCacheContainer.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/value/ILastCacheValue.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/cache/schema/lastcache/value/LastCacheValue.java
 copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/{BuiltinFunctionResolver.java => fetcher/cache/IDeviceSchema.java} (86%)
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{analyze/cache/schema => relational/metadata/fetcher/cache}/SchemaCacheEntry.java (52%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableAttributeSchema.java
 delete mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableDeviceId.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TableDeviceLastCache.java
 rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{analyze/cache/schema/DataNodeSchemaCacheMetrics.java => relational/metadata/fetcher/cache/TableDeviceSchemaCacheMetrics.java} (70%)
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceNormalSchema.java
 create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceSchemaCacheManager.java
 copy iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/table/ShowTablePlan.java => datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/cache/TreeDeviceTemplateSchema.java} (55%)
 rename iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/cache/{DataNodeSchemaCacheTest.java => TreeDeviceSchemaCacheManagerTest.java} (53%)