Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(4)  |  Call(2)  |  Derive(0)  |  Import(2)
Used internally by RiakPbcTransport to implement MapReduce
streams.

src/r/i/riak-2.0.3/riak/transports/pbc/transport.py   riak(Download)
from riak.util import decode_index_value
from connection import RiakPbcConnection
from stream import (RiakPbcKeyStream, RiakPbcMapredStream, RiakPbcBucketStream,
                    RiakPbcIndexStream)
from codec import RiakPbcCodec
        self._send_msg(MSG_CODE_MAPRED_REQ, req)
 
        return RiakPbcMapredStream(self)
 
    def get_index(self, bucket, index, startkey, endkey=None,

src/r/i/riak-python-client-HEAD/riak/transports/pbc/transport.py   riak-python-client(Download)
from riak.util import decode_index_value
from connection import RiakPbcConnection
from stream import (RiakPbcKeyStream, RiakPbcMapredStream, RiakPbcBucketStream,
                    RiakPbcIndexStream)
from codec import RiakPbcCodec
        self._send_msg(MSG_CODE_MAPRED_REQ, req)
 
        return RiakPbcMapredStream(self)
 
    def get_index(self, bucket, index, startkey, endkey=None,