org.rvpf.processor.engine.executor.remote

Class RemoteExecutorTransform

Object

Proxied.Abstract

AbstractTransform

RemoteExecutorTransform

All Implemented Interfaces:

Transform, Proxied

public class RemoteExecutorTransform
extends AbstractTransform

Remote transform.

Nested Class Summary

Nested classes/interfaces inherited from interface Proxied

Proxied.Abstract

Field Summary

Fields inherited from interface Transform

ACTION_PARAM, CEILING_INTERVAL_PARAM, CEILING_RATIO_PARAM, FAIL_RETURNS_NULL_PARAM, FINAL_PROGRAM_PARAM, FLOOR_INTERVAL_PARAM, FLOOR_RATIO_PARAM, INITIAL_PROGRAM_PARAM, NULL_REMOVES_PARAM, PARAM_PARAM, PROGRAM_PARAM, STEP_PROGRAM_PARAM

Method Summary

Modifier and Type	Method and Description
Optional<PointValue>	applyTo(ResultValue resultValue, Batch batch) Applies the program to provide the specified result value.
boolean	usesFetchedResult() Asks if this transform needs the fetched result value.

Methods inherited from class AbstractTransform

addUpdate, getInstance, isNullRemoves, setUp, setUp

Methods inherited from class Proxied.Abstract

getMetadata, getName, getParams, getProxyEntity, getThisLogger, tearDown

Methods inherited from class Object

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

Methods inherited from interface Proxied

getName, getParams, getProxyEntity, tearDown

Method Detail

applyTo

public Optional<PointValue> applyTo(ResultValue resultValue,
                                    Batch batch)
                             throws InterruptedException,
                                    ServiceNotReadyException

Applies the program to provide the specified result value.

When this method is called, the result value must have been provided with all its needed input values.

Note: the returned value is not required to be an instance of the ResultValue class.

Parameters:

resultValue - The result value needing update.

batch - The current batch.

Returns:

The resulting point value or empty.

Throws:

InterruptedException - When interrupted.

ServiceNotReadyException

usesFetchedResult

public boolean usesFetchedResult()

Asks if this transform needs the fetched result value.

Specified by:

usesFetchedResult in interface Transform

Overrides:

usesFetchedResult in class AbstractTransform

Returns:

True if the result is used.