aggregateResult
abstract suspend fun aggregateResult(frame: DataFrame, result: AnalyzerResult): Pair<InterimResult, FinalResult?>
Aggregate a new result. If this method returns a non-null FinalResult, the aggregator will stop listening for new results.
Parameters
result
: The result to aggregate