anchor.diff:          {ok, QId} ->
               case fetch_with_patience(QId, ?FETCH_RETRIES) of
                   {ok, Data} ->
  -                    {reply, make_tsqueryresp(Data, fun Mod:get_field_type/1), State};
  +                    {reply, make_tsqueryresp(Data, Mod), State};
                   {error, Reason} ->
                       {reply, make_rpberrresp(?E_FETCH, Reason), State}
               end;
  
positive.code:             Result
      end.
  
  
  -spec make_tsqueryresp([[{binary(), term()}]], fun()) ->
                                #tsqueryresp{}.
  make_tsqueryresp([], _Fun) ->
      #tsqueryresp{columns = [], rows = []};
  make_tsqueryresp(Rows, GetFieldTypeF) ->
      %% as returned by fetch, we have in Rows a sequence of KV pairs,
      %% making records concatenated in a flat list
      ColumnNames = get_column_names(Rows),
  
negative.code:           fun(C) ->
                    %% make column a single-element list, as
                    %% encode_field_type requires
                    riak_pb_ts_codec:encode_field_type(Module:get_field_type([C]))
            end, ColumnNames),
      Records = assemble_records(Rows, length(ColumnNames)),
      JustRows = lists:map(
  