Class MapReduceStrategy

Namespace

JD.AI.Core.Agents.Orchestration.Strategies

Assembly

JD.AI.Core.dll

Map-Reduce strategy — split input into chunks, process in parallel, then reduce. Good for: bulk file analysis, large codebase scanning, data processing.

public sealed class MapReduceStrategy : IOrchestrationStrategy

Inheritance

object

MapReduceStrategy

Implements

IOrchestrationStrategy

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

MaxParallelism

Maximum number of parallel mapper agents.

public int MaxParallelism { get; init; }

Property Value

int

Name

The strategy name (sequential, fan-out, supervisor, debate).

public string Name { get; }

Property Value

string

Methods

ExecuteAsync(IReadOnlyList<SubagentConfig>, TeamContext, ISubagentExecutor, AgentSession, Action<SubagentProgress>?, CancellationToken)

Execute the orchestration strategy with the given agents, context, and executor.

public Task<TeamResult> ExecuteAsync(IReadOnlyList<SubagentConfig> agents, TeamContext context, ISubagentExecutor executor, AgentSession parentSession, Action<SubagentProgress>? onProgress = null, CancellationToken ct = default)

Parameters

agents IReadOnlyList<SubagentConfig>

context TeamContext

executor ISubagentExecutor

parentSession AgentSession

onProgress Action<SubagentProgress>

ct CancellationToken

Returns

Task<TeamResult>