public class CacheBulkProcessor extends Object
Constructor and Description |
---|
CacheBulkProcessor(SolrCache cache) |
CacheBulkProcessor(SolrCache cache,
long delay,
TimeUnit delayUnit,
CacheStrategy cacheStrategy)
Create a new cache bulk processor that will check added metacards for bulk processing at the
configured delay interval.
|
Modifier and Type | Method and Description |
---|---|
void |
add(List<Result> results)
Adds metacards to be bulk added to cache.
|
void |
setBatchSize(int batchSize) |
void |
setCacheStrategy(CacheStrategy cacheStrategy) |
void |
setFlushInterval(long flushInterval) |
void |
setMaximumBacklogSize(int maximumBacklogSize) |
void |
shutdown()
Shutdown scheduled tasks.
|
public CacheBulkProcessor(SolrCache cache)
public CacheBulkProcessor(SolrCache cache, long delay, TimeUnit delayUnit, CacheStrategy cacheStrategy)
cache
- target Solr cache to bulk add metacardsdelay
- delay between decision to bulk adddelayUnit
- units of the delaypublic void add(List<Result> results)
results
- metacards to add to current batchpublic void shutdown()
public void setFlushInterval(long flushInterval)
public void setBatchSize(int batchSize)
public void setMaximumBacklogSize(int maximumBacklogSize)
public void setCacheStrategy(CacheStrategy cacheStrategy)
This work is licensed under a Creative Commons Attribution 4.0 International License.