DICE API Documentation/com.embabel.dice.entity/EntityIncrementalAnalyzer

EntityIncrementalAnalyzer

class EntityIncrementalAnalyzer<T>(pipeline: EntityPipeline, historyStore: ChunkHistoryStore, formatter: IncrementalSourceFormatter<T>, config: WindowConfig = WindowConfig()) : AbstractIncrementalAnalyzer<T, ChunkEntityResult>

Incremental analyzer that extracts entities (without propositions) using an EntityPipeline.

This is a simpler alternative to com.embabel.dice.incremental.proposition.PropositionIncrementalAnalyzer when you only need entity extraction from conversations or other incremental sources.

Example usage:

val entityExtractor = LlmEntityExtractor.withLlm(llmOptions).withAi(ai)
val pipeline = EntityPipeline.withExtractor(entityExtractor)

val analyzer = EntityIncrementalAnalyzer(
    pipeline = pipeline,
    historyStore = myHistoryStore,
    formatter = MessageFormatter.INSTANCE,
)

val source = ConversationSource(conversation)
val result = analyzer.analyze(source, context)

// Persist extracted entities
result?.persist(entityRepository)