com.scaleoutsoftware.soss.client

Interface Invokable<O,P extends java.io.Serializable,R>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

FilterInvokable, IgDaemonInvokable

public interface Invokable<O,P extends java.io.Serializable,R>
extends java.io.Serializable

The interface that must be implemented by all processing classes, and passed into the invoke call. The eval method can be used to implement "map" operations, and the merge method can be used to implement "reduce" operations.

Method Summary

Modifier and Type	Method and Description
R	eval(O toEval, P param, EvalArgs<O> args) Evaluates an object according the specified parameters
R	merge(R first, R second) Merges two result objects into one.

Method Detail

eval

R eval(O toEval,
       P param,
       EvalArgs<O> args)
throws InvokeException,
       java.lang.InterruptedException

Evaluates an object according the specified parameters

Parameters:

toEval - object to evaluate

param - parameters object

args - evaluation arguments

Returns:

result object

Throws:

InvokeException - if an error occurred. This exception will be passed back to the invoker in the InvokeResult.

java.lang.InterruptedException - if any thread has interrupted the current thread.

merge

R merge(R first,
        R second)
 throws InvokeException,
        java.lang.InterruptedException

Merges two result objects into one.

Parameters:

first - first result object

second - second result object

Returns:

merged result object

Throws:

InvokeException - if an error occurred. This exception will be passed back to the invoker in the InvokeResult.

java.lang.InterruptedException - if any thread has interrupted the current thread.