Persists a dataframe to the online store asynchronously. Args: feature_view: The feature view to which the dataframe corresponds. df: The dataframe to be persisted. field_mapping: A dictionary mapping dataframe column names to feature names.
(
self,
feature_view: Union[BaseFeatureView, FeatureView, OnDemandFeatureView],
df: pd.DataFrame,
field_mapping: Optional[Dict] = None,
)
| 189 | pass |
| 190 | |
| 191 | async def ingest_df_async( |
| 192 | self, |
| 193 | feature_view: Union[BaseFeatureView, FeatureView, OnDemandFeatureView], |
| 194 | df: pd.DataFrame, |
| 195 | field_mapping: Optional[Dict] = None, |
| 196 | ): |
| 197 | """ |
| 198 | Persists a dataframe to the online store asynchronously. |
| 199 | |
| 200 | Args: |
| 201 | feature_view: The feature view to which the dataframe corresponds. |
| 202 | df: The dataframe to be persisted. |
| 203 | field_mapping: A dictionary mapping dataframe column names to feature names. |
| 204 | """ |
| 205 | pass |
| 206 | |
| 207 | def ingest_df_to_offline_store( |
| 208 | self, |
no outgoing calls
no test coverage detected