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%)