VectorStoreDestination

Class VectorStoreDestination

Writes batches of records into a Microsoft.Extensions.VectorData.VectorStoreCollection<TKey, TRecord>. Embeddings are not created here. Run an embedding transformation before this destination when the record needs a vector.

Inheritance

DataFlowComponent

DataFlowDestination<ExpandoObject>

DataFlowBatchDestination<ExpandoObject>

VectorStoreDestination<string, ExpandoObject>

VectorStoreDestination

Implements

IDataFlowBatchDestination<ExpandoObject>

IDataFlowDestination<ExpandoObject>

IDataFlowBatchDestination

IDataFlowDestination

IDataFlowComponent

Inherited Members

VectorStoreDestination<string, ExpandoObject>.Collection

VectorStoreDestination<string, ExpandoObject>.CheckParameter()

VectorStoreDestination<string, ExpandoObject>.PrepareWrite()

VectorStoreDestination<string, ExpandoObject>.BulkInsertData(ExpandoObject[])

VectorStoreDestination<string, ExpandoObject>.FinishWrite()

DataFlowBatchDestination<ExpandoObject>.BeforeBatchWrite

DataFlowBatchDestination<ExpandoObject>.AfterBatchWrite

DataFlowBatchDestination<ExpandoObject>.BatchSize

DataFlowBatchDestination<ExpandoObject>.UseBufferBlock

DataFlowBatchDestination<ExpandoObject>.CleanUpOnSuccess()

DataFlowBatchDestination<ExpandoObject>.CleanUpOnFaulted(Exception)

DataFlowBatchDestination<ExpandoObject>.InitComponent()

DataFlowBatchDestination<ExpandoObject>.WriteBatch(ExpandoObject[])

DataFlowBatchDestination<ExpandoObject>.PrepareWrite()

DataFlowBatchDestination<ExpandoObject>.BulkInsertData(ExpandoObject[])

DataFlowBatchDestination<ExpandoObject>.FinishWrite()

DataFlowDestination<ExpandoObject>.TargetBlock

DataFlowDestination<ExpandoObject>.TargetAction

DataFlowDestination<ExpandoObject>.CompleteBuffer()

DataFlowDestination<ExpandoObject>.FaultBuffer(Exception)

DataFlowDestination<ExpandoObject>.Buffer

DataFlowDestination<ExpandoObject>.BufferTargetAction

DataFlowDestination<ExpandoObject>.InternalBatchSize

DataFlowDestination<ExpandoObject>.DEFAULT_BATCH_SIZE

DataFlowComponent.MaxBufferSize

DataFlowComponent.Predecessors

DataFlowComponent.Successors

DataFlowComponent.Completion

DataFlowComponent.BufferCancellationSource

DataFlowComponent.BufferCancellationToken

DataFlowComponent.WasComponentInitialized

DataFlowComponent.IsReadyForProcessing

DataFlowComponent.SetParentComponent(DataFlowComponent)

DataFlowComponent.LinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.InternalLinkTo<T>(IDataFlowDestination, object, object)

DataFlowComponent.AddComplementVoidLinkToOtherTargets(Func<Type, IDataFlowDestination>, Delegate)

DataFlowComponent.ResetComponent()

DataFlowComponent.InitBufferObjects(CancellationToken?)

DataFlowComponent.Reset()

DataFlowComponent.PrepareParameterForCheck()

DataFlowComponent.CheckParameter()

DataFlowComponent.InitCheckedParameter()

DataFlowComponent.OnInitialization

DataFlowComponent.OnCompletion

DataFlowComponent.OnException

DataFlowComponent.CompleteOrFaultBufferOnPredecessorCompletion(Task)

DataFlowComponent.Exception

DataFlowComponent.ErrorSource

DataFlowComponent.CancelBufferAndThrowOperationCanceledException()

DataFlowComponent.InternalLinkErrorTo(IDataFlowDestination<ETLBoxError>)

DataFlowComponent.ThrowOrRedirectError(Exception, string, string)

DataFlowComponent.ThrowErrorAndFaultNetwork(Exception, string)

DataFlowComponent.CancelComponent()

DataFlowComponent.ErrorCount

DataFlowComponent.ProgressCount

DataFlowComponent.OnProgress

DataFlowComponent.ExecutionStartTime

DataFlowComponent.ExecutionEndTime

DataFlowComponent.Tag

DataFlowComponent.LoggingStartOnce()

DataFlowComponent.LoggingFinishOnce()

DataFlowComponent.LogProgressBatch_AfterThrowOrRedirectError(int)

DataFlowComponent.LogProgress_AfterThrowOrRedirectError()

LoggableTask.TaskType

LoggableTask.TaskName

LoggableTask.DisableLogging

LoggableTask.LogThreshold

LoggableTask.TaskHash

LoggableTask.LogInstance

LoggableTask.ParentTask

LoggableTask.LogTrace(string, params object[])

LoggableTask.LogDebug(string, params object[])

LoggableTask.LogInfo(string, params object[])

LoggableTask.LogInfoOrDebug(string, params object[])

LoggableTask.LogWarn(string, params object[])

LoggableTask.LogError(string, params object[])

LoggableTask.LogFatal(string, params object[])

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: ETLBox.AI

Assembly: ETLBox.AI.dll

Syntax

    public class VectorStoreDestination : VectorStoreDestination<string, ExpandoObject>, IDataFlowBatchDestination<ExpandoObject>, IDataFlowDestination<ExpandoObject>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask

Constructors

VectorStoreDestination()

Declaration

    public VectorStoreDestination()

VectorStoreDestination(VectorStoreCollection<string, ExpandoObject>)

Declaration

    public VectorStoreDestination(VectorStoreCollection<string, ExpandoObject> collection)

Parameters

Type	Name	Description
VectorStoreCollection<string, ExpandoObject>	collection

VectorStoreDestination(VectorStoreCollection<string, ExpandoObject>, int)

Declaration

    public VectorStoreDestination(VectorStoreCollection<string, ExpandoObject> collection, int batchSize)

Parameters

Type	Name	Description
VectorStoreCollection<string, ExpandoObject>	collection
int	batchSize

Implements

IDataFlowBatchDestination<TInput>

IDataFlowDestination<TInput>

IDataFlowBatchDestination

IDataFlowDestination

IDataFlowComponent