org.apache.unomi.router.core.processor

Class LineSplitProcessor

java.lang.Object

org.apache.unomi.router.core.processor.LineSplitProcessor

All Implemented Interfaces:

org.apache.camel.Processor

public class LineSplitProcessor
extends Object
implements org.apache.camel.Processor

Created by amidani on 29/12/2016.

Constructor Summary

Constructors

Constructor and Description
LineSplitProcessor()

Method Summary

Modifier and Type	Method and Description
void	process(org.apache.camel.Exchange exchange)
void	setColumnSeparator(String columnSeparator) Sets the line separator.
void	setFieldsMapping(Map<String,Integer> fieldsMapping) Setter of fieldsMapping
void	setHasDeleteColumn(boolean hasDeleteColumn)
void	setHasHeader(boolean hasHeader)
void	setMergingProperty(String mergingProperty) Sets the merging property.
void	setMultiValueDelimiter(String multiValueDelimiter) Sets the multi value delimiter.
void	setMultiValueSeparator(String multiValueSeparator) Sets the multi value separator.
void	setOverwriteExistingProfiles(boolean overwriteExistingProfiles)
void	setProfilePropertyTypes(Collection<PropertyType> profilePropertyTypes) Sets the profile property types to use for the field mappings
void	setPropertiesToOverwrite(List<String> propertiesToOverwrite)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LineSplitProcessor

public LineSplitProcessor()

Method Detail

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception

Specified by:

process in interface org.apache.camel.Processor

Throws:

Exception

setFieldsMapping

public void setFieldsMapping(Map<String,Integer> fieldsMapping)

Setter of fieldsMapping

Parameters:

fieldsMapping - map String,Integer fieldName in ES and the matching column index in the import file

setPropertiesToOverwrite

public void setPropertiesToOverwrite(List<String> propertiesToOverwrite)

setOverwriteExistingProfiles

public void setOverwriteExistingProfiles(boolean overwriteExistingProfiles)

setHasHeader

public void setHasHeader(boolean hasHeader)

setHasDeleteColumn

public void setHasDeleteColumn(boolean hasDeleteColumn)

setMergingProperty

public void setMergingProperty(String mergingProperty)

Sets the merging property.

Parameters:

mergingProperty - property used to check if the profile exist when merging

setColumnSeparator

public void setColumnSeparator(String columnSeparator)

Sets the line separator.

Parameters:

columnSeparator - property used to specify a line separator. Defaults to ','

setMultiValueSeparator

public void setMultiValueSeparator(String multiValueSeparator)

Sets the multi value separator.

Parameters:

multiValueSeparator - multi value separator

setMultiValueDelimiter

public void setMultiValueDelimiter(String multiValueDelimiter)

Sets the multi value delimiter.

Parameters:

multiValueDelimiter - multi value delimiter

setProfilePropertyTypes

public void setProfilePropertyTypes(Collection<PropertyType> profilePropertyTypes)

Sets the profile property types to use for the field mappings

Parameters:

profilePropertyTypes - the collection of property types to use