Serialized Form
-
Package org.jppf
-
Error org.jppf.JPPFError
class JPPFError extends Error implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.JPPFException
class JPPFException extends Exception implements Serializable- serialVersionUID:
- 1L
-
Error org.jppf.JPPFNodeReconnectionNotification
class JPPFNodeReconnectionNotification extends JPPFReconnectionNotification implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
reason
org.jppf.node.connection.ConnectionReason reason
-
-
Error org.jppf.JPPFReconnectionNotification
class JPPFReconnectionNotification extends JPPFError implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.JPPFRuntimeException
class JPPFRuntimeException extends RuntimeException implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.JPPFSuspendedNodeException
class JPPFSuspendedNodeException extends RuntimeException implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.JPPFTimeoutException
class JPPFTimeoutException extends RuntimeException implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.JPPFUnsupportedOperationException
class JPPFUnsupportedOperationException extends Exception implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.classloader
-
Class org.jppf.classloader.ClassLoaderEvent
class ClassLoaderEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.classloader.CompositeResourceWrapper
class CompositeResourceWrapper extends JPPFResourceWrapper implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.classloader.JPPFResourceWrapper
class JPPFResourceWrapper extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
dataMap
Map<ResourceIdentifier,
Object> dataMap Contains data about the kind of lookup that is to be done. -
dynamic
boolean dynamic
Determines whether the class should be loaded through the network classloader. -
providerUuid
String providerUuid
The uuid sent by a node when it first contacts a resource provider. -
requestUuid
String requestUuid
Uuid of the original task bundle that triggered this resource request. -
resourceIds
Map<String,
Long> resourceIds Uniquely identifies this resource request in the server. -
state
JPPFResourceWrapper.State state
The state associated with this resource wrapper. -
uuidPath
TraversalList<String> uuidPath
Keeps and manages the uuid path list and the current position in it.
-
-
-
Package org.jppf.client.taskwrapper
-
Class org.jppf.client.taskwrapper.AbstractTaskObjectWrapper
class AbstractTaskObjectWrapper extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
methodType
TaskObjectWrapper.MethodType methodType
The type of the method to execute on the object.
-
-
Class org.jppf.client.taskwrapper.CallableTaskWrapper
class CallableTaskWrapper extends AbstractTaskObjectWrapper implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
callable
Callable<?> callable
The callable object to execute.
-
-
Class org.jppf.client.taskwrapper.JPPFAnnotatedTask
- serialVersionUID:
- 1L
-
Serialized Fields
-
cancelCallback
JPPFTaskCallback<Object> cancelCallback
A delegate for theonCancel()method. -
taskObjectWrapper
TaskObjectWrapper taskObjectWrapper
Wrapper around a task that is not an instance ofTask. -
timeoutCallback
JPPFTaskCallback<Object> timeoutCallback
A delegate for theonTimeout()method.
-
-
Class org.jppf.client.taskwrapper.JPPFTaskCallback
class JPPFTaskCallback extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.client.taskwrapper.PojoTaskWrapper
class PojoTaskWrapper extends AbstractTaskObjectWrapper implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
args
Object[] args
The arguments of the method to execute. -
className
String className
The name of the object's class if the method is static or a constructor. -
method
String method
The name of the method to execute on the task object. Can be any method, including static method and constructor. -
taskObject
Object taskObject
The runnable object to execute.
-
-
Class org.jppf.client.taskwrapper.RunnableTaskWrapper
class RunnableTaskWrapper extends AbstractTaskObjectWrapper implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
runnable
Runnable runnable
The object on which to execute a method, or the class of the object if the method is static.
-
-
-
Package org.jppf.comm.discovery
-
Class org.jppf.comm.discovery.JPPFConnectionInformation
class JPPFConnectionInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
host
String host
The host name. -
recoveryEnabled
boolean recoveryEnabled
Whether the recovery (aka heartbeat) mechanism is enabled. -
serverPorts
int[] serverPorts
The ports on which the server is listening. -
sslServerPorts
int[] sslServerPorts
The SSL ports on which the server is listening. -
uuid
String uuid
Identifier for this object.
-
-
-
Package org.jppf.comm.recovery
-
Class org.jppf.comm.recovery.HeartbeatConnectionEvent
class HeartbeatConnectionEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.comm.recovery.HeartbeatMessage
class HeartbeatMessage extends Object implements Serializable-
Serialized Fields
-
messageID
long messageID
Message id used to correlate the message send and the response received. -
properties
TypedProperties properties
Additional properties sent in the message.
-
-
-
-
Package org.jppf.execute
-
Class org.jppf.execute.ExecutionInfo
class ExecutionInfo extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
cpuTime
long cpuTime
Total cpu time used by the tasks. -
userTime
long userTime
Total user time used by the tasks.
-
-
Class org.jppf.execute.ExecutorChannelStatusEvent
class ExecutorChannelStatusEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
newValue
ExecutorStatus newValue
The channel status after the change. -
oldValue
ExecutorStatus oldValue
The channel status before the change.
-
-
-
Package org.jppf.ga
-
Class org.jppf.ga.AbstractChromosome
class AbstractChromosome extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.ga.CrossoverTask
- serialVersionUID:
- 1L
-
Serialized Fields
-
c1
Chromosome c1
The chromosomes to crossover. -
c2
Chromosome c2
The chromosomes to crossover. -
index
int index
Index of the resulting chromosme in the population -
pos
int pos
Crossover position.
-
-
Class org.jppf.ga.FitnessTask
- serialVersionUID:
- 1L
-
Serialized Fields
-
c
Chromosome c
Chromosome whose fitness to compute.
-
-
-
Package org.jppf.io
-
Class org.jppf.io.OffloadableObject
class OffloadableObject extends Object implements Serializable-
Serialization Methods
-
readObject
Reconstitute this object from a stream (i.e., deserialize it).- Parameters:
in- the input stream from which to read the object.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph could not be found.
-
writeObject
Save the state of this object to a stream (i.e.,serialize it).- Parameters:
out- the output stream to which to write this object.- Throws:
IOException- if any I/O error occurs.
-
-
-
Class org.jppf.io.SerializableObject
class SerializableObject extends Object implements Serializable-
Serialization Methods
-
readObject
Reconstitute this object from a stream (i.e., deserialize it).- Parameters:
in- the input stream from which to read the object.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph could not be found.
-
writeObject
Save the state of this object to a stream (i.e.,serialize it).- Parameters:
out- the output stream to which to write this object.- Throws:
IOException- if any I/O error occurs.
-
-
-
Exception org.jppf.io.SerializationOverflowException
class SerializationOverflowException extends IOException implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.job
-
Class org.jppf.job.AllJobsSelector
class AllJobsSelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.AtLeastJobSelector
class AtLeastJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.AtMostJobSelector
class AtMostJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.BetweenEEJobSelector
class BetweenEEJobSelector extends org.jppf.job.AbstractTernaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.BetweenEIJobSelector
class BetweenEIJobSelector extends org.jppf.job.AbstractTernaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.BetweenIEJobSelector
class BetweenIEJobSelector extends org.jppf.job.AbstractTernaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.BetweenIIJobSelector
class BetweenIIJobSelector extends org.jppf.job.AbstractTernaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.ContainsJobSelector
class ContainsJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<String> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.EqualsJobSelector
class EqualsJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Object> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.IsOneOfJobSelector
class IsOneOfJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Set<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.JobInformation
class JobInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
initialTaskCount
int initialTaskCount
The initial number of tasks in the job. -
jobName
String jobName
The user-defined name for the job. -
jobUuid
String jobUuid
The unique identifier for the job. -
maxNodes
int maxNodes
The maximum number of nodes this job can run on. -
pending
boolean pending
Determines whether the job is waiting to reach its scheduled execution date. -
priority
int priority
The priority of this job. -
suspended
boolean suspended
Determines whether the job is in suspended state. -
taskCount
int taskCount
The current number of tasks in the job.
-
-
Class org.jppf.job.JobNameSelector
class JobNameSelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.JobNotification
class JobNotification extends Notification implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
eventType
JobEventType eventType
The type of this job event. -
jobInfo
JobInformation jobInfo
Information about the job. -
nodeInfo
JPPFManagementInfo nodeInfo
Information about a node.
-
-
Class org.jppf.job.JobTasksEvent
class JobTasksEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
jobMetadata
JobMetadata jobMetadata
The job metadata. -
jobName
String jobName
The name of the job whose tasks were dispatched. -
jobSLA
JobSLA jobSLA
The job SLA. -
nodeInfo
JPPFManagementInfo nodeInfo
Info on the node to which the job was dispatched. -
returnReason
JobReturnReason returnReason
The reason why the set of tasks wass returned by a node. -
serverTasks
List<ServerTaskInformation> serverTasks
The list of tasks that were disptached.
-
-
Class org.jppf.job.JobUuidSelector
class JobUuidSelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.LessThanJobSelector
class LessThanJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.MoreThanJobSelector
class MoreThanJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Comparable<?>> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.NotEqualsJobSelector
class NotEqualsJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<Object> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.RegexJobSelector
class RegexJobSelector extends org.jppf.job.AbstractBinaryComparisonJobSelector<String> implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
flags
int flags
The regex flags, as defined inPattern.
-
-
Class org.jppf.job.ScriptedJobSelector
class ScriptedJobSelector extends BaseScriptEvaluator implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.ServerTaskInformation
class ServerTaskInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
expirationCount
int expirationCount
Number of times a dispatch of this task has expired. -
jobPosition
int jobPosition
The position of this task within the job submitted by the client. -
maxResubmits
int maxResubmits
Maximum number of times the task can be resubmitted. -
resubmitCount
int resubmitCount
Number of times the task was resubmitted. -
throwable
Throwable throwable
The throwable traised during execution.
-
-
-
Package org.jppf.job.persistence
-
Exception org.jppf.job.persistence.JobPersistenceException
class JobPersistenceException extends JPPFException implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.job.persistence.PersistenceInfoImpl
class PersistenceInfoImpl extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
jobUuid
String jobUuid
The job uuid. -
taskPosition
int taskPosition
The position of the task in the job, if applicable. -
type
PersistenceObjectType type
The type of persisted object.
-
-
-
Package org.jppf.load.balancer
-
Class org.jppf.load.balancer.AbstractLoadBalancingProfile
class AbstractLoadBalancingProfile extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.load.balancer.LoadBalancingInformation
class LoadBalancingInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
algorithm
String algorithm
The name of the algorithm. -
algorithmNames
List<String> algorithmNames
The names of all available algorithms. -
parameters
TypedProperties parameters
The algorithm's parameters.
-
-
Class org.jppf.load.balancer.PerformanceCache
class PerformanceCache extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
mean
double mean
Current value of the moving average. -
nbSamples
long nbSamples
Current number of samples. -
previousMean
double previousMean
Previous value of the moving average, generally before a new sample was added. -
samples
LinkedList<PerformanceSample> samples
Holds the samples required for calculating the moving average. -
size
int size
Number of samples required to compute the moving average. -
totalTime
double totalTime
Current value of the moving average.
-
-
Class org.jppf.load.balancer.PerformanceSample
class PerformanceSample extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
mean
double mean
Mean compute time for server to node round trip. -
samples
long samples
Number of samples used to compute the mean value.
-
-
-
Package org.jppf.load.balancer.impl
-
Class org.jppf.load.balancer.impl.AnnealingTuneProfile
class AnnealingTuneProfile extends AbstractLoadBalancingProfile implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
decreaseRatio
float decreaseRatio
This parameter defines how fast does it will stop generating random numbers. This is essential to define what is the size of the universe will be explored. Greater numbers make the algorithm stop sooner. Just as example, if the best solution is between 0-100, the following might occur:- 1 => 5 max guesses
- 2 => 2 max guesses
- 0.5 => 9 max guesses
- 0.1 => 46 max guesses
- 0.05 => 96 max guesses
-
maxDeviation
double maxDeviation
The percentage of deviation of the current mean to the mean when the system was considered stable. -
maxGuessToStable
int maxGuessToStable
The maximum number of guesses of number generated that were already tested for the algorithm to consider the current best solution stable. -
minSamplesToAnalyse
long minSamplesToAnalyse
The minimum number of samples that must be collected before an analysis is triggered. -
minSamplesToCheckConvergence
long minSamplesToCheckConvergence
The minimum number of samples to be collected before checking if the performance profile has changed. -
size
int size
The initial bundle size to start from. -
sizeRatioDeviation
float sizeRatioDeviation
This parameter defines the multiplicity used to define the range available to random generator, as the maximum.
-
-
Class org.jppf.load.balancer.impl.FixedSizeProfile
class FixedSizeProfile extends AbstractLoadBalancingProfile implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
size
int size
The bundle size.
-
-
Class org.jppf.load.balancer.impl.NodeThreadsProfile
class NodeThreadsProfile extends AbstractLoadBalancingProfile implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
multiplicator
int multiplicator
The multiplicator for the number of threads in the node. The max number of tasks sent to the node will bemultiplicator * number_of_threads.
-
-
Class org.jppf.load.balancer.impl.ProportionalProfile
class ProportionalProfile extends AbstractLoadBalancingProfile implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
initialMeanTime
double initialMeanTime
The initial value of the mean execution time, used to bootstrap the algorithm. -
initialSize
int initialSize
The initial bundle size to use when the performance cache is empty, to bootstrap the algorithm. -
name
String name
The name of this profile. -
performanceCacheSize
int performanceCacheSize
The maximum size of the performance samples cache. -
proportionalityFactor
int proportionalityFactor
The proportionality factor.
-
-
Class org.jppf.load.balancer.impl.RL2Profile
class RL2Profile extends AbstractLoadBalancingProfile implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
maxRelativeSize
double maxRelativeSize
The maximum bundle size, expressed as a fraction in the range ]0.0, 1.0], of the current job size. -
maxSamples
int maxSamples
Number of known states from which the learning phase is considered complete. -
minSamples
int minSamples
Number of known states from which to start computing a probablity that the next action will be chsen randomly. -
performanceCacheSize
int performanceCacheSize
The maximum size of the performance samples cache. -
performanceVariationThreshold
double performanceVariationThreshold
Variation of the mean execution time that triggers a reset of the bundler.
-
-
-
Package org.jppf.load.balancer.persistence
-
Exception org.jppf.load.balancer.persistence.LoadBalancerPersistenceException
class LoadBalancerPersistenceException extends JPPFException implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.location
-
Class org.jppf.location.AbstractLocation
class AbstractLocation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
eventsEnabled
boolean eventsEnabled
Boolean flag that determines if at least one listener is registered. Used to minimize the overhead of sending events if there is no listener. -
listeners
List<LocationEventListener> listeners
The list of listeners to this location. -
path
T path
The path for this location.
-
-
Class org.jppf.location.FileLocation
- serialVersionUID:
- 1L
-
Serialized Fields
-
size
long size
The file size.
-
-
Class org.jppf.location.LocationEvent
class LocationEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
n
long n
The number of bytes that were transferred to another location.
-
-
Class org.jppf.location.MavenCentralLocation
class MavenCentralLocation extends MavenLocation implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.location.MavenLocation
class MavenLocation extends URLLocation implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.location.MemoryLocation
class MemoryLocation extends AbstractLocation<byte[]> implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
len
int len
Length of data to handle. -
offset
int offset
Start offset in the byte array.
-
-
Class org.jppf.location.URLLocation
- serialVersionUID:
- 1L
-
Serialized Fields
-
size
long size
The size of the artifact pointed to by this URL location. We attempt to cache it to avoid looking it up by opening a connection every time.
-
-
-
Package org.jppf.management
-
Class org.jppf.management.AbstractJMXConnectionWrapper
class AbstractJMXConnectionWrapper extends ThreadSynchronization implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
closed
AtomicBoolean closed
Determines whether this connection has been closed by a all to theAutoCloseable.close()method. -
connected
AtomicBoolean connected
Determines whether the connection to the JMX server has been established. -
connectionLock
Object connectionLock
Used to synchronize during the connection process. -
connectionStart
long connectionStart
The time at which connection attempts started. -
connectionThread
AtomicReference<org.jppf.management.JMXConnectionThread> connectionThread
The connection thread that performs the connection to the management server. -
displayName
String displayName
A string representing this connection, used for displaying in the admin conosle. -
env
Map<String,
Object> env JMX properties used for establishing the connection. -
host
String host
The host the server is running on. -
idString
String idString
A string representing this connection, used for logging purposes. -
jmxc
JMXConnector jmxc
The JMX client. -
lastConnectionException
Throwable lastConnectionException
The last exception received when attempting to connect, if any. -
local
boolean local
Determines whether the connection to the JMX server has been established. -
mbeanConnection
AtomicReference<MBeanServerConnection> mbeanConnection
A connection to the MBean server. -
port
int port
The port used by the server. -
protocol
String protocol
The JMX remote protocol. -
reconnectOnError
boolean reconnectOnError
Whether to try to reconnect upon error. -
sslEnabled
boolean sslEnabled
Determines whether the JMX connection should be secure or not. -
url
JMXServiceURL url
URL of the MBean server, in a JMX-compliant format.
-
-
Class org.jppf.management.AllDriversSelector
class AllDriversSelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.AllNodesSelector
class AllNodesSelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.ExecutionPolicySelector
class ExecutionPolicySelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
policy
ExecutionPolicy policy
The execution policy to use to select the nodes.
-
-
Class org.jppf.management.JMXConnectionWrapper
class JMXConnectionWrapper extends AbstractJMXConnectionWrapper implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
listeners
List<JMXConnectionWrapperListener> listeners
The list of listeners to this connection wrapper.
-
-
Class org.jppf.management.JMXConnectionWrapperEvent
class JMXConnectionWrapperEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.JMXDriverConnectionWrapper
class JMXDriverConnectionWrapper extends JMXConnectionWrapper implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.JMXNodeConnectionWrapper
class JMXNodeConnectionWrapper extends JMXConnectionWrapper implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.JPPFDriverAdmin
class JPPFDriverAdmin extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
currentLoadBalancingInformation
LoadBalancingInformation currentLoadBalancingInformation
-
driver
org.jppf.server.JPPFDriver driver
-
loadBalancingInformationLock
Object loadBalancingInformationLock
-
selectionHelper
org.jppf.management.NodeSelectionHelper selectionHelper
-
-
Class org.jppf.management.JPPFManagementInfo
class JPPFManagementInfo extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
active
boolean active
Determines whether the node is active or inactive. -
host
String host
The name of the host on which the node or driver is running. -
ipAddress
String ipAddress
The ip address of the host on which the node or driver is running.- Since:
- 5.0
-
masterUuid
String masterUuid
The uuid of the node of which this node is a slave, if any. -
port
int port
The port on which the node's JMX server is listening. -
secure
boolean secure
Determines whether communication with the node or driver should be secure, i.e. via SSL/TLS. -
type
int type
The type of component this info is for, must be one ofJPPFManagementInfo.NODEorJPPFManagementInfo.DRIVER. -
uuid
String uuid
Unique id for the node.
-
-
Class org.jppf.management.JPPFNodeAdmin
class JPPFNodeAdmin extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
nodeState
JPPFNodeState nodeState
-
-
Class org.jppf.management.JPPFNodeMaintenance
class JPPFNodeMaintenance extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.JPPFNodeState
class JPPFNodeState extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
connectionStatus
JPPFNodeState.ConnectionState connectionStatus
Status of the connection between the node and the server. -
cpuTime
long cpuTime
The total cpu time used by the task processing threads. -
executionStatus
JPPFNodeState.ExecutionState executionStatus
Latest execution status of the node. -
nbTasksExecuted
int nbTasksExecuted
The number of tasks executed by the node. -
pendingAction
NodePendingAction pendingAction
The current pending action for the node. -
threadPoolSize
int threadPoolSize
Size of the node's thread pool. -
threadPriority
int threadPriority
Priority of the threads in the pool.
-
-
Class org.jppf.management.JPPFSystemInformation
class JPPFSystemInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
local
boolean local
trueif the JPPF component is local (local node or local client executor),falseotherwise. -
map
Map<String,
TypedProperties> map Mapping of all properties containers. -
resolveInetAddressesNow
boolean resolveInetAddressesNow
Iftrue, then the name resolution forInetAddresses should occur immediately,
-
-
Class org.jppf.management.NodeConfigNotifier
class NodeConfigNotifier extends NotificationBroadcasterSupport implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.OffloadableNotification
class OffloadableNotification extends Notification implements Serializable- serialVersionUID:
- 1L
-
Serialization Methods
-
readObject
Reconstitute the notification instance from an object stream (i.e. deserialize it).- Parameters:
in- the input stream from which to read the job.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph can not be found.
-
writeObject
Save the state of the notification to a stream (i.e. serialize it).- Parameters:
out- the output stream to which to write the job.- Throws:
IOException- if any I/O error occurs.
-
-
Serialized Fields
-
userDataOffloaded
boolean userDataOffloaded
Whether the user data is offloaded to file.
-
-
Class org.jppf.management.PeerDriver
class PeerDriver extends NotificationBroadcasterSupport implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
driver
org.jppf.server.JPPFDriver driver
-
-
Class org.jppf.management.ScriptedNodeSelector
class ScriptedNodeSelector extends BaseScriptEvaluator implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.TaskExecutionNotification
class TaskExecutionNotification extends OffloadableNotification implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
taskInformation
TaskInformation taskInformation
Information about the task that triggered this notification. -
userNotification
boolean userNotification
Determines whether this is a user-defined notification sent from a task.
-
-
Class org.jppf.management.TaskInformation
class TaskInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
cpuTime
long cpuTime
The cpu time taken by the task. -
elapsedTime
long elapsedTime
The wall clock time taken by the task. -
error
boolean error
Determines whether the task had an exception. -
id
String id
The task id. -
jobId
String jobId
The id of the job this task belongs to. -
jobName
String jobName
The name of the job this task belongs to. -
jobPosition
int jobPosition
The position of the task in the job to which it belongs.- Since:
- 5.0
-
timestamp
long timestamp
Timestamp for the creation of this event.
-
-
Class org.jppf.management.UuidSelector
class UuidSelector extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
uuids
Collection<String> uuids
The list of uuids of the nodes to select. This list is immutable.
-
-
Class org.jppf.management.WrappedObject
class WrappedObject extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialization Methods
-
readObject
Reconstitute the notification instance from an object stream (i.e. deserialize it).- Parameters:
in- the input stream from which to read the job.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph can not be found.
-
writeObject
Save the state of the notification to a stream (i.e. serialize it).- Parameters:
out- the output stream to which to write the job.- Throws:
IOException- if any I/O error occurs.
-
-
Serialized Fields
-
object
Object object
The object to wrap.
-
-
-
Package org.jppf.management.diagnostics
-
Class org.jppf.management.diagnostics.HealthSnapshot
class HealthSnapshot extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
properties
TypedProperties properties
Contains the attributes of this snapshot with their values.
-
-
Class org.jppf.management.diagnostics.LockInformation
class LockInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
className
String className
The fully qualified class name of this lock. -
identityHashcode
int identityHashcode
The identity hash code of this lock.
-
-
Class org.jppf.management.diagnostics.MemoryInformation
class MemoryInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
heapMemoryUsage
MemoryUsageInformation heapMemoryUsage
The heap memory usage. -
nonHeapMemoryUsage
MemoryUsageInformation nonHeapMemoryUsage
The non-heap memory usage.
-
-
Class org.jppf.management.diagnostics.MemoryUsageInformation
class MemoryUsageInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
committed
long committed
Current memory size. -
init
long init
Initial memory size. -
max
long max
Maximum memory size. -
used
long used
Current used memory.
-
-
Class org.jppf.management.diagnostics.StackFrameInformation
class StackFrameInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
lock
LockInformation lock
The associated lock, if any. -
stackTraceElement
StackTraceElement stackTraceElement
The stack trace element.
-
-
Class org.jppf.management.diagnostics.ThreadDump
class ThreadDump extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
deadlockedThreads
long[] deadlockedThreads
The ids of the deadlocked threads. -
threads
Map<Long,
ThreadInformation> threads Information on the threads.
-
-
Class org.jppf.management.diagnostics.ThreadInformation
class ThreadInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
blockedCount
long blockedCount
The count of times this thread has been blocked. -
blockedTime
long blockedTime
The total cumulated block time. -
id
long id
The id of this thread. -
inNative
boolean inNative
Whether this thread is in native code. -
lockInformation
LockInformation lockInformation
The the lock this thread is waiting for, if any. -
lockOwnerId
long lockOwnerId
The id of the owner of the lock this thread is waiting for, if any. -
name
String name
The name of this thread. -
ownableSynchronizers
List<LockInformation> ownableSynchronizers
The ownable synchronizers held by this thread. -
stackTrace
List<StackFrameInformation> stackTrace
The stack trace of this thread. -
state
Thread.State state
The state of this thread. -
suspended
boolean suspended
Whether this thread is uspended. -
waitCount
long waitCount
The count of times this thread has been waiting. -
waitTime
long waitTime
The total cumulated wait time.
-
-
-
Package org.jppf.management.forwarding
-
Class org.jppf.management.forwarding.ForwardingNotificationEvent
class ForwardingNotificationEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
mBeanName
String mBeanName
-
notification
Notification notification
-
-
Class org.jppf.management.forwarding.InternalNotificationFilter
class InternalNotificationFilter extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
filter
NotificationFilter filter
The user-provided notification filter. -
listenerID
String listenerID
The ID of the associated listener.
-
-
Class org.jppf.management.forwarding.JPPFNodeForwarding
class JPPFNodeForwarding extends org.jppf.management.forwarding.AbstractNodeForwarding implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.management.forwarding.JPPFNodeForwardingNotification
class JPPFNodeForwardingNotification extends Notification implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
mBeanName
String mBeanName
The name of the originating MBean in the node. -
nodeUuid
String nodeUuid
The uuid of the originating node. -
notification
Notification notification
The notification to forward.
-
-
Class org.jppf.management.forwarding.NodeForwarding
class NodeForwarding extends org.jppf.management.forwarding.AbstractNodeForwarding implements Serializable
-
-
Package org.jppf.node.event
-
Class org.jppf.node.event.NodeLifeCycleEvent
class NodeLifeCycleEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
cl
org.jppf.classloader.AbstractJPPFClassLoader cl
-
dataProvider
DataProvider dataProvider
-
job
JPPFDistributedJob job
-
tasks
List<Task<?>> tasks
-
type
org.jppf.node.event.NodeLifeCycleEventType type
-
-
Class org.jppf.node.event.TaskExecutionEvent
class TaskExecutionEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
sendViaJmx
boolean sendViaJmx
Iftruethen also send this notification via the JMX MBean, otherwise only send to local listeners. -
taskCompletion
boolean taskCompletion
Whether this is a task completion or user-sent event. -
taskInformation
TaskInformation taskInformation
Object encapsulating information about the task. -
userObject
Object userObject
User-defined object to send as part of the notification.
-
-
-
Package org.jppf.node.idle
-
Class org.jppf.node.idle.IdleStateEvent
class IdleStateEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
state
IdleState state
The idle state when this event was emitted.
-
-
-
Package org.jppf.node.policy
-
Class org.jppf.node.policy.AbstractExpression
class AbstractExpression extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.AbstractIsInIPSubnet
class AbstractIsInIPSubnet extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
subnets
List<Expression<String>> subnets
String value(s) to test for subnet membership
-
-
Class org.jppf.node.policy.AcceptAll
class AcceptAll extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.AtLeast
class AtLeast extends org.jppf.node.policy.BinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.AtMost
class AtMost extends org.jppf.node.policy.BinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.BetweenEE
class BetweenEE extends org.jppf.node.policy.TrinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.BetweenEI
class BetweenEI extends org.jppf.node.policy.TrinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.BetweenIE
class BetweenIE extends org.jppf.node.policy.TrinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.BetweenII
class BetweenII extends org.jppf.node.policy.TrinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.BooleanExpression
- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.Contains
class Contains extends org.jppf.node.policy.LeftOperandRule implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
ignoreCase
boolean ignoreCase
Determines if the comparison should ignore the string case. -
value
Expression<String> value
A string value to compare with.
-
-
Class org.jppf.node.policy.CustomPolicy
class CustomPolicy extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
args
String[] args
The list of user-defined arguments.
-
-
Class org.jppf.node.policy.Equal
class Equal extends org.jppf.node.policy.LeftOperandRule implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
booleanValue
Expression<Boolean> booleanValue
An object value to compare with. -
ignoreCase
boolean ignoreCase
Determines if the comparison should ignore the string case. -
numberValue
Expression<Double> numberValue
A numeric value to compare with. -
stringValue
Expression<String> stringValue
A string value to compare with.
-
-
Class org.jppf.node.policy.ExecutionPolicy
class ExecutionPolicy extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
children
ExecutionPolicy[] children
The children of this rule.
-
-
Class org.jppf.node.policy.ExecutionPolicy.AndRule
class AndRule extends LogicalRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.ExecutionPolicy.NotRule
class NotRule extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.ExecutionPolicy.OrRule
class OrRule extends LogicalRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.ExecutionPolicy.XorRule
class XorRule extends LogicalRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.IsInIPv4Subnet
- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.IsInIPv6Subnet
- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.IsLocalChannel
class IsLocalChannel extends org.jppf.node.policy.NoArgRule implements Serializable -
Class org.jppf.node.policy.IsMasterNode
class IsMasterNode extends org.jppf.node.policy.NoArgRule implements Serializable -
Class org.jppf.node.policy.IsPeerDriver
class IsPeerDriver extends org.jppf.node.policy.NoArgRule implements Serializable -
Class org.jppf.node.policy.IsSlaveNode
class IsSlaveNode extends org.jppf.node.policy.NoArgRule implements Serializable -
Class org.jppf.node.policy.LessThan
class LessThan extends org.jppf.node.policy.BinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.LogicalRule
class LogicalRule extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.MoreThan
class MoreThan extends org.jppf.node.policy.BinaryNumericRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.NodesMatching
class NodesMatching extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
expectedNodes
Expression<Double> expectedNodes
The expected number of nodes to use in the comparison. -
nodePolicy
ExecutionPolicy nodePolicy
The execution policy to match the nodes against. -
operator
Operator operator
The comparison operator to use for the number of nodes.
-
-
Class org.jppf.node.policy.NotEqual
class NotEqual extends Equal implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.NumericExpression
- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.OneOf
class OneOf extends org.jppf.node.policy.LeftOperandRule implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
ignoreCase
boolean ignoreCase
Determines if the comparison should ignore the string case. -
numbers
List<Expression<Double>> numbers
A numeric value to compare with. -
strings
List<Expression<String>> strings
A string value to compare with.
-
-
Class org.jppf.node.policy.Preference
class Preference extends LogicalRule implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.PropertyNameExpression
class PropertyNameExpression extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.RegExp
class RegExp extends org.jppf.node.policy.LeftOperandRule implements Serializable- serialVersionUID:
- 1L
-
Serialization Methods
-
readObject
Reconstitute this object from a stream (i.e., deserialize it).- Parameters:
in- the input stream from which to read the state.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph can not be found.- Since:
- 5.2
-
writeObject
Save the state of this object to a stream (i.e.,serialize it).- Parameters:
out- the output stream to which to write the job.- Throws:
IOException- if any I/O error occurs.- Since:
- 5.2
-
-
Serialized Fields
-
regExp
String regExp
A regular expression to match the property value against.
-
-
Class org.jppf.node.policy.RejectAll
class RejectAll extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.policy.ScriptedPolicy
class ScriptedPolicy extends ExecutionPolicy implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
evaluationError
boolean evaluationError
Flag set if an error is raised while executing the script, to avoid evaluating the script again. -
spec
ScriptDefinition spec
The script specification.
-
-
Class org.jppf.node.policy.StringExpression
- serialVersionUID:
- 1L
-
-
Package org.jppf.node.protocol
-
Class org.jppf.node.protocol.AbstractNotificationBundle
class AbstractNotificationBundle extends JPPFJobMetadata implements Serializable -
Class org.jppf.node.protocol.AbstractTask
class AbstractTask extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
id
String id
A user-assigned id for this task. -
position
int position
The position of this task at the submission time. -
result
T result
The result of the task execution. -
throwable
Throwable throwable
TheThrowablethat was raised by this task's execution. -
timeoutSchedule
JPPFSchedule timeoutSchedule
The task timeout schedule configuration.
-
-
Class org.jppf.node.protocol.BundleWithTasks
-
Class org.jppf.node.protocol.ClassPathElementImpl
class ClassPathElementImpl extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
copyToExistingFile
boolean copyToExistingFile
Whether to copy the source to the target if the target is a file and if it already exists on the file system. -
name
String name
Deprecated.The name of this classpath element. -
sourceLocation
Location<?> sourceLocation
The location of this classpath element in the client environment. -
targetLocation
Location<?> targetLocation
The location of this classpath element in the node environment.
-
-
Class org.jppf.node.protocol.ClassPathImpl
class ClassPathImpl extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
elementList
List<ClassPathElement> elementList
Mapping of classpath elements to their names. -
forceClassLoaderReset
boolean forceClassLoaderReset
Determines whether the node should force a reset of the class loader before executing the tasks.
-
-
Class org.jppf.node.protocol.CommandLineTask
- serialVersionUID:
- 1L
-
Serialized Fields
-
captureOutput
boolean captureOutput
Determines whether the process output should be captured. -
commandList
List<String> commandList
The list of command-line arguments. -
env
Map<String,
String> env The environment variables to set. -
errorOutput
StringBuilder errorOutput
Content of the error output for the process. -
exitCode
int exitCode
The exit code returned by the sub-process. -
standardOutput
StringBuilder standardOutput
Content of the standard output for the process. -
startDir
String startDir
The directory to start the command in.
-
-
Class org.jppf.node.protocol.JobClientSLA
- serialVersionUID:
- 1L
-
Serialized Fields
-
graphTraversalInClient
boolean graphTraversalInClient
Whether the traversal of the graph of tasks, if any, should occur on the client side.
-
-
Class org.jppf.node.protocol.JobCommonSLA
class JobCommonSLA extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
allowMultipleDispatchesToSameChannel
boolean allowMultipleDispatchesToSameChannel
Whether to allow multiple concurrent dispatches of the job to the same channel. -
executionPolicy
ExecutionPolicy executionPolicy
The tasks execution policy. -
jobExpirationSchedule
JPPFSchedule jobExpirationSchedule
The job expiration schedule configuration. -
jobSchedule
JPPFSchedule jobSchedule
The job start schedule configuration. -
maxChannels
int maxChannels
The maximum number of nodes this job can run on. -
maxDispatchSize
int maxDispatchSize
The maximum number of tasks allowed in a dispatch of the job. -
preferencePolicy
Preference preferencePolicy
The preference policy.
-
-
Class org.jppf.node.protocol.JobDependencySpec
class JobDependencySpec extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
cascadeCancellation
boolean cascadeCancellation
Whether cancelling the job triggers the cancellation of all the jobs that depend on it. -
dependencies
List<String> dependencies
The application-defined ids of the job's dependencies. -
graphRoot
boolean graphRoot
Whether the job and its dependencies should be removed from the graph upon completetion. -
id
String id
The application-defined id assigned to a job.
-
-
Class org.jppf.node.protocol.JobSLA
- serialVersionUID:
- 1L
-
Serialized Fields
-
applyMaxResubmitsUponNodeError
boolean applyMaxResubmitsUponNodeError
Whether the max resubmits limit for tasks is also applied when tasks are resubmitted due to a node error. -
broadcastJob
boolean broadcastJob
Specifies whether the job is a broadcast job. -
cancelUponClientDisconnect
boolean cancelUponClientDisconnect
Determines whether the job should be canceled by the driver if the client gets disconnected. -
classPath
ClassPath classPath
The classpath associated with the job. -
dependencySpec
JobDependencySpec dependencySpec
The specification of dependencies for the job. -
dispatchExpirationSchedule
JPPFSchedule dispatchExpirationSchedule
The expiration schedule for any subset of the job dispatched to a node. -
gridExecutionPolicy
ExecutionPolicy gridExecutionPolicy
The global execution policy which applies to the driver only. -
maxDispatchExpirations
int maxDispatchExpirations
The number of times a dispatched task can expire before it is finally cancelled. -
maxDriverDepth
int maxDriverDepth
In a multi server topology, an upper bound for how many drivers a job can be transfered to before being executed on a node. -
maxNodeProvisioningGroups
int maxNodeProvisioningGroups
The maximum number of groups of master/slave nodes the job can be executed on at any given time.This setting means that the job can only be executed on at most
maxMasterNodeGroupsmaster nodes and all their slaves. -
maxTaskResubmits
int maxTaskResubmits
Maximum number of times a task can rsubmit itself viaAbstractTask.setResubmit(boolean). -
nodeConfigurationSpec
JPPFNodeConfigSpec nodeConfigurationSpec
The configuration of the node(s) this job should be executed on. -
persistenceSpec
PersistenceSpec persistenceSpec
Whether this job is persisted by the driver and behavior upon recovery. -
priority
int priority
The priority of this job, used by the server to prioritize queued jobs. -
remoteClassLoadingEnabled
boolean remoteClassLoadingEnabled
Whether remote class loading is enabled for the job. -
resultsStrategy
String resultsStrategy
Get the name of the strategy used to return the results back to the client. -
suspended
boolean suspended
Determines whether this job is initially suspended. If it is, it will have to be resumed, using either the admin console or the JMX APIs.
-
-
Class org.jppf.node.protocol.JPPFExceptionResult
- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.JPPFExceptionResultEx
class JPPFExceptionResultEx extends JPPFExceptionResult implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
throwableClassName
String throwableClassName
These fields describe theThrowableobject. -
throwableMessage
String throwableMessage
These fields describe theThrowableobject. -
throwableStackTrace
StackTraceElement[] throwableStackTrace
The throwable object's stack trace.
-
-
Class org.jppf.node.protocol.JPPFJobMetadata
class JPPFJobMetadata extends MetadataImpl implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.JPPFNodeConfigSpec
class JPPFNodeConfigSpec extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
configuration
TypedProperties configuration
The desired JPPF configuration of each node. -
forceRestart
boolean forceRestart
Whether to force the restart of a node after reconfiguring it.
-
-
Class org.jppf.node.protocol.JPPFTask
- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.JPPFTaskBundle
class JPPFTaskBundle extends MetadataImpl implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
currentTaskCount
int currentTaskCount
The current number of tasks in this bundle. -
driverQueueTaskCount
int driverQueueTaskCount
The number of tasks in this bundle at the time it is received by a driver. -
executionStartTime
long executionStartTime
The time at which the bundle is taken out of the queue for sending to a node. -
handshake
boolean handshake
Indicates whether this object is used for handshake instead of execution. -
initialTaskCount
int initialTaskCount
The initial number of tasks in this bundle. -
jobMetadata
JobMetadata jobMetadata
The user-defined metadata associated with this job. -
jobSLA
JobSLA jobSLA
The service level agreement between the job and the server. -
name
String name
The user-defined display name for this job. -
nodeExecutionTime
long nodeExecutionTime
The time it took a node to execute this task. -
taskCount
int taskCount
The number of tasks in this bundle. -
uuid
String uuid
The unique identifier for the request (the job) this task bundle is a part of. -
uuidPath
TraversalList<String> uuidPath
The unique identifier for the submitting application.
-
-
Class org.jppf.node.protocol.JPPFTaskSerializationException
class JPPFTaskSerializationException extends Throwable implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.MemoryMapDataProvider
class MemoryMapDataProvider extends MetadataImpl implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.NotificationBundle
class NotificationBundle extends AbstractNotificationBundle implements Serializable -
Class org.jppf.node.protocol.PersistenceSpec
class PersistenceSpec extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
autoExecuteOnRestart
boolean autoExecuteOnRestart
Whether the driver should automatically execute the job after a restart. -
deleteOnCompletion
boolean deleteOnCompletion
Whether the persisteed job should be deleted from the persistence store when it terminates. -
persistent
boolean persistent
Whether the job is persisted in the driver.
-
-
Class org.jppf.node.protocol.ScriptedTask
- serialVersionUID:
- 1L
-
Serialized Fields
-
scriptSpec
ScriptDefinition scriptSpec
Specfications for the script to execute.
-
-
-
Package org.jppf.node.protocol.graph
-
Class org.jppf.node.protocol.graph.AbstractTaskNode
-
Class org.jppf.node.protocol.graph.JobDependencyGraphImpl
class JobDependencyGraphImpl extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialization Methods
-
readObject
Reconstitute the obejct from a stream (i.e., deserialize it).- Parameters:
in- the input stream from which to read the object.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph can not be found.
-
writeObject
Save the state of this object to a stream (i.e.,serialize it).- Parameters:
out- the output stream to which to write the object.- Throws:
IOException- if any I/O error occurs.
-
-
Serialized Fields
-
nodes
Map<String,
JobDependencyNode> nodes Job custom ids to nodes. -
nodesByUuid
Map<String,
JobDependencyNode> nodesByUuid Job uuids to nodes.
-
-
Class org.jppf.node.protocol.graph.JobDependencyNode
class JobDependencyNode extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
cancelled
boolean cancelled
Whether the job represented by this dependency node should be cancelled when it arrives in the server queue. -
completed
boolean completed
Whether the job represented by this node has completed. -
dependedOn
Map<String,
JobDependencyNode> dependedOn The ids of the nodes that depend on this node. -
dependencies
Map<String,
JobDependencyNode> dependencies A mapping of this node's dependencies ids to the correspondingJobDependencyNodeobjects. This is in effect a representation of the whole graph. -
graphRoot
boolean graphRoot
Whether this node should be removed from the graph upon the corresponding job completion. -
id
String id
The id asociated with this node. This is the application-defined id for the corresponding job. -
jobUuid
String jobUuid
The JPPF uuid of the associated job. -
pendingDependencies
Set<String> pendingDependencies
The ids of the nodes that depend on this node.
-
-
Exception org.jppf.node.protocol.graph.JPPFDependencyCycleException
class JPPFDependencyCycleException extends JPPFException implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.node.protocol.graph.JPPFJobDependencyCycleException
class JPPFJobDependencyCycleException extends JPPFDependencyCycleException implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.graph.MutableJobDependencyGraph
class MutableJobDependencyGraph extends JobDependencyGraphImpl implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.node.protocol.graph.TaskGraph
class TaskGraph extends Object implements Serializable-
Serialization Methods
-
readObject
Reconstitute this object from a stream (i.e., deserialize it).- Parameters:
in- the input stream from which to read the object.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph could not be found.
-
writeObject
Save the state of this object to a stream (i.e.,serialize it).- Parameters:
out- the output stream to which to write this object.- Throws:
IOException- if any I/O error occurs.
-
-
-
Class org.jppf.node.protocol.graph.TaskGraph.Node
class Node extends Object implements Serializable-
Serialized Fields
-
dependencies
List<TaskGraph.Node> dependencies
The dependencies of this task, if any. -
done
boolean done
Whether this task is done, that is, either completed or cancelled. -
position
int position
The position of this task in the job.
-
-
-
Class org.jppf.node.protocol.graph.TaskGraphInfo
class TaskGraphInfo extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialization Methods
-
readObject
Reconstitute the obejct from a stream (i.e., deserialize it).- Parameters:
in- the input stream from which to read the object.- Throws:
IOException- if any I/O error occurs.ClassNotFoundException- if the class of an object in the object graph can not be found.
-
writeObject
Save the state of this object to a stream (i.e.,serialize it).- Parameters:
out- the output stream to which to write the object.- Throws:
IOException- if any I/O error occurs.
-
-
Serialized Fields
-
dependenciesMap
CollectionMap<Integer,
Integer> dependenciesMap Mapping of each task position to the positions of its dependencies. -
dependenciesPositions
int[] dependenciesPositions
An ordered set of positions of the dependencies. -
nbDependencies
int nbDependencies
The total number of dependencies for all the tasks.
-
-
-
Package org.jppf.node.provisioning
-
Class org.jppf.node.provisioning.JPPFNodeProvisioning
class JPPFNodeProvisioning extends NotificationBroadcasterSupport implements Serializable-
Serialized Fields
-
master
boolean master
-
slaveManager
org.jppf.node.provisioning.SlaveNodeManager slaveManager
-
-
-
Class org.jppf.node.provisioning.JPPFProvisioningInfo
class JPPFProvisioningInfo extends Object implements Serializable-
Serialized Fields
-
-
-
Package org.jppf.process
-
Class org.jppf.process.ProcessLauncherEvent
class ProcessLauncherEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.process.ProcessWrapperEvent
class ProcessWrapperEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.queue
-
Class org.jppf.queue.QueueEvent
class QueueEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
requeued
boolean requeued
Determines if the event is a requeued bundle, following a node failure for instance.
-
-
-
Package org.jppf.scheduling
-
Class org.jppf.scheduling.JPPFSchedule
class JPPFSchedule extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
date
String date
Schedule date as a string. -
duration
long duration
Time in milliseconds, after which this task will be aborted.
A value of 0 or less indicates this task never times out. -
durationObject
Duration durationObject
A duration expressed as aDurationinstance. -
format
String format
Schedule date format as a string. -
zonedDateTime
ZonedDateTime zonedDateTime
A date expressed as aZonedDateTimeinstance.
-
-
-
Package org.jppf.scripting
-
Class org.jppf.scripting.BaseScriptEvaluator
class BaseScriptEvaluator extends Object implements Serializable- serialVersionUID:
- 1L
-
Exception org.jppf.scripting.JPPFScriptingException
class JPPFScriptingException extends JPPFException implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.scripting.ScriptDefinition
class ScriptDefinition extends Object implements Serializable
-
-
Package org.jppf.server.job.management
-
Class org.jppf.server.job.management.NodeJobInformation
class NodeJobInformation extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
jobInfo
JobInformation jobInfo
The information about the job dispatch. -
nodeInfo
JPPFManagementInfo nodeInfo
The information about the node.
-
-
-
Package org.jppf.ssl
-
Exception org.jppf.ssl.SSLConfigurationException
class SSLConfigurationException extends Exception implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.utils
-
Class org.jppf.utils.AbstractTypedProperties
class AbstractTypedProperties extends Properties implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
initialProps
AbstractTypedProperties initialProps
The default (initial) properties, if any.
-
-
Class org.jppf.utils.HostIP
- serialVersionUID:
- 1L
-
Class org.jppf.utils.InvocationResult
class InvocationResult extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
ref
Object ref
The referenced object.
-
-
Class org.jppf.utils.Pair
class Pair extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.ResultsMap
class ResultsMap extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
map
Map<K,
InvocationResult<V>> map The backing map.
-
-
Class org.jppf.utils.TraversalList
class TraversalList extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.TypedProperties
class TypedProperties extends AbstractTypedProperties implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.UnmodifiableTypedProperties
class UnmodifiableTypedProperties extends TypedProperties implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.VersionUtils.Version
class Version extends Object implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.utils.cli
-
Class org.jppf.utils.cli.NamedArguments
class NamedArguments extends org.jppf.utils.cli.AbstractCLIArguments<NamedArguments> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.cli.PositionalArguments
class PositionalArguments extends org.jppf.utils.cli.AbstractCLIArguments<PositionalArguments> implements Serializable- serialVersionUID:
- 1L
-
-
Package org.jppf.utils.collections
-
Class org.jppf.utils.collections.AbstractCollectionConcurrentMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.AbstractCollectionHashtable
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.AbstractCollectionMap
class AbstractCollectionMap extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
map
Map<K,
Collection<V>> map The underlying map to which operations are delegated.
-
-
Class org.jppf.utils.collections.AbstractCollectionSortedMap
- serialVersionUID:
- 1L
-
Serialized Fields
-
comparator
Comparator<K> comparator
Comparator used to sort the keys.
-
-
Class org.jppf.utils.collections.ArrayListHashMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.ArrayListSortedMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.CopyOnWriteListConcurrentMap
class CopyOnWriteListConcurrentMap extends AbstractCollectionConcurrentMap<K,V> implements Serializable - serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.EnumSetEnumMap
class EnumSetEnumMap extends AbstractCollectionMap<S extends Enum<S>,S extends Enum<S>> implements Serializable - serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.LinkedListHashMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.LinkedListSortedMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.LRUMap
- serialVersionUID:
- 1L
-
Serialized Fields
-
maxCapacity
int maxCapacity
The maximum cache capacity
-
-
Class org.jppf.utils.collections.MetadataImpl
class MetadataImpl extends Object implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.SetHashMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.SetIdentityMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.SetSortedMap
- serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.SortedSetSortedMap
- serialVersionUID:
- 1L
-
Serialized Fields
-
valueComparator
Comparator<V> valueComparator
Comparator used to sort the keys.
-
-
Class org.jppf.utils.collections.SynchronizedLinkedListConcurrentMap
class SynchronizedLinkedListConcurrentMap extends AbstractCollectionConcurrentMap<K,V> implements Serializable - serialVersionUID:
- 1L
-
Class org.jppf.utils.collections.VectorHashtable
- serialVersionUID:
- 1L
-
-
Package org.jppf.utils.concurrent
-
Class org.jppf.utils.concurrent.JPPFQueueLock
class JPPFQueueLock extends ReentrantLock implements Serializable-
Serialized Fields
-
name
String name
Name given to this lock.
-
-
-
Class org.jppf.utils.concurrent.JPPFReentrantLock
class JPPFReentrantLock extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
name
String name
Name given to this lock. -
synchronizer
org.jppf.utils.concurrent.JPPFReentrantLock.Synchronizer synchronizer
Synchronizer providing all implementation mechanics
-
-
-
Package org.jppf.utils.configuration
-
Class org.jppf.utils.configuration.AbstractJPPFProperty
class AbstractJPPFProperty extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
aliases
String[] aliases
Other names that may be given to this property (e.g. older names from previous versions). -
defaultValue
T defaultValue
The default value of this property. -
deprecated
boolean deprecated
Whether this property is deprecated. -
i18nBase
String i18nBase
Location of the localization resource bundles. -
name
String name
The name of this property. -
paramNames
String[] paramNames
Names of the parmaters used in the property's name, if any. -
possibleValues
T[] possibleValues
The possible values for this property, if any. -
tags
Set<String> tags
The tags that apply to this property.
-
-
Class org.jppf.utils.configuration.BooleanProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.CharProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.DoubleProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.FileProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.FloatProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.IntArrayProperty
class IntArrayProperty extends AbstractJPPFProperty<int[]> implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.IntProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.LongProperty
- serialVersionUID:
- 1L
-
Class org.jppf.utils.configuration.NumberProperty
- serialVersionUID:
- 1L
-
Serialized Fields
-
hasMinAndMax
boolean hasMinAndMax
-
maxValue
Comparable<T extends Number> maxValue
The maximum accepted value for this property. -
minValue
Comparable<T extends Number> minValue
The minimum accepted value for this property.
-
-
Class org.jppf.utils.configuration.StringArrayProperty
- serialVersionUID:
- 1L
-
Serialized Fields
-
delimiter
String delimiter
The delimiter used to split the value into an array of strings. It MUST be a litteral string, i.e. not a regex.
-
-
Class org.jppf.utils.configuration.StringProperty
- serialVersionUID:
- 1L
-
-
Package org.jppf.utils.stats
-
Class org.jppf.utils.stats.AbstractBaseJPPFSnapshot
class AbstractBaseJPPFSnapshot extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
label
String label
Label for this snapshot, used in theObject.toString()method. -
total
double total
The total cumulated values. -
updateNanos
long updateNanos
The last update time of this snapshot, as the result of callingSystem.nanoTime() - creationTimeNanos.
-
-
Class org.jppf.utils.stats.AbstractJPPFSnapshot
class AbstractJPPFSnapshot extends AbstractBaseJPPFSnapshot implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
avg
double avg
The average value. -
latest
double latest
The most recent value. -
max
double max
The maximum value. -
min
double min
The minimum value. -
valueCount
long valueCount
Count of values added to this snapshot.
-
-
Class org.jppf.utils.stats.CumulativeSnapshot
class CumulativeSnapshot extends AbstractJPPFSnapshot implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.stats.JPPFStatistics
class JPPFStatistics extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialization Methods
-
readObject
Restore the state of this object from a stream.- Parameters:
ois- the stream to read from.- Throws:
IOException- if an I/O error occurs.ClassNotFoundException- if a class cannot be found or initialized during deserialization.
-
writeObject
Saves the state of this object to a stream.- Parameters:
oos- the stream to write to.- Throws:
IOException- if an I/O error occurs.
-
-
Serialized Fields
-
snapshots
ConcurrentHashMap<String,
JPPFSnapshot> snapshots Contains all snapshots currently handled.
-
-
Class org.jppf.utils.stats.JPPFStatisticsEvent
class JPPFStatisticsEvent extends EventObject implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
snapshot
JPPFSnapshot snapshot
The snapshot that was created, removed or updated.
-
-
Class org.jppf.utils.stats.NonCumulativeSnapshot
class NonCumulativeSnapshot extends AbstractJPPFSnapshot implements Serializable- serialVersionUID:
- 1L
-
Class org.jppf.utils.stats.SingleValueSnapshot
class SingleValueSnapshot extends AbstractBaseJPPFSnapshot implements Serializable- serialVersionUID:
- 1L
-
nameattribute has no clearly defined, consistent semantics. It is no longer used.