anchor.diff:  
   
   -spec decode(integer(), binary()) ->
  -                    {ok, #tsputreq{} | #tsttbputreq{} | #tsdelreq{} | #tsgetreq{} | #tslistkeysreq{}
  +                    {ok, #tsputreq{} | #tsputreqttb{} | #tsdelreq{} | #tsgetreq{} | #tslistkeysreq{}
                        | #ddl_v1{} | ?SQL_SELECT{} | #riak_sql_describe_v1{},
                        {PermSpec::string(), Table::binary()}} |
                       {error, _}.
  
positive.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) ->
  
negative.code:             {reply, missing_helper_module(Table, BucketProps), State}
      end;
  
  process(#tsputreqttb{rows = []}, State) ->
      {reply, #tsputresp{}, State};
  process(#tsputreqttb{table = Table, columns = _Columns, rows = Rows}, State) ->
  
      Mod = riak_ql_ddl:make_module_name(Table),
      Data = Rows,
  