anchor.diff:      lists:map(fun(Resp) ->
                         encode_snapshot_read_resp(Resp)
                 end, Zipped).
  -encode_snapshot_read_resp({{read, Key, riak_dt_pncounter}, Result}) ->
  +encode_snapshot_read_resp({{read, {Key, riak_dt_pncounter}}, Result}) ->
       #fpbsnapshotreadtxnrespvalue{key=Key,counter=#fpbgetcounterresp{value =Result}};
  -encode_snapshot_read_resp({{read,Key,riak_dt_orset}, Result}) ->
  +encode_snapshot_read_resp({{read,{Key,riak_dt_orset}}, Result}) ->
       #fpbsnapshotreadtxnrespvalue{key=Key,set=#fpbgetsetresp{value = term_to_binary(Result)}}.
  
positive.code:                       end, RemElems),
      Op = case length(Adds) of
               0 -> [];
               1 -> [{update, Key, riak_dt_orset, {{add,Adds}, node()}}];
               _ -> [{update, Key, riak_dt_orset, {{add_all, Adds},node()}}]
           end, 
      case length(Rems) of
          0 -> Op;
          1 -> [{update, Key, riak_dt_orset, {{remove,Adds}, ignore}}] ++ Op;
          _ -> [{update, Key, riak_dt_orset, {{remove_all, Adds},ignore}}] ++ Op
      end.
          
  
  
negative.code:                 end, [], Ops).
  %% Counter
  decode_au_txn_op(#fpbatomicupdatetxnop{counterinc=#fpbincrementreq{key=Key, amount=Amount}}) ->
      [{update, {Key, riak_dt_pncounter, {{increment, Amount}, node()}}}];
  decode_au_txn_op(#fpbatomicupdatetxnop{counterdec=#fpbdecrementreq{key=Key, amount=Amount}}) ->
      [{update, {Key, riak_dt_pncounter, {{decrement, Amount}, node()}}}];
  %% Set
  decode_au_txn_op(#fpbatomicupdatetxnop{setupdate=#fpbsetupdatereq{key=Key, adds=AddElems, rems=RemElems}}) ->
       Adds = lists:map(fun(X) ->
  