Package org.apache.tika.pipes

Class PipesReporter

java.lang.Object

org.apache.tika.pipes.PipesReporter

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

CompositePipesReporter, FileSystemStatusReporter, OpenSearchPipesReporter

public abstract class PipesReporter
extends Object
implements Closeable

This is called asynchronously by the AsyncProcessor. This is not thread safe, and implementers must be careful to implement report(FetchEmitTuple, PipesResult, long) in a thread safe way.

Note, however, that this is not called in the forked processes. Implementers do not have to worry about synchronizing across processes; for example, one could use an in-memory h2 database as a target.

Field Summary

Fields

Modifier and Type	Field	Description
static PipesReporter	NO_OP_REPORTER

Constructor Summary

Constructors

Constructor	Description
PipesReporter()

Method Summary

Modifier and Type	Method	Description
void	close()	No-op implementation.
abstract void	report(FetchEmitTuple t, PipesResult result, long elapsed)

Methods inherited from class java.lang.Object

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

Field Detail

NO_OP_REPORTER

public static final PipesReporter NO_OP_REPORTER

Constructor Detail

PipesReporter

public PipesReporter()

Method Detail

report

public abstract void report(FetchEmitTuple t,
                            PipesResult result,
                            long elapsed)

close

public void close()
           throws IOException

No-op implementation. Override for custom behavior

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException