| Package | Description |
|---|---|
| com.englishtown.vertx.solr.streams.impl |
| 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 |
SolrPump |
SolrPump.setWriteQueueMaxSize(int maxSize)
Set the write queue max size to
writeQueueMaxSize |
SolrPump |
SolrPump.start()
Start the Pump.
|
SolrPump |
SolrPump.stop()
Stop the SolrDataPump.
|
Copyright © 2015 Englishtown. All rights reserved.