org.objectweb.proactive.calcium
Class Stream<T>

java.lang.Object
  org.objectweb.proactive.calcium.Stream<T>

public class Stream<T>
extends java.lang.Object

Constructor Summary

protected

Stream(Facade facade, Skeleton<T> skeleton)

Method Summary

T	getResult() This method returns the result of the computation for every inputed parameter.
Stats	getStats(T res) After a T has been computed and obtained through getResult(), this method retrieves the statistics for this T.
void	input(T param) Inputs a new T to be computed.
void	input(java.util.Vector<T> paramV) Inputs a vector of T to be computed.

Methods inherited from class java.lang.Object

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

Constructor Detail

Stream

protected Stream(Facade facade,
                 Skeleton<T> skeleton)

Method Detail

input

public void input(T param)

Inputs a new T to be computed.

Parameters:

param - The T to be computed.

input

public void input(java.util.Vector<T> paramV)

Inputs a vector of T to be computed.

Parameters:

paramV - A vector containing the T.

getResult

public T getResult()
            throws PanicException,
                   MuscleException

This method returns the result of the computation for every inputed parameter. If no parameter is yet available this method will block.

Returns:

The result of the computation on a parameter, or null if there are no more parameters being computed.

Throws:

PanicException - Is thrown if a unrecoverable error takes place inside the framework.

MuscleException - Is thrown if a functional exception happens during the execution of the skeleton's muscle.

getStats

public Stats getStats(T res)

After a T has been computed and obtained through getResult(), this method retrieves the statistics for this T.

Parameters:

res - The T obtained through getResult().

Returns:

The statistics of this T, or null if the parameter is unknown.