feat: Initial Bytewax materialization engine
What this PR does / why we need it:
This PR adds a Bytewax batch materialization engine.
Which issue(s) this PR fixes:
Fixes #
/ok-to-test
Codecov Report
Merging #2974 (383e3cb) into master (0ed1a63) will increase coverage by
8.50%. The diff coverage is44.00%.
@@ Coverage Diff @@
## master #2974 +/- ##
==========================================
+ Coverage 67.44% 75.94% +8.50%
==========================================
Files 169 203 +34
Lines 14936 16939 +2003
==========================================
+ Hits 10074 12865 +2791
+ Misses 4862 4074 -788
| Flag | Coverage Δ | |
|---|---|---|
| integrationtests | 67.01% <44.00%> (-0.44%) |
:arrow_down: |
| unittests | 58.27% <44.00%> (?) |
Flags with carried forward coverage won't be shown. Click here to find out more.
| Impacted Files | Coverage Δ | |
|---|---|---|
| sdk/python/feast/repo_config.py | 88.80% <ø> (+5.40%) |
:arrow_up: |
| setup.py | 0.00% <0.00%> (ø) |
|
| ...on/materialization/contrib/bytewax/test_bytewax.py | 45.83% <45.83%> (ø) |
|
| sdk/python/feast/cli.py | 41.59% <0.00%> (-0.10%) |
:arrow_down: |
| ...ocal_feast_tests/test_stream_feature_view_apply.py | ||
| ...ffline_stores/contrib/athena_repo_configuration.py | 50.00% <0.00%> (ø) |
|
| ...offline_stores/contrib/spark_repo_configuration.py | 100.00% <0.00%> (ø) |
|
| ...b/cassandra_online_store/cassandra_online_store.py | 2.63% <0.00%> (ø) |
|
| ...hon/feast/infra/utils/postgres/connection_utils.py | 48.00% <0.00%> (ø) |
|
| ...line_stores/contrib/postgres_repo_configuration.py | 100.00% <0.00%> (ø) |
|
| ... and 102 more |
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here.
@whoahbot looking at this PR now, but do you mind signing your commits? Also you may need a rebase!
[APPROVALNOTIFIER] This PR is APPROVED
This pull-request has been approved by: achals, whoahbot
The full list of commands accepted by this bot can be found here.
The pull request process is described here
- ~~OWNERS~~ [achals]
Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment