aligned.data_source.batch_data_source.JoinDataSource

class documentation

class JoinDataSource(CodableBatchDataSource): (source)

View In Hierarchy

Undocumented

Method all_between_dates Undocumented
Method all_data Undocumented
Method all_with_limit Undocumented
Method depends_on Undocumented
Async Method freshness .table("my_table") .freshness()
Method job_group_key A key defining which sources can be grouped together in one request.
Method join Undocumented
Async Method schema Returns the schema for the data source
Class Variable left_on Undocumented
Class Variable left_request Undocumented
Class Variable method Undocumented
Class Variable right_on Undocumented
Class Variable right_request Undocumented
Class Variable right_source Undocumented
Class Variable source Undocumented
Class Variable type_name Undocumented

Inherited from CodableBatchDataSource:

Class Method _deserialize Undocumented
Method _serialize Undocumented

Inherited from BatchDataSource (via CodableBatchDataSource):

Class Method multi_source_features_for Undocumented
Method __hash__ Undocumented
Method all Undocumented
Method all_columns Undocumented
Async Method feature_view_code Setup the code needed to represent the data source as a feature view
Method features_for Undocumented
Method filter Undocumented
Method location_id Undocumented
Method source_id An id that identifies a source from others.
Method tags Undocumented
Method transform_with_polars Undocumented
Method with_loaded_at Undocumented
Method with_view Undocumented
def all_between_dates(self, request: RetrivalRequest, start_date: datetime, end_date: datetime) -> RetrivalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.all_between_dates

Undocumented

def all_data(self, request: RetrivalRequest, limit: int | None) -> RetrivalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.all_data

Undocumented

def all_with_limit(self, limit: int | None) -> RetrivalJob: (source)

Undocumented

def depends_on(self) -> set[FeatureLocation]: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.depends_on

Undocumented

async def freshness(self, feature: Feature) -> datetime | None: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.freshness

my_table_freshenss = await (PostgreSQLConfig("DB_URL")
.table("my_table") .freshness()

)

def job_group_key(self) -> str: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.job_group_key

A key defining which sources can be grouped together in one request.

def join(self, view: Any, on: str | FeatureFactory | list[str] | list[FeatureFactory] | None = None, on_left: str | FeatureFactory | list[str] | list[FeatureFactory] | None = None, on_right: str | FeatureFactory | list[str] | list[FeatureFactory] | None = None, how: str = 'inner') -> JoinDataSource: (source)

Undocumented

async def schema(self) -> dict[str, FeatureType]: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.schema

Returns the schema for the data source

`python source = FileSource.parquet_at('test_data/titanic.parquet') schema = await source.schema() >>> {'passenger_id': FeatureType(name='int64'), ...} `

Returns:
dict[str, FeatureType]: A dictionary containing the column name and the feature type
left_on: list[str] = (source)

Undocumented

left_request: RetrivalRequest = (source)

Undocumented

method: str = (source)

Undocumented

right_on: list[str] = (source)

Undocumented

right_request: RetrivalRequest = (source)

Undocumented

right_source: CodableBatchDataSource = (source)

Undocumented

source: CodableBatchDataSource = (source)

Undocumented

type_name: str = (source)
overrides aligned.data_source.batch_data_source.CodableBatchDataSource.type_name

Undocumented