Module datarush.commons

Package com.pervasive.datarush.cal

Class DistributedCommandBatch<T>

java.lang.Object

com.pervasive.datarush.cal.DistributedCommandBatch<T>

Type Parameters:

T - the result type.

All Implemented Interfaces:

DistributedCallableBatch<T>, ResultMerger<T>, Serializable

public abstract class DistributedCommandBatch<T>
extends Object
implements DistributedCallableBatch<T>

Convenient base class for DistributedCallableBatch's that do not support monitoring/partial results.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DistributedCommandBatch()

Method Summary

Modifier and Type	Method	Description
protected abstract T	execute(DistributedCallableContextBatch ctx)	Subclasses must override to provide an execution implementation
MonitoredCallable<T>	init(DistributedCallableContextBatch ctx)	Implementation of init that returns a callable whose call method invokes execute(DistributedCallableContextBatch).

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.pervasive.datarush.cal.ResultMerger

merge

Constructor Detail

DistributedCommandBatch

public DistributedCommandBatch()

Method Detail

init

public final MonitoredCallable<T> init(DistributedCallableContextBatch ctx)

Implementation of init that returns a callable whose call method invokes execute(DistributedCallableContextBatch).

Specified by:

init in interface DistributedCallableBatch<T>

Parameters:

ctx - a remote context containing all of the contexts for this physicalNodeID.

Returns:

the actual callable to invoke.

execute

protected abstract T execute(DistributedCallableContextBatch ctx)
                      throws Exception

Subclasses must override to provide an execution implementation

Parameters:

ctx - the context that was passed to init(DistributedCallableContextBatch).

Returns:

the result

Throws:

Exception - if an exception occurred while processing