A C D E F G H I K L N O P R S T V W X

P

Param - Annotation Type in xsmeral.pipe.interfaces

Indicates that the value of the field should be retrieved from the processor's initialization parameter map.

PARAM_STATS - Static variable in class xsmeral.pipe.stats.Stats

ParamInitializer - Class in xsmeral.pipe

Initializes values of fields annotated with Param with values from the initialization parameter map.

ParamInitializer() - Constructor for class xsmeral.pipe.ParamInitializer

Pipe - Class in xsmeral.pipe

A simple implementation of the Chain of Responsibility pattern.

Pipe(List<ObjectProcessor>, Collection<AttachedProcessor>) - Constructor for class xsmeral.pipe.Pipe

In addition to Pipe.Pipe(java.util.List) also sets attached processors.

Pipe(List<ObjectProcessor>) - Constructor for class xsmeral.pipe.Pipe

Initializes the pipe with supplied chain of processors and instantiates a context.

Pipe(ObjectProcessor[]) - Constructor for class xsmeral.pipe.Pipe

Does the same as calling Pipe(Arrays.asList(processors))

PipeAttachedProcessor - Class in xsmeral.pipe

Basic attached processor associated to a Pipe instance.

PipeAttachedProcessor() - Constructor for class xsmeral.pipe.PipeAttachedProcessor

PipeContext - Class in xsmeral.pipe.context

A processing context with additional possibility of accessing the underlying Pipe and the file system.

PipeContext(Pipe) - Constructor for class xsmeral.pipe.context.PipeContext

Creates empty parameter map and associates with a Pipe

postContext() - Method in interface xsmeral.pipe.AttachedProcessor

Called after context has been assigned to all processors.

postContext() - Method in class xsmeral.pipe.PipeAttachedProcessor

postContext() - Method in class xsmeral.pipe.stats.StatsWriter

postRun() - Method in class xsmeral.pipe.AbstractObjectProcessor

Called as the last statement in run().

preContext() - Method in interface xsmeral.pipe.AttachedProcessor

Called before context is assigned to object processors, can be used for resource injection.

preContext() - Method in class xsmeral.pipe.PipeAttachedProcessor

preRun() - Method in class xsmeral.pipe.AbstractObjectProcessor

Called after initialization, as the first statement in run().

prev(ObjectSource<I>) - Method in interface xsmeral.pipe.interfaces.ObjectSink

Sets this processor as the next in the chain, after the given processor.

prev(ObjectSource<I>) - Method in class xsmeral.pipe.LocalObjectFilter

prev - Variable in class xsmeral.pipe.LocalObjectSink

Reference to the previous processor in chain.

prev(ObjectSource<I>) - Method in class xsmeral.pipe.LocalObjectSink

process() - Method in class xsmeral.pipe.AbstractObjectProcessor

Called by the processor itself from run().

process() - Method in class xsmeral.pipe.LocalObjectFilter

Called by the processor itself from run().

process() - Method in class xsmeral.pipe.LocalObjectSink

Called by the processor itself from run().

process() - Method in class xsmeral.pipe.LocalObjectSource

Called by the processor itself from run().

ProcessingContext - Interface in xsmeral.pipe.context

A processing context is a shared space and possibly a communication channel between processors.

ProcessorStoppedException - Exception in xsmeral.pipe

Indicates that a neighboring processor has stopped during an I/O operation.

ProcessorStoppedException() - Constructor for exception xsmeral.pipe.ProcessorStoppedException