anchor.diff:        rows ->
             run_select_on_rows_chunk(SubQId, SelClause, DecodedChunk, QueryResult1);
         aggregate ->
  -          run_select_on_aggregate_chunk(SelClause, QueryResult1, DecodedChunk)
  +          run_select_on_aggregate_chunk(SelClause, DecodedChunk, QueryResult1)
     end.
   
   %% Run the selection clause on results that accumulate rows
  
positive.code:           qry           = none                :: none | ?SQL_SELECT{},
            qid           = undefined           :: undefined | {node(), non_neg_integer()},
            sub_qrys      = []                  :: [integer()],
            status        = void                :: void | accumulating_chunks,
            receiver_pid                        :: pid(),
            result        = []                  :: [{non_neg_integer(), list()}] | [{binary(), term()}],
            run_sub_qs_fn = fun run_sub_qs_fn/1 :: fun()
  
negative.code:     case lists:member(SubQId, SubQs) of
          true ->
              try
                  QueryResult2 = run_select_on_chunk(SubQId, Chunk, State),
                  NSubQ = lists:delete(SubQId, SubQs),
                  State#state{result   = QueryResult2,
                              sub_qrys = NSubQ}
              catch
                error:divide_by_zero ->
                    cancel_error_query(divide_by_zero, State)
  