-module(dqe_hfun1).
-behaviour(dflow).

-export([describe/1, init/1, start/2, emit/3, done/2]).

init([Aggr, SubQ]) ->
    {ok, Aggr, SubQ}.

describe(Aggr) ->
    atom_to_list(Aggr).

start({_Start, _Count}, Aggr) ->
    {ok, Aggr}.

emit(_Child, {histograms, {Histogram, Resolution}}, Aggr) ->
    Vs = [hdr_histogram:Aggr(H) || H <- Histogram],
    Data = mmath_bin:realize(mmath_bin:from_list(Vs)),
    {emit, {realized, {Data, Resolution}}, Aggr}.

done({last, _Child}, Aggr) ->
    {done, Aggr}.