com.emphysic.myriad.network

Class SlidingWindowPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

com.emphysic.myriad.network.SlidingWindowPool

All Implemented Interfaces:

akka.actor.Actor

public class SlidingWindowPool
extends LinkedWorkerPool

SlidingWindowPool - a linked worker pool performing sliding windows.

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
SlidingWindowPool(int stepSize, int windowSize) Creates a new pool
SlidingWindowPool(int stepSize, int windowSize, DatasetOperation operation) Creates a new pool
SlidingWindowPool(int workers, int stepSize, int windowSize) Creates a new pool with no DatasetOperation performed on each window.
SlidingWindowPool(int workers, int stepSize, int windowSize, DatasetOperation op) Creates a new pool
SlidingWindowPool(int workers, int stepSize, int windowWidth, int windowHeight) Creates a new pool
SlidingWindowPool(int workers, int stepSize, int windowWidth, int windowHeight, DatasetOperation operation) Creates a new pool

Method Summary

Modifier and Type	Method and Description
void	onReceive(java.lang.Object message) Handled Messages DatasetMessage - sends the message to the worker pool for processing ActorRef - sets the next link in the processing chain for the worker pool 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

SlidingWindowPool

public SlidingWindowPool(int workers,
                         int stepSize,
                         int windowWidth,
                         int windowHeight,
                         DatasetOperation operation)

Creates a new pool

Parameters:

workers - number of workers

stepSize - step size between windows

windowWidth - width of window

windowHeight - height of window

operation - operation to perform on each window

SlidingWindowPool

public SlidingWindowPool(int workers,
                         int stepSize,
                         int windowWidth,
                         int windowHeight)

Creates a new pool

Parameters:

workers - number of workers

stepSize - step size between windows

windowWidth - width of window

windowHeight - height of window

SlidingWindowPool

public SlidingWindowPool(int workers,
                         int stepSize,
                         int windowSize,
                         DatasetOperation op)

Creates a new pool

Parameters:

workers - number of workers

stepSize - step size between windows

windowSize - dimension of square window

op - operation to perform on each window

SlidingWindowPool

public SlidingWindowPool(int stepSize,
                         int windowSize,
                         DatasetOperation operation)

Creates a new pool

Parameters:

stepSize - step size between windows

windowSize - dimension of square window

operation - operation to perform on each window

SlidingWindowPool

public SlidingWindowPool(int workers,
                         int stepSize,
                         int windowSize)

Creates a new pool with no DatasetOperation performed on each window.

Parameters:

workers - number of workers in the pool

stepSize - step size between windows

windowSize - dimension of square window

SlidingWindowPool

public SlidingWindowPool(int stepSize,
                         int windowSize)

Creates a new pool

Parameters:

stepSize - step size between windows

windowSize - dimension of square window

Method Detail

onReceive

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

Handled Messages DatasetMessage - sends the message to the worker pool for processing ActorRef - sets the next link in the processing chain for the worker pool ShutdownMessage - initiates shutdown

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception