org.thales.punch.libraries.punchlang.resource.builder

Class AbstractCsvLineResourceBuilder

java.lang.Object

org.thales.punch.libraries.punchlang.resource.builder.AbstractCsvLineResourceBuilder

All Implemented Interfaces:

IResourceBuilder

Direct Known Subclasses:

AbstractCsvResourceBuilder, CsvToArrayResourceBuilder

public abstract class AbstractCsvLineResourceBuilder
extends Object
implements IResourceBuilder

Abstract class to load a remote CSV resource using a streaming strategy.

This class deals with the CSV streaming part and invoke the IResourceTuple.addKeyValue(String, Tuple) method for each read value. s * @author dimi

Nested Class Summary

Nested classes/interfaces inherited from interface org.thales.punch.libraries.punchlang.api.IResourceBuilder

IResourceBuilder.CompactionType

Field Summary

Fields

Modifier and Type	Field and Description
protected List<String>	columns
protected CsvOperator	csvOperator

Constructor Summary

Constructors

Constructor and Description
AbstractCsvLineResourceBuilder(List<String> columns, String delimiter, boolean inferTypes, boolean hasHeader) Ctor.

Method Summary

Modifier and Type	Method and Description
void	onStart() Callback to tell you you are about to receive new lines.
void	onStream(Reader reader) Callback for you to stream the remote resource file.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.thales.punch.libraries.punchlang.api.IResourceBuilder

onEnd, prepare

Field Detail

columns

protected List<String> columns

csvOperator

protected CsvOperator csvOperator

Constructor Detail

AbstractCsvLineResourceBuilder

public AbstractCsvLineResourceBuilder(List<String> columns,
                                      String delimiter,
                                      boolean inferTypes,
                                      boolean hasHeader)

Ctor.

Parameters:

columns - the expected csv columns

delimiter - the csv delimiter

inferTypes - true to make the inner tuple typed.

hashKey - not null to declare the key to be used to build the hash table

lowerCase - true if keys must be converted to loewr cases

hasHeader - true if the csv file has a header with column declared

compact - true to leverage compact tuples

Method Detail

onStart

public void onStart()

Description copied from interface: IResourceBuilder

Callback to tell you you are about to receive new lines.

Specified by:

onStart in interface IResourceBuilder

onStream

public void onStream(Reader reader)
              throws IOException

Description copied from interface: IResourceBuilder

Callback for you to stream the remote resource file.

Specified by:

onStream in interface IResourceBuilder

Parameters:

reader - the input stream to consume the resource file

Throws:

IOException - in case of IO error