Packages

riak

1.1.1
1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.0

A Riak client written in Elixir.

HexDocs

Current section

Files

Jump to
Readme
8 Versions
3 Dependencies
Dependants
Files
Activity
riak lib riak map_reduce.ex
Raw

lib/riak/map_reduce.ex 

defmodule Riak.Mapred do

  import Riak.Pool

  import :riakc_pb_socket



  @doc """

  @deprecated There are performance issues with MapReduce, please use another query strategy.

  Perform a MapReduce job across the cluster.

  See the MapReduce documentation for explanation of behavior.

  """

  defpool query(pid, inputs, query) when is_pid(pid), do: mapred(pid, inputs, query)

  defpool query(pid, inputs, query, timeout) when is_pid(pid), do: mapred(pid, inputs, query, timeout)



  defmodule Bucket do

    @doc """

    @deprecated There are performance issues with MapReduce, please use another query strategy.

    Perform a MapReduce job across the cluster using an entire bucket as the input.

    See the MapReduce documentation for explanation of behavior.

    """

    defpool query(pid, bucket, query) when is_pid(pid), do: mapred_bucket(pid, bucket, query)

    defpool query(pid, bucket, query, timeout) when is_pid(pid), do: mapred_bucket(pid, bucket, query, timeout)

  end

end