Save the embedded documents to the online store.
(self, df: pd.DataFrame, feature_view_name: str)
| 237 | return _DEFAULT_VECTOR_LENGTH |
| 238 | |
| 239 | def save_to_online_store(self, df: pd.DataFrame, feature_view_name: str) -> None: |
| 240 | """ |
| 241 | Save the embedded documents to the online store. |
| 242 | """ |
| 243 | from feast.feature_store import FeatureStore |
| 244 | |
| 245 | if self.store is None: |
| 246 | self.store = FeatureStore(repo_path=self.repo_path) |
| 247 | self.store.write_to_online_store( |
| 248 | feature_view_name=feature_view_name, |
| 249 | df=df, |
| 250 | ) |
| 251 | |
| 252 | # TODO (Future scope): Implement save_to_offline_store to write embedded |
| 253 | # documents to the offline store. Currently blocked by DaskOfflineStore |