class documentation
class CustomMethodDataSource(CodableBatchDataSource): (source)
Constructors: CustomMethodDataSource.from_load(method, depends_on, docker_config)
, CustomMethodDataSource.from_methods(all_data, all_between_dates, features_for, generic_load, depends_on_sources, ...)
Undocumented
Class Method | multi |
Undocumented |
Static Method | default |
Undocumented |
Static Method | from |
Undocumented |
Static Method | from |
Undocumented |
Method | all |
Undocumented |
Method | all |
Undocumented |
Method | depends |
Undocumented |
Method | features |
Undocumented |
Method | job |
A key defining which sources can be grouped together in one request. |
Class Variable | all |
Undocumented |
Class Variable | all |
Undocumented |
Class Variable | depends |
Undocumented |
Class Variable | docker |
Undocumented |
Class Variable | features |
Undocumented |
Class Variable | generic |
Undocumented |
Class Variable | type |
Undocumented |
Property | all |
Undocumented |
Property | as |
Undocumented |
Property | between |
Undocumented |
Property | for |
Undocumented |
Inherited from CodableBatchDataSource
:
Class Method | _deserialize |
Undocumented |
Method | _serialize |
Undocumented |
Inherited from BatchDataSource
(via CodableBatchDataSource
):
Method | __hash__ |
Undocumented |
Method | all |
Undocumented |
Method | all |
Undocumented |
Async Method | feature |
Setup the code needed to represent the data source as a feature view |
Method | filter |
Undocumented |
Async Method | freshness |
.table("my_table") .freshness() |
Method | location |
Undocumented |
Method | needed |
Undocumented |
Async Method | schema |
Returns the schema for the data source |
Method | source |
An id that identifies a source from others. |
Method | tags |
Undocumented |
Method | transform |
Undocumented |
Method | with |
Undocumented |
Method | with |
Undocumented |
@classmethod
def multi_source_features_for(cls:
def multi_source_features_for(cls:
type[ T]
, facts: RetrievalJob
, requests: list[ tuple[ T, RetrievalRequest]]
) -> RetrievalJob
:
(source)
¶
Undocumented
@staticmethod
def from_load(method:
def from_load(method:
Callable[ [ RetrievalRequest], Coroutine[ None, None, pl.LazyFrame]]
, depends_on: set[ FeatureLocation] | None
= None, docker_config: DockerConfig | None
= None) -> CustomMethodDataSource
:
(source)
¶
Undocumented
@staticmethod
def from_methods(all_data:
def from_methods(all_data:
Callable[ [ RetrievalRequest, (int | None)], Coroutine[ None, None, pl.LazyFrame]] | None
= None, all_between_dates: Callable[ [ RetrievalRequest, datetime, datetime], Coroutine[ None, None, pl.LazyFrame]] | None
= None, features_for: Callable[ [ RetrievalJob, RetrievalRequest], Coroutine[ None, None, pl.LazyFrame]] | None
= None, generic_load: Callable[ [ RetrievalRequest], Coroutine[ None, None, pl.LazyFrame]] | None
= None, depends_on_sources: set[ FeatureLocation] | None
= None, docker_config: DockerConfig | str | None
= None) -> CustomMethodDataSource
:
(source)
¶
Undocumented
def all_between_dates(self, request:
RetrievalRequest
, start_date: datetime
, end_date: datetime
) -> RetrievalJob
:
(source)
¶
Undocumented
@property
all_method:
all_method:
Callable[ [ RetrievalRequest, (int | None)], Coroutine[ None, None, pl.LazyFrame]]
=
(source)
¶
Undocumented