com.englishtown.vertx.solr.streams.impl

Class CursorMarkReadJsonStream

java.lang.Object

com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase<CursorMarkReadJsonStream>

com.englishtown.vertx.solr.streams.impl.CursorMarkReadJsonStream

All Implemented Interfaces:

ReadJsonStream<CursorMarkReadJsonStream>, org.vertx.java.core.streams.ExceptionSupport<CursorMarkReadJsonStream>, org.vertx.java.core.streams.ReadSupport<CursorMarkReadJsonStream,org.vertx.java.core.json.JsonObject>

public class CursorMarkReadJsonStream
extends ReadJsonStreamBase<CursorMarkReadJsonStream>

CursorMark implementation of ReadJsonStreamBase using CursorMark to paginate json Solr results

Constructor Summary

Constructors

Constructor and Description
CursorMarkReadJsonStream()

Method Summary

Modifier and Type	Method and Description
protected void	handleReply(org.vertx.java.core.json.JsonObject reply) Pagination looping logic - continuously runs through a doQuery loop until all results have been streamed
protected boolean	isComplete(org.vertx.java.core.json.JsonObject reply)
protected void	setQueryStart(org.apache.solr.client.solrj.SolrQuery query) Set the query start point for pagination.

Methods inherited from class com.englishtown.vertx.solr.streams.impl.ReadJsonStreamBase

address, dataHandler, endHandler, eventBus, exceptionHandler, pause, resume, serializer, solrQuery

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CursorMarkReadJsonStream

public CursorMarkReadJsonStream()

Method Detail

setQueryStart

protected void setQueryStart(org.apache.solr.client.solrj.SolrQuery query)

Description copied from class: ReadJsonStreamBase

Set the query start point for pagination. Typically either the start or cursorMark param.

Specified by:

setQueryStart in class ReadJsonStreamBase<CursorMarkReadJsonStream>

Parameters:

query - SolrQuery object

handleReply

protected void handleReply(org.vertx.java.core.json.JsonObject reply)

Description copied from class: ReadJsonStreamBase

Pagination looping logic - continuously runs through a doQuery loop until all results have been streamed

Overrides:

handleReply in class ReadJsonStreamBase<CursorMarkReadJsonStream>

Parameters:

reply - JsonObject query reply from Solr

isComplete

protected boolean isComplete(org.vertx.java.core.json.JsonObject reply)

Specified by:

isComplete in class ReadJsonStreamBase<CursorMarkReadJsonStream>