aligned.sources.azure_blob_storage.AzureBlobDirectory

class documentation

class AzureBlobDirectory(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	`sub_directory`	Undocumented
Method	`with_schema_version`	Undocumented
Class Variable	`config`	Undocumented
Class Variable	`sub_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, date_formatter: DateFormatter | None = None) -> AzureBlobCsvDataSource: (source) ¶

Undocumented

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

Undocumented

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

Undocumented

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

Undocumented

def parquet_at(self, path: str, mapping_keys: dict[str, str] | None = None, config: ParquetConfig | None = None, date_formatter: DateFormatter | None = None) -> AzureBlobParquetDataSource: (source) ¶

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

Undocumented

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

Undocumented

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

Undocumented

config: AzureBlobConfig = (source) ¶

Undocumented

sub_path: Path = (source) ¶

Undocumented