in Elastic.SemanticKernel.Connectors.Elasticsearch/ElasticsearchVectorStoreRecordCollection.cs [197:216]
public async Task<TRecord?> GetAsync(string key, GetRecordOptions? options = null,
CancellationToken cancellationToken = default)
{
// TODO: Handle options
var storageModel = await RunOperationAsync(
"get",
() => _elasticsearchClient.GetDocumentAsync(CollectionName, key, cancellationToken))
.ConfigureAwait(false);
if (!storageModel.HasValue)
{
return default;
}
var record = VectorStoreErrorHandler.RunModelConversion(DatabaseName, CollectionName, "get",
() => _mapper.MapFromStorageToDataModel(storageModel.Value, new StorageToDataModelMapperOptions()));
return record;
}