[tejasiyer-dev]

Part of #40976

Follow-up to #40543.

Moves BundleLifter from sdks/java/io/iceberg to sdks/java/core/src/main/java/org/apache/beam/sdk/util and marks it @Internal, so it can be reused outside Iceberg (e.g. by WriteFiles direct writes).

Changes

• Moved BundleLifter and BundleLifterTest into org.apache.beam.sdk.util (@Internal).
• Updated the import in Iceberg's WriteToDestinations.
• No behavior changes.

Update compatibility

The class name, the BundleLiftDoFn step name, and the output tags are unchanged, so Iceberg pipeline step names stay the same and streaming --update is unaffected. Only the Java package changed, which Dataflow does not use for update matching.

Testing

• BundleLifterTest (core)
• IcebergIOWriteTest

[github-actions]

📋 Review Summary

This PR cleanly relocates BundleLifter and BundleLifterTest from org.apache.beam.sdk.io.iceberg to org.apache.beam.sdk.util and annotates BundleLifter with @Internal for reuse across other SDK components (such as WriteFiles). The refactor preserves step names and output tags, maintaining pipeline update compatibility.

🔍 General Feedback

• The package move, visibility annotations, and import updates in Iceberg IO are clean and have no behavioral regressions.

---

💡 Tip: Comment /gemini review on this pull request to trigger a new Gemini code review.

[github-actions]

Assigning reviewers:

R: @ahmedabu98 for label iceberg.
Backup reviewer: chamikaramj (if the main reviewer is unresponsive, you can escalate to them by tagging their username)

This pull request likely touches a core component ("core" label). Please review with scrutiny.

Note: If you would like to opt out of this review, comment assign to next reviewer.

Available commands:

• stop reviewer notifications - opt out of the automated review tooling
• remind me after tests pass - tag the comment author after tests pass
• waiting on author - shift the attention set back to the author (any comment or push by the author will return the attention set to the reviewers)

The PR bot will only process comments in the main thread (not review comments).

[ahmedabu98]

LGTM

[arunpandianp]

R: @scwhittle

[github-actions]

Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control. If you'd like to restart, comment assign set of reviewers

[scwhittle]

Unrelated so can be done separate PR, but I think that it could be improved to stream the elements through. Once we've exceeded threshold we transition to large output and

1. flush the existing queue
2. stop sizing/queuing further process elements and just outputting them directly.

[tejasiyer-dev]

The beam_PreCommit_Java failure on #40978 seems to be unrelated to the change.