Skip to content
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

Remove passPartitionByAsOptions from DeltaDataSource #506

Conversation

scottsand-db
Copy link
Collaborator

Resolves #505

Signed-off-by: Scott Sandre [email protected]

Copy link
Member

@zsxwing zsxwing left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM. Thanks!

liwensun pushed a commit that referenced this pull request Sep 18, 2020
…urce (#12269)

Resolves #505

Signed-off-by: Scott Sandre <[email protected]>

Closes #506

Signed-off-by: Scott Sandre <[email protected]>

GitOrigin-RevId: 62b4353ef9e8e4f2e52f5f73349bc801d3474693
LantaoJin pushed a commit to LantaoJin/delta that referenced this pull request Jun 15, 2021
…urce (#12269)

Resolves delta-io#505

Signed-off-by: Scott Sandre <[email protected]>

Closes delta-io#506

Signed-off-by: Scott Sandre <[email protected]>

GitOrigin-RevId: 62b4353ef9e8e4f2e52f5f73349bc801d3474693
(cherry picked from commit 7c75c0b)
tdas pushed a commit to tdas/delta that referenced this pull request Jun 6, 2023
* [FlinkSQL_PR_1] Flink Delta Sink - Table API UPDATED (delta-io#389)

Signed-off-by: Krzysztof Chmielewski <[email protected]>
Signed-off-by: Krzysztof Chmielewski <[email protected]>
Signed-off-by: Krzysztof Chmielewski <[email protected]>
Co-authored-by: Paweł Kubit <[email protected]>
Co-authored-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_2] - SQL Support for Delta Source connector. (delta-io#487)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_3] - Delta catalog skeleton (delta-io#503)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_4] - Delta catalog - Interactions with DeltaLog. Create and get table. (delta-io#506)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_5] - Delta catalog - DDL option validation. (delta-io#509)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_6] - Delta catalog - alter table + tests. (delta-io#510)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_7] - Delta catalog - Restrict Delta Table factory to work only with Delta Catalog + tests. (delta-io#514)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_8] - Delta Catalog - DDL/Query hint validation + tests. (delta-io#520)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_9] - Delta Catalog - Adding Flink's Hive catalog as decorated catalog. (delta-io#524)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_10] - Table API support SELECT with filter on partition column. (delta-io#528)

* [FlinkSQL_PR_10] - Table API support SELECT with filter on partition column.

---------

Signed-off-by: Krzysztof Chmielewski <[email protected]>
Co-authored-by: Scott Sandre <[email protected]>

* [FlinkSQL_PR_11] - Delta Catalog - cache DeltaLog instances in DeltaCatalog. (delta-io#529)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_12] - UML diagrams. (delta-io#530)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_13] - Remove mergeSchema option from SQL API. (delta-io#531)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_14] - SQL examples. (delta-io#535)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* remove duplicate function after rebasing against master

---------

Signed-off-by: Krzysztof Chmielewski <[email protected]>
Signed-off-by: Krzysztof Chmielewski <[email protected]>
Co-authored-by: kristoffSC <[email protected]>
Co-authored-by: Paweł Kubit <[email protected]>
Co-authored-by: Krzysztof Chmielewski <[email protected]>
tdas pushed a commit to tdas/delta that referenced this pull request Jun 8, 2023
* [FlinkSQL_PR_1] Flink Delta Sink - Table API UPDATED (delta-io#389)

Signed-off-by: Krzysztof Chmielewski <[email protected]>
Signed-off-by: Krzysztof Chmielewski <[email protected]>
Signed-off-by: Krzysztof Chmielewski <[email protected]>
Co-authored-by: Paweł Kubit <[email protected]>
Co-authored-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_2] - SQL Support for Delta Source connector. (delta-io#487)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_3] - Delta catalog skeleton (delta-io#503)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_4] - Delta catalog - Interactions with DeltaLog. Create and get table. (delta-io#506)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_5] - Delta catalog - DDL option validation. (delta-io#509)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_6] - Delta catalog - alter table + tests. (delta-io#510)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_7] - Delta catalog - Restrict Delta Table factory to work only with Delta Catalog + tests. (delta-io#514)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_8] - Delta Catalog - DDL/Query hint validation + tests. (delta-io#520)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_9] - Delta Catalog - Adding Flink's Hive catalog as decorated catalog. (delta-io#524)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_10] - Table API support SELECT with filter on partition column. (delta-io#528)

* [FlinkSQL_PR_10] - Table API support SELECT with filter on partition column.

---------

Signed-off-by: Krzysztof Chmielewski <[email protected]>
Co-authored-by: Scott Sandre <[email protected]>

* [FlinkSQL_PR_11] - Delta Catalog - cache DeltaLog instances in DeltaCatalog. (delta-io#529)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_12] - UML diagrams. (delta-io#530)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_13] - Remove mergeSchema option from SQL API. (delta-io#531)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* [FlinkSQL_PR_14] - SQL examples. (delta-io#535)

Signed-off-by: Krzysztof Chmielewski <[email protected]>

* remove duplicate function after rebasing against master

---------

Signed-off-by: Krzysztof Chmielewski <[email protected]>
Signed-off-by: Krzysztof Chmielewski <[email protected]>
Co-authored-by: kristoffSC <[email protected]>
Co-authored-by: Paweł Kubit <[email protected]>
Co-authored-by: Krzysztof Chmielewski <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Remove the "passPartitionByAsOptions" config from DeltaDataSource
2 participants