com.neurosys.etl.common.transformers

Class MapConcatTransformer

java.lang.Object

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

com.neurosys.etl.common.transformers.MapConcatTransformer

All Implemented Interfaces:

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

public class MapConcatTransformer
extends JoinTransformer<Map>

Joins multiple Maps or Map.Entrys in sequence (best as can supported by LinkedHashMap). Note: If the individual elements within a Map are not in sequence, then you should use LinkedHashMap for the maps being merged/added. TODO: Add unit test case

Field Summary

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

filter, processors

Constructor Summary

Constructors

Constructor and Description
MapConcatTransformer()
MapConcatTransformer(List processors)

Method Summary

Modifier and Type	Method and Description
protected Map	join(Map 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

MapConcatTransformer

public MapConcatTransformer()

MapConcatTransformer

public MapConcatTransformer(List processors)

Method Detail

join

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

Join results of type T

Specified by:

join in class JoinTransformer<Map>

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)