anchor.diff:                end,
       [#fitting_spec{name={kvget_map,I},
                      module=riak_kv_pipe_get,
  -                   chashfun=fun bkey_chash/1,
  -                   nval=fun bkey_nval/1},
  +                   chashfun={riak_kv_pipe_get, bkey_chash},
  +                   nval={riak_kv_pipe_get, bkey_nval}},
        #fitting_spec{name={xform_map,I},
                      module=riak_kv_mrc_map,
                      arg={FunSpec, SafeArg},
  
positive.code:          group_outputs/2,
           mapred_plan/1,
           mapred_plan/2,
           compile_string/1
          ]).
  %% NOTE: Example functions are used by EUnit tests
  -export([example/0, example_bucket/0, example_reduce/0,
  
negative.code: -spec link2pipe(link_match(), link_match(), boolean(),
                  Index :: integer(), Query :: tuple()) ->
           [ riak_pipe:fitting_spec() ].
  link2pipe(Bucket, Tag, Keep, I, _QueryT) ->
      [#fitting_spec{name={kvget_map,I},
                     module=riak_kv_pipe_get,
                     chashfun={riak_kv_pipe_get, bkey_chash},
                     nval={riak_kv_pipe_get, bkey_nval}},
       #fitting_spec{name={xform_map,I},
                     module=riak_kv_mrc_map,
                     arg={{modfun, riak_kv_mrc_map, link_phase},
                          {Bucket, Tag}},
                     chashfun=follow}|
       [#fitting_spec{name=I,
                      module=riak_pipe_w_tee,
  