This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/sonar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0bb317ebc49 server/src/main/java/org/apache/iotdb/db/mpp/execution
done except for operator package
add 76d66786814 Rename ViewType values to VIEW/BASE (#10191) (#10206)
add dc5ca0b4ff9 Support show isAligned as null when showing devices with
no timeseries but view (#10197)
add 0bf7d75ea46 Set compaction selector log from info to debug (#10207)
add be8fa171e92 [IOTDB-6010] Fix NPE and IndexOutOfRange Exception in CPU
metrics (#10217) (#10224)
add c1467f50f0b Add leader change log (#10230)
add e8cbc76edd5 [IOTDB-6013] Pipe: pipe-related threads (pools) should not
be initialized unless necessary (#10229)
add 49fd2eb1feb Flush previous time partition memtable by wal (#10221)
(#10235)
add b7472ea1355 Rename PB_Tree to PBTree (#10223)
add f35b5b7fd9e Add memory usage and series num to log when series
overflow (#10227)
new 328211c1fea Merge remote-tracking branch 'origin/master' into ty/sonar
new 52e900afe94
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator done except for
SeriesScanUtil
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:
.../manager/load/service/StatisticsService.java | 3 +-
.../manager/pipe/runtime/PipeHeartbeatParser.java | 47 +++--
.../pipe/runtime/PipeLeaderChangeHandler.java | 14 +-
.../pipe/runtime/PipeRuntimeCoordinator.java | 22 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 6 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 2 +-
docs/UserGuide/Reference/Status-Codes.md | 4 +-
.../Data-Modeling/SchemaRegion-rocksdb.md | 2 +-
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 8 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 2 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 4 +-
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 32 +--
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 56 ++---
.../it/schema/view/IoTDBCreateAndShowViewIT.java | 72 +++----
.../view/IoTDBShowDevicesContainedViewIT.java | 226 +++++++++++++++++++++
.../org/apache/iotdb/util/AbstractSchemaIT.java | 4 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 12 +-
iotdb-client/client-cpp/src/main/Session.h | 4 +-
iotdb-client/client-py/tests/test_dataframe.py | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +-
.../metrics/metricsets/cpu/CpuUsageMetrics.java | 6 +-
.../resources/conf/iotdb-common.properties | 2 +-
.../iotdb/commons/concurrent/ThreadName.java | 1 -
.../apache/iotdb/commons/path/MeasurementPath.java | 11 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 12 +-
...FilterVisitor.java => SchemaFilterFactory.java} | 45 ++--
.../commons/schema/filter/SchemaFilterType.java | 9 +-
.../commons/schema/filter/SchemaFilterVisitor.java | 28 ++-
.../impl/{DataTypeFilter.java => AndFilter.java} | 41 ++--
.../commons/schema/filter/impl/DataTypeFilter.java | 6 +-
.../schema/filter/impl/PathContainsFilter.java | 8 +-
.../commons/schema/filter/impl/TagFilter.java | 6 +-
.../{DataTypeFilter.java => ViewTypeFilter.java} | 32 +--
.../node/common/AbstractDatabaseDeviceMNode.java | 11 +-
.../schema/node/common/AbstractDeviceMNode.java | 11 +-
.../node/common/AbstractMeasurementMNode.java | 2 +-
.../commons/schema/node/info/IDeviceInfo.java | 4 +-
.../commons/schema/node/role/IDeviceMNode.java | 4 +-
.../PipeStatus.java => schema/view/ViewType.java} | 41 ++--
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 6 +-
.../metadata/SeriesOverflowException.java | 8 +-
.../SchemaFileLogCorruptedException.java | 2 +-
.../metadata/schemafile/SchemaFileNotExists.java | 2 +-
.../schemafile/SchemaPageOverflowException.java | 3 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 8 +-
.../idtable/AppendOnlyDiskSchemaManager.java | 2 +-
.../metadata/metric/SchemaEngineCachedMetric.java | 2 +-
.../db/metadata/mnode/mem/info/DeviceInfo.java | 6 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 2 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 32 ++-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +-
.../mtree/store/disk/schemafile/ISchemaFile.java | 4 +-
.../store/disk/schemafile/MockSchemaFile.java | 4 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 28 +--
.../store/disk/schemafile/SchemaFileConfig.java | 4 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 2 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 2 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 9 +-
.../schemaregion/result/ShowDevicesResult.java | 6 +-
.../db/metadata/query/info/IDeviceSchemaInfo.java | 2 +-
.../rescon/CachedSchemaEngineStatistics.java | 2 +-
.../rescon/CachedSchemaRegionStatistics.java | 4 +-
.../metadata/rescon/ISchemaRegionStatistics.java | 4 +
.../metadata/rescon/MemSchemaRegionStatistics.java | 10 +
.../db/metadata/rescon/SchemaResourceManager.java | 4 +-
.../db/metadata/schemaregion/SchemaEngine.java | 2 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 2 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 12 +-
.../schemaregion/SchemaRegionPBTreeImpl.java | 27 +--
.../db/metadata/visitor/DeviceFilterVisitor.java | 6 +-
.../metadata/visitor/TimeseriesFilterVisitor.java | 15 +-
.../db/mpp/execution/operator/AggregationUtil.java | 56 ++---
.../iotdb/db/mpp/execution/operator/Operator.java | 27 ++-
.../db/mpp/execution/operator/OperatorContext.java | 2 +-
.../schema/source/LogicalViewSchemaSource.java | 77 ++-----
.../schema/source/TimeSeriesSchemaSource.java | 7 +-
.../AbstractSeriesAggregationScanOperator.java | 14 +-
.../AlignedSeriesAggregationScanOperator.java | 1 +
.../operator/source/AlignedSeriesScanOperator.java | 53 +++--
.../operator/source/AlignedSeriesScanUtil.java | 87 ++++----
.../operator/source/DataSourceOperator.java | 1 +
.../operator/source/ExchangeOperator.java | 1 +
.../operator/source/LastCacheScanOperator.java | 1 +
.../source/SeriesAggregationScanOperator.java | 2 +
.../operator/source/SeriesScanOperator.java | 6 +-
.../execution/operator/source/SeriesScanUtil.java | 1 +
.../operator/source/ShowQueriesOperator.java | 15 +-
.../execution/operator/source/SourceOperator.java | 1 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 14 +-
.../pipe/connector/v2/IoTDBThriftConnectorV2.java | 47 +++--
.../protocol/influxdb/util/QueryResultUtils.java | 2 +-
.../db/tools/schema/PBTreeFileSketchTool.java | 6 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 2 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 12 +-
.../mtree/schemafile/AliasIndexPageTest.java | 2 +-
.../mtree/schemafile/InternalPageTest.java | 2 +-
.../mtree/schemafile/SchemaFileLogTest.java | 8 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 2 +-
.../mtree/schemafile/WrappedSegmentTest.java | 2 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 6 +-
.../schemaRegion/SchemaRegionBasicTest.java | 29 ++-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../iotdb/db/tools/PBTreeFileSketchTest.java | 4 +-
.../src/test/resources/iotdb-datanode.properties | 4 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 19 +-
109 files changed, 962 insertions(+), 601 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/view/IoTDBShowDevicesContainedViewIT.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/{SchemaFilterVisitor.java
=> SchemaFilterFactory.java} (52%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/{DataTypeFilter.java
=> AndFilter.java} (58%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/{DataTypeFilter.java
=> ViewTypeFilter.java} (63%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/{pipe/task/meta/PipeStatus.java
=> schema/view/ViewType.java} (58%)
