Skip to content

Spark: Implement ArrayData.getVariant for row-based Parquet readers - #14349

Merged
huaxingao merged 4 commits into
apache:mainfrom
huaxingao:read_nested
Nov 5, 2025
Merged

huaxingao merged 4 commits into
apache:mainfrom
huaxingao:read_nested

Conversation

@huaxingao

Copy link
Copy Markdown
Contributor

No description provided.

@github-actions github-actions Bot added the spark label Oct 16, 2025
@huaxingao

Copy link
Copy Markdown
Contributor Author

@ValueSource(booleans = {false, true})
public void testNestedStructVariant(boolean vectorized) {
assumeThat(vectorized).as("Variant vectorized Parquet read is not implemented yet").isFalse();
spark.conf().set("spark.sql.parquet.enableVectorizedReader", String.valueOf(vectorized));

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

nit : we have withSQLConf in iceberg too, can try using it ?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

I just noticed that some of the tests in this test set vectorization via table property. To be consistent, I will change all the tests to use table property.

@aihuaxu aihuaxu left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

LGTM.

@singhpk234 singhpk234 left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

LGTM, thanks @huaxingao !

@huaxingao
huaxingao merged commit 34b03f5 into apache:main Nov 5, 2025
27 checks passed
@huaxingao
huaxingao deleted the read_nested branch November 5, 2025 01:45
@huaxingao

Copy link
Copy Markdown
Contributor Author

Thanks @aihuaxu @singhpk234 for the review!

thomaschow pushed a commit to thomaschow/iceberg that referenced this pull request Jan 19, 2026
…pache#14349)

* Spark: Implement ArrayData.getVariant for row-based Parquet readers

* address comments

* address comments

* fix set vectorization
talatuyarer pushed a commit to talatuyarer/iceberg that referenced this pull request Apr 1, 2026
…pache#14349)

* Spark: Implement ArrayData.getVariant for row-based Parquet readers

* address comments

* address comments

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

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants