Zum Hauptinhalt springen

Class: IngestionPipeline

Constructors

constructor

new IngestionPipeline(init?): IngestionPipeline

Parameters

NameType
init?Partial<IngestionPipeline>

Returns

IngestionPipeline

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:61

Properties

_docStoreStrategy

Private Optional _docStoreStrategy: TransformComponent

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:59


cache

Optional cache: IngestionCache

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:56


disableCache

disableCache: boolean = false

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:57


docStore

Optional docStore: BaseDocumentStore

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:54


docStoreStrategy

docStoreStrategy: DocStoreStrategy = DocStoreStrategy.UPSERTS

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:55


documents

Optional documents: Document<Metadata>[]

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:51


reader

Optional reader: BaseReader

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:52


transformations

transformations: TransformComponent[] = []

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:50


vectorStore

Optional vectorStore: VectorStore

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:53

Methods

prepareInput

prepareInput(documents?, nodes?): Promise<BaseNode<Metadata>[]>

Parameters

NameType
documents?Document<Metadata>[]
nodes?BaseNode<Metadata>[]

Returns

Promise<BaseNode<Metadata>[]>

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:73


run

run(args?, transformOptions?): Promise<BaseNode<Metadata>[]>

Parameters

NameType
argsIngestionRunArgs & TransformRunArgs
transformOptions?any

Returns

Promise<BaseNode<Metadata>[]>

Defined in

packages/core/src/ingestion/IngestionPipeline.ts:93