public class IndexSource extends RiakStreamClient<IndexEntry>
conn, continuation
Constructor and Description |
---|
IndexSource(RiakClient client,
com.basho.riak.pbc.RiakConnection conn,
IndexRequest request) |
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext() |
IndexEntry |
next() |
close, getContinuation, hasContinuation, isClosed, iterator
public IndexSource(RiakClient client, com.basho.riak.pbc.RiakConnection conn, IndexRequest request) throws IOException
IOException
public boolean hasNext() throws IOException
hasNext
in class RiakStreamClient<IndexEntry>
IOException
public IndexEntry next() throws IOException
next
in class RiakStreamClient<IndexEntry>
IOException
Copyright © 2013. All Rights Reserved.