anchor.diff:  %% MR helper funs
   -export([value/1, counter_value/1, set_value/1, map_value/1]).
   %% Other helper funs
  --export([is_crdt/1]).
  +-export([is_crdt/1, is_crdt/2]).
   
   -include("riak_kv_wm_raw.hrl").
   -include("riak_object.hrl").
  
positive.code:     Bucket = riak_object:bucket(RObj),
      case riak_core_bucket:get_bucket(Bucket) of
          BProps when is_list(BProps) ->
              Type = proplists:get_value(datatype, BProps),
              Mod = riak_kv_crdt:to_mod(Type),
              supported(Mod)
      end.
  
  %% @TODO in riak_dt change value to query allow query to take an
  
negative.code:             true
      end.
  
  -spec new(riak_object:bucket(), riak_object:key(), DT_MOD::module())
           -> riak_object:riak_object().
  new(B, K, Mod) ->
      CRDT=#crdt{ctype=CType} = to_record(Mod, Mod:new()),
      Bin = to_binary(CRDT),
  