anchor.diff:  
   
   -spec decode(integer(), binary()) ->
  -                    {ok, #tsputreq{} | #tsdelreq{} | #tsgetreq{} | #tslistkeysreq{}
  +                    {ok, #tsputreq{} | #tsttbputreq{} | #tsdelreq{} | #tsgetreq{} | #tslistkeysreq{}
                        | #ddl_v1{} | ?SQL_SELECT{} | #riak_sql_describe_v1{},
                        {PermSpec::string(), Table::binary()}} |
                       {error, _}.
  
positive.code:             end;
          BadRowIdxs when is_list(BadRowIdxs) ->
              {reply, validate_rows_error_response(BadRowIdxs), State};
          {_, {undef, _}} ->
              BucketProps = riak_core_bucket:get_bucket(table_to_bucket(Table)),
              {reply, missing_helper_module(Table, BucketProps), State}
  
negative.code:     {ok, riak_pb_codec:encode(Message)}.
  
  
  -spec process(atom() | #tsputreq{} | #tsttbputreq{} | #tsdelreq{} | #tsgetreq{} | #tslistkeysreq{}
                | #ddl_v1{} | ?SQL_SELECT{} | #riak_sql_describe_v1{}, #state{}) ->
                       {reply, #tsqueryresp{} | #rpberrorresp{}, #state{}}.
  process(#tsputreq{rows = []}, State) ->
  