Table of Contents

Class KnowledgeGraphConsolidationDataPipelineStagePlugin

Namespace
FoundationaLLM.Plugins.DataPipeline.Plugins.DataPipelineStage
Assembly
FoundationaLLM.DataPipelinePlugins.dll

Implements the Knowledge Graph Consolidation Data Pipeline Stage Plugin.

public class KnowledgeGraphConsolidationDataPipelineStagePlugin : KnowledgeGraphDataPipelineStagePluginBase, IDataPipelineStagePlugin
Inheritance
KnowledgeGraphConsolidationDataPipelineStagePlugin
Implements
Inherited Members
Extension Methods

Constructors

KnowledgeGraphConsolidationDataPipelineStagePlugin(Dictionary<string, object>, IPluginPackageManager, IPluginPackageManagerResolver, IServiceProvider)

Implements the Knowledge Graph Consolidation Data Pipeline Stage Plugin.

public KnowledgeGraphConsolidationDataPipelineStagePlugin(Dictionary<string, object> pluginParameters, IPluginPackageManager packageManager, IPluginPackageManagerResolver packageManagerResolver, IServiceProvider serviceProvider)

Parameters

pluginParameters Dictionary<string, object>

The dictionary containing the plugin parameters.

packageManager IPluginPackageManager

The package manager for the plugin.

packageManagerResolver IPluginPackageManagerResolver

The package manager resolver for the plugin.

serviceProvider IServiceProvider

The service provider of the dependency injection container.

Properties

Name 

protected override string Name { get; }

Property Value

string

Methods

GetStageWorkItems(DataPipelineDefinition, DataPipelineRun, List<string>, string, string)

Gets the list of data pipeline work items based on the provided content items canonical identifiers.

public override Task<List<DataPipelineRunWorkItem>> GetStageWorkItems(DataPipelineDefinition dataPipelineDefinition, DataPipelineRun dataPipelineRun, List<string> contentItemsCanonicalIds, string dataPipelineStageName, string previousDataPipelineStageName)

Parameters

dataPipelineDefinition DataPipelineDefinition

The definition of the data pipeline.

dataPipelineRun DataPipelineRun

The data pipeline run.

contentItemsCanonicalIds List<string>

The list of icontent items canonical identifiers.

dataPipelineStageName string

The name of the data pipeline stage.

previousDataPipelineStageName string

The name of the previous data pipeline stage.

Returns

Task<List<DataPipelineRunWorkItem>>

A list of data pipeline work items.

ProcessWorkItem(DataPipelineDefinition, DataPipelineRun, DataPipelineRunWorkItem)

Processes a specified data pipeline run work item.

public override Task<PluginResult> ProcessWorkItem(DataPipelineDefinition dataPipelineDefinition, DataPipelineRun dataPipelineRun, DataPipelineRunWorkItem dataPipelineRunWorkItem)

Parameters

dataPipelineDefinition DataPipelineDefinition

The definition of the data pipeline associated with the data pipeline run work item.

dataPipelineRun DataPipelineRun

The data pipeline run associated with the data pipeline run work item.

dataPipelineRunWorkItem DataPipelineRunWorkItem

The data pipeline run work item to process.

Returns

Task<PluginResult>

An object that contains the processing result.

Edit this page