Skip to content

Conversation

@tarun-google
Copy link
Contributor

@tarun-google tarun-google commented Nov 20, 2025

Fixes #36864
Adding Schema Iceberg support for PassThroughLogicalType

GitHub Actions Tests Status (on master branch)

Build python source distribution and wheels
Python tests
Java tests
Go tests

See CI.md for more information about GitHub Actions CI or the workflows README to see a list of phrases to trigger workflows.

String logicalTypeIdentifier =
checkArgumentNotNull(beamType.getLogicalType()).getIdentifier();
Schema.LogicalType<?, ?> logicalType = checkArgumentNotNull(beamType.getLogicalType());
if (logicalType instanceof FixedPrecisionNumeric) {
Copy link
Contributor Author

Choose a reason for hiding this comment

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

not fully sure if this is the right way. But DecimalType need inputs of precision and scale. which is not the case with other types

Copy link
Contributor

Choose a reason for hiding this comment

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

parametrized timestamp type may be another case. cc: @claudevdm

@tarun-google tarun-google marked this pull request as ready for review November 20, 2025 19:27
@tarun-google
Copy link
Contributor Author

R: @ahmedabu98 @Abacn

@github-actions
Copy link
Contributor

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

Copy link
Contributor

@Abacn Abacn left a comment

Choose a reason for hiding this comment

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

Thanks, LGTM

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Bug]: Varchar logical type fails Iceberg Pipelines

3 participants