anchor.diff:  
   
   compile(_Mod, {error, Err}) ->
  -    {error, decoder_parse_error_resp(Err)};
  +    {error, make_decoder_error_response(Err)};
   compile(_Mod, {'EXIT', {Err, _}}) ->
  -    {error, decoder_parse_error_resp(Err)};
  +    {error, make_decoder_error_response(Err)};
   compile(Mod, {ok, SQL}) ->
       case (catch Mod:get_ddl()) of
           {_, {undef, _}} ->
  
positive.code: 
  -spec process(atom() | ts_requests() | ts_query_types(), #state{}) ->
                       {reply, ts_responses(), #state{}}.
  process(M = #tsputreq{table = Table}, State) ->
      check_table_and_call(Table, fun sub_tsputreq/4, M, State);
  
  
negative.code: sub_tscoveragereq(Mod, _DDL, #tscoveragereq{table = Table,
                                              query = Q},
                    State) ->
      case compile(Mod, catch decode_query(Q)) of
          {error, #rpberrorresp{} = Error} ->
              {reply, Error, State};
          {error, _} ->
              {reply, make_rpberrresp(
                        ?E_BAD_QUERY, "Failed to compile query"),
               State};
          SQL ->
              %% SQL is a list of queries (1 per quantum)
              Bucket = riak_kv_ts_util:table_to_bucket(Table),
              Client = {riak_client, [node(), undefined]},
              convert_cover_list(sql_to_cover(Client, SQL, Bucket, []), State)
      end.
  
  