Package org.apache.tika.eval.app.io

Class PipesReport

java.lang.Object

org.apache.tika.eval.app.io.PipesReport

public class PipesReport
extends Object

The per-tuple ledger written by tika-pipes' file-system-jsonl-reporter during a batch run, keyed by FetchEmitTuple.id. For the filesystem iterator the id is the source-relative path, so it joins to containers.file_path; both sides are normalized to '/' here. Read-only after load(java.nio.file.Path); get(java.nio.file.Path) is thread-safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PipesReport.Row

Method Summary

Modifier and Type	Method	Description
PipesReport.Row	get(Path relativeSourcePath)
List<String>	getErrors()	Final {"error":...} lines: the pipeline died before the run finished.
long	getJoined()	Number of get(java.nio.file.Path) calls that found a row.
Path	getPath()
static PipesReport	load(Path path)
static String	normalize(String id)
int	size()

Methods inherited from class java.lang.Object

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

Method Details

load

public static PipesReport load(Path path)
                        throws IOException

Throws:

IOException

normalize

public static String normalize(String id)

get

public PipesReport.Row get(Path relativeSourcePath)

getPath

public Path getPath()

size

public int size()

getJoined

public long getJoined()

Number of get(java.nio.file.Path) calls that found a row.

getErrors

public List<String> getErrors()

Final {"error":...} lines: the pipeline died before the run finished.