com.neurosys.etl.common

Class TransformerParallel

java.lang.Object

com.neurosys.etl.common.TransformerParallel

All Implemented Interfaces:

org.apache.commons.collections.Transformer

public class TransformerParallel
extends Object
implements org.apache.commons.collections.Transformer

Allow multiple Transformers to fire independently with the same input. The output is a List for each Transformer in the order in which they exist in transformers
By default this implementation is Serial or Single Thread, however one can safely make true parallel implementations as the outcome of one Transformer is mutually exclusive from another.

Author:

Arjun Dhar

See Also:

(similar), TransformerChain.isChainOutput()

Constructor Summary

Constructors

Constructor and Description
TransformerParallel()
TransformerParallel(List<org.apache.commons.collections.Transformer> transformers)
TransformerParallel(org.apache.commons.collections.Transformer transformer)

Method Summary

Modifier and Type	Method and Description
List<org.apache.commons.collections.Transformer>	getTransformers()
boolean	isCollectExceptions() If true will collect ContinueProcessingExceptions and throw a WrapperException with a LinkedHashMap of the Transformer that caused and the particular Exception
void	setCollectExceptions(boolean collectExceptions) If true will collect ContinueProcessingExceptions and throw a WrapperException with a LinkedHashMap of the Transformer that caused and the particular Exception
void	setTransformers(List<org.apache.commons.collections.Transformer> transformers)
Object	transform(Object in)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformerParallel

public TransformerParallel()

TransformerParallel

public TransformerParallel(List<org.apache.commons.collections.Transformer> transformers)

TransformerParallel

public TransformerParallel(org.apache.commons.collections.Transformer transformer)

Method Detail

transform

public Object transform(Object in)

Specified by:

transform in interface org.apache.commons.collections.Transformer

getTransformers

public List<org.apache.commons.collections.Transformer> getTransformers()

setTransformers

public void setTransformers(List<org.apache.commons.collections.Transformer> transformers)

isCollectExceptions

public boolean isCollectExceptions()

If true will collect ContinueProcessingExceptions and throw a WrapperException with a LinkedHashMap of the Transformer that caused and the particular Exception

Default value:

false

setCollectExceptions

public void setCollectExceptions(boolean collectExceptions)

If true will collect ContinueProcessingExceptions and throw a WrapperException with a LinkedHashMap of the Transformer that caused and the particular Exception

Default value:

false