aligned.data_source.batch_data_source.CodableBatchDataSource

class documentation

class CodableBatchDataSource(Codable, SerializableType, BatchDataSource): (source)

Known subclasses: aligned.CustomMethodDataSource, aligned.data_source.batch_data_source.FilteredDataSource, aligned.data_source.batch_data_source.JoinAsofDataSource, aligned.data_source.batch_data_source.JoinDataSource, aligned.data_source.batch_data_source.LoadedAtSource, aligned.data_source.batch_data_source.StackSource, aligned.data_source.batch_data_source.TransformSource, aligned.data_source.batch_data_source.UnknownDataSource, aligned.InMemorySource, aligned.sources.azure_blob_storage.AzureBlobCsvDataSource, aligned.sources.azure_blob_storage.AzureBlobParquetDataSource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCFeatureTableSource, aligned.sources.databricks.UCSqlSource, aligned.sources.databricks.UCTableSource, aligned.sources.iceberg.IcebergTable, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.ParquetFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.psql.PostgreSQLDataSource, aligned.sources.random_source.RandomDataSource, aligned.sources.redis.RedisSource, aligned.sources.redshift.RedshiftSQLDataSource, aligned.sources.s3.AwsS3CsvDataSource, aligned.sources.s3.AwsS3ParquetDataSource

Constructor: CodableBatchDataSource._deserialize(value)

View In Hierarchy

A definition to where a specific piece of data can be found. E.g: A database table, a file, a web service, etc.

This can thereafter be combined with other BatchDataSources in order to create a rich dataset.

Class Variable type_name Undocumented
Property as_markdown Undocumented
Class Method _deserialize Undocumented
Method _serialize Undocumented

Inherited from BatchDataSource:

Class Method multi_source_features_for Undocumented
Method __hash__ Undocumented
Method all Undocumented
Method all_between_dates Undocumented
Method all_columns Undocumented
Method all_data Undocumented
Method depends_on Undocumented
Async Method feature_view_code Setup the code needed to represent the data source as a feature view
Method features_for Undocumented
Method filter Undocumented
Async Method freshness .table("my_table") .freshness()
Method job_group_key A key defining which sources can be grouped together in one request.
Method location_id Undocumented
Method needed_configs Undocumented
Async Method schema Returns the schema for the data source
Method source_id An id that identifies a source from others.
Method tags Undocumented
Method transform_with_polars Undocumented
Method with_loaded_at Undocumented
Method with_view Undocumented
type_name: str = (source)
overridden in aligned.CustomMethodDataSource, aligned.data_source.batch_data_source.FilteredDataSource, aligned.data_source.batch_data_source.JoinAsofDataSource, aligned.data_source.batch_data_source.JoinDataSource, aligned.data_source.batch_data_source.LoadedAtSource, aligned.data_source.batch_data_source.StackSource, aligned.data_source.batch_data_source.TransformSource, aligned.data_source.batch_data_source.UnknownDataSource, aligned.InMemorySource, aligned.sources.azure_blob_storage.AzureBlobCsvDataSource, aligned.sources.azure_blob_storage.AzureBlobParquetDataSource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCFeatureTableSource, aligned.sources.databricks.UCSqlSource, aligned.sources.databricks.UCTableSource, aligned.sources.iceberg.IcebergTable, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.ParquetFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.psql.PostgreSQLDataSource, aligned.sources.random_source.RandomDataSource, aligned.sources.redis.RedisSource, aligned.sources.redshift.RedshiftSQLDataSource, aligned.sources.s3.AwsS3CsvDataSource, aligned.sources.s3.AwsS3ParquetDataSource

Undocumented

as_markdown: str = (source)
overridden in aligned.CustomMethodDataSource, aligned.data_source.batch_data_source.LoadedAtSource, aligned.data_source.batch_data_source.TransformSource, aligned.data_source.batch_data_source.UnknownDataSource, aligned.sources.azure_blob_storage.AzureBlobCsvDataSource, aligned.sources.azure_blob_storage.AzureBlobParquetDataSource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCSqlSource, aligned.sources.local.CsvFileSource, aligned.sources.local.ParquetFileSource, aligned.sources.local.PartitionedParquetFileSource

Undocumented

def _deserialize(cls, value: dict) -> CodableBatchDataSource: (source)

Undocumented

def _serialize(self) -> dict: (source)
overridden in aligned.InMemorySource

Undocumented