org.kurator.validation.actors.mapstream

Class FileToFlatDataStreamer

java.lang.Object

akka.actor.UntypedActor

org.kurator.akka.KuratorActor

org.kurator.validation.actors.mapstream.FileToFlatDataStreamer

All Implemented Interfaces:

akka.actor.Actor

public class FileToFlatDataStreamer
extends org.kurator.akka.KuratorActor

Actor that can take as input (in onData()) an options map containing a reference to a workspace and a a csv or tsv file name (as outputfile) with a header, and then broadcasts as a stream each line of the provided file (in a map where headers of the csv are keys and the cell values are values). The provided file must have at least two columns.

Author:

mole

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.csv.CSVFormat	csvFormat
protected org.apache.commons.csv.CSVFormat	pipeFormat
protected org.apache.commons.csv.CSVFormat	tsvFormat

Fields inherited from class org.kurator.akka.KuratorActor

configuration, endOnEos, EOL, errStream, id, inputs, inStream, logger, name, needsTrigger, outStream, sendEosOnEnd, settings, state, workflowRef

Constructor Summary

Constructors

Constructor and Description
FileToFlatDataStreamer()

Method Summary

Modifier and Type	Method and Description
protected void	onData(Object data) Expects a message consisting of an object that can be cast into Map <String,Object> .

Methods inherited from class org.kurator.akka.KuratorActor

broadcast, configuration, endStreamAndStop, endStreamAndStop, errorStream, getReceivedWrappedMessage, inputs, inputStream, listeners, logger, metadataReaders, metadataWriters, onEnd, onEndOfStream, onFutureComplete, onInitialize, onReceive, onStart, onTrigger, outputStream, publishArtifact, publishArtifact, publishArtifacts, publishProduct, publishProduct, publishProducts, reportException, runner, setNeedsTrigger, settings

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Field Detail

csvFormat

protected org.apache.commons.csv.CSVFormat csvFormat

tsvFormat

protected org.apache.commons.csv.CSVFormat tsvFormat

pipeFormat

protected org.apache.commons.csv.CSVFormat pipeFormat

Constructor Detail

FileToFlatDataStreamer

public FileToFlatDataStreamer()

Method Detail

onData

protected void onData(Object data)
               throws Exception

Expects a message consisting of an object that can be cast into Map <String,Object> . Where the string keys include at least workspace and outputfile (where outputfile is the file name for the input csv file to be streamed.

Overrides:

onData in class org.kurator.akka.KuratorActor

Throws:

Exception