aligned.data_source.batch_data_source.ColumnFeatureMappable

class documentation

class ColumnFeatureMappable: (source)

View In Hierarchy

Undocumented

Method	`columns_for`	Undocumented
Method	`feature_identifier_for`	Undocumented
Method	`with_renames`	Undocumented
Class Variable	`mapping_keys`	Undocumented

def columns_for(self, features: list[Feature]) -> list[str]: (source) ¶

Undocumented

def feature_identifier_for(self, columns: Iterable[str]) -> list[str]: (source) ¶

Undocumented

def with_renames(self: T, mapping_keys: dict[str, str]) -> T: (source) ¶

Undocumented

mapping_keys: dict[str, str] = (source) ¶

overridden in aligned.sources.azure_blob_storage.AzureBlobCsvDataSource, aligned.sources.azure_blob_storage.AzureBlobDeltaDataSource, aligned.sources.azure_blob_storage.AzureBlobParquetDataSource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.ParquetFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.psql.PostgreSQLDataSource, aligned.sources.redis.RedisStreamSource, aligned.sources.redshift.RedshiftSQLDataSource, aligned.sources.s3.AwsS3CsvDataSource, aligned.sources.s3.AwsS3ParquetDataSource

Undocumented