seatunnel
seatunnel copied to clipboard
[Paimon]support projection for paimon source
Purpose of this pull request
support projection for paimon source
Does this PR introduce any user-facing change?
How was this patch tested?
Check list
- [ ] If any new Jar binary package adding in your PR, please add License Notice according New License Guide
- [ ] If necessary, please update the documentation to describe the new feature. https://github.com/apache/seatunnel/tree/dev/docs
- [ ] If you are contributing the connector code, please check that the following files are updated:
- Update change log that in connector document. For more details you can refer to connector-v2
- Update plugin-mapping.properties and add new connector information in it
- Update the pom file of seatunnel-dist
- [ ] Update the
release-note
.
PTAL @Hisoka-X @EricJoy2048
cc @dailai
Please support projection by field name.
Please support projection by field name.
Fixed. Thanks.
LGTM
Hi @TaoZex , could you solve the conflict?
Hi @TaoZex , could you solve the conflict?
Of course.
For https://github.com/apache/seatunnel/pull/6887 There also seems to be an intention to cover the projection, at which point we will have two projection parameters,Do we need to keep both? @Hisoka-X @TaoZex @dailai
For #6887 There also seems to be an intention to cover the projection, at which point we will have two projection parameters,Do we need to keep both? @Hisoka-X @TaoZex @dailai
This pr implements the projection for paimon. After the pr was merged, https://github.com/apache/seatunnel/pull/6887 can be further through SQL for the projection.
For #6887 There also seems to be an intention to cover the projection, at which point we will have two projection parameters,Do we need to keep both? @Hisoka-X @TaoZex @dailai
This pr implements the projection for paimon. After the pr was merged, #6887 can be further through SQL for the projection.
@TaoZex I think 'read_columns' can be overlaid in 'query sql'. Can we transform this pr based on sql?
For #6887 There also seems to be an intention to cover the projection, at which point we will have two projection parameters,Do we need to keep both? @Hisoka-X @TaoZex @dailai
This pr implements the projection for paimon. After the pr was merged, #6887 can be further through SQL for the projection.
@TaoZex I think 'read_columns' can be overlaid in 'query sql'. Can we transform this pr based on sql?
I had a discussion with @dailai on wechat. Currently his pr only supports select * sql queries. I will wait for his pr to merge, and modify this pr code to select id, name sql query (Assuming multiple fields, but only two fields are queried by projection) cc @hailin0 @Hisoka-X
this pr https://github.com/apache/seatunnel/pull/6887 is merged @TaoZex
this pr #6887 is merged @TaoZex
I have changed the code. PTAL. @Hisoka-X @hailin0
cc @dailai
LGTM @hailin0
Thanks for review. Done.