This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6ef35e4537e Cleaned multiple potential problems in pipe module (#17396)
add 67b017b3469 Support COPY TO TsFile for exporting query results in
table model (#17372)
No new revisions were added by this update.
Summary of changes:
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 667 +++++++++++++++++++++
.../exception/DiskSpaceInsufficientException.java | 4 +
.../operator/process/copyto/CopyToOptions.java | 157 +++++
.../process/copyto/IFormatCopyToWriter.java | 72 +++
.../process/copyto/TableCopyToOperator.java | 187 ++++++
.../process/copyto/tsfile/CopyToTsFileOptions.java | 272 +++++++++
.../copyto/tsfile/TsFileFormatCopyToWriter.java | 186 ++++++
.../plan/planner/TableOperatorGenerator.java | 36 ++
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../relational/analyzer/StatementAnalyzer.java | 9 +
.../plan/relational/metadata/TableSchema.java | 9 +
.../relational/planner/TableLogicalPlanner.java | 68 ++-
.../planner/distribute/AddExchangeNodes.java | 23 +
.../distribute/TableDistributedPlanGenerator.java | 8 +
.../TableModelTypeProviderExtractor.java | 7 +
...tSourceColumns.java => PruneCopyToColumns.java} | 18 +-
.../{ExplainAnalyzeNode.java => CopyToNode.java} | 122 ++--
.../plan/relational/planner/node/Patterns.java | 4 +
.../optimizations/LogicalOptimizeFactory.java | 2 +
.../optimizations/UnaliasSymbolReferences.java | 20 +
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../sql/ast/{Prepare.java => CopyTo.java} | 81 +--
.../sql/ast/DefaultTraversalVisitor.java | 6 +
.../plan/relational/sql/parser/AstBuilder.java | 74 +++
.../plan/relational/sql/util/SqlFormatter.java | 16 +
.../db/storageengine/rescon/disk/TierManager.java | 32 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../schema/column/ColumnHeaderConstant.java | 15 +
.../db/relational/grammar/sql/RelationalSql.g4 | 30 +-
pom.xml | 2 +-
30 files changed, 2014 insertions(+), 123 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/copyto/IoTDBCopyToTsFileIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/CopyToOptions.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/IFormatCopyToWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/TableCopyToOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/tsfile/CopyToTsFileOptions.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/copyto/tsfile/TsFileFormatCopyToWriter.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneOutputSourceColumns.java
=> PruneCopyToColumns.java} (76%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{ExplainAnalyzeNode.java
=> CopyToNode.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Prepare.java
=> CopyTo.java} (50%)
