| Package | Description |
|---|---|
| com.englishtown.vertx.solr.streams.impl |
| Modifier and Type | Class and Description |
|---|---|
class |
CursorMarkReadJsonStream
CursorMark implementation of
ReadJsonStreamBase
using CursorMark to paginate json Solr results |
class |
OffsetReadJsonStream
Implementation of
ReadJsonStreamBase using an integer offset
to paginate json Solr results |
class |
ReadJsonStreamBase<T extends ReadJsonStreamBase<T>>
Base implementation of
ReadJsonStream |
| Modifier and Type | Method and Description |
|---|---|
static SolrPump |
SolrPump.createPump(ReadJsonStream<?> rs,
WriteJsonStream<?> ws)
Pumps data from a
ReadJsonStream to a WriteJsonStream
and performs flow control where necessary to prevent the write stream buffer from getting overfull. |
static SolrPump |
SolrPump.createPump(ReadJsonStream<?> rs,
WriteJsonStream<?> ws,
int writeQueueMaxSize)
Create a new
SolrDataPump with the given ReadJsonStream and WriteJsonStream and
writeQueueMaxSize |
Copyright © 2015 Englishtown. All rights reserved.