-
Notifications
You must be signed in to change notification settings - Fork 4.3k
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
[Iceberg] Add support for default namespace (database name) #52068
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎
|
/format-fix
|
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.
couple nits, otherwise (don't forget to regen the spec files, CI will complain)
(also cc @johnny-schmidt - if you want a testbed for https://github.com/airbytehq/airbyte-internal-issues/issues/11424's "test default namespace" thing, iceberg is adding support for that here)
.../src/main/kotlin/io/airbyte/cdk/load/command/iceberg/parquet/IcebergCatalogSpecifications.kt
Outdated
Show resolved
Hide resolved
...ta-lake/src/main/kotlin/io/airbyte/integrations/destination/s3_data_lake/TableIdGenerator.kt
Outdated
Show resolved
Hide resolved
/format-fix
|
What
Allow our users to set a database name for the s3-data-lake destination.
This value will be used if will only be used if the stream namespace is null, meaning when the
Destination Namespace
setting for the connection is set toDestination-defined
orSource-defined
How
We are checking if the stream.namespace is null and setting it to the new configuration value if that is the case
Can this PR be safely reverted and rolled back?