com.neurosys.etl.common.transformers

Class ListConcatTransformer

java.lang.Object

com.neurosys.etl.common.transformers.JoinTransformer<List>

com.neurosys.etl.common.transformers.ListConcatTransformer

All Implemented Interfaces:

FunctionTransformer, Function, org.apache.commons.collections.Transformer

public class ListConcatTransformer
extends JoinTransformer<List>

Joins (merges) Lists or processors that result in a List, into a List in the order they are configured.
If an input is provided then that input is passed on in parallel to all processors.

Author:

Arjun Dhar TODO: Add Unit Test case

See Also:

for parent definition

Field Summary

Fields inherited from class com.neurosys.etl.common.transformers.JoinTransformer

filter, processors

Constructor Summary

Constructors

Constructor and Description
ListConcatTransformer()
ListConcatTransformer(List processors)

Method Summary

Modifier and Type	Method and Description
protected List	join(List result, Object transformedInput) Join results of type T

Methods inherited from class com.neurosys.etl.common.transformers.JoinTransformer

cleanDangligngDelimets, getFilter, getProcessors, joinDelimet, setFilter, setProcessors, transform

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

Constructor Detail

ListConcatTransformer

public ListConcatTransformer()

ListConcatTransformer

public ListConcatTransformer(List processors)

Method Detail

join

protected List join(List result,
                    Object transformedInput)
             throws ContinueProcessingException

Join results of type T

Specified by:

join in class JoinTransformer<List>

Parameters:

result - as ; intermediate result as a result of the Chain processing on the list of JoinTransformer.processors as a result of a previous JoinTransformer.join(Object, Object) or input.

transformedInput - as Object of type T that maybe a literal from the JoinTransformer.processors or as a result of transformation from a processor that acts on the main input
Example: Define processors as {"A", Transformer1}; with input : {"hello"}
Then transformedInput for 1st iteration = "A"
Then transformedInput for 2nd iteration = Transformer1.transform("hello")

Returns:

result as T

Throws:

ContinueProcessingException - if we want to ignore the call with the param and continue with the mail processing loop in JoinTransformer.transform(Object)