Package org.apache.tika.pipes.iterator.solr

Class SolrPipesIterator

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.pipesiterator.PipesIteratorBase

org.apache.tika.pipes.iterator.solr.SolrPipesIterator

All Implemented Interfaces:

Iterable<FetchEmitTuple>, Callable<Integer>, PipesIterator, TikaExtension

public class SolrPipesIterator
extends PipesIteratorBase

Iterates through results from a Solr query.

Field Summary

Fields inherited from class org.apache.tika.pipes.pipesiterator.PipesIteratorBase

DEFAULT_MAX_WAIT_MS, DEFAULT_QUEUE_SIZE

Fields inherited from class org.apache.tika.plugins.AbstractTikaExtension

pluginConfig

Fields inherited from interface org.apache.tika.pipes.api.pipesiterator.PipesIterator

COMPLETED_SEMAPHORE

Method Summary

Modifier and Type	Method	Description
static SolrPipesIterator	build(ExtensionConfig extensionConfig)
protected void	enqueue()

Methods inherited from class org.apache.tika.pipes.pipesiterator.PipesIteratorBase

call, iterator, tryToAdd

Methods inherited from class org.apache.tika.plugins.AbstractTikaExtension

getExtensionConfig

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.apache.tika.plugins.TikaExtension

getExtensionConfig

Method Details

build

public static SolrPipesIterator build(ExtensionConfig extensionConfig)
                               throws IOException,
TikaConfigException

Throws:

IOException

TikaConfigException

enqueue

protected void enqueue()
                throws InterruptedException,
IOException,
TimeoutException

Specified by:

enqueue in class PipesIteratorBase

Throws:

InterruptedException

IOException

TimeoutException