fi.techila.user.workerutils

Class TechilaConn

java.lang.Object

fi.techila.user.workerutils.TechilaConn

public class TechilaConn
extends java.lang.Object

Functionality for Techila Interconnection.

Constructor Summary

Constructors

Constructor and Description
TechilaConn()

Method Summary

Modifier and Type	Method and Description
<T> java.util.List<T>	binaryTreeCat(T data, int target, java.lang.String group)
<T> T	binaryTreeOperation(Func<T> func, T data, int target, java.lang.String group)
<T> T	cloudBc(int jobid, T data) Cloud broadcast, send data from given job to all other jobs.
<T> java.util.List<T>	cloudCat(T data) Catenate/join data from all jobs.
<T> java.util.List<T>	cloudCat(T data, int target) Catenate/join data from all jobs.
<T> java.util.List<T>	cloudCat(T data, int target, java.lang.String group) Catenate/join data from all jobs in a given group.
<T> T	cloudOp(Func<T> func, T data) Do an operation on the data given.
<T> T	cloudOp(Func<T> func, T data, int target) Do an operation on the data given.
<T> T	cloudOp(Func<T> func, T data, int target, java.lang.String group) Do an operation on the data given on a given group.
java.lang.String	executeCmd(java.lang.String cmd) Execute a command.
java.util.List<java.lang.Integer>	getActiveJobs() Get the number of active jobs in the current project.
java.util.List<java.lang.Integer>	getActiveJobs(int projectId) Get the number of active jobs in the given project.
java.util.List<java.lang.Integer>	getActiveProjects() Get a list a active project IDs.
int	getJobCount() Get the number of jobs in the current project.
int	getJobCount(java.lang.String group) Get the number of jobs in the given group.
int	getJobId() Get the current jobs ID.
int	getJobId(java.lang.String group) Get the currents jobs ID in the given group.
JobInfo	getProjectJobCounts() Get the the number of jobs in different states in the current project.
JobInfo	getProjectJobCounts(int projectId) Get the number of jobs in differents stats in the given project.
java.lang.String	getProjectParameter(java.lang.String param) Get project parameter value.
java.lang.String	getProjectParameter(java.lang.String param, int projectId) Get a project parameter value in a given project.
void	initInterconnection(int timeout) initiate interconnection between the jobs.
java.lang.Object	loadIMData() Load received intermediate data.
java.lang.Object	loadIMData(long timeout) Load received intermediate data, wait at maximum timeout ms.
<T> T	receiveDataFromJob(int jobid) Receive data from a given job.
<T> T	receiveDataFromJob(int jobid, java.lang.String group) Receive data from a given job in a given group.
void	registerToGroup(java.lang.String group) Register the current job to a given group.
<T> void	sendDataToJob(int jobid, T data) Send data to the given job.
<T> void	sendDataToJob(int jobid, T data, java.lang.String group) Send data to the given job in a given group.
void	sendIMData(java.lang.Object data) Send intermediate data (a serializable object) to the end-user.
void	setProjectParameter(java.lang.String param, java.lang.String value) Set project parameter.
void	setProjectParameter(java.lang.String param, java.lang.String value, int projectId) Set project parameted in a given project.
<T> T	synchronizeDataFromJob(int jobid, T data) Send data from one job to all other jobs.
<T> T	synchronizeDataFromJob(int jobid, T data, java.lang.String group) Send data from one job to all other jobs in the given group.
void	unregisterFromGroup(java.lang.String group) Unregister the current job from a given group.
void	waitForOthers() Wait for other jobs to reach the same point in the code.

Methods inherited from class java.lang.Object

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

Constructor Detail

TechilaConn

public TechilaConn()

Method Detail

receiveDataFromJob

public <T> T receiveDataFromJob(int jobid)

Receive data from a given job.

Parameters:

jobid - the job ID of the job to receive data from

Returns:

the data

receiveDataFromJob

public <T> T receiveDataFromJob(int jobid,
                                java.lang.String group)

Receive data from a given job in a given group.

Parameters:

jobid - Job ID to receive from

group - group name

Returns:

the data

sendDataToJob

public <T> void sendDataToJob(int jobid,
                              T data)

Send data to the given job.

Parameters:

jobid - The Job to send to

data - the data to be sent

sendDataToJob

public <T> void sendDataToJob(int jobid,
                              T data,
                              java.lang.String group)

Send data to the given job in a given group.

Parameters:

jobid - The Jod to send to

data - the data to be sent

group - the group name

waitForOthers

public void waitForOthers()
                   throws java.lang.Exception

Wait for other jobs to reach the same point in the code.

Throws:

java.lang.Exception

cloudBc

public <T> T cloudBc(int jobid,
                     T data)

Cloud broadcast, send data from given job to all other jobs.

Parameters:

jobid - the sender job ID

data - the data to send, should be null in the receiving jobs

Returns:

the data received

synchronizeDataFromJob

public <T> T synchronizeDataFromJob(int jobid,
                                    T data)

Send data from one job to all other jobs.

Parameters:

jobid - the sender job ID

data - the data to send, should be null in the receiving jobs

Returns:

the data

synchronizeDataFromJob

public <T> T synchronizeDataFromJob(int jobid,
                                    T data,
                                    java.lang.String group)

Send data from one job to all other jobs in the given group.

Parameters:

jobid - the sender job ID

data - the data to send, should be null in the receiving jobs

group - the group name

Returns:

the data

cloudCat

public <T> java.util.List<T> cloudCat(T data)

Catenate/join data from all jobs. The data is catenated in the numbered order of jobs.

Parameters:

data - the data from the current job

Returns:

all data joined together in a List

cloudCat

public <T> java.util.List<T> cloudCat(T data,
                                      int target)

Catenate/join data from all jobs. The data is catenated in the numbered order of jobs. Only the target job will receive the data, others will receive null.

Parameters:

data - the data from the current job

target - target job to send data to

Returns:

all data joined together in a List

cloudCat

public <T> java.util.List<T> cloudCat(T data,
                                      int target,
                                      java.lang.String group)

Catenate/join data from all jobs in a given group. The data is catenated in the numbered order of jobs. Only the target job will receive the data, others will receive null.

Parameters:

data - the data from the current job

target - target job to send data to

group - the group name

Returns:

all data joined together in a List

binaryTreeCat

public <T> java.util.List<T> binaryTreeCat(T data,
                                           int target,
                                           java.lang.String group)

cloudOp

public <T> T cloudOp(Func<T> func,
                     T data)

Do an operation on the data given. One operation is done for two data elements at once (possibly parallel). The operations are repeated until only one result remains. This result is returned on all jobs.

Parameters:

func - The object implementing the op

data - the data to operate on

Returns:

the resulting data

cloudOp

public <T> T cloudOp(Func<T> func,
                     T data,
                     int target)

Do an operation on the data given. One operation is done for two data elements at once (possibly parallel). The operations are repeated until only one result remains. This result is returned on the given target job, others will receive null.

Parameters:

func - The object implementing the op

data - the data to operate on

target - the target job ID

Returns:

the resulting data

cloudOp

public <T> T cloudOp(Func<T> func,
                     T data,
                     int target,
                     java.lang.String group)

Do an operation on the data given on a given group. One operation is done for two data elements at once (possibly parallel). The operations are repeated until only one result remains. This result is returned on the given target job, others will receive null.

Parameters:

func - The object implementing the op

data - the data to operate on

target - the target job ID

group - the name of the group

Returns:

the resulting data

binaryTreeOperation

public <T> T binaryTreeOperation(Func<T> func,
                                 T data,
                                 int target,
                                 java.lang.String group)

getJobCount

public int getJobCount()

Get the number of jobs in the current project.

Returns:

getJobCount

public int getJobCount(java.lang.String group)

Get the number of jobs in the given group.

Parameters:

group -

Returns:

getJobId

public int getJobId()

Get the current jobs ID.

Returns:

getJobId

public int getJobId(java.lang.String group)

Get the currents jobs ID in the given group.

Parameters:

group - the group name

Returns:

registerToGroup

public void registerToGroup(java.lang.String group)

Register the current job to a given group.

Parameters:

group - the group name

unregisterFromGroup

public void unregisterFromGroup(java.lang.String group)

Unregister the current job from a given group.

Parameters:

group - the group name

executeCmd

public java.lang.String executeCmd(java.lang.String cmd)

Execute a command.

Parameters:

cmd - the command to execute

Returns:

setProjectParameter

public void setProjectParameter(java.lang.String param,
                                java.lang.String value)
                         throws java.lang.Exception

Set project parameter.

Parameters:

param - the parameter name

value - the parameter value

Throws:

java.lang.Exception

setProjectParameter

public void setProjectParameter(java.lang.String param,
                                java.lang.String value,
                                int projectId)
                         throws java.lang.Exception

Set project parameted in a given project.

Parameters:

param - the parameter name

value - the parameter value

projectId - the ID of the project

Throws:

java.lang.Exception

getProjectParameter

public java.lang.String getProjectParameter(java.lang.String param)
                                     throws java.lang.Exception

Get project parameter value.

Parameters:

param - the parameter name

Returns:

the value or null

Throws:

java.lang.Exception

getProjectParameter

public java.lang.String getProjectParameter(java.lang.String param,
                                            int projectId)
                                     throws java.lang.Exception

Get a project parameter value in a given project.

Parameters:

param - the parameter name

projectId - the ID of the project

Returns:

the value or null

Throws:

java.lang.Exception

getProjectJobCounts

public JobInfo getProjectJobCounts()
                            throws java.lang.Exception

Get the the number of jobs in different states in the current project.

Returns:

Throws:

java.lang.Exception

getProjectJobCounts

public JobInfo getProjectJobCounts(int projectId)
                            throws java.lang.Exception

Get the number of jobs in differents stats in the given project.

Parameters:

projectId - the project ID

Returns:

Throws:

java.lang.Exception

getActiveJobs

public java.util.List<java.lang.Integer> getActiveJobs()
                                                throws java.lang.Exception

Get the number of active jobs in the current project.

Returns:

Throws:

java.lang.Exception

getActiveJobs

public java.util.List<java.lang.Integer> getActiveJobs(int projectId)
                                                throws java.lang.Exception

Get the number of active jobs in the given project.

Parameters:

projectId - The project ID

Returns:

Throws:

java.lang.Exception

getActiveProjects

public java.util.List<java.lang.Integer> getActiveProjects()
                                                    throws java.lang.Exception

Get a list a active project IDs.

Returns:

Throws:

java.lang.Exception

initInterconnection

public void initInterconnection(int timeout)

initiate interconnection between the jobs.

Parameters:

timeout - timeout in ms to wait for other jobs, if 0 defaults to 30000

sendIMData

public void sendIMData(java.lang.Object data)

Send intermediate data (a serializable object) to the end-user.

Parameters:

data - the data

loadIMData

public java.lang.Object loadIMData()

Load received intermediate data.

Returns:

the object received

loadIMData

public java.lang.Object loadIMData(long timeout)

Load received intermediate data, wait at maximum timeout ms.

Parameters:

timeout - max time to wait in ms

Returns:

the received Object or null