public class RecursiveParserWrapperFSConsumer extends AbstractFSConsumer
| Modifier and Type | Field and Description |
|---|---|
private ContentHandlerFactory |
contentHandlerFactory |
private OutputStreamFactory |
fsOSFactory |
private java.lang.String |
outputEncoding |
private ParserFactory |
parserFactory |
private TikaConfig |
tikaConfig |
ELAPSED_MILLIS, IO_IS, IO_OS, LOG, OOM, PARSE_ERR, PARSE_EX, TIMED_OUT| Constructor and Description |
|---|
RecursiveParserWrapperFSConsumer(java.util.concurrent.ArrayBlockingQueue<FileResource> queue,
ParserFactory parserFactory,
ContentHandlerFactory contentHandlerFactory,
OutputStreamFactory fsOSFactory,
TikaConfig tikaConfig) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getOutputEncoding() |
boolean |
processFileResource(FileResource fileResource)
Main piece of code that needs to be implemented.
|
void |
setOutputEncoding(java.lang.String outputEncoding) |
getInputStream, getOutputStreamcall, checkForTimedOutMillis, close, flushAndClose, getCurrentFile, getNumHandledExceptions, getNumResourcesConsumed, getXMLifiedLogMsg, getXMLifiedLogMsg, incrementHandledExceptions, isStillActive, parse, pleaseShutdownprivate final ParserFactory parserFactory
private final ContentHandlerFactory contentHandlerFactory
private final OutputStreamFactory fsOSFactory
private final TikaConfig tikaConfig
private java.lang.String outputEncoding
public RecursiveParserWrapperFSConsumer(java.util.concurrent.ArrayBlockingQueue<FileResource> queue, ParserFactory parserFactory, ContentHandlerFactory contentHandlerFactory, OutputStreamFactory fsOSFactory, TikaConfig tikaConfig)
public boolean processFileResource(FileResource fileResource)
FileResourceConsumerFileResourceConsumer.incrementHandledExceptions() appropriately in
your implementation of this method.
processFileResource in class FileResourceConsumerfileResource - resource to processpublic java.lang.String getOutputEncoding()
public void setOutputEncoding(java.lang.String outputEncoding)