Package org.apache.tika.pipes.pipesiterator.json

Class JsonPipesIterator

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.pipesiterator.PipesIteratorBase

org.apache.tika.pipes.pipesiterator.json.JsonPipesIterator

All Implemented Interfaces:

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

public class JsonPipesIterator
extends PipesIteratorBase

Iterates through a UTF-8 text file with one FetchEmitTuple json object per line.

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 JsonPipesIterator	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 JsonPipesIterator 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