anchor.diff:                              || {Name, Type} <- lists:zip(ColumnNames, ColumnTypes)],
                    rows = make_data(Rows)}.
   
  +
  +%% TODO: implement
   process_stream(_, _, State)->
       {ignore, State}.
   
  
positive.code:             Parsed
      end.
  
  decode_query_permissions(#ddl_v1{bucket=NewBucket}) ->
      {"riak_kv.ts_create_table", NewBucket};
  decode_query_permissions(#riak_sql_v1{'FROM'=Bucket}) ->
      {"riak_kv.ts_query", Bucket}.
  
  make_data(Rows) ->
      make_d2(Rows, []).
  
  
negative.code: init() ->
      #state{}.
  
  -spec decode(integer(), binary()) ->
                      {ok, #ddl_v1{} | #riak_sql_v1{} | #tsputreq{},
                       {PermSpec::string(), Table::binary()}}.
  decode(Code, Bin) ->
      Msg = riak_pb_codec:decode(Code, Bin),
      case Msg of
  