Package org.mapfish.print.processor

Class ProcessorGraphNode<IN,OUT>

java.lang.Object

org.mapfish.print.processor.ProcessorGraphNode<IN,OUT>

Type Parameters:

IN - Same as Processor In parameter

OUT - Same as Processor Out parameter

public final class ProcessorGraphNode<IN,OUT>
extends Object

Represents one node in the Processor dependency graph (ProcessorDependencyGraph).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ProcessorGraphNode.ProcessorNodeForkJoinTask<In,Out>	A ForkJoinTask that will run the processor and all of its dependencies.

Constructor Summary

Constructors

Constructor	Description
ProcessorGraphNode(Processor<IN,OUT> processor, com.codahale.metrics.MetricRegistry metricRegistry)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	addDependency(ProcessorGraphNode node)	Add a dependency to this node.
Optional<ProcessorGraphNode.ProcessorNodeForkJoinTask<IN,OUT>>	createTask(ProcessorExecutionContext execContext)	Create a ForkJoinTask for running in a fork join pool.
Set<? extends Processor<?,?>>	getAllProcessors()	Create a set containing all the processor at the current node and the entire subgraph.
com.google.common.collect.BiMap<String,String>	getInputMapper()	Return input mapper from processor.
String	getName()
com.google.common.collect.BiMap<String,String>	getOutputMapper()	Get the output mapper from processor.
Processor<?,?>	getProcessor()
String	toString()
void	toString(StringBuilder builder, int indent, String parent)	Create a string representing this node.

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessorGraphNode

public ProcessorGraphNode(@Nonnull
 Processor<IN,OUT> processor,
 @Nonnull
 com.codahale.metrics.MetricRegistry metricRegistry)

Constructor.

Parameters:

processor - The processor associated with this node.

metricRegistry - registry for timing the execution time of the processor.

Method Details

getProcessor

public Processor<?,?> getProcessor()

addDependency

public void addDependency(ProcessorGraphNode node)

Add a dependency to this node.

Parameters:

node - the dependency to add.

createTask

public Optional<ProcessorGraphNode.ProcessorNodeForkJoinTask<IN,OUT>> createTask(@Nonnull
 ProcessorExecutionContext execContext)

Create a ForkJoinTask for running in a fork join pool.

Parameters:

execContext - the execution context, used for tracking certain aspects of the execution.

Returns:

a task ready to be submitted to a fork join pool.

getOutputMapper

@Nonnull
public com.google.common.collect.BiMap<String,String> getOutputMapper()

Get the output mapper from processor.

getInputMapper

@Nonnull
public com.google.common.collect.BiMap<String,String> getInputMapper()

Return input mapper from processor.

toString

public void toString(StringBuilder builder,
 int indent,
 String parent)

Create a string representing this node.

Parameters:

builder - the builder to add the string to.

indent - the number of steps of indent for this node

parent - the parent node

toString

public String toString()

Overrides:

toString in class Object

getName

public String getName()

getAllProcessors

public Set<? extends Processor<?,?>> getAllProcessors()

Create a set containing all the processor at the current node and the entire subgraph.