anchor.diff:              {ok, Msg, {"riak_kv.ts_get", Table}};
           #tsputreq{table = Table} ->
               {ok, Msg, {"riak_kv.ts_put", Table}};
  +        #tsttbputreq{table = Table} ->
  +            {ok, Msg, {"riak_kv.ts_put", Table}};
           #tsdelreq{table = Table} ->
               {ok, Msg, {"riak_kv.ts_del", Table}};
           #tslistkeysreq{table = Table} ->
  
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) ->
  