Package com.helix.core.executor

Class BatchExecutor

java.lang.Object

com.helix.core.executor.BatchExecutor

public class BatchExecutor
extends Object

Parallel batch rule executor for bulk context processing using parallel streams and configurable parallelism.

Constructor Summary

Constructors

Constructor	Description
BatchExecutor()
BatchExecutor(int parallelism)
BatchExecutor(SyncExecutor syncExecutor, int parallelism)

Method Summary

Modifier and Type	Method	Description
List<ExecutionResult>	executeBatch(CompiledRule compiledRule, List<ExecutionContext> contexts)	Executes a compiled rule against a list of execution contexts in parallel.
ExecutorMetrics	getMetrics()
int	getParallelism()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BatchExecutor

public BatchExecutor()

BatchExecutor

public BatchExecutor(int parallelism)

BatchExecutor

public BatchExecutor(SyncExecutor syncExecutor,
 int parallelism)

Method Details

executeBatch

public List<ExecutionResult> executeBatch(CompiledRule compiledRule,
 List<ExecutionContext> contexts)

Executes a compiled rule against a list of execution contexts in parallel.

Parameters:

compiledRule - rule instance

contexts - list of contexts to process

Returns:

List of ExecutionResult objects preserving input order

getMetrics

public ExecutorMetrics getMetrics()

getParallelism

public int getParallelism()