-
Notifications
You must be signed in to change notification settings - Fork 3.1k
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
Report physical input data size in EXPLAIN ANALYZE #14907
Conversation
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/TextRenderer.java
Outdated
Show resolved
Hide resolved
9937be9
to
cdd2c4b
Compare
cdd2c4b
to
4cbdb82
Compare
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
I think the approach here should be similar to #10472 |
I think we want "physical input data size" displayed even if |
@raunaqmorarka As @lukasz-stec wrote, connector metrics are displayed only for verbose output, whereas we want to display |
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/PlanNodeStatsSummarizer.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/PlanNodeStatsSummarizer.java
Outdated
Show resolved
Hide resolved
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/TextRenderer.java
Outdated
Show resolved
Hide resolved
4cbdb82
to
3fc3ca9
Compare
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.
Please add a test (see BaseJdbcConnectorTest#testExplainAnalyzePhysicalReadWallTime
)
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/HashCollisionPlanNodeStats.java
Show resolved
Hide resolved
3fc3ca9
to
4e5ee25
Compare
4e5ee25
to
7218d33
Compare
78d3fc4
to
8802812
Compare
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/PlanPrinter.java
Outdated
Show resolved
Hide resolved
8802812
to
084b0c4
Compare
core/trino-main/src/main/java/io/trino/sql/planner/planprinter/PlanPrinter.java
Outdated
Show resolved
Hide resolved
084b0c4
to
81814fe
Compare
Example output: - ScanFilterProject[table = hive:sf1:orders, filterPredicate = ("orderdate" > DATE '1995-01-01')] Layout: [clerk:varchar(15), $hashvalue_2:bigint] Estimates: {rows: 1500000 (41.48MB), cpu: 35.76M, memory: 0B, network: 0B}/{rows: 816424 (22.58MB), cpu: 35.76M, memory: 0B, network: 0B}/{rows: 816424 (22.58MB), cpu: 22.58M, memory: 0B, network: 0B} CPU: 180.00ms (78.95%), Scheduled: 298.00ms (71.46%), Blocked: 0.00ns (0.00%), Output: 818058 rows (12.98MB) Input avg.: 1500000.00 rows, Input std.dev.: 0.00% $hashvalue_2 := combine_hash(bigint '0', COALESCE("$operator$hash_code"("clerk"), 0)) clerk := clerk:varchar(15):REGULAR orderdate := orderdate:date:REGULAR Input: 1500000 rows (18.17MB), Filtered: 45.46%, Physical Input: 4.51MB
81814fe
to
f276cde
Compare
Description
Additional information about physical data size used by connector to EXPLAIN ANALYZE in connector metrics section.
Example output.
Non-technical explanation
Additional information about physical data size used by connector to EXPLAIN ANALYZE.
Release notes
( ) This is not user-visible or docs only and no release notes are required.
( ) Release notes are required, please propose a release note for me.
(x) Release notes are required, with the following suggested text: