Package org.apache.tika.pipes.iterator.kafka

Class KafkaPipesIterator

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.pipesiterator.PipesIteratorBase

org.apache.tika.pipes.iterator.kafka.KafkaPipesIterator

All Implemented Interfaces:

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

public class KafkaPipesIterator
extends PipesIteratorBase

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 KafkaPipesIterator	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 KafkaPipesIterator build(ExtensionConfig extensionConfig)
                                throws TikaConfigException,
IOException

Throws:

TikaConfigException

IOException

enqueue

protected void enqueue()
                throws InterruptedException,
TimeoutException

Specified by:

enqueue in class PipesIteratorBase

Throws:

InterruptedException

TimeoutException