public class RecursiveParserWrapperFSConsumer extends AbstractFSConsumer
ELAPSED_MILLIS, IO_IS, IO_OS, LOG, OOM, PARSE_ERR, PARSE_EX, TIMED_OUT
Constructor and Description |
---|
RecursiveParserWrapperFSConsumer(ArrayBlockingQueue<FileResource> queue,
Parser parser,
ContentHandlerFactory contentHandlerFactory,
OutputStreamFactory fsOSFactory,
MetadataFilter metadataFilter) |
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 RecursiveParserWrapperFSConsumer(ArrayBlockingQueue<FileResource> queue, Parser parser, ContentHandlerFactory contentHandlerFactory, OutputStreamFactory fsOSFactory, MetadataFilter metadataFilter)
queue
- parser
- -- must be RecursiveParserWrapper or a ForkParser that wraps a RecursiveParserWrappercontentHandlerFactory
- fsOSFactory
- 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–1969 The Apache Software Foundation. All rights reserved.