Package org.apache.tika.pipes.iterator.jdbc

Class JDBCPipesIterator

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.pipesiterator.PipesIteratorBase

org.apache.tika.pipes.iterator.jdbc.JDBCPipesIterator

All Implemented Interfaces:

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

public class JDBCPipesIterator
extends PipesIteratorBase

Iterates through a the results from a sql call via jdbc. This adds all columns (except for the 'fetchKeyColumn' and 'emitKeyColumn', if specified) to the metadata object.

• If a 'fetchKeyColumn' is specified, this will use that column's value as the fetchKey.
• If no 'fetchKeyColumn' is specified, this will send the metadata from the other columns.
• The 'fetchKeyColumn' value is not added to the metadata.

• An 'emitKeyColumn' must be specified
• The 'emitKeyColumn' value is not added to the metadata.

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