anchor.diff:      new_state().
   
   %%
  -subqueries_done(QId,
  -                #state{qid          = QId,
  -                       receiver_pid = ReceiverPid,
  -                       sub_qrys     = SubQQ} = State) ->
  +subqueries_done(QId, #state{qid          = QId,
  +                            receiver_pid = ReceiverPid,
  +                            sub_qrys     = SubQQ} = State) ->
       case SubQQ of
           [] ->
               QueryResult2 = prepare_final_results(State),
  
positive.code: %%
  run_select_on_chunk(SubQId, Chunk, #state{ qry = Query,
                                             result = QueryResult1 }) ->
    DecodedChunk = decode_results(lists:flatten(Chunk)),
    SelClause = sql_select_clause(Query),
    case sql_select_calc_type(Query) of
        rows ->
            run_select_on_rows_chunk(SubQId, SelClause, DecodedChunk, QueryResult1);
        aggregate ->
            run_select_on_aggregate_chunk(SelClause, DecodedChunk, QueryResult1)
    end.
  
  %% Run the selection clause on results that accumulate rows
  run_select_on_rows_chunk(SubQId, SelClause, DecodedChunk, QueryResult1) ->
  
negative.code:             Key
      end.
  
  decode_results([]) ->
      [];
  decode_results([{_,V}|Tail]) when is_binary(V) ->
  