You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2023/01/05 09:18:08 UTC

[iotdb] branch master updated (5a40a19ed4 -> 22bd622a57)

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

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


    from 5a40a19ed4 [IOTDB-5284] Fix some iotdb-server code smells (#8754)
     add 22bd622a57 [IOTDB-5284] Fix some code smells (#8751)

No new revisions were added by this update.

Summary of changes:
 .../mpp/aggregation/FirstValueDescAccumulator.java |  6 ++++++
 .../mpp/aggregation/LastValueDescAccumulator.java  |  6 ++++++
 .../slidingwindow/SlidingWindowAggregator.java     |  2 +-
 .../SlidingWindowAggregatorFactory.java            | 11 ++++++----
 .../iotdb/db/mpp/common/header/DatasetHeader.java  |  2 +-
 .../common/schematree/node/SchemaInternalNode.java |  1 +
 .../db/mpp/common/schematree/node/SchemaNode.java  |  2 +-
 .../iotdb/db/mpp/execution/driver/Driver.java      |  2 +-
 .../fragment/FragmentInstanceContext.java          |  1 +
 .../operator/process/AbstractIntoOperator.java     |  8 ++++---
 .../process/SingleInputAggregationOperator.java    |  2 +-
 .../operator/process/TransformOperator.java        |  6 +-----
 .../process/join/RowBasedTimeJoinOperator.java     |  2 +-
 .../operator/process/join/TimeJoinOperator.java    |  2 +-
 .../process/join/VerticallyConcatOperator.java     |  2 +-
 .../last/AbstractUpdateLastCacheOperator.java      |  2 +-
 .../schema/SchemaQueryOrderByHeatOperator.java     |  5 +----
 .../AbstractSeriesAggregationScanOperator.java     |  2 +-
 .../execution/schedule/AbstractDriverThread.java   | 11 +++++-----
 .../db/mpp/execution/schedule/DriverScheduler.java |  2 +-
 .../apache/iotdb/db/mpp/plan/TestRPCClient.java    |  2 +-
 .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java  |  4 ++--
 .../mpp/plan/analyze/ClusterPartitionFetcher.java  |  5 +----
 .../db/mpp/plan/analyze/ExpressionAnalyzer.java    |  6 +++---
 .../db/mpp/plan/analyze/cache/PartitionCache.java  |  6 +++---
 .../analyze/cache/StorageGroupCacheResult.java     |  2 +-
 .../db/mpp/plan/execution/QueryExecution.java      |  6 ++----
 .../plan/expression/ternary/BetweenExpression.java |  1 +
 .../visitor/ColumnTransformerVisitor.java          | 25 +++++++++++-----------
 .../iotdb/db/mpp/plan/parser/ASTVisitor.java       | 11 +++++-----
 .../db/mpp/plan/planner/OperatorTreeGenerator.java | 10 ++++-----
 .../db/mpp/plan/planner/SubPlanTypeExtractor.java  |  5 +++++
 .../SimpleFragmentParallelPlanner.java             |  4 ++--
 .../plan/planner/distribution/SourceRewriter.java  |  2 +-
 .../iotdb/db/mpp/plan/planner/plan/SubPlan.java    |  2 +-
 .../plan/planner/plan/node/PlanGraphPrinter.java   | 13 ++++++-----
 .../db/mpp/plan/planner/plan/node/PlanNode.java    |  2 +-
 .../metedata/read/AbstractSchemaMergeNode.java     |  4 ++--
 .../metedata/read/PathsUsingTemplateScanNode.java  |  2 ++
 .../node/metedata/read/SchemaFetchMergeNode.java   |  1 +
 .../node/metedata/read/SchemaQueryMergeNode.java   |  1 +
 .../write/CreateAlignedTimeSeriesNode.java         |  1 +
 .../metedata/write/CreateMultiTimeSeriesNode.java  |  1 +
 .../node/metedata/write/CreateTimeSeriesNode.java  |  1 +
 .../plan/node/process/MultiChildProcessNode.java   |  4 ++--
 .../planner/plan/node/process/ProcessNode.java     |  2 +-
 .../plan/node/process/SingleChildProcessNode.java  |  4 ++--
 .../node/process/last/LastQueryCollectNode.java    |  1 +
 .../plan/node/process/last/LastQueryMergeNode.java |  1 +
 .../plan/node/process/last/LastQueryNode.java      |  1 +
 .../mpp/plan/planner/plan/node/sink/SinkNode.java  |  2 +-
 .../source/AlignedSeriesAggregationScanNode.java   |  3 +++
 .../node/source/SeriesAggregationScanNode.java     |  3 +++
 .../node/source/SeriesAggregationSourceNode.java   |  2 +-
 .../planner/plan/node/source/SeriesSourceNode.java |  2 +-
 .../CrossSeriesAggregationDescriptor.java          |  1 +
 .../plan/planner/plan/parameter/OutputColumn.java  |  2 +-
 .../scheduler/AbstractFragInsStateTracker.java     |  2 +-
 .../scheduler/FixedRateFragInsStateTracker.java    |  4 ++--
 .../scheduler/load/LoadTsFileDispatcherImpl.java   |  2 +-
 .../plan/scheduler/load/LoadTsFileScheduler.java   | 18 +++++++---------
 .../plan/statement/component/IntoComponent.java    |  8 +++----
 .../crud/InsertMultiTabletsStatement.java          |  1 +
 .../plan/statement/crud/InsertRowStatement.java    |  1 +
 .../crud/InsertRowsOfOneDeviceStatement.java       |  3 ++-
 .../plan/statement/crud/InsertRowsStatement.java   |  1 +
 .../plan/statement/crud/InsertTabletStatement.java |  1 +
 .../iotdb/db/mpp/statistics/StatisticsManager.java |  2 +-
 .../dag/column/ColumnTransformer.java              |  2 +-
 .../binary/ArithmeticBinaryColumnTransformer.java  |  2 +-
 .../dag/column/binary/BinaryColumnTransformer.java |  2 +-
 .../binary/CompareBinaryColumnTransformer.java     |  2 +-
 .../binary/LogicBinaryColumnTransformer.java       |  2 +-
 .../dag/column/leaf/LeafColumnTransformer.java     |  2 +-
 .../ternary/CompareTernaryColumnTransformer.java   |  4 ++--
 .../column/ternary/TernaryColumnTransformer.java   |  2 +-
 .../dag/column/unary/UnaryColumnTransformer.java   |  2 +-
 .../dag/transformer/unary/UnaryTransformer.java    |  2 +-
 78 files changed, 158 insertions(+), 129 deletions(-)