com.englishtown.vertx.solr.streams.impl

Class OffsetReadJsonStream

java.lang.Object

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

com.englishtown.vertx.solr.streams.impl.OffsetReadJsonStream

All Implemented Interfaces:

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

public class OffsetReadJsonStream
extends ReadJsonStreamBase<OffsetReadJsonStream>

Implementation of ReadJsonStreamBase using an integer offset to paginate json Solr results

Constructor Summary

Constructors

Constructor and Description
OffsetReadJsonStream()

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

OffsetReadJsonStream

public OffsetReadJsonStream()

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<OffsetReadJsonStream>

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<OffsetReadJsonStream>

Parameters:

reply - JsonObject query reply from Solr

isComplete

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

Specified by:

isComplete in class ReadJsonStreamBase<OffsetReadJsonStream>