anchor.diff:  list_buckets(Filter, Timeout) ->
       Me = self(),
       ReqId = mk_reqid(),
  -    riak_kv_buckets_fsm_sup:start_buckets_fsm(Node, [{raw, ReqId, Me}, [Filter, Timeout, plain]]),
  +    riak_kv_buckets_fsm_sup:start_buckets_fsm(Node, [{raw, ReqId, Me}, [Filter, Timeout]]),
       wait_for_listbuckets(ReqId, Timeout).
   
   %% @spec filter_buckets(Fun :: function()) ->
  
positive.code: %%      and a final {ReqId, done} message.
  %%      None of the Keys lists will be larger than the number of
  %%      keys in Bucket on any single vnode.
  %%      If ClientType is set to 'mapred' instead of 'plain', then the
  %%      messages will be sent in the form of a MR input stream.
  stream_list_keys(Input, Timeout, Client, ClientType) when is_pid(Client) ->
      ReqId = mk_reqid(),
      case Input of
          {Bucket, FilterInput} ->
  
negative.code:                                                           Client},
                                                           [Bucket,
                                                            FilterExprs,
                                                            Timeout]]),
                      {ok, ReqId}
              end;
          Bucket ->
  