com.emphysic.myriad.network

Class DataIngestorPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

com.emphysic.myriad.network.DataIngestorPool

All Implemented Interfaces:

akka.actor.Actor

public class DataIngestorPool
extends LinkedWorkerPool

DataIngestorPool - a linked pool for reading Dataset input files.

Nested Class Summary

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

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

Field Summary

Fields inherited from class com.emphysic.myriad.network.LinkedWorkerPool

next

Fields inherited from class com.emphysic.myriad.network.WorkerPool

DEFAULTWORKERS, router

Constructor Summary

Constructors

Constructor and Description
DataIngestorPool() Starts a new pool with the default number of workers.
DataIngestorPool(boolean normalize) Starts a new pool with the default number of workers.
DataIngestorPool(int numWorkers) Creates a new pool.
DataIngestorPool(int numWorkers, boolean normalize) Creates a new pool.
DataIngestorPool(akka.routing.Pool pool) Creates a new pool from an existing pool.
DataIngestorPool(akka.routing.Pool pool, boolean normalize) Creates a new pool from an existing pool.

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
void	onReceive(java.lang.Object message) Handled Messages FileMessage - sends to pool for reading DatasetMessage - sends to the next link ActorRef - sets the next link ShutdownMessage - initiates shutdown

Methods inherited from class com.emphysic.myriad.network.LinkedWorkerPool

getNext, getNextActor, setNext, shutdown, tellNextActor, tellNextActor

Methods inherited from class com.emphysic.myriad.network.WorkerPool

genMessage, getRouter, setRouter, start, start, start, tellRouter, tellRouter

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

DataIngestorPool

public DataIngestorPool(int numWorkers,
                        boolean normalize)

Creates a new pool.

Parameters:

numWorkers - number of workers to create

normalize - true if data should be normalized between 0 and 1

DataIngestorPool

public DataIngestorPool(akka.routing.Pool pool,
                        boolean normalize)

Creates a new pool from an existing pool.

Parameters:

pool - pool

normalize - true if data should be normalized between 0 and 1

DataIngestorPool

public DataIngestorPool(boolean normalize)

Starts a new pool with the default number of workers.

DataIngestorPool

public DataIngestorPool(int numWorkers)

Creates a new pool. Data are not normalized.

Parameters:

numWorkers - number of workers to create

DataIngestorPool

public DataIngestorPool(akka.routing.Pool pool)

Creates a new pool from an existing pool. Data are not normalized.

Parameters:

pool - pool

DataIngestorPool

public DataIngestorPool()

Starts a new pool with the default number of workers. Data are not normalized.

Method Detail

onReceive

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

Handled Messages FileMessage - sends to pool for reading DatasetMessage - sends to the next link ActorRef - sets the next link ShutdownMessage - initiates shutdown

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception

main

public static void main(java.lang.String[] args)