aligned.Directory

class documentation

class Directory(Protocol): (source)

Known subclasses: aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

View In Hierarchy

Undocumented

Method csv_at Undocumented
Method delta_at Undocumented
Method json_at Undocumented
Method parquet_at Undocumented
Method partitioned_parquet_at Undocumented
Method sub_directory Undocumented
Method with_schema_version Undocumented
def csv_at(self, path: str, mapping_keys: dict[str, str] | None = None, csv_config: CsvConfig | None = None) -> CodableBatchDataSource: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented

def delta_at(self, path: str, mapping_keys: dict[str, str] | None = None, config: DeltaFileConfig | None = None) -> CodableBatchDataSource: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented

def json_at(self, path: str) -> StorageFileReference: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented

def parquet_at(self, path: str, mapping_keys: dict[str, str] | None = None, config: ParquetConfig | None = None, date_formatter: DateFormatter | None = None) -> CodableBatchDataSource: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented

def partitioned_parquet_at(self, directory: str, partition_keys: list[str], mapping_keys: dict[str, str] | None = None, config: ParquetConfig | None = None, date_formatter: DateFormatter | None = None) -> CodableBatchDataSource: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented

def sub_directory(self, path: str) -> Directory: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented

def with_schema_version(self, sub_directory: str | None = None) -> Directory: (source)
overridden in aligned.AzureBlobConfig, aligned.sources.local.FileDirectory

Undocumented