DICE API Documentation/com.embabel.dice.incremental.proposition/PropositionIncrementalAnalyzer

PropositionIncrementalAnalyzer

class PropositionIncrementalAnalyzer<T>(pipeline: PropositionPipeline, historyStore: ChunkHistoryStore, formatter: IncrementalSourceFormatter<T>, config: WindowConfig = WindowConfig()) : AbstractIncrementalAnalyzer<T, ChunkPropositionResult>

Incremental analyzer that produces com.embabel.dice.pipeline.ChunkPropositionResult using a com.embabel.dice.pipeline.PropositionPipeline.

Example usage:

val analyzer = PropositionIncrementalAnalyzer(
    pipeline = PropositionPipeline.withExtractor(extractor),
    historyStore = myHistoryStore,
    formatter = MessageFormatter.INSTANCE,
)

val source = ConversationSource(conversation)
val result = analyzer.analyze(source, context)
Content copied to clipboard

Parameters

T

The type of items in the source

pipeline

The proposition extraction pipeline

historyStore

Tracks processing history

formatter

Formats source items to text

config

Window and trigger configuration

Constructors

Link copied to clipboard
constructor(pipeline: PropositionPipeline, historyStore: ChunkHistoryStore, formatter: IncrementalSourceFormatter<T>, config: WindowConfig = WindowConfig())

Functions

Link copied to clipboard
open override fun analyze(source: IncrementalSource<T>, context: SourceAnalysisContext): ChunkPropositionResult?

Analyze the source if enough new content has accumulated.

Link copied to clipboard
open override fun analyzeNow(source: IncrementalSource<T>, context: SourceAnalysisContext): ChunkPropositionResult?

Force analysis regardless of trigger interval. Implementations may still skip if content was already processed.