anchor.diff:  erlify_mapred_input(#rpbmapredinput{bucket = Bucket, key = Key, data = undefined}) ->
       {Bucket, Key};
   erlify_mapred_input(#rpbmapredinput{bucket = Bucket, key = Key, data = PbData}) ->
  -    {Bucket, Key, erlify_rpbterm(PbData)}.
  +    {{Bucket, Key}, erlify_rpbterm(PbData)}.
   
   %% Convert list of RpbMapRedPhase to list of erlang phase tuples
   erlify_mapred_query(PbQuery) ->
  
positive.code: pbify_bucket_prop({chash_keyfun, {Module, Function}}) ->
      {?PB_CHASH, {struct, [{?PB_MOD, to_binary(Module)},
                            {?PB_FUN, to_binary(Function)}]}};
  pbify_bucket_prop({Prop, Value}) ->
      {list_to_binary(atom_to_list(Prop)), Value}.
  
  
negative.code: pbify_rpbterm({struct, L}) ->
      E = [#rpbobjectentry{name = to_binary(Name), value = pbify_rpbterm(Value)} ||
              {Name, Value} <- L],
      #rpbterm{type = ?RPB_TERM_OBJECT, object_entries = E};
  pbify_rpbterm({bool, B}) ->
      V = case B of true -> 1; false -> 0 end,
      #rpbterm{type = ?RPB_TERM_BOOLEAN, int_value = V}.
      
  %% Convert RpbTerm message to a term()
  erlify_rpbterm(#rpbterm{type = ?RPB_TERM_INTEGER, int_value = Int}) when Int =/= undefined ->
      Int;
  