Package org.apache.tika.pipes.core.serialization

Class PipesRequest

java.lang.Object

org.apache.tika.pipes.core.serialization.PipesRequest

public final class PipesRequest
extends Object

The NEW_REQUEST envelope on the parent-to-child IPC: the tuple, plus the optional inline document payload beside it. Bytes are data, not tuple state -- a FetchEmitTuple and its ParseContext are never serialized with content in them (FetchEmitTupleSerializer refuses loudly if an InlineBytes slips through).

of(org.apache.tika.pipes.api.FetchEmitTuple) lifts the payload out of the caller's context on the parent; applyTo(org.apache.tika.parser.ParseContext) plants it into the worker's merged context on the child, where BytesFetcher reads it.

Method Summary

Modifier and Type	Method	Description
void	applyTo(ParseContext mergedContext)	Plants the payload into the worker's context for BytesFetcher; no-op without one.
byte[]	getInlineBytes()
FetchEmitTuple	getTuple()
static PipesRequest	of(FetchEmitTuple t)	Wraps t for the wire, lifting any InlineBytes out of its ParseContext.

Methods inherited from class java.lang.Object

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

Method Details

of

public static PipesRequest of(FetchEmitTuple t)

Wraps t for the wire, lifting any InlineBytes out of its ParseContext. The caller's live context is never mutated; the stripped copy exists only for serialization.

applyTo

public void applyTo(ParseContext mergedContext)

Plants the payload into the worker's context for BytesFetcher; no-op without one.

getTuple

public FetchEmitTuple getTuple()

getInlineBytes

public byte[] getInlineBytes()