anchor.diff:      Chunk;
   get_decoded_results(Chunk) ->
       decode_results(lists:flatten(Chunk)).
  +
  +rows_in_chunk({decoded, Chunk}) ->
  +    length(Chunk);
  +rows_in_chunk(Chunk) ->
  +    length(Chunk).
  +
   
   %%
   run_select_on_group(Query, SelClause, Chunk, QueryResult1) ->
  
positive.code:           max_running_fsms   = ?MAX_RUNNING_FSMS    :: pos_integer(),
            %% 2. Estimate query size (wget-style):
            n_subqueries_done  = 0                    :: non_neg_integer(),
            total_query_data   = 0                    :: non_neg_integer(),
            max_query_data                            :: non_neg_integer(),
            %% For queries not backed by query buffers, results are
  
negative.code: %%
  add_subquery_result(SubQId, Chunk, #state{sub_qrys = SubQs,
                                            total_query_data = TotalQueryData,
                                            total_query_rows = TotalQueryRows,
                                            n_subqueries_done = NSubqueriesDone,
                                            n_running_fsms = NRunning} = State) ->
      case lists:member(SubQId, SubQs) of
  