-
Notifications
You must be signed in to change notification settings - Fork 3.7k
[improvement](external)add some improvements for external scan #38946
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[improvement](external)add some improvements for external scan #38946
Conversation
|
Thank you for your contribution to Apache Doris. Since 2024-03-18, the Document has been moved to doris-website. |
|
run buildall |
TPC-H: Total hot run time: 41239 ms |
TPC-DS: Total hot run time: 170008 ms |
ClickBench: Total hot run time: 29.93 s |
|
run buildall |
TPC-H: Total hot run time: 41919 ms |
TPC-DS: Total hot run time: 168283 ms |
ClickBench: Total hot run time: 30.26 s |
|
run p1 |
|
run p0 |
45279ef to
5e9efaa
Compare
|
run buildall |
TPC-H: Total hot run time: 41954 ms |
TPC-DS: Total hot run time: 168002 ms |
ClickBench: Total hot run time: 30.04 s |
|
run buildall |
TPC-H: Total hot run time: 39598 ms |
TPC-DS: Total hot run time: 202328 ms |
ClickBench: Total hot run time: 30.79 s |
7ba0f8e to
aec6027
Compare
|
run buildall |
TPC-H: Total hot run time: 39937 ms |
TPC-DS: Total hot run time: 201660 ms |
ClickBench: Total hot run time: 31.46 s |
|
run buildall |
TPC-H: Total hot run time: 37270 ms |
|
|
||
| if (split instanceof DataSplit) { | ||
| List<DataFileMeta> dataFileMetas = ((DataSplit) split).dataFiles(); | ||
| this.path = new Path("hdfs://" + dataFileMetas.get(0).fileName()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why using hdfs://?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Because it will be checked by location for be.
|
run buildall |
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/source/PaimonSplit.java
Outdated
Show resolved
Hide resolved
fe/fe-core/src/main/java/org/apache/doris/datasource/paimon/source/PaimonScanNode.java
Outdated
Show resolved
Hide resolved
|
run buildall |
2d434ac to
bfcc9b5
Compare
bfcc9b5 to
f83781c
Compare
|
run buildall |
|
run buildall |
morningman
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
|
PR approved by at least one committer and no changes requested. |
|
PR approved by anyone and no changes requested. |
…e#38946) 1. add session variable: `use_consistent_hash_for_external_scan`, which can specify consistent hash for external scan. 2. add session variable: `ignore_split_type`, which can ignore splits of the specified type, use for performance tuning. 3. add split weight for paimon split with consistent hash. 4. add `executeFilter` for paimon jni split.
…e#38946) ## Proposed changes 1. add session variable: `use_consistent_hash_for_external_scan`, which can specify consistent hash for external scan. 2. add session variable: `ignore_split_type`, which can ignore splits of the specified type, use for performance tuning. 3. add split weight for paimon split with consistent hash. 4. add `executeFilter` for paimon jni split.
Proposed changes
use_consistent_hash_for_external_scan, which can specify consistent hash for external scan.ignore_split_type, which can ignore splits of the specified type, use for performance tuning.executeFilterfor paimon jni split.