aligned.feature_source.BatchFeatureSource

class documentation

class BatchFeatureSource(FeatureSource, RangeFeatureSource): (source)

View In Hierarchy

A factory for different type of jobs This could either be a "fetch all", or "fetch features for ids"

This class will then know how to strucutre the query in the correct way

Method all_between Undocumented
Method all_for Undocumented
Method features_for Undocumented
Async Method freshness_for Undocumented
Class Variable sources Undocumented
Property source_types Undocumented
def all_between(self, start_date: datetime, end_date: datetime, request: FeatureRequest) -> RetrivalJob: (source)
overrides aligned.feature_source.RangeFeatureSource.all_between

Undocumented

def all_for(self, request: FeatureRequest, limit: int | None = None) -> RetrivalJob: (source)
overrides aligned.feature_source.RangeFeatureSource.all_for

Undocumented

def features_for(self, facts: RetrivalJob, request: FeatureRequest) -> RetrivalJob: (source)
overrides aligned.feature_source.FeatureSource.features_for

Undocumented

async def freshness_for(self, locations: dict[FeatureLocation, Feature]) -> dict[FeatureLocation, datetime | None]: (source)
overrides aligned.feature_source.FeatureSource.freshness_for

Undocumented

sources: Mapping[str, BatchDataSource] = (source)

Undocumented

@property
source_types: dict[str, type[BatchDataSource]] = (source)

Undocumented