aligned.sources.local

module documentation
(source)

Undocumented

Class AsRepoDefinition Undocumented
Class CsvFileSource A source pointing to a CSV file
Class Deletable Undocumented
Class DeltaFileConfig Undocumented
Class DeltaFileSource A source pointing to a Parquet file
Class DirectoryRepo Undocumented
Class FileDirectory Undocumented
Class LiteralReference A class containing a in mem pandas frame.
Class ParquetFileSource A source pointing to a Parquet file
Class PartitionedParquetFileSource A source pointing to a Parquet file
Class StorageFileReference A reference to a file that can be loaded as bytes.
Class StorageFileSource Undocumented
Function create_parent_dir Undocumented
Async Function data_file_freshness Undocumented
Function delete_path Undocumented
Function do_file_exist Undocumented
Function fill_missing_in_request Undocumented
Function fill_with_default Undocumented
Variable logger Undocumented
def create_parent_dir(path: str): (source)

Undocumented

async def data_file_freshness(reference: DataFileReference, column_name: str, formatter: DateFormatter | None = None) -> datetime | None: (source)

Undocumented

def delete_path(path: str): (source)

Undocumented

def do_file_exist(path: str) -> bool: (source)

Undocumented

def fill_missing_in_request(request: RetrivalRequest, df: pl.LazyFrame, feature_rename: dict[str, str]) -> pl.LazyFrame: (source)

Undocumented

def fill_with_default(features: list[Feature], df: pl.LazyFrame, feature_rename: dict[str, str]) -> pl.LazyFrame: (source)

Undocumented

logger = (source)

Undocumented