com.neurosys.etl.common.transformers

Class MergeCols

java.lang.Object

com.neurosys.etl.common.transformers.UsesIntermediateObjectImpl<Map<String,Object>>

com.neurosys.etl.common.transformers.MergeCols

All Implemented Interfaces:

ContextAware<Map<String,Object>>, FunctionTransformer, UsesIntermediateObject<Map<String,Object>>, Serializable, Function, org.apache.commons.collections.Transformer

public class MergeCols
extends UsesIntermediateObjectImpl<Map<String,Object>>
implements FunctionTransformer

During an ETL transformation merge multiple columns in a tuple, into a Map OR JSON (if transformer is a JSONTransformer.
If the ETL context has an intermediate object context; then it uses that or simply returns the input unchanged.

Author:

Arjun Dhar TODO: Add unit test case

See Also:

Serialized Form

Field Summary

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

intermediateResults, resultNamesUsed, resultsThatAreOptional

Constructor Summary

Constructors

Constructor and Description
MergeCols()

Method Summary

Modifier and Type	Method and Description
org.apache.commons.collections.Transformer	getTransformer() If provided will transform the input Map of intermediate results.
void	setTransformer(org.apache.commons.collections.Transformer transformer) If provided will transform the input Map of intermediate results.
Object	transform(Object in)

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

determineInput, getInputFromContext, getInterMediateResults, getResultNamesThatAreOptional, getResultNamesUsed, setIntermediateResults, setResultNamesThatAreOptional, setResultNamesUsed

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

MergeCols

public MergeCols()

Method Detail

transform

public Object transform(Object in)

Specified by:

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

getTransformer

public org.apache.commons.collections.Transformer getTransformer()

If provided will transform the input Map of intermediate results. For example one can use a JSONTransformer to convert to a JSON String or format based on the configuration backing the JSONTransformer

Can be null:

true

Default value:

null

setTransformer

public void setTransformer(org.apache.commons.collections.Transformer transformer)

If provided will transform the input Map of intermediate results. For example one can use a JSONTransformer to convert to a JSON String or format based on the configuration backing the JSONTransformer

Can be null:

true

Default value:

null