com.emphysic.myriad.network

Class DataIngestorActor

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.DataIngestorActor

All Implemented Interfaces:

akka.actor.Actor

public class DataIngestorActor
extends akka.actor.UntypedActor

DataIngestorActor - Akka actor for reading data files

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
DataIngestorActor() Default constructor.
DataIngestorActor(boolean normalizeData) Constructor

Method Summary

Modifier and Type	Method and Description
boolean	Normalize() Returns the current data normalization policy.
void	Normalize(boolean norm) Sets the data normalization policy.
void	onReceive(java.lang.Object message) Handled Messages: FileMessage - attempts to read a Dataset from the message's payload, sends a DatasetMessage response back to the sender.

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

Constructor Detail

DataIngestorActor

public DataIngestorActor(boolean normalizeData)

Constructor

Parameters:

normalizeData - true if data should be normalized between 0 and 1 after reading

DataIngestorActor

public DataIngestorActor()

Default constructor. Data are not normalized after reading.

Method Detail

Normalize

public void Normalize(boolean norm)

Sets the data normalization policy.

Parameters:

norm - true if data should be normalized between 0 and 1 after reading, false if not.

Normalize

public boolean Normalize()

Returns the current data normalization policy.

Returns:

true if data are normalized, false otherwise.

onReceive

public void onReceive(java.lang.Object message)
               throws java.lang.Exception

Handled Messages: FileMessage - attempts to read a Dataset from the message's payload, sends a DatasetMessage response back to the sender.

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception