aligned.feature_source.WritableFeatureSource

class documentation

class WritableFeatureSource: (source)

Known subclasses: aligned.InMemorySource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCFeatureTableSource, aligned.sources.databricks.UCTableSource, aligned.sources.iceberg.IcebergTable, aligned.sources.in_mem_source.RetrievalJobSource, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.psql.PostgreSQLDataSource, aligned.sources.random_source.RandomDataSource, aligned.sources.redis.RedisSource

View In Hierarchy

Undocumented

Async Method insert Undocumented
Async Method overwrite Undocumented
Async Method upsert Undocumented
async def insert(self, job: RetrievalJob, request: RetrievalRequest): (source)
overridden in aligned.InMemorySource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCFeatureTableSource, aligned.sources.databricks.UCTableSource, aligned.sources.iceberg.IcebergTable, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.psql.PostgreSQLDataSource, aligned.sources.random_source.RandomDataSource, aligned.sources.redis.RedisSource

Undocumented

async def overwrite(self, job: RetrievalJob, request: RetrievalRequest, predicate: Expression | None = None): (source)
overridden in aligned.InMemorySource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCFeatureTableSource, aligned.sources.databricks.UCTableSource, aligned.sources.iceberg.IcebergTable, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.random_source.RandomDataSource, aligned.sources.redis.RedisSource

Undocumented

async def upsert(self, job: RetrievalJob, request: RetrievalRequest): (source)
overridden in aligned.InMemorySource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.databricks.UCFeatureTableSource, aligned.sources.databricks.UCTableSource, aligned.sources.iceberg.IcebergTable, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.DeltaFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.psql.PostgreSQLDataSource, aligned.sources.random_source.RandomDataSource, aligned.sources.redis.RedisSource

Undocumented