You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/02/23 14:10:48 UTC
[iotdb] branch lmh/planPushDown updated (9084bf884e -> f41eb28af9)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/planPushDown
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9084bf884e add test & fix bug
add e14325d94d [IOTDB-5560] Increase default consensusLogAppenderBufferSize from 4M to 16M to reduce the probability of large request write failures (#9101)
add 8605ae4952 [IOTDB-5533] Make IoTDB Internal Reporter as default
add 8f8652f25b [IOTDB-5553] Fix NPE while using count_if (contains keep expression) with group by level (#9100)
add 6ace6afa08 [IOTDB-4438] Add session window in RawDataAggregationOperator window management framework
add 9816ea3074 [IOTDB-5556] Gracefully exit Cluster Nodes through stop script (#9102)
add 4127dc0012 [IOTDB-5561] Fix NPE of SchemaRegionTemplateTest.testDeactivateTemplate (#9105)
add e204dddfc8 [IOTDB-5562] Change the data type of AutoGuage from long to double in metric module (#9107)
add 4dcd5641fc [IOTDB-5512] Fixed same flushIndex situation (#9111)
add 55e8678c3d Update Template.md (#9110)
add d90819f45c modify README.md for release 1.0.1 (#9114)
add d6e015eab1 [IOTDB-5517] Add metrics for disk io (#9113)
add 16c1c9efab Fix python IT fail caused by the database root.__system (#9116)
add bb7973f564 [IOTDB-5516] Try sync delete schema region when dropping database (#9108)
add 99ea2c9f7e [IOTDB-5546] Allow consumeAllOperator to run when only some of children is blocked
add 63e88d9221 feat(site): 1. Add Page RightMenu 2. Enable Algolia Search 3. Add ESLint And Fix config.js (#9125)
add ee49665f4d [IOTDB-5524] Add Metrics for Schema Module (#9109)
add b20758ac56 [IOTDB-5516] Accelerate async delete DataRegion during dropping database (#9120)
add 3a4aee19cc Fix CI error by ignore license check for some site files (#9127)
add 92358e9d30 [IOTDB-5577] Metric dashboard for Schema Module (#9135)
add a2c935aa68 [IOTDB-5533] Add IoTDB Internal Reporter params back and Modify the config of root.__system (#9119)
add f41eb28af9 Merge remote-tracking branch 'origin/master' into lmh/planPushDown
No new revisions were added by this update.
Summary of changes:
.github/workflows/site-build.yml | 2 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 1 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 2 +-
client-py/tests/test_dataframe.py | 4 +-
client-py/tests/test_todf.py | 6 +-
.../confignode/client/ConfigNodeRequestType.java | 3 +-
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/sync/SyncConfigNodeClientPool.java | 2 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 6 +-
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
...ava => PollSpecificRegionMaintainTaskPlan.java} | 35 +-
.../iotdb/confignode/manager/ConfigManager.java | 33 +
.../apache/iotdb/confignode/manager/IManager.java | 17 +
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../region/CopySetRegionGroupAllocator.java | 2 +-
.../region/GreedyRegionGroupAllocator.java | 8 +-
.../balancer/region/IRegionGroupAllocator.java | 2 +-
.../iotdb/confignode/manager/node/NodeManager.java | 4 +-
.../node/heartbeat/ConfigNodeHeartbeatCache.java | 11 +-
.../node/heartbeat/DataNodeHeartbeatCache.java | 4 +-
.../node/heartbeat/NodeHeartbeatSample.java | 20 +-
.../manager/partition/PartitionManager.java | 255 +-
.../persistence/executor/ConfigPlanExecutor.java | 4 +
.../persistence/partition/PartitionInfo.java | 27 +
.../partition/maintainer/RegionCreateTask.java | 6 +
.../partition/maintainer/RegionMaintainTask.java | 3 +
.../procedure/env/ConfigNodeProcedureEnv.java | 10 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 83 +-
.../iotdb/confignode/service/ConfigNode.java | 26 +-
.../confignode/service/ConfigNodeShutdownHook.java | 96 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 25 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 17 +
.../region/GreedyRegionGroupAllocatorTest.java | 14 +-
.../iot/logdispatcher/IndexController.java | 3 +
docs/Download/README.md | 16 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 123 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 2799 +++++++++--
docs/UserGuide/Query-Data/Align-By.md | 2 +-
docs/UserGuide/Query-Data/Group-By.md | 82 +-
docs/UserGuide/Query-Data/Overview.md | 5 +-
docs/zh/Download/README.md | 16 +-
docs/zh/UserGuide/Operate-Metadata/Template.md | 2 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 120 +-
docs/zh/UserGuide/Query-Data/Overview.md | 5 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 1 +
.../it/cluster/IoTDBClusterNodeShutdownHookIT.java | 103 +
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 18 +
...ByLevel2IT.java => IoTDBTagAggregation2IT.java} | 15 +-
.../db/it/aggregation/IoTDBTagAggregationIT.java | 4 +-
.../iotdb/db/it/groupby/IoTDBGroupBySessionIT.java | 509 ++
.../dropwizard/DropwizardMetricManager.java | 4 +-
.../dropwizard/type/DropwizardAutoGauge.java | 16 +-
.../iotdb/metrics/AbstractMetricManager.java | 27 +-
.../iotdb/metrics/AbstractMetricService.java | 6 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 2 +-
.../metrics/config/MetricConfigDescriptor.java | 1 -
.../iotdb/metrics/impl/DoNothingAutoGauge.java | 4 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 28 +-
.../iotdb/metrics/metricsets/disk/DiskMetrics.java | 16 +-
.../metricsets/disk/IDiskMetricsManager.java | 24 +-
.../metricsets/disk/LinuxDiskMetricsManager.java | 74 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 12 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 2 +-
.../iotdb/metrics/config/MetricConfigTest.java | 5 +-
.../micrometer/MicrometerMetricManager.java | 6 +-
.../micrometer/type/MicrometerAutoGauge.java | 17 +-
.../resources/conf/iotdb-common.properties | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +-
.../iotdb/commons/service/metric/enums/Metric.java | 4 +-
pom.xml | 3 +
.../schemaregion/rocksdb/RSchemaRegion.java | 6 +
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 6 +
.../resources/conf/iotdb-datanode.properties | 2 +-
.../codegen/templates/evEventWindowManager.ftl | 6 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 23 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 +
.../db/metadata/metric/ISchemaEngineMetric.java | 5 +-
.../db/metadata/metric/ISchemaRegionMetric.java | 5 +-
.../metadata/metric/SchemaEngineCachedMetric.java | 187 +
.../db/metadata/metric/SchemaEngineMemMetric.java | 131 +
.../db/metadata/metric/SchemaMetricManager.java | 85 +
.../metadata/metric/SchemaRegionCachedMetric.java | 188 +
.../db/metadata/metric/SchemaRegionMemMetric.java | 62 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 4 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 23 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 13 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 12 +-
.../mtree/store/disk/cache/CacheManager.java | 13 +
.../mtree/store/disk/cache/CacheMemoryManager.java | 44 +-
.../mtree/store/disk/cache/ICacheManager.java | 4 +
.../mtree/store/disk/cache/LRUCacheManager.java | 15 +
.../mtree/store/disk/cache/PlainCacheManager.java | 5 +
.../ReleaseFlushStrategyNumBasedImpl.java | 4 +-
.../ReleaseFlushStrategySizeBasedImpl.java | 4 +-
.../rescon/CachedSchemaEngineStatistics.java | 13 +-
.../rescon/CachedSchemaRegionStatistics.java | 36 +-
.../metadata/rescon/ISchemaEngineStatistics.java | 3 +-
.../metadata/rescon/MemSchemaEngineStatistics.java | 19 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 16 +-
.../rescon/SchemaEngineStatisticsHolder.java | 41 -
.../db/metadata/rescon/SchemaResourceManager.java | 14 +-
.../rescon/SchemaResourceManagerMetrics.java | 96 -
.../db/metadata/schemaregion/ISchemaRegion.java | 3 +
.../db/metadata/schemaregion/SchemaEngine.java | 41 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 16 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 31 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 33 +-
.../process/AbstractConsumeAllOperator.java | 126 +
.../operator/process/AbstractProcessOperator.java | 24 -
.../operator/process/AggregationOperator.java | 78 +-
.../operator/process/DeviceMergeOperator.java | 1 +
.../operator/process/MergeSortOperator.java | 103 +-
.../process/RawDataAggregationOperator.java | 4 +-
.../operator/process/TagAggregationOperator.java | 93 +-
.../process/join/HorizontallyConcatOperator.java | 68 +-
.../process/join/RowBasedTimeJoinOperator.java | 125 +-
.../operator/process/join/TimeJoinOperator.java | 4 +-
.../execution/operator/window/IWindowManager.java | 5 +-
.../execution/operator/window/SeriesWindow.java | 4 +
.../operator/window/SeriesWindowManager.java | 3 +
.../execution/operator/window/SessionWindow.java | 157 +
...indowManager.java => SessionWindowManager.java} | 118 +-
...wParameter.java => SessionWindowParameter.java} | 13 +-
.../operator/window/WindowManagerFactory.java | 13 +-
.../mpp/execution/operator/window/WindowType.java | 3 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 13 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 11 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 24 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 15 +-
.../planner/plan/parameter/GroupByParameter.java | 17 +-
.../plan/parameter/GroupBySeriesParameter.java | 15 +-
...Parameter.java => GroupBySessionParameter.java} | 35 +-
.../plan/parameter/GroupByVariationParameter.java | 20 +-
...Component.java => GroupBySessionComponent.java} | 16 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 28 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 6 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 24 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 10 +-
.../schemaRegion/SchemaStatisticsTest.java | 30 +-
.../apache/iotdb/db/metric/MetricServiceTest.java | 24 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 8 +-
.../operator/AlignedSeriesScanOperatorTest.java | 18 +-
.../operator/HorizontallyConcatOperatorTest.java | 3 +-
.../mpp/execution/operator/LimitOperatorTest.java | 10 +-
.../execution/operator/MergeSortOperatorTest.java | 82 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 26 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 37 -
.../operator/RawDataAggregationOperatorTest.java | 104 +-
.../operator/SingleDeviceViewOperatorTest.java | 8 +-
.../execution/operator/TimeJoinOperatorTest.java | 3 +-
site/src/main/.eslintignore | 4 +
site/src/main/.eslintrc.cjs | 73 +
site/src/main/.vuepress/config.js | 4939 ++++++++++----------
.../theme/components/AlgoliaSearchBox.vue | 55 +-
site/src/main/.vuepress/theme/components/Page.vue | 182 +-
.../main/.vuepress/theme/components/RightMenu.vue | 136 +
site/src/main/.vuepress/theme/styles/palette.styl | 1 +
site/src/main/package.json | 16 +-
.../src/main/thrift/confignode.thrift | 16 +
thrift/src/main/thrift/datanode.thrift | 4 +-
166 files changed, 8742 insertions(+), 4272 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/region/{PollRegionMaintainTaskPlan.java => PollSpecificRegionMaintainTaskPlan.java} (54%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNodeShutdownHook.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/cluster/IoTDBClusterNodeShutdownHookIT.java
copy integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{IoTDBAggregationByLevel2IT.java => IoTDBTagAggregation2IT.java} (75%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupBySessionIT.java
copy confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceMBean.java => server/src/main/java/org/apache/iotdb/db/metadata/metric/ISchemaEngineMetric.java (83%)
copy confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceMBean.java => server/src/main/java/org/apache/iotdb/db/metadata/metric/ISchemaRegionMetric.java (83%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaEngineCachedMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaEngineMemMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaMetricManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaRegionCachedMetric.java
copy consensus/src/main/java/org/apache/iotdb/consensus/iot/logdispatcher/IoTConsensusMemoryManagerMetrics.java => server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaRegionMemMetric.java (52%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaEngineStatisticsHolder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaResourceManagerMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractConsumeAllOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractProcessOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/SessionWindow.java
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{SeriesWindowManager.java => SessionWindowManager.java} (55%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{TimeWindowParameter.java => SessionWindowParameter.java} (73%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/{GroupByVariationParameter.java => GroupBySessionParameter.java} (67%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{GroupByVariationComponent.java => GroupBySessionComponent.java} (76%)
create mode 100644 site/src/main/.eslintignore
create mode 100644 site/src/main/.eslintrc.cjs
create mode 100644 site/src/main/.vuepress/theme/components/RightMenu.vue
create mode 100644 site/src/main/.vuepress/theme/styles/palette.styl