org.apache.tika.batch.fs

Class AbstractFSConsumer

java.lang.Object

org.apache.tika.batch.FileResourceConsumer

org.apache.tika.batch.fs.AbstractFSConsumer

All Implemented Interfaces:

Callable<IFileProcessorFutureResult>

Direct Known Subclasses:

BasicTikaFSConsumer, RecursiveParserWrapperFSConsumer, StreamOutRPWFSConsumer

public abstract class AbstractFSConsumer
extends FileResourceConsumer

Field Summary

Fields inherited from class org.apache.tika.batch.FileResourceConsumer

ELAPSED_MILLIS, IO_IS, IO_OS, LOG, OOM, PARSE_ERR, PARSE_EX, TIMED_OUT

Constructor Summary

Constructors

Constructor and Description
AbstractFSConsumer(ArrayBlockingQueue<FileResource> fileQueue)

Method Summary

Modifier and Type	Method and Description
protected InputStream	getInputStream(FileResource fileResource)
protected OutputStream	getOutputStream(OutputStreamFactory fsOSFactory, FileResource fileResource) Use this for consistent logging of exceptions.

Methods inherited from class org.apache.tika.batch.FileResourceConsumer

call, checkForTimedOutMillis, close, flushAndClose, getCurrentFile, getNumHandledExceptions, getNumResourcesConsumed, getXMLifiedLogMsg, getXMLifiedLogMsg, incrementHandledExceptions, isStillActive, parse, pleaseShutdown, processFileResource

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFSConsumer

public AbstractFSConsumer(ArrayBlockingQueue<FileResource> fileQueue)

Method Detail

getOutputStream

protected OutputStream getOutputStream(OutputStreamFactory fsOSFactory,
                                       FileResource fileResource)

Use this for consistent logging of exceptions. Clients must check for whether the os is null, which is the signal that the output file already exists and should be skipped.

Parameters:

fsOSFactory - factory that creates the outputstream

fileResource - used by the OSFactory to create the stream

Returns:

the OutputStream or null if the output file already exists

getInputStream

protected InputStream getInputStream(FileResource fileResource)

Parameters:

fileResource -

Returns:

inputStream, can be null if there is an exception opening IS