aligned.sources.iceberg.IcebergTable

class documentation

class IcebergTable(CodableBatchDataSource, Deletable, WritableFeatureSource): (source)

View In Hierarchy

Undocumented

Class Method multi_source_features_for Undocumented
Method __hash__ Undocumented
Method all_data Undocumented
Async Method delete Undocumented
Method identifier Undocumented
Async Method insert Undocumented
Method job_group_key A key defining which sources can be grouped together in one request.
Async Method overwrite Undocumented
Async Method upsert Undocumented
Class Variable catalog Undocumented
Class Variable table Undocumented
Class Variable type_name Undocumented
Class Variable _schema Undocumented

Inherited from CodableBatchDataSource:

Property as_markdown Undocumented
Class Method _deserialize Undocumented
Method _serialize Undocumented

Inherited from BatchDataSource (via CodableBatchDataSource):

Method all Undocumented
Method all_between_dates Undocumented
Method all_columns Undocumented
Method depends_on 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
Async Method freshness .table("my_table") .freshness()
Method location_id Undocumented
Method needed_configs Undocumented
Async Method schema Returns the schema for the data source
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 multi_source_features_for(cls, facts: RetrievalJob, requests: list[tuple[IcebergTable, RetrievalRequest]]) -> RetrievalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.multi_source_features_for

Undocumented

def __hash__(self) -> int: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.__hash__

Undocumented

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

Undocumented

async def delete(self, predicate: Expression | None = None): (source)
overrides aligned.sources.local.Deletable.delete

Undocumented

def identifier(self) -> tuple[str, str]: (source)

Undocumented

async def insert(self, job: RetrievalJob, request: RetrievalRequest): (source)
overrides aligned.feature_source.WritableFeatureSource.insert

Undocumented

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.

async def overwrite(self, job: RetrievalJob, request: RetrievalRequest, predicate: Expression | None = None): (source)
overrides aligned.feature_source.WritableFeatureSource.overwrite

Undocumented

async def upsert(self, job: RetrievalJob, request: RetrievalRequest): (source)
overrides aligned.feature_source.WritableFeatureSource.upsert

Undocumented

catalog: IcebergCatalog = (source)

Undocumented

table: ConfigValue = (source)

Undocumented

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

Undocumented

_schema: ConfigValue = (source)

Undocumented