This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/disableView
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3904372fd8c merge master
add fc2746e7a58 [IOTDB-5936] Pipe: correct the behaviour of the historical
data collector in realtime only mode (#9987)
add 9579c9a1da9 [IOTDB-5942] Pipe: Fix bugs in PipeWALResourceManager,
EnrichedEvent, IoTDBThriftReceiverV1 (#9993)
add d8324726279 [IOTDB-5934] Let series_slot_num compatible (#9990)
add 4ab546a00ce [IOTDB-5930] Support OrderBy in Last Query
add 6589f6ab121 Release resource of FI after all drivers have been closed
add a786871178c Merge remote-tracking branch 'origin/master' into
lmh/disableView
add b8195fa8f81 delete copy() in expression
No new revisions were added by this update.
Summary of changes:
.../confignode/conf/SystemPropertiesUtils.java | 38 +++--
docs/UserGuide/Query-Data/Last-Query.md | 26 ++-
docs/UserGuide/Query-Data/Order-By.md | 165 +++++++++++++++++--
docs/zh/UserGuide/Query-Data/Last-Query.md | 22 ++-
docs/zh/UserGuide/Query-Data/Order-By.md | 168 +++++++++++++++++--
.../apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java | 92 +++++++++++
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 11 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 2 +-
.../db/mpp/execution/driver/SchemaDriver.java | 2 +-
.../fragment/FragmentInstanceContext.java | 25 +++
.../fragment/FragmentInstanceExecution.java | 2 +-
.../fragment/FragmentInstanceManager.java | 2 +
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 23 ++-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 27 +--
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 181 +++++++++++++++++----
.../iotdb/db/mpp/plan/expression/Expression.java | 18 +-
.../plan/expression/binary/AdditionExpression.java | 5 -
.../plan/expression/binary/DivisionExpression.java | 5 -
.../plan/expression/binary/EqualToExpression.java | 5 -
.../expression/binary/GreaterEqualExpression.java | 5 -
.../expression/binary/GreaterThanExpression.java | 5 -
.../expression/binary/LessEqualExpression.java | 5 -
.../plan/expression/binary/LessThanExpression.java | 5 -
.../plan/expression/binary/LogicAndExpression.java | 5 -
.../plan/expression/binary/LogicOrExpression.java | 5 -
.../plan/expression/binary/ModuloExpression.java | 5 -
.../binary/MultiplicationExpression.java | 5 -
.../plan/expression/binary/NonEqualExpression.java | 5 -
.../expression/binary/SubtractionExpression.java | 5 -
.../plan/expression/binary/WhenThenExpression.java | 5 -
.../mpp/plan/expression/leaf/ConstantOperand.java | 6 -
.../db/mpp/plan/expression/leaf/NullOperand.java | 6 -
.../plan/expression/leaf/TimeSeriesOperand.java | 6 -
.../mpp/plan/expression/leaf/TimestampOperand.java | 6 -
.../plan/expression/multi/FunctionExpression.java | 9 -
.../expression/other/CaseWhenThenExpression.java | 9 -
.../plan/expression/ternary/BetweenExpression.java | 6 -
.../db/mpp/plan/expression/unary/InExpression.java | 5 -
.../plan/expression/unary/IsNullExpression.java | 5 -
.../mpp/plan/expression/unary/LikeExpression.java | 5 -
.../plan/expression/unary/LogicNotExpression.java | 5 -
.../plan/expression/unary/NegationExpression.java | 5 -
.../plan/expression/unary/RegularExpression.java | 5 -
.../BindTypeForTimeSeriesOperandVisitor.java | 1 +
.../expression/visitor/ReconstructVisitor.java | 4 +-
.../ReplaceRawPathWithGroupedPathVisitor.java | 2 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 2 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 3 +-
.../visitor/cartesian/CartesianProductVisitor.java | 4 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 2 +-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 2 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 2 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 21 ++-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 27 +--
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 17 +-
.../plan/planner/distribution/SourceRewriter.java | 36 ++--
.../plan/node/process/last/LastQueryMergeNode.java | 48 ++++--
.../plan/node/process/last/LastQueryNode.java | 56 ++++---
.../plan/statement/component/OrderByComponent.java | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 12 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 5 +
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 2 +-
.../core/collector/IoTDBDataRegionCollector.java | 22 ++-
.../PipeHistoricalDataRegionTsFileCollector.java | 103 +++++++++---
.../PipeRealtimeDataRegionHybridCollector.java | 2 +
.../PipeRealtimeDataRegionLogCollector.java | 1 +
.../PipeRealtimeDataRegionTsFileCollector.java | 1 +
.../impl/iotdb/v1/IoTDBThriftReceiverV1.java | 12 +-
.../iotdb/db/pipe/core/event/EnrichedEvent.java | 5 +-
.../event/realtime/PipeRealtimeCollectEvent.java | 18 ++
.../pipe/resource/wal/PipeWALResourceManager.java | 12 +-
.../org/apache/iotdb/db/pipe/task/PipeBuilder.java | 12 +-
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 46 ++----
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 4 +-
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 2 +-
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 2 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 1 +
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 6 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 4 +-
79 files changed, 977 insertions(+), 476 deletions(-)
