Analyzers\ScanShareableAnalyzer.cs

internal abstract class ScanShareableAnalyzer<S, M> : Analyzer<S, M>, ...
{
    ...

    public override Option<S> ComputeStateFrom(DataFrame dataFrame)
    {
        IEnumerable<Column> aggregations = AggregationFunctions();
        Row result = dataFrame
            .Agg(aggregations.First(), aggregations.Skip(1).ToArray())
            .Collect()
            .FirstOrDefault();

        return FromAggregationResult(result, 0);
    }
}