Fix Handling of Aggregation Expressions in Pinot Passthrough Queries#9781
Conversation
|
is there any update to this PR? my org would find this pretty useful |
|
Yes, will be updating shortly. |
9d77b77 to
8436f89
Compare
|
Fixes #10148 |
|
Any chance this can get into the 368 release? |
fa2dac2 to
aea36fd
Compare
8178c73 to
56d842e
Compare
There was a problem hiding this comment.
context.getIdentifierQuote() is identity, right? is it OK?
There was a problem hiding this comment.
It's ok: the DynamicTablePqlExtractor quotes identifiers.
56d842e to
45a8c8b
Compare
hashhar
left a comment
There was a problem hiding this comment.
LGTM "Simplify logic for generating Pinot ColumnMetadata"
hashhar
left a comment
There was a problem hiding this comment.
"Fix handling of complex aggregate expressions in Pinot passthrough queries".
(just over length limit commit message, reword)
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTableBuilder.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTableBuilder.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTableBuilder.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/test/java/io/trino/plugin/pinot/AbstractPinotIntegrationSmokeTest.java
Outdated
Show resolved
Hide resolved
hashhar
left a comment
There was a problem hiding this comment.
"Cleanup various minor issues in the Pinot Connector" - reword to indicate these are not "issues" - just refactors.
hashhar
left a comment
There was a problem hiding this comment.
"Fix Pinot aggregate functions with mixed case columns" -> mixed case column names
Some comments, mostly stylistic + comment from Piotr already about the identifier quote - even though pre-existing. IIUC the quote here may not matter since Pinot library performs quoting of literal values for us - but not sure about column names.
9f62e75 to
dac3cd5
Compare
dac3cd5 to
2e2e979
Compare
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/PinotMetadata.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/test/java/io/trino/plugin/pinot/AbstractPinotIntegrationSmokeTest.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/DynamicTableBuilder.java
Outdated
Show resolved
Hide resolved
2e2e979 to
cfb4ad7
Compare
Directly create ColumnMetadata from Pinot FieldSpecs. Create PinotColumnHandles from ColumnMetadata in getColumnHandles. Previously a PinotColumnHandle was created which would be turned into ColumnMetadata and then converted back to PinotColumnHandle.
cfb4ad7 to
fd8d1c6
Compare
plugin/trino-pinot/src/test/java/io/trino/plugin/pinot/AbstractPinotIntegrationSmokeTest.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/test/java/io/trino/plugin/pinot/AbstractPinotIntegrationSmokeTest.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/test/java/io/trino/plugin/pinot/TestDynamicTable.java
Outdated
Show resolved
Hide resolved
Remove unused methods. Remove unused parameters in methods. Fix warnings in TestDynamicTable.
fd8d1c6 to
090ce8a
Compare
Also includes some minor code cleanup.
Based off of #9098