Skip to content
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

Spark: Add some tests for variant fixup #12497

Open
wants to merge 2 commits into
base: main
Choose a base branch
from

Conversation

XBaith
Copy link
Contributor

@XBaith XBaith commented Mar 11, 2025

close #12473

The implementation of variant in various visitors has been basically completed in #11831. Since Spark3 does not support the variant type, this PR only adds preliminary work and unit tests.

import org.apache.iceberg.variants.Variants;

public class RandomVariants {
private RandomVariants() {}
Copy link
Contributor Author

@XBaith XBaith Mar 11, 2025

Choose a reason for hiding this comment

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

Copy from core/src/test/java/org/apache/iceberg/RandomVariants.java, will rebase when the PR is merged

@@ -54,6 +54,10 @@ static VariantMetadata from(ByteBuffer buffer) {
return SerializedMetadata.from(buffer);
}

static VariantMetadata empty() {
return SerializedMetadata.EMPTY_V1_METADATA;
}
Copy link
Contributor

Choose a reason for hiding this comment

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

Can you add the implementation for PruneColumnsWithoutReordering class?

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.

Flink/Spark: add visitor support for variant
2 participants