Class PipesIterator

java.lang.Object
org.apache.tika.config.ConfigBase
org.apache.tika.pipes.pipesiterator.PipesIterator
All Implemented Interfaces:
Iterable<FetchEmitTuple>, Callable<Integer>, Initializable
Direct Known Subclasses:
AZBlobPipesIterator, CSVPipesIterator, FileListPipesIterator, FileSystemPipesIterator, GCSPipesIterator, JDBCPipesIterator, JsonPipesIterator, KafkaPipesIterator, S3PipesIterator, SolrPipesIterator

public abstract class PipesIterator extends ConfigBase implements Callable<Integer>, Iterable<FetchEmitTuple>, Initializable
Abstract class that handles the testing for timeouts/thread safety issues. Concrete classes implement the blocking enqueue(). If there's an exception in the enqueuing thread, this will throw a RuntimeException. It will throw an IllegalStateException if next() is called after hasNext() has returned false.