-
Notifications
You must be signed in to change notification settings - Fork 4.4k
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
chore: add generation id handling for iceberg #48568
chore: add generation id handling for iceberg #48568
Conversation
The latest updates on your projects. Learn more about Vercel for Git ↗︎ 1 Skipped Deployment
|
@@ -27,13 +28,35 @@ import org.apache.iceberg.util.PropertyUtil | |||
@Singleton | |||
class IcebergTableWriterFactory { | |||
|
|||
companion object { |
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.
Nit: we don't need to use a companion object for this stuff -- you can just make the class, regex and methods file-level objections. If we needed to expose these statically to Java code, then putting them in an object would be required. However, since all of this is Kotlin code, we don't need to do that here.
…genreation-id-logic
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.
…genreation-id-logic
Tests passing locally, merging in |
f51173e
into
jonathan/implement-iceberg-stream-loader
Iceberg generation id deletion