Method get_historical_features

sdk/python/feast/infra/provider.py:249–281

Retrieves the point-in-time correct historical feature values for the specified entity rows. Args: config: The config for the current feature store. feature_views: A list containing all feature views that are referenced in the entity rows. featur

(
        self,
        config: RepoConfig,
        feature_views: List[Union[FeatureView, OnDemandFeatureView]],
        feature_refs: List[str],
        entity_df: Optional[Union[pd.DataFrame, str]],
        registry: BaseRegistry,
        project: str,
        full_feature_names: bool,
        **kwargs,
    )

    @abstractmethod
    def get_historical_features(
        self,
        config: RepoConfig,
        feature_views: List[Union[FeatureView, OnDemandFeatureView]],
        feature_refs: List[str],
        entity_df: Optional[Union[pd.DataFrame, str]],
        registry: BaseRegistry,
        project: str,
        full_feature_names: bool,
        **kwargs,
    ) -> RetrievalJob:
        """
        Retrieves the point-in-time correct historical feature values for the specified entity rows.

        Args:
            config: The config for the current feature store.
            feature_views: A list containing all feature views that are referenced in the entity rows.
            feature_refs: The features to be retrieved.
            entity_df: A collection of rows containing all entity columns on which features need to be joined,
                as well as the timestamp column used for point-in-time joins. Either a pandas dataframe can be
                provided or a SQL query. If None, features will be retrieved for the specified timestamp range.
            registry: The registry for the current feature store.
            project: Feast project to which the feature views belong.
            full_feature_names: If True, feature names will be prefixed with the corresponding feature view name,
                changing them from the format "feature" to "feature_view__feature" (e.g. "daily_transactions"
                changes to "customer_fv__daily_transactions").
            start_date: Start date for the timestamp range when retrieving features without entity_df.
            end_date: End date for the timestamp range when retrieving features without entity_df.

        Returns:
            A RetrievalJob that can be executed to get the features.
        """
        pass

    @abstractmethod
    def online_read(