aligned.redshift.jobs.FactRedshiftJob

class documentation

class FactRedshiftJob(RetrivalJob): (source)

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_sql_entity_query`	Undocumented
Method	`describe`	Undocumented
Method	`dtype_to_sql_type`	Undocumented
Method	`generate_query`	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	`entity_table_name`	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	`ignore_event_timestamp`	Undocumented
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_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, event_timestamp_col: str | None) -> str: (source) ¶

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

entity_table_name: str = (source) ¶

Undocumented

facts: RetrivalJob = (source) ¶

Undocumented

requests: list[RetrivalRequest] = (source) ¶

Undocumented

sources: dict[FeatureLocation, RedshiftSQLDataSource] = (source) ¶

Undocumented

@property
config: RedshiftSQLConfig = (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