com.pega.pegarules.pub.context

Interface ClusterExecutor

Deprecated.

The entire PRCluster project is deprecated in favor of the modularized cluster in platform/kernel/cluster. This project will eventually be removed sometime post 7.3. See: platform/kernel/cluster/README.MD for more information and instructions. Contact [email protected] if you have any questions

@Deprecated
public interface ClusterExecutor

ExecutorService like interface for running distributed jobs

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	COPYRIGHT Deprecated.
static java.lang.String	VERSION Deprecated.

Method Summary

Modifier and Type	Method and Description
boolean	canExecuteOn(java.util.UUID node) Deprecated. Checks whether it is possible to execute on the given node
<P extends java.io.Serializable,R extends java.io.Serializable> java.util.Map<java.lang.String,com.google.common.util.concurrent.ListenableFuture<R>>	executeOnAllNodes(java.lang.Class<? extends Job<P,R>> aJobClass, P aJobData) Deprecated. Runs a job on all nodes in the cluster
<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R>	executeOnNode(java.lang.Class<? extends Job<P,R>> jobClass, P jobData, java.util.UUID node) Deprecated. Runs a job on a remote node
<P extends java.io.Serializable,R extends java.io.Serializable> java.util.Map<java.lang.String,com.google.common.util.concurrent.ListenableFuture<R>>	executeOnSelectedNodes(java.lang.Class<? extends Job<P,R>> aJobClass, P aJobData, java.util.Set<java.util.UUID> nodes) Deprecated. Runs a job on given nodes in the cluster
<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R>	startStopAgentOnNode(P jobData, java.util.UUID node) Deprecated.

Field Detail

COPYRIGHT

static final java.lang.String COPYRIGHT

Deprecated.

See Also:

Constant Field Values

VERSION

static final java.lang.String VERSION

Deprecated.

Method Detail

canExecuteOn

boolean canExecuteOn(java.util.UUID node)

Deprecated.

Checks whether it is possible to execute on the given node

Parameters:

node - unique id

Returns:

true if execution can be performed on the indicated node.

executeOnNode

<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R> executeOnNode(java.lang.Class<? extends Job<P,R>> jobClass,
                                                                                                                                    P jobData,
                                                                                                                                    java.util.UUID node)

Deprecated.

Runs a job on a remote node

Parameters:

jobClass - class that implements the job

jobData - to be passed to the job during execution

node - on which to execute the job

Returns:

future result

startStopAgentOnNode

<P extends java.io.Serializable,R extends java.io.Serializable> com.google.common.util.concurrent.ListenableFuture<R> startStopAgentOnNode(P jobData,
                                                                                                                                           java.util.UUID node)

Deprecated.

executeOnAllNodes

<P extends java.io.Serializable,R extends java.io.Serializable> java.util.Map<java.lang.String,com.google.common.util.concurrent.ListenableFuture<R>> executeOnAllNodes(java.lang.Class<? extends Job<P,R>> aJobClass,
                                                                                                                                                                        P aJobData)

Deprecated.

Runs a job on all nodes in the cluster

Parameters:

aJobClass - class that implements the job

aJobData - to be passed to the job during execution

Returns:

Map future objects keyed by node id

executeOnSelectedNodes

<P extends java.io.Serializable,R extends java.io.Serializable> java.util.Map<java.lang.String,com.google.common.util.concurrent.ListenableFuture<R>> executeOnSelectedNodes(java.lang.Class<? extends Job<P,R>> aJobClass,
                                                                                                                                                                             P aJobData,
                                                                                                                                                                             java.util.Set<java.util.UUID> nodes)

Deprecated.

Runs a job on given nodes in the cluster

Parameters:

aJobClass - class that implements the job

aJobData - to be passed to the job during execution

nodes - on which the job must be executed

Returns:

Map future objects keyed by node id