Visitar URL original
feat(spark): Add compute-on-read support for BatchFeatureView in get_… by SIDDHESH1564 · Pull Request #6357 · feast-dev/feast · GitHub
Skip to content

feat(spark): Add compute-on-read support for BatchFeatureView in get_… #6357

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.

Sign up for GitHub

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

Merged
ntkathole merged 7 commits into from
May 3, 2026
+283 −0
Merged

feat(spark): Add compute-on-read support for BatchFeatureView in get_… #6357

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
11d69be
feat(spark): add compute-on-read support for BatchFeatureView in get_…
SIDDHESH1564 May 1, 2026
c2a3d7a
Merge branch 'master' into feature/spark-bfv-compute-on-read
SIDDHESH1564 May 2, 2026
9390de9
Add None check for batch_source in _apply_bfv_transformations
SIDDHESH1564 May 2, 2026
a424bbf
refactor(spark): use feature_view_utils helpers for BFV transformatio…
SIDDHESH1564 May 2, 2026
c9e72de
fix(spark): apply time-range filter before BFV UDF and update temp vi…
SIDDHESH1564 May 3, 2026
502fad2
Merge branch 'master' into feature/spark-bfv-compute-on-read
SIDDHESH1564 May 3, 2026
e1e1764
refactor(spark): use resolve_feature_view_source_with_fallback for BF…
SIDDHESH1564 May 3, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add None check for batch_source in _apply_bfv_transformations 
Signed-off-by: Siddhesh Khairnar <khairnarsiddhesh4057@gmail.com>
  • Loading branch information
@SIDDHESH1564
SIDDHESH1564 committed May 2, 2026
commit 9390de9cb24489cd77dd9b54f89a4017a2a6cc5b
1 change: 1 addition & 0 deletions sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -738,6 +738,7 @@ def _apply_bfv_transformations(
if (
fv is not None
and isinstance(fv, BatchFeatureView)
and fv.batch_source is not None
and fv.feature_transformation is not None
and fv.feature_transformation.udf is not None
):
Expand Down
Loading