com.neurosys.etl.common.transformers

Class StringConcatTransformer

java.lang.Object

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

com.neurosys.etl.common.transformers.StringConcatTransformer

All Implemented Interfaces:

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

Direct Known Subclasses:

URLGeneratorTransformer

public class StringConcatTransformer
extends JoinTransformer<String>

Joins results into a single String

Author:

Arjun Dhar

Field Summary

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

filter, processors

Constructor Summary

Constructors

Constructor and Description
StringConcatTransformer()
StringConcatTransformer(List processors)

Method Summary

Modifier and Type	Method and Description
protected String	cleanDangligngDelimets(String result) If a JoinTransformer.filter is given then there maybe dangling delimiters in the end.
Pattern	getDanglingDelimRegEx() Used by cleanDangligngDelimets(String) to clean any dangling delimiters at the end of the join process
String	getDelimiter()
protected String	join(String result, Object transformedInput) Join results of type T
protected String	joinDelimet(String result, Object processor, boolean hasNext) In Join operations it maybe desired a delimeter is needed between joins of two JoinTransformer.processors in sequence.
void	setDanglingDelimRegEx(Pattern danglingDelimRegEx) Used by cleanDangligngDelimets(String) to clean any dangling delimiters at the end of the join process
void	setDelimiter(String delimiter)

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

getFilter, getProcessors, 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

StringConcatTransformer

public StringConcatTransformer()

StringConcatTransformer

public StringConcatTransformer(List processors)

Method Detail

joinDelimet

protected String joinDelimet(String result,
                             Object processor,
                             boolean hasNext)

Description copied from class: JoinTransformer

In Join operations it maybe desired a delimeter is needed between joins of two JoinTransformer.processors in sequence.

Overrides:

joinDelimet in class JoinTransformer<String>

Parameters:

result - as T so far of all joins

processor - as type T or Transformer

hasNext - as boolean (if there are any more processors in the chain). If false the current processor is the last. Note: If a JoinTransformer.filter is defined; hasNext cannot factor the next in the chain will be part of result or not. However, if there are any dangling delims left JoinTransformer.cleanDangligngDelimets(Object) can be defined.

Returns:

Object as result after delimition

cleanDangligngDelimets

protected String cleanDangligngDelimets(String result)

Description copied from class: JoinTransformer

If a JoinTransformer.filter is given then there maybe dangling delimiters in the end. This method, defines how they can be cleared.

Overrides:

cleanDangligngDelimets in class JoinTransformer<String>

Returns:

join

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

Join results of type T

Specified by:

join in class JoinTransformer<String>

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)

getDelimiter

public String getDelimiter()

Default value:

null

setDelimiter

public void setDelimiter(String delimiter)

Default value:

null

getDanglingDelimRegEx

public Pattern getDanglingDelimRegEx()

Used by cleanDangligngDelimets(String) to clean any dangling delimiters at the end of the join process

setDanglingDelimRegEx

public void setDanglingDelimRegEx(Pattern danglingDelimRegEx)

Used by cleanDangligngDelimets(String) to clean any dangling delimiters at the end of the join process