Class JsonPipesIterator

java.lang.Object

org.apache.tika.config.ConfigBase

org.apache.tika.pipes.pipesiterator.PipesIterator

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

All Implemented Interfaces:

Iterable<FetchEmitTuple>, Callable<Integer>, Initializable

public class JsonPipesIterator
extends PipesIterator
implements Initializable

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

Field Summary

Fields inherited from class PipesIterator

COMPLETED_SEMAPHORE, DEFAULT_MAX_WAIT_MS, DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Constructor	Description
JsonPipesIterator()

Method Summary

Modifier and Type	Method	Description
protected void	enqueue()
void	setJsonPath(String jsonPath)

Methods inherited from class PipesIterator

build, call, checkInitialization, getEmitterName, getFetcherName, getHandlerConfig, getOnParseException, initialize, iterator, setEmitterName, setFetcherName, setHandlerType, setMaxEmbeddedResources, setMaxWaitMs, setOnParseException, setOnParseException, setParseMode, setParseMode, setQueueSize, setThrowOnWriteLimitReached, setWriteLimit, tryToAdd

Methods inherited from class ConfigBase

buildComposite, buildComposite, buildSingle, buildSingle, configure, handleSettings

Methods inherited from class Object

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

Methods inherited from interface Initializable

checkInitialization, initialize

Methods inherited from interface Iterable

forEach, spliterator

Constructor Details

JsonPipesIterator

public JsonPipesIterator()

Method Details

enqueue

protected void enqueue()
                throws InterruptedException,
IOException,
TimeoutException

Specified by:

enqueue in class PipesIterator

Throws:

InterruptedException

IOException

TimeoutException

setJsonPath

public void setJsonPath(String jsonPath)