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 Secondary Index
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_INDEX_REQ, req)
 
        return RiakPbcIndexStream(self, index, return_terms)
 
    def search(self, index, query, **params):

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_INDEX_REQ, req)
 
        return RiakPbcIndexStream(self, index, return_terms)
 
    def create_search_index(self, index, schema=None):