aligned.sources.local.FileDirectory

class documentation

class FileDirectory(Codable, Directory): (source)

Undocumented

Class Method	`schema_placeholder`	Undocumented
Method	`csv_at`	Undocumented
Method	`delta_at`	Undocumented
Method	`directory`	Undocumented
Method	`json_at`	Undocumented
Method	`parquet_at`	Undocumented
Method	`partitioned_parquet_at`	Undocumented
Method	`path_string`	Undocumented
Method	`repo_from_dir`	Undocumented
Method	`sub_directory`	Undocumented
Method	`with_schema_version`	Undocumented
Class Variable	`dir_path`	Undocumented

@classmethod
def schema_placeholder(cls) -> str: (source) ¶

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_at

Undocumented

def delta_at(self, path: str, mapping_keys: dict[str, str] | None = None, config: DeltaFileConfig | None = None) -> DeltaFileSource: (source) ¶

overrides aligned.Directory.delta_at

Undocumented

def directory(self, path: str) -> FileDirectory: (source) ¶

Undocumented

def json_at(self, path: str) -> StorageFileSource: (source) ¶

overrides aligned.Directory.json_at

Undocumented

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_at

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) -> PartitionedParquetFileSource: (source) ¶

overrides aligned.Directory.partitioned_parquet_at

Undocumented

def path_string(self, path: str) -> str: (source) ¶

Undocumented

def repo_from_dir(self, dir: str, exclude: list[str] | None = None) -> AsRepoDefinition: (source) ¶

Undocumented

def sub_directory(self, path: str) -> FileDirectory: (source) ¶

overrides aligned.Directory.sub_directory

Undocumented

def with_schema_version(self, sub_directory: str | None = None) -> Directory: (source) ¶

overrides aligned.Directory.with_schema_version

Undocumented

dir_path: Path = (source) ¶

Undocumented