Package kieker.analysis.generic.source

Class CsvRowReaderProducerStage<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<T>

kieker.analysis.generic.source.CsvRowReaderProducerStage<T>

Type Parameters:

T - ICsvRecord datatype

public class CsvRowReaderProducerStage<T>
extends teetime.framework.AbstractProducerStage<T>

Reader for a single CSV file. Every row is outputed as one event.

Since:

2.0.0

Author:

Reiner Jung

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor	Description
CsvRowReaderProducerStage(Path path, char separator, char quoteSymbol, char escapeSymbol, boolean header, Class<T> clazz)	Read a single CSV file.

Method Summary

Modifier and Type	Method	Description
protected void	execute()

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Constructor Details

CsvRowReaderProducerStage

public CsvRowReaderProducerStage(Path path,
 char separator,
 char quoteSymbol,
 char escapeSymbol,
 boolean header,
 Class<T> clazz)
                          throws IOException

Read a single CSV file.

Parameters:

path - file path

separator - string containing the separator symbol for cells

quoteSymbol - quote symbol used for cells

escapeSymbol - escape character

header - indicate how to interpret the first line in the CSV file, set to true to indicate that the first line contains the header information

clazz - bean class

Throws:

IOException - when a stream could not be opened.

Method Details

execute

protected void execute()
                throws Exception

Specified by:

execute in class teetime.framework.AbstractStage

Throws:

Exception