aligned.psql.jobs.FactPsqlJob

class documentation

class FactPsqlJob(RetrivalJob): (source)

View In Hierarchy

Fetches features for defined facts within a postgres DB

It is supported to fetch from different tables, in one request This is hy the source property is a dict with sources

NB: It is expected that the data sources are for the same psql instance

Method aggregated_values_from_request Undocumented
Method build_entities_from_values Undocumented
Async Method build_request Undocumented
Method build_request_from_facts Undocumented
Method build_sql_entity_query Undocumented
Method describe Undocumented
Method dtype_to_sql_type Undocumented
Method generate_query Undocumented
Method ignore_event_timestamp Undocumented
Async Method psql_job Undocumented
Method sql_aggregated_request Undocumented
Async Method to_lazy_polars Undocumented
Async Method to_pandas Undocumented
Method value_selection Undocumented
Class Variable facts Undocumented
Class Variable requests Undocumented
Class Variable sources Undocumented
Property config Undocumented
Property request_result Undocumented
Property retrival_requests Undocumented

Inherited from RetrivalJob:

Static Method from_convertable Undocumented
Static Method from_dict Undocumented
Static Method from_lazy_function Undocumented
Static Method from_polars_df Undocumented
Method aggregate Undocumented
Method cache_raw_data Undocumented
Method cached_at Undocumented
Method chuncked Undocumented
Method combined_features Undocumented
Method derive_features Undocumented
Method drop_duplicate_entities Undocumented
Method drop_invalid Drops invalid row based on the defined features.
Method ensure_types Undocumented
Method fill_missing_columns Undocumented
Method filter Filters based on a condition referencing either a feature, a feature name, or an polars expression to filter on.
Method inject_store Undocumented
Method join Undocumented
Method join_asof Undocumented
Method listen_to_events Undocumented
Method log_each_job Undocumented
Method monitor_time_used Undocumented
Method on_load Undocumented
Method polars_method Undocumented
Method remove_derived_features Undocumented
Method rename Undocumented
Method return_invalid Undocumented
Method select Undocumented
Method select_columns Undocumented
Method split Undocumented
Async Method to_polars Undocumented
Method train_test Undocumented
Method train_test_validate Undocumented
Method transform_polars Undocumented
Method unique_entities Undocumented
Method unique_on Undocumented
Method unpack_embeddings Undocumented
Method update_vector_index Undocumented
Method validate_entites Undocumented
Method with_request Undocumented
Method with_subfeatures Undocumented
Method without_derived_features Undocumented
Async Method write_to_source Writes the output of the retrival job to the passed source.
Property loaded_columns Undocumented
def aggregated_values_from_request(self, request: RetrivalRequest) -> list[TableFetch]: (source)

Undocumented

def build_entities_from_values(self, values: list[list[SqlValue]]) -> str: (source)

Undocumented

async def build_request(self) -> str: (source)

Undocumented

def build_request_from_facts(self, facts: pl.LazyFrame) -> str: (source)

Undocumented

def build_sql_entity_query(self, sql_facts: PostgreSqlJob) -> str: (source)

Undocumented

def describe(self) -> str: (source)
overrides aligned.retrival_job.RetrivalJob.describe

Undocumented

def dtype_to_sql_type(self, dtype: object) -> str: (source)

Undocumented

def generate_query(self, entity_columns: list[str], entity_query: str, tables: list[TableFetch], aggregates: list[TableFetch], final_select: list[str], final_joins: str) -> str: (source)

Undocumented

def ignore_event_timestamp(self) -> RetrivalJob: (source)
overrides aligned.retrival_job.RetrivalJob.ignore_event_timestamp

Undocumented

async def psql_job(self) -> PostgreSqlJob: (source)

Undocumented

def sql_aggregated_request(self, window: AggregateOver, features: set[AggregatedFeature], request: RetrivalRequest) -> TableFetch: (source)

Undocumented

async def to_lazy_polars(self) -> pl.LazyFrame: (source)
overrides aligned.retrival_job.RetrivalJob.to_lazy_polars

Undocumented

async def to_pandas(self) -> pd.DataFrame: (source)
overrides aligned.retrival_job.RetrivalJob.to_pandas

Undocumented

def value_selection(self, request: RetrivalRequest, entities_has_event_timestamp: bool) -> TableFetch: (source)

Undocumented

facts: RetrivalJob = (source)

Undocumented

requests: list[RetrivalRequest] = (source)

Undocumented

sources: dict[FeatureLocation, PostgreSQLDataSource] = (source)

Undocumented

@property
config: PostgreSQLConfig = (source)

Undocumented

@property
request_result: RequestResult = (source)
overrides aligned.retrival_job.RetrivalJob.request_result

Undocumented

@property
retrival_requests: list[RetrivalRequest] = (source)
overrides aligned.retrival_job.RetrivalJob.retrival_requests

Undocumented