aligned.InMemorySource

class documentation

class InMemorySource(CodableBatchDataSource, DataFileReference, WritableFeatureSource, VectorIndex, Deletable): (source)

Constructors: InMemorySource.empty(), InMemorySource.from_values(values), InMemorySource(data)

View In Hierarchy

Undocumented

Class Method multi_source_features_for Undocumented
Static Method empty Undocumented
Static Method from_values Undocumented
Method __init__ Undocumented
Async Method delete Undocumented
Async Method insert Undocumented
Method job_group_key A key defining which sources can be grouped together in one request.
Method nearest_n_to Undocumented
Async Method overwrite Undocumented
Async Method to_lazy_polars Undocumented
Async Method upsert Undocumented
Method vector_index_name Undocumented
Method with_view Undocumented
Async Method write_polars Undocumented
Class Variable type_name Undocumented
Instance Variable data Undocumented
Instance Variable job_key Undocumented
Method _serialize Undocumented
Instance Variable _vector_index_name Undocumented

Inherited from CodableBatchDataSource:

Property as_markdown Undocumented
Class Method _deserialize Undocumented

Inherited from BatchDataSource (via CodableBatchDataSource):

Method __hash__ Undocumented
Method all Undocumented
Method all_between_dates Undocumented
Method all_columns Undocumented
Method all_data 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

Inherited from DataFileReference (via CodableBatchDataSource, BatchDataSource):

Async Method read_pandas Undocumented
Async Method to_pandas Undocumented
Async Method to_polars Undocumented
Async Method write_pandas Undocumented
def multi_source_features_for(cls: type[InMemorySource], facts: RetrievalJob, requests: list[tuple[InMemorySource, RetrievalRequest]]) -> RetrievalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.multi_source_features_for

Undocumented

def empty() -> InMemorySource: (source)

Undocumented

def from_values(values: dict[str, object]) -> InMemorySource: (source)

Undocumented

def __init__(self, data: pl.DataFrame): (source)

Undocumented

async def delete(self, predicate: Expression | None = None): (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.

def nearest_n_to(self, data: RetrievalJob, number_of_records: int, request: RetrievalRequest) -> RetrievalJob: (source)
overrides aligned.sources.vector_index.VectorIndex.nearest_n_to

Undocumented

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

Undocumented

async def to_lazy_polars(self) -> pl.LazyFrame: (source)
overrides aligned.data_file.DataFileReference.to_lazy_polars

Undocumented

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

Undocumented

def vector_index_name(self) -> str | None: (source)
overrides aligned.sources.vector_index.VectorIndex.vector_index_name

Undocumented

def with_view(self, view: CompiledFeatureView) -> InMemorySource: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.with_view

Undocumented

async def write_polars(self, df: pl.LazyFrame): (source)
overrides aligned.data_file.DataFileReference.write_polars

Undocumented

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

Undocumented

data = (source)

Undocumented

job_key = (source)

Undocumented

def _serialize(self) -> dict: (source)
overrides aligned.data_source.batch_data_source.CodableBatchDataSource._serialize

Undocumented

_vector_index_name = (source)

Undocumented