aligned.feature_source.WritableFeatureSource

class documentation

class WritableFeatureSource: (source)

View In Hierarchy

Undocumented

Async Method	`insert`	Undocumented
Async Method	`overwrite`	Undocumented
Async Method	`upsert`	Undocumented

async def insert(self, job: RetrivalJob, request: RetrivalRequest): (source) ¶

overridden in aligned.sources.azure_blob_storage.AzureBlobDeltaDataSource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.in_mem_source.InMemorySource, 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: RetrivalJob, request: RetrivalRequest): (source) ¶

overridden in aligned.sources.azure_blob_storage.AzureBlobDeltaDataSource, aligned.sources.azure_blob_storage.AzureBlobPartitionedParquetDataSource, aligned.sources.in_mem_source.InMemorySource, aligned.sources.lancedb.LanceDbTable, aligned.sources.local.CsvFileSource, aligned.sources.local.PartitionedParquetFileSource, aligned.sources.random_source.RandomDataSource

Undocumented

async def upsert(self, job: RetrivalJob, request: RetrivalRequest): (source) ¶

Undocumented