DICE API Documentation/com.embabel.dice.text2graph.support/ParallelSourceAnalyzer

ParallelSourceAnalyzer

class ParallelSourceAnalyzer(analyzers: List<SourceAnalyzer>, executor: ExecutorService = Executors.newFixedThreadPool(analyzers.size), config: ParallelSourceAnalyzer.Config = Config()) : SourceAnalyzer

Runs multiple source analyzers in parallel on the same chunk and merges results. Entities suggested by multiple analyzers are weighted higher (agreement scoring).

Constructors

constructor(analyzers: List<SourceAnalyzer>, executor: ExecutorService = Executors.newFixedThreadPool(analyzers.size), config: ParallelSourceAnalyzer.Config = Config())

Types

Config

data class Config(val minAgreement: Int = 1)

Functions

suggestEntities

open override fun suggestEntities(chunk: <Error class: unknown class>, context: SourceAnalysisContext): SuggestedEntities

Identify entities in a chunk based on the provided schema.

suggestRelationships

open override fun suggestRelationships(chunk: <Error class: unknown class>, suggestedEntitiesResolution: Resolutions<SuggestedEntityResolution>, context: SourceAnalysisContext): SuggestedRelationships

Suggest relationships between the given entities based on the provided schema.