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