public class BasicTikaFSConsumer extends AbstractFSConsumer
This catches all exceptions and errors and then logs them. This will re-throw errors.
ELAPSED_MILLIS, IO_IS, IO_OS, logger, OOM, PARSE_ERR, PARSE_EX, TIMED_OUT
Constructor and Description |
---|
BasicTikaFSConsumer(ArrayBlockingQueue<FileResource> queue,
ParserFactory parserFactory,
ContentHandlerFactory contentHandlerFactory,
OutputStreamFactory fsOSFactory,
TikaConfig config) |
Modifier and Type | Method and Description |
---|---|
String |
getOutputEncoding() |
boolean |
processFileResource(FileResource fileResource)
Main piece of code that needs to be implemented.
|
void |
setOutputEncoding(String outputEncoding) |
getInputStream, getOutputStream
call, checkForTimedOutMillis, close, flushAndClose, getCurrentFile, getNumHandledExceptions, getNumResourcesConsumed, getXMLifiedLogMsg, getXMLifiedLogMsg, incrementHandledExceptions, isStillActive, parse, pleaseShutdown
public BasicTikaFSConsumer(ArrayBlockingQueue<FileResource> queue, ParserFactory parserFactory, ContentHandlerFactory contentHandlerFactory, OutputStreamFactory fsOSFactory, TikaConfig config)
public boolean processFileResource(FileResource fileResource)
FileResourceConsumer
FileResourceConsumer.incrementHandledExceptions()
appropriately in
your implementation of this method.
processFileResource
in class FileResourceConsumer
fileResource
- resource to processpublic String getOutputEncoding()
public void setOutputEncoding(String outputEncoding)
Copyright © 2007-2015 The Apache Software Foundation. All Rights Reserved.