The SUMO toolbox  2018a
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Pages
Public Member Functions | Protected Member Functions | List of all members
RemoteSGEDataSource Class Reference

Evaluates samplepoints through a remote SGE administered cluster. More...

Inheritance diagram for RemoteSGEDataSource:
Inheritance graph
[legend]

Public Member Functions

 RemoteSGEDataSource (Config config) throws DataSourceException
 
void cleanup ()
 Perform any necessary cleanups and stops the polling. More...
 
void evaluate (SamplePoint point)
 Evaluate a sample. More...
 
void processResult (String directory, Job job)
 A job is finished, turn the Job object into a sample point and update the queues. More...
 
DataSourceStatus getStatus ()
 Return status of this SE (eg., how many free nodes available) More...
 
LinkedList< String > getDependencies ()
 
final void run ()
 Polls the input queue for new samples in a separate thread and calls evaluate. More...
 
SamplePoint requestNewSample ()
 Request a new sample for evaluation. More...
 
void submitSamplesForEvaluation (SamplePoint[] points)
 Schedule points for evaluation. More...
 
SamplePoint fetchEvaluatedSample ()
 Get the next evaluated point. More...
 
int getNumPendingSamples ()
 Return the number of poitns pending evaluation. More...
 
int getNumEvaluatedSamples ()
 Return the number of evaluated points waiting to be fetched. More...
 
double getAverageEvaluationTime ()
 Return the average evaluation time (in seconds) for one data point. More...
 
int getInputDimension ()
 
int getOutputDimension ()
 

Protected Member Functions

String getLocalExe ()
 
String getRemoteExe ()
 
String getOptions ()
 
DistributedBackend getBackend ()
 
final void submitEvaluatedSample (SamplePoint point)
 This function is called by the derived subclass whenever a successfully evaluated point needs to be added to the queue. More...
 
final void submitFailedSample (SamplePoint point)
 This function is called by the derived subclass whenever a FAILED point needs to be added to the queue. More...
 
AbstractSampleQueueManager getSampleQueueManager ()
 Get the sample queue manager for this sample evaluator. More...
 

Detailed Description

Evaluates samplepoints through a remote SGE administered cluster.

Constructor & Destructor Documentation

RemoteSGEDataSource ( Config  config) throws DataSourceException
inline

Member Function Documentation

void cleanup ( )
inline

Perform any necessary cleanups and stops the polling.

Implements DataSource.

void evaluate ( SamplePoint  point)
inline

Evaluate a sample.

SamplePoint fetchEvaluatedSample ( )
inlineinherited

Get the next evaluated point.

Implements DataSource.

double getAverageEvaluationTime ( )
inlineinherited

Return the average evaluation time (in seconds) for one data point.

Implements DataSource.

DistributedBackend getBackend ( )
inlineprotectedinherited
LinkedList<String> getDependencies ( )
inlineinherited
int getInputDimension ( )
inlineinherited
String getLocalExe ( )
inlineprotectedinherited
int getNumEvaluatedSamples ( )
inlineinherited

Return the number of evaluated points waiting to be fetched.

Implements DataSource.

int getNumPendingSamples ( )
inlineinherited

Return the number of poitns pending evaluation.

Implements DataSource.

String getOptions ( )
inlineprotectedinherited
int getOutputDimension ( )
inlineinherited
String getRemoteExe ( )
inlineprotectedinherited
AbstractSampleQueueManager getSampleQueueManager ( )
inlineprotectedinherited

Get the sample queue manager for this sample evaluator.

DataSourceStatus getStatus ( )
inlineinherited

Return status of this SE (eg., how many free nodes available)

Implements DataSource.

void processResult ( String  directory,
Job  job 
)
inline

A job is finished, turn the Job object into a sample point and update the queues.

Implements ResultProcessor.

SamplePoint requestNewSample ( )
inlineinherited

Request a new sample for evaluation.

final void run ( )
inlineinherited

Polls the input queue for new samples in a separate thread and calls evaluate.

final void submitEvaluatedSample ( SamplePoint  point)
inlineprotectedinherited

This function is called by the derived subclass whenever a successfully evaluated point needs to be added to the queue.

final void submitFailedSample ( SamplePoint  point)
inlineprotectedinherited

This function is called by the derived subclass whenever a FAILED point needs to be added to the queue.

void submitSamplesForEvaluation ( SamplePoint[]  points)
inlineinherited

Schedule points for evaluation.

Implements DataSource.


The documentation for this class was generated from the following file: