This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 25b8831afd [fix](Outfile) fix core dump when export data to orc file
format using `outfile` (#23586)
add 05771e8a14 [Enhancement](Load) stream Load using SQL (#23362)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.cpp | 2 +
be/src/common/config.h | 2 +
.../{stream_load_with_sql.cpp => http_stream.cpp} | 241 ++----
.../{stream_load_with_sql.h => http_stream.h} | 14 +-
be/src/io/file_factory.cpp | 13 +-
be/src/runtime/stream_load/stream_load_context.h | 10 +-
be/src/service/http_service.cpp | 10 +-
.../import/import-way/stream-load-manual.md | 11 +-
.../import/import-way/stream-load-manual.md | 10 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 2 +-
.../doris/planner/external/FileQueryScanNode.java | 23 +-
.../apache/doris/planner/external/TVFScanNode.java | 3 +
.../java/org/apache/doris/qe/ConnectContext.java | 2 +-
.../main/java/org/apache/doris/qe/Coordinator.java | 34 +-
.../apache/doris/service/FrontendServiceImpl.java | 153 +---
.../ExternalFileTableValuedFunction.java | 26 +-
...ion.java => HttpStreamTableValuedFunction.java} | 23 +-
.../doris/tablefunction/TableValuedFunctionIf.java | 4 +-
gensrc/thrift/FrontendService.thrift | 6 -
.../test_http_stream.csv} | 2 +-
.../data/load_p0/http_stream/test_http_stream.out | 571 ++++++++++++++
.../test_http_stream_column_separator.csv} | 0
.../test_http_stream_data_model.csv} | 0
.../test_http_stream_line_delimiter.csv} | 0
.../test_http_stream_multiple_times.csv} | 0
.../test_http_stream_orc_case.orc} | Bin
.../test_http_stream_parquet_case.parquet} | Bin
.../test_stream_load_with_sql.out | 534 -------------
.../regression/action/StreamLoadAction.groovy | 4 +-
.../load_p0/http_stream/test_http_stream.groovy | 832 +++++++++++++++++++++
.../test_stream_load_with_sql.groovy | 793 --------------------
.../test_streamload_perfomance.groovy | 17 +-
32 files changed, 1661 insertions(+), 1681 deletions(-)
rename be/src/http/action/{stream_load_with_sql.cpp => http_stream.cpp} (52%)
rename be/src/http/action/{stream_load_with_sql.h => http_stream.h} (84%)
rename
fe/fe-core/src/main/java/org/apache/doris/tablefunction/{StreamTableValuedFunction.java
=> HttpStreamTableValuedFunction.java} (76%)
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql.csv
=> http_stream/test_http_stream.csv} (95%)
create mode 100644
regression-test/data/load_p0/http_stream/test_http_stream.out
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql_column_separator.csv
=> http_stream/test_http_stream_column_separator.csv} (100%)
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql_data_model.csv
=> http_stream/test_http_stream_data_model.csv} (100%)
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql_line_delimiter.csv
=> http_stream/test_http_stream_line_delimiter.csv} (100%)
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql_multiple_times.csv
=> http_stream/test_http_stream_multiple_times.csv} (100%)
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql_orc_case.orc
=> http_stream/test_http_stream_orc_case.orc} (100%)
rename
regression-test/data/load_p0/{stream_load_with_sql/test_stream_load_with_sql_parquet_case.parquet
=> http_stream/test_http_stream_parquet_case.parquet} (100%)
delete mode 100644
regression-test/data/load_p0/stream_load_with_sql/test_stream_load_with_sql.out
create mode 100644
regression-test/suites/load_p0/http_stream/test_http_stream.groovy
delete mode 100644
regression-test/suites/load_p0/stream_load_with_sql/test_stream_load_with_sql.groovy
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
