This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/intoOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c62e8d6b7f Implement analyzer for SELECT INTO statement
new 2293ea4ca4 finish IntoOperator v1
add a3749028b6 add IntoComponent
add 7e14a8429f Merge remote-tracking branch 'origin/master' into
lmh/selectInto
add de41d7c81c finish sql parser for SELECT INTO statement
add cf7d9cdee4 Merge remote-tracking branch 'origin/master' into
lmh/selectInto
add 55118b8b06 fix sql parser
add df5d9e4eb6 add semantic check
add 62b2d495b9 tmp save (analyzer for SELECT INTO)
add bbeca341d5 Merge branch 'lmh/selectInto' into lmh/mppSelectInto
add fb63d17c6b tmp save (analyzer for SELECT INTO)
add fa3290a015 finish analyzer
add 4904bea0ad refactor analyzer
add 9113b516a6 add header
add 66a200c55b fix bugs
add 20502476aa Merge remote-tracking branch 'origin/master' into
lmh/mppSelectInto
add 15ca69b62b pr self check
add 144638a5d9 fix CI
add 9838423df3 Merge remote-tracking branch 'origin/master' into
lmh/mppSelectInto
add 93e707f0f1 change descriptor ALIGN BY DEVICE
add c5306406e6 unified naming
add 7ccd902bca Merge branch 'master' of github.com:apache/iotdb into
lmh/mppSelectInto
add 7adf5582a0 refactor IntoPathDescriptor & DeviceViewIntoPathDescriptor
add ce39446b95 add UT
add 3e50f56e3e disable GROUP BY TAGS
new fbc3c41ece Merge branch 'lmh/mppSelectInto' into lmh/intoOperator
new 9ce4eacfcb add IntoNode & DeviceViewNode
new 248dacce56 implement LogicalPlan for SELECT INTO statement
new aeff0ab7a9 add OperatorTreeGenerator for IntoOperator
new 4646bf1285 fix bugs
new 96481443c4 add DeviceViewIntoOperator
new de98a1a31d implement DeviceViewIntoOperator
new 41f8243a0d OperatorTreeGenerator visitDeviceViewInto
new a8d74daf90 finish execute insertMultiTabletsStatement
new bb548fd9fa fix sessionId
new 94cebb2572 add session info in FragmentInstance
The 12 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:
.../iotdb/db/client/DataNodeInternalClient.java | 98 +++++++
...ledException.java => IntoProcessException.java} | 4 +-
.../fragment/FragmentInstanceContext.java | 39 ++-
.../fragment/FragmentInstanceManager.java | 12 +-
.../db/mpp/execution/operator/OperatorContext.java | 8 +
...IntoOperator.java => AbstractIntoOperator.java} | 180 ++++++++-----
.../operator/process/DeviceViewIntoOperator.java | 135 ++++++++++
.../execution/operator/process/IntoOperator.java | 288 +++------------------
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 7 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 40 +++
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 7 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 123 +++++++++
.../planner/distribution/ExchangeNodeAdder.java | 6 +-
.../SimpleFragmentParallelPlanner.java | 2 +
.../plan/planner/distribution/SourceRewriter.java | 11 +-
.../distribution/WriteFragmentParallelPlanner.java | 4 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 28 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 4 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 10 +
.../metedata/read/SchemaQueryOrderByHeatNode.java | 4 +-
.../planner/plan/node/process/AggregationNode.java | 23 +-
.../planner/plan/node/process/DeviceMergeNode.java | 32 +--
.../{LimitNode.java => DeviceViewIntoNode.java} | 97 +++----
.../planner/plan/node/process/DeviceViewNode.java | 19 +-
.../planner/plan/node/process/ExchangeNode.java | 41 +--
.../plan/planner/plan/node/process/FillNode.java | 46 +---
.../plan/node/process/GroupByLevelNode.java | 29 +--
.../planner/plan/node/process/GroupByTagNode.java | 17 +-
.../node/process/{LimitNode.java => IntoNode.java} | 94 +++----
.../plan/planner/plan/node/process/LimitNode.java | 37 +--
...tiChildNode.java => MultiChildProcessNode.java} | 23 +-
.../plan/planner/plan/node/process/OffsetNode.java | 36 +--
.../planner/plan/node/process/ProjectNode.java | 40 +--
...iChildNode.java => SingleChildProcessNode.java} | 50 +++-
.../node/process/SlidingWindowAggregationNode.java | 36 +--
.../plan/planner/plan/node/process/SortNode.java | 29 +--
.../planner/plan/node/process/TimeJoinNode.java | 17 +-
.../planner/plan/node/process/TransformNode.java | 29 +--
.../node/process/last/LastQueryCollectNode.java | 4 +-
.../plan/node/process/last/LastQueryMergeNode.java | 4 +-
.../plan/node/process/last/LastQueryNode.java | 4 +-
.../parameter/DeviceViewIntoPathDescriptor.java | 177 +++++++++++--
.../planner/plan/parameter/IntoPathDescriptor.java | 132 +++++++++-
.../plan/scheduler/load/LoadTsFileScheduler.java | 8 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 3 +
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 169 ++++++++++++
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 9 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 21 +-
48 files changed, 1361 insertions(+), 875 deletions(-)
create mode 100644
server/src/main/java/org/apache/iotdb/db/client/DataNodeInternalClient.java
copy
server/src/main/java/org/apache/iotdb/db/exception/{WriteLockFailedException.java
=> IntoProcessException.java} (88%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{IntoOperator.java
=> AbstractIntoOperator.java} (63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/DeviceViewIntoOperator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{LimitNode.java
=> DeviceViewIntoNode.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{LimitNode.java
=> IntoNode.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{MultiChildNode.java
=> MultiChildProcessNode.java} (77%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{MultiChildNode.java
=> SingleChildProcessNode.java} (59%)
