sirius.web.data

Class SmartLineBasedProcessor

java.lang.Object

sirius.web.data.SmartLineBasedProcessor

All Implemented Interfaces:

RowProcessor

public class SmartLineBasedProcessor
extends Object
implements RowProcessor

Provides an additional processing step within a LineBasedProcessor to transform rows into maps.

Based on a list of known columns and aliases and the first row of the input, an assignment map is computed to transform an incoming row into a map of column names to values.

Constructor Summary

Constructors

Constructor and Description
SmartLineBasedProcessor()

Method Summary

Modifier and Type	Method and Description
List<sirius.kernel.commons.Tuple<String,String>>	getColumnMapping() Returns tuples of the original column names and their mapped column names.
void	handleRow(int lineNumber, sirius.kernel.commons.Values row) Called the handle a row of an input file.
SmartLineBasedProcessor	withColumn(String key, String... aliases) Registers a known column and possible aliases.
SmartLineBasedProcessor	withProcessor(NamedRowProcessor processor) Attaches the processor which is supplied with a map of data per row in the input.

Methods inherited from class java.lang.Object

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

Constructor Detail

SmartLineBasedProcessor

public SmartLineBasedProcessor()

Method Detail

withColumn

public SmartLineBasedProcessor withColumn(String key,
                                          String... aliases)

Registers a known column and possible aliases.

Parameters:

key - the column name

aliases - a list of aliases for this column

Returns:

the processor itself for fluent method calls

withProcessor

public SmartLineBasedProcessor withProcessor(NamedRowProcessor processor)

Attaches the processor which is supplied with a map of data per row in the input.

Note that all column names which are used as map keys here, are trimmed and made lower case.

Parameters:

processor - the processor used to process input data.

Returns:

the processor itself for fluent method calls

handleRow

public void handleRow(int lineNumber,
                      sirius.kernel.commons.Values row)

Description copied from interface: RowProcessor

Called the handle a row of an input file.

Note that an exception thrown here will completely abort the whole process. Therefore proper exception handling is required.

Specified by:

handleRow in interface RowProcessor

Parameters:

lineNumber - the line number which is currently being processed.

row - the data of the row / line to process

getColumnMapping

public List<sirius.kernel.commons.Tuple<String,String>> getColumnMapping()

Returns tuples of the original column names and their mapped column names.

Returns:

the original column names and their mapped column names. Contains nulls before the first row has been read!