Persists a dataframe to the online store. 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,
)
| 173 | pass |
| 174 | |
| 175 | def ingest_df( |
| 176 | self, |
| 177 | feature_view: Union[BaseFeatureView, FeatureView, OnDemandFeatureView], |
| 178 | df: pd.DataFrame, |
| 179 | field_mapping: Optional[Dict] = None, |
| 180 | ): |
| 181 | """ |
| 182 | Persists a dataframe to the online store. |
| 183 | |
| 184 | Args: |
| 185 | feature_view: The feature view to which the dataframe corresponds. |
| 186 | df: The dataframe to be persisted. |
| 187 | field_mapping: A dictionary mapping dataframe column names to feature names. |
| 188 | """ |
| 189 | pass |
| 190 | |
| 191 | async def ingest_df_async( |
| 192 | self, |
no outgoing calls
no test coverage detected