Skip to content

Spark 4.1: Add BaseSparkScanBuilder#15360

Open
aokolnychyi wants to merge 1 commit intoapache:mainfrom
aokolnychyi:base-spark-scan-builder
Open

Spark 4.1: Add BaseSparkScanBuilder#15360
aokolnychyi wants to merge 1 commit intoapache:mainfrom
aokolnychyi:base-spark-scan-builder

Conversation

@aokolnychyi
Copy link
Contributor

This PR adds BaseSparkScanBuilder to be used in PR #15240.

@github-actions github-actions bot added the spark label Feb 19, 2026
import org.apache.spark.sql.util.CaseInsensitiveStringMap;

class SparkStagedScanBuilder implements ScanBuilder, SupportsPushDownRequiredColumns {
class SparkStagedScanBuilder extends BaseSparkScanBuilder
Copy link
Contributor Author

Choose a reason for hiding this comment

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

This builder now gets the projection with case sensitivity and partition field ID dedup for free.

SparkScanBuilder builder =
new SparkScanBuilder(spark, TABLES.load(options.get("path")), options)
.caseSensitive(false);
new SparkScanBuilder(spark, TABLES.load(options.get("path")), options);
Copy link
Contributor Author

Choose a reason for hiding this comment

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

Passing options with case sensitivity set is enough.

@aokolnychyi
Copy link
Contributor Author

return Expressions.alwaysTrue();
}

public SparkScanBuilder caseSensitive(boolean isCaseSensitive) {
Copy link
Contributor

Choose a reason for hiding this comment

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

nit: this is a public api. Is it OK to remove?

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.

2 participants

Comments