Add timestamp support to Pinot connector#14244
Conversation
15f8080 to
3d46ac7
Compare
|
@xiangfu0 apologies for the delay and many thanks for rebasing the code. Unfortunately I don't have my personal laptop where I am but I'm happy to either continue the code review on this PR or rebasing your branch into mine next Monday if Trino developers prefer to continue reviewing that instead |
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/decoders/TimestampDecoder.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/PinotQueryBuilder.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/PinotTypeResolver.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/query/PinotTypeResolver.java
Outdated
Show resolved
Hide resolved
.../trino-pinot/src/test/java/io/trino/plugin/pinot/BasePinotIntegrationConnectorSmokeTest.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
I think we don't need this test doesn't support SUPPORTS_CREATE_TABLE behavior.
There was a problem hiding this comment.
The base class don't have the check for SUPPORTS_CREATE_TABLE, so need o override here.
There was a problem hiding this comment.
No need to override. The base class has the behavior check.
88d9b2b to
fee1273
Compare
Since there are a bunch of refactors happened, I would just go with this PR. |
|
Hi @Praveen2112 , thanks for your review. Can u do another pass? |
3762bd3 to
a83f08b
Compare
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/PinotSegmentPageSource.java
Outdated
Show resolved
Hide resolved
plugin/trino-pinot/src/main/java/io/trino/plugin/pinot/decoders/TimestampDecoder.java
Outdated
Show resolved
Hide resolved
a83f08b to
7b66a63
Compare
ddcprg
left a comment
There was a problem hiding this comment.
thanks for rebasing and reviving the PR
|
cc: @ebyhr as well |
|
Many thanks @martint ! |
| public void testPredicatePushdown() | ||
| { | ||
| assertThat(query("SELECT timestamp_col FROM " + ALL_TYPES_TABLE + " WHERE timestamp_col < TIMESTAMP '1971-01-01 00:00:00.000'")) | ||
| .isFullyPushedDown(); |
There was a problem hiding this comment.
The method name is testPredicatePushdown but the test is specific to timestamp type. Moving to testTimestamp seems better.
Description
Add support for TIMESTAMP data type in Pinot connector.
Release notes