Class VectorStoreDestination<TRecord>

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

object

LoggableTask

DataFlowComponent

DataFlowDestination<TRecord>

DataFlowBatchDestination<TRecord>

VectorStoreDestination<string, TRecord>

VectorStoreDestination<TRecord>

Implements

IDataFlowBatchDestination<TRecord>

IDataFlowDestination<TRecord>

IDataFlowBatchDestination

IDataFlowDestination

IDataFlowComponent

ILoggableTask

Inherited Members

VectorStoreDestination<string, TRecord>.Collection

VectorStoreDestination<string, TRecord>.CheckParameter()

VectorStoreDestination<string, TRecord>.PrepareWrite()

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

VectorStoreDestination<string, TRecord>.FinishWrite()

DataFlowBatchDestination<TRecord>.BeforeBatchWrite

DataFlowBatchDestination<TRecord>.AfterBatchWrite

DataFlowBatchDestination<TRecord>.BatchSize

DataFlowBatchDestination<TRecord>.UseBufferBlock

DataFlowBatchDestination<TRecord>.CleanUpOnSuccess()

DataFlowBatchDestination<TRecord>.CleanUpOnFaulted(Exception)

DataFlowBatchDestination<TRecord>.InitComponent()

DataFlowBatchDestination<TRecord>.WriteBatch(TRecord[])

DataFlowBatchDestination<TRecord>.PrepareWrite()

DataFlowBatchDestination<TRecord>.BulkInsertData(TRecord[])

DataFlowBatchDestination<TRecord>.FinishWrite()

DataFlowDestination<TRecord>.TargetBlock

DataFlowDestination<TRecord>.TargetAction

DataFlowDestination<TRecord>.CompleteBuffer()

DataFlowDestination<TRecord>.FaultBuffer(Exception)

DataFlowDestination<TRecord>.Buffer

DataFlowDestination<TRecord>.BufferTargetAction

DataFlowDestination<TRecord>.InternalBatchSize

DataFlowDestination<TRecord>.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

{{< /rawhtml >}} ```C# public class VectorStoreDestination : VectorStoreDestination, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask where TRecord : class ``` {{< rawhtml >}}

Type Parameters

Name	Description
TRecord	Type of ingoing records.

Constructors

VectorStoreDestination()

Declaration

{{< /rawhtml >}} ```C# public VectorStoreDestination() ``` {{< rawhtml >}}

VectorStoreDestination(VectorStoreCollection<string, TRecord>)

Declaration

{{< /rawhtml >}} ```C# public VectorStoreDestination(VectorStoreCollection collection) ``` {{< rawhtml >}}

Parameters

Type	Name	Description
VectorStoreCollection<string, TRecord>	collection

VectorStoreDestination(VectorStoreCollection<string, TRecord>, int)

Declaration

{{< /rawhtml >}} ```C# public VectorStoreDestination(VectorStoreCollection collection, int batchSize) ``` {{< rawhtml >}}

Parameters

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

Implements

IDataFlowBatchDestination<TInput>

IDataFlowDestination<TInput>

IDataFlowBatchDestination

IDataFlowDestination

IDataFlowComponent

ILoggableTask