ds.granules.interfere.computation.eeg

Class EEGDeployer

java.lang.Object

ds.granules.operation.InstanceDeployer

ds.granules.interfere.computation.eeg.EEGDeployer

All Implemented Interfaces:

JobLifecycleObserver

public class EEGDeployer
extends InstanceDeployer

First pass at refactoring - need to add stress test specific stuff eventually...

Author:

ericson

Field Summary

Fields inherited from class ds.granules.operation.InstanceDeployer

MODULE

Constructor Summary

Constructors

Constructor and Description
EEGDeployer()
EEGDeployer(java.util.Properties streamingProperties) Initializes the deployer.

Method Summary

Modifier and Type	Method and Description
EEGMap	initializeEEGMap(EEGReduce reduce, int computationID)
static void	main(java.lang.String[] args)
void	prepareInstancesAndDeploy(int numOfMaps)

Methods inherited from class ds.granules.operation.InstanceDeployer

completedExecution, completedSuccessfully, completedWithErrors, createJobIdentifier, deployOperations, deployOperations, deployOperations, getStatus, initialize, initialize, initialize, killJob, refreshStatus, refreshStatus, resetTrackers, setStartTime, startedExecution

Methods inherited from class java.lang.Object

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

Constructor Detail

EEGDeployer

public EEGDeployer()

EEGDeployer

public EEGDeployer(java.util.Properties streamingProperties)
            throws CommunicationsException,
                   java.io.IOException,
                   MarshallingException,
                   DeploymentException

Initializes the deployer.

Parameters:

streamingProperties - The properties for streaming

Throws:

CommunicationsException - If there are network problems during communications

java.io.IOException - If there are IO problems

MarshallingException - If there are marshalling erros

DeploymentException - If there are deployment related problems

Method Detail

initializeEEGMap

public EEGMap initializeEEGMap(EEGReduce reduce,
                               int computationID)
                        throws DatasetException,
                               MapReduceException

Throws:

DatasetException

MapReduceException

prepareInstancesAndDeploy

public void prepareInstancesAndDeploy(int numOfMaps)
                               throws DatasetException,
                                      MapReduceException,
                                      CommunicationsException,
                                      DeploymentException,
                                      MarshallingException

Throws:

DatasetException

MapReduceException

CommunicationsException

DeploymentException

MarshallingException

main

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

Parameters:

args -