| Package | Description |
|---|---|
| com.englishtown.vertx.solr.streams.impl |
| Modifier and Type | Class and Description |
|---|---|
class |
WriteJsonStreamBase<T extends WriteJsonStreamBase>
Abstract default implementation of
WriteJsonStream |
| 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.