Abstract
constructor(historyStore: ChunkHistoryStore, formatter: IncrementalSourceFormatter<T>, config: WindowConfig = WindowConfig(), contentHasher: ContentHasher = Sha256ContentHasher)
Parameters
T
The type of items in the source
R
The type of result produced by analysis
history
Tracks processing history (caller provides implementation)
formatter
Formats source items to text
config
Window and trigger configuration