Zum Hauptinhalt springen

EtlDataOrchestrator

Namespace: Meshmakers.Octo.Sdk.Common.EtlDataPipeline

Implements an extract-transform-load data orchestrator

public class EtlDataOrchestrator : IEtlDataOrchestrator

Inheritance Object → EtlDataOrchestrator
Implements IEtlDataOrchestrator

Constructors​

EtlDataOrchestrator(IServiceProvider, INodeLookupService)​

Creates a new instance of EtlDataOrchestrator

public EtlDataOrchestrator(IServiceProvider globalServiceProvider, INodeLookupService nodeLookupService)

Parameters​

globalServiceProvider IServiceProvider

nodeLookupService INodeLookupService

Methods​

ExecutePipelineAsync<TEtlContext>(NodeDefinitionRoot, TEtlContext, IPipelineDebugger, Object, IPipelineExecutionMode)​

public Task<object> ExecutePipelineAsync<TEtlContext>(NodeDefinitionRoot nodeDefinitionRoot, TEtlContext etlContext, IPipelineDebugger pipelineDebugger, object value, IPipelineExecutionMode executionMode)

Type Parameters​

TEtlContext

Parameters​

nodeDefinitionRoot NodeDefinitionRoot

etlContext TEtlContext

pipelineDebugger IPipelineDebugger

value Object

executionMode IPipelineExecutionMode

Returns​

Task<Object>