class documentation
Undocumented
| Class Method | schema |
Undocumented |
| Method | csv |
Undocumented |
| Method | delta |
Undocumented |
| Method | directory |
Undocumented |
| Method | json |
Undocumented |
| Method | parquet |
Undocumented |
| Method | partitioned |
Undocumented |
| Method | repo |
Undocumented |
| Method | sub |
Undocumented |
| Method | with |
Undocumented |
| Class Variable | path |
Undocumented |
def csv_at(self, path:
str, mapping_keys: dict[ str, str] | None = None, csv_config: CsvConfig | None = None) -> CsvFileSource:
(source)
¶
overrides
aligned.Directory.csv_atUndocumented
def delta_at(self, path:
str, mapping_keys: dict[ str, str] | None = None, config: DeltaConfig | None = None) -> DeltaFileSource:
(source)
¶
overrides
aligned.Directory.delta_atUndocumented
def parquet_at(self, path:
str, mapping_keys: dict[ str, str] | None = None, config: ParquetConfig | None = None, date_formatter: DateFormatter | None = None) -> ParquetFileSource:
(source)
¶
overrides
aligned.Directory.parquet_atUndocumented
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) -> PartitionedParquetFileSource:
(source)
¶
overrides
aligned.Directory.partitioned_parquet_atUndocumented
def with_schema_version(self, sub_directory:
str | ConfigValue | None = None) -> Directory:
(source)
¶
overrides
aligned.Directory.with_schema_versionUndocumented