This is an automated email from the ASF dual-hosted git repository.
lancelly pushed a change to branch pipelinehierarchyTree
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1b63668faf2 remove useless test
add 548ee3808c3 operator memory
add 05a64f2abd4 implement memorymeasureable interface for some operators
No new revisions were added by this update.
Summary of changes:
.../execution/MemoryEstimationHelper.java | 67 ++++++++++++++++++++++
.../queryengine/execution/MemoryMeasurable.java} | 22 +++----
.../queryengine/execution/exchange/sink/ISink.java | 3 +-
.../execution/exchange/sink/LocalSinkChannel.java | 11 ++++
.../execution/exchange/sink/ShuffleSinkHandle.java | 17 ++++++
.../execution/exchange/sink/SinkChannel.java | 14 +++++
.../execution/exchange/source/ISourceHandle.java | 3 +-
.../exchange/source/LocalSourceHandle.java | 14 ++++-
.../execution/exchange/source/SourceHandle.java | 13 +++++
.../execution/operator/ExplainAnalyzeOperator.java | 21 +++++--
.../queryengine/execution/operator/Operator.java | 3 +-
.../execution/operator/OperatorContext.java | 15 ++++-
.../process/AggregationMergeSortOperator.java | 16 ++++++
.../operator/process/AggregationOperator.java | 15 +++++
.../operator/process/ColumnInjectOperator.java | 12 ++++
.../operator/process/DeviceViewIntoOperator.java | 12 ++++
.../operator/process/DeviceViewOperator.java | 14 +++++
.../execution/operator/process/FillOperator.java | 11 ++++
.../operator/process/FilterAndProjectOperator.java | 12 ++++
.../execution/operator/process/IntoOperator.java | 21 +++++++
.../execution/operator/process/LimitOperator.java | 11 ++++
.../operator/process/LinearFillOperator.java | 12 ++++
.../operator/process/MergeSortOperator.java | 16 ++++++
.../execution/operator/process/OffsetOperator.java | 11 ++++
.../operator/process/ProjectOperator.java | 11 ++++
.../process/RawDataAggregationOperator.java | 12 ++++
.../operator/process/SingleDeviceViewOperator.java | 11 ++++
.../process/SlidingWindowAggregationOperator.java | 11 ++++
.../execution/operator/process/SortOperator.java | 13 +++++
.../operator/process/TagAggregationOperator.java | 18 ++++++
.../execution/operator/process/TopKOperator.java | 15 +++++
.../operator/process/TransformOperator.java | 14 +++++
.../process/join/FullOuterTimeJoinOperator.java | 19 ++++++
.../process/join/HorizontallyConcatOperator.java | 16 ++++++
.../process/join/InnerTimeJoinOperator.java | 16 ++++++
.../process/join/LeftOuterTimeJoinOperator.java | 13 +++++
.../last/AlignedUpdateLastCacheOperator.java | 17 ++++++
.../AlignedUpdateViewPathLastCacheOperator.java | 6 ++
.../process/last/LastQueryCollectOperator.java | 16 ++++++
.../process/last/LastQueryMergeOperator.java | 17 ++++++
.../operator/process/last/LastQueryOperator.java | 16 ++++++
.../process/last/LastQuerySortOperator.java | 16 ++++++
.../process/last/LastQueryTransformOperator.java | 14 +++++
.../process/last/UpdateLastCacheOperator.java | 15 +++++
.../last/UpdateViewPathLastCacheOperator.java | 6 ++
.../schema/CountGroupByLevelMergeOperator.java | 14 +++++
.../schema/CountGroupByLevelScanOperator.java | 18 +++++-
.../operator/schema/CountMergeOperator.java | 12 ++++
.../schema/NodeManageMemoryMergeOperator.java | 12 ++++
.../operator/schema/NodePathsConvertOperator.java | 12 ++++
.../operator/schema/NodePathsCountOperator.java | 12 ++++
.../operator/schema/SchemaCountOperator.java | 12 ++++
.../operator/schema/SchemaFetchMergeOperator.java | 15 +++++
.../operator/schema/SchemaFetchScanOperator.java | 12 ++++
.../operator/schema/SchemaQueryMergeOperator.java | 13 +++++
.../schema/SchemaQueryOrderByHeatOperator.java | 14 +++++
.../operator/schema/SchemaQueryScanOperator.java | 15 +++++
.../operator/sink/IdentitySinkOperator.java | 16 ++++++
.../operator/sink/ShuffleHelperOperator.java | 16 ++++++
.../AlignedSeriesAggregationScanOperator.java | 14 +++++
.../operator/source/AlignedSeriesScanOperator.java | 12 ++++
.../operator/source/ExchangeOperator.java | 13 +++++
.../operator/source/LastCacheScanOperator.java | 11 ++++
.../source/SeriesAggregationScanOperator.java | 14 +++++
.../operator/source/SeriesScanOperator.java | 12 ++++
.../execution/operator/source/SeriesScanUtil.java | 20 ++++++-
.../operator/source/ShowQueriesOperator.java | 12 ++++
.../queryengine/plan/execution/QueryExecution.java | 1 +
.../plan/execution/memory/MemorySourceHandle.java | 9 +++
.../plan/planner/LocalExecutionPlanContext.java | 8 +++
.../plan/planner/LocalExecutionPlanner.java | 5 ++
.../plan/planner/OperatorTreeGenerator.java | 25 ++++++++
.../planner/memory/PipelineMemoryEstimator.java | 2 +-
.../plan/planner/plan/node/PlanNodeId.java | 12 +++-
.../queryengine/execution/exchange/StubSink.java | 8 +++
.../execution/operator/FillOperatorTest.java | 15 +++++
.../operator/LastQueryMergeOperatorTest.java | 20 +++++++
.../execution/operator/LinearFillOperatorTest.java | 35 +++++++++++
.../process/join/InnerTimeJoinOperatorTest.java | 60 +++++++++++++++++++
.../join/LeftOuterTimeJoinOperatorTest.java | 30 ++++++++++
.../plan/planner/PipelineBuilderTest.java | 2 +-
81 files changed, 1162 insertions(+), 29 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/MemoryEstimationHelper.java
copy
iotdb-core/datanode/src/{test/java/org/apache/iotdb/db/queryengine/execution/QueryIdGeneratorTest.java
=> main/java/org/apache/iotdb/db/queryengine/execution/MemoryMeasurable.java}
(68%)
