com.neurosys.etl.common

Class TransformerChain

java.lang.Object

com.neurosys.etl.common.TransformerChain

All Implemented Interfaces:

Chain, FunctionTransformer, Serializable, Consumer, Function, Supplier, org.apache.commons.collections.Transformer

Direct Known Subclasses:

LookupChain

public class TransformerChain
extends Object
implements FunctionTransformer, Supplier, Consumer, Chain, Serializable

Allow chaining of multiple Transformers

Author:

Arjun Dhar

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	accept(Object t)
Object	chain(Object t)
Object	get()
List<? extends org.apache.commons.collections.Transformer>	getProcessors() Gets the List of processors in the chain
List<org.apache.commons.collections.Transformer>	getTransformers()
boolean	isChainOutput() If true, the output from previous transformation becomes input for the next.
boolean	isCollectExceptions() If true will collect ContinueProcessingExceptions and throw a WrapperException with a LinkedHashMap of the Transformer that caused and the particular Exception
boolean	isMaintainContext() If true, will create a Context as a List of outputs generated by each transformer per mutually exclusive chain, including the original input as the first (0th index), element. So for chainOutput true, the context list will contain the first input and then every subsequent output produced in the chain.
void	setChainOutput(boolean chainOutput) If true, the output from previous transformation becomes input for the next.
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	setMaintainContext(boolean maintainContext) If true, will create a Context as a List of outputs generated by each transformer per mutually exclusive chain, including the original input as the first (0th index), element. So for chainOutput true, the context list will contain the first input and then every subsequent output produced in the chain.
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

Methods inherited from interface com.neurosys.etl.common.transformers.FunctionTransformer

apply

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

TransformerChain

public TransformerChain()

TransformerChain

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

TransformerChain

public TransformerChain(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)

chain

public Object chain(Object t)

Specified by:

chain in interface Chain

getProcessors

public List<? extends org.apache.commons.collections.Transformer> getProcessors()

Description copied from interface: Chain

Gets the List of processors in the chain

Specified by:

getProcessors in interface Chain

Returns:

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

isChainOutput

public boolean isChainOutput()

If true, the output from previous transformation becomes input for the next. If false, each transformer in the chain will get the input and output will be the input.
Possible use cases of using false are parallel processing, independent event handlers to an input.

See Also:

TransformerParallel

Default value:

true

setChainOutput

public void setChainOutput(boolean chainOutput)

If true, the output from previous transformation becomes input for the next. If false, each transformer in the chain will get the input and output will be the input.
Possible use cases of using false are parallel processing, independent event handlers to an input.

See Also:

TransformerParallel

Default value:

true

isMaintainContext

public boolean isMaintainContext()

If true, will create a Context as a List of outputs generated by each transformer per mutually exclusive chain, including the original input as the first (0th index), element.
So for chainOutput true, the context list will contain the first input and then every subsequent output produced in the chain. A Transformer that ContextAware will be passed the context not the output of the previous step then. Similarly if chainOutput is false, then logically the context can only be the original input (which is no different) from passing it directly. So it will ignore maintainContext

Default value:

false

setMaintainContext

public void setMaintainContext(boolean maintainContext)

If true, will create a Context as a List of outputs generated by each transformer per mutually exclusive chain, including the original input as the first (0th index), element.
So for chainOutput true, the context list will contain the first input and then every subsequent output produced in the chain. A Transformer that ContextAware will be passed the context not the output of the previous step then. Similarly if chainOutput is false, then logically the context can only be the original input (which is no different) from passing it directly. So it will ignore maintainContext

Default value:

false

get

public Object get()

Specified by:

get in interface Supplier

accept

public void accept(Object t)

Specified by:

accept in interface Consumer