EntityIncrementalAnalyzer

constructor(pipeline: EntityPipeline, historyStore: ChunkHistoryStore, formatter: IncrementalSourceFormatter<T>, config: WindowConfig = WindowConfig())

Parameters

T

The type of items in the source

pipeline

The entity extraction pipeline

historyStore

Tracks processing history

formatter

Formats source items to text

config

Window and trigger configuration