String name
String value
String connectionId
JMXServiceURL jmxServiceURL
Vector<E> listeners
Map<K,V> env
AccessControlContext context
Map<K,V> connections
org.objectweb.proactive.core.remoteobject.RemoteObjectExposer<T> roe
Permissions permissions
boolean paAllPermissions
Subject subject
boolean pingable
String name
org.objectweb.proactive.core.UniqueID id
String url
Credentials credentials
org.ow2.proactive.resourcemanager.core.RMCore rmcore
RMStateNodeUrls rmNodeUrls
Long maxNumberOfNodes
String RMUrl
RMEventType type
String initiator
long timeStamp
long counter
long firstCounter
SortedUniqueSet<T extends org.ow2.proactive.resourcemanager.common.event.SortedUniqueSet.Unique & Comparable<T> & Serializable> events
AtomicLong latestCounter
String nodeUrl
String nodeSource
String PADName
ProActiveDescriptor
name of the nodeString VnName
VirtualNode
name of the nodeString hostName
String VMName
NodeState nodeState
NodeState previousNodeState
String nodeProvider
String nodeOwner
String description
String defaultJMXUrl
String proactiveJMXUrl
boolean isLocked
long lockTime
String nodeLocker
String nodeSourceName
String nodeSourceDescription
String nodeSourceAdmin
String nodeSourceStatus
HashMap<K,V> distances
HashMap<K,V> hosts
Long long0
Long longMax
ConfigurableAdapter.ConfigurableValues type
String description
boolean dynamic
String name
String value
Configurable meta
String nodeSourceName
boolean nodesRecoverable
PluginDescriptor infrastructurePluginDescriptor
PluginDescriptor policyPluginDescriptor
boolean myJobsOnly
boolean pending
boolean running
boolean finished
SchedulerEvent eventType
Object data
Set<E> users
UserIdentification.compareTo(UserIdentification)
method !SchedulerEventListener internalListener
String taskName
Stack<E> tags
XMLAttributes attribute
boolean isSchemaException
JobId jobId
String name
String description
String projectName
JobPriority priority
String inputSpace
String outputSpace
String globalSpace
String userSpace
String visualization
Map<K,V> variables
Map<K,V> unresolvedVariables
String jobContent
boolean toRemove
String task
FlowError.FlowErrorType errorType
UpdatableProperties<T> restartTaskOnError
It will be restarted according to the number of execution remaining.
You can override this property inside each task.
UpdatableProperties<T> maxNumberOfExecution
You can override this property inside each task.
Map<K,V> genericInformation
Map<K,V> unresolvedGenericInformation
UpdatableProperties<T> onTaskError
String javaHome
String workingDir
Map<K,V> systemEnvironment
List<E> jvmArguments
List<E> additionalClasspath
Script<E> script
private void writeObject(ObjectOutputStream out) throws IOException
IOException
byte[] serializedAllEvents
String loggerName
String[] commandLine
String descriptor
int nodesNumber
TopologyDescriptor topologyDescriptor
int index
String description
TaskScript script
String name
String flowBlock
String description
String tag
List<E> inputFiles
List<E> outputFiles
ParallelEnvironment parallelEnvironment
List<E> sScripts
Script<E> preScript
Script<E> postScript
Script<E> cScript
FlowScript flowScript
FlowAction
which will perform flow actions on the jobboolean preciousResult
boolean preciousLogs
boolean runAsMe
List<E> dependences
long wallTime
ForkEnvironment forkEnvironment
Map<K,V> variables
boolean jobInherited
Object value
boolean set
org.objectweb.proactive.extensions.dataspaces.vfs.selector.FileSelector inputFiles
InputAccessMode mode
org.objectweb.proactive.extensions.dataspaces.vfs.selector.FileSelector outputFiles
OutputAccessMode mode
String type
FlowActionType.parse(String)
int dupNumber
FlowAction.type
is FlowActionType.REPLICATE
String target
FlowAction.type
is FlowActionType.LOOP
or selected branch if FlowAction.type
FlowActionType.IF
String targetContinuation
FlowAction.type
is FlowActionType.IF
String targetElse
FlowAction.type
is FlowActionType.IF
String cronExpr
String actionType
FlowActionType.parse(String)
String target
String targetElse
String targetContinuation
boolean booleanValue
byte[] byteArray
Integer value
String path
Scheduler uischeduler
MBeanInfoViewer mbeaninfoviewer
URI remoteCollectorURI
String hostname
int port
String hostname
int port
int remoteSSHPort
Map<K,V> spacesConfigurations
String namingServiceURL
String localhostname
org.objectweb.proactive.core.node.NodeImpl schedulerNode
boolean serviceStarted
String appidConfigured
ArrayList<E> servers
String emailTarget
Set<E> pendingJobs
Set<E> runningJobs
Set<E> finishedJobs
SchedulerStatus status
SchedulerUsers sUsers
Map<K,V> jobs
boolean initialized
jobs
field has already been
initialized. Used only when this state is updated through
events.org.ow2.proactive.scheduler.core.SchedulingService schedulingService
private void readObject(ObjectInputStream ois) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
ClientJobSerializationHelper clientJobSerializationHelper
JobInfoImpl jobInfo
String owner
JobType type
Map<K,V> tasks
int maxNumberOfExecution
JobId jobId
UserIdentificationImpl userIdentification
boolean finished
Map<K,V> genericInformation
Map<K,V> tasks
JobInfoImpl jobInfo
Map<K,V> resultMap
JobDescriptor jobDescriptor
Map<K,V> taskDataSpaceApplications
long restartWaitingTimer
boolean jobSubmissionDetailedLogging
Credentials credentials
Job taskFlowJob
SynchronizationInternal synchronizationAPI
long id
String readableName
JobId jobId
String owner
long submittedTime
long startTime
long inErrorTime
long finishedTime
long removedTime
long scheduledTimeForRemoval
long lastUpdatedTime
int totalNumberOfTasks
int numberOfPendingTasks
int numberOfRunningTasks
int numberOfFinishedTasks
int numberOfFailedTasks
int numberOfFaultyTasks
int numberOfInErrorTasks
JobPriority priority
JobStatus status
boolean toBeRemoved
Set<E> tasksSkipped
List<E> modifiedTasks
Map<K,V> genericInformation
Map<K,V> variables
String applicationId
org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService namingService
boolean alreadyRegistered
String username
Subject subject
int submitNumber
long connectionTime
long lastSubmitTime
String hostName
boolean myEventsOnly
long submittedTime
long startTime
long inErrorTime
long finishedTime
long removedTime
long lastUpdatedTime
JobId jobId
String jobOwner
int totalNumberOfTasks
int numberOfPendingTasks
int numberOfRunningTasks
int numberOfFinishedTasks
int numberOfFailedTasks
int numberOfFaultyTasks
int numberOfInErrorTasks
JobPriority jobPriority
JobStatus jobStatus
long scheduledTimeForRemoval
boolean toBeRemoved
Map<K,V> genericInformation
Map<K,V> variables
org.ow2.proactive_grid_cloud_portal.scheduler.dto.JobStateData jobStateData
long executionDuration
String executionHostName
long inErrorTime
long finishedTime
long scheduledTime
JobId jobId
JobInfo jobInfo
String name
int numberOfExecutionLeft
int numberOfExecutionOnFailureLeft
int progress
long startTime
TaskStatus status
TaskId taskId
TaskId id
byte[] serializedValue
byte[] serializedException
Serializable value
TaskLogs taskLogs
String exceptionMessage
Map<K,V> propagatedVariables
Map<K,V> resultMap
Map<K,V> metadata
boolean isRaw
org.ow2.proactive_grid_cloud_portal.scheduler.dto.TaskStateData d
String jobId
String localInputFolder
String inputSpaceURL
String pushURL
HashMap<K,V> awaitedTasks
boolean isolateTaskOutputs
boolean automaticTransfer
String localOutputFolder
String outputSpaceURL
String pullURL
File statusFile
File statusFileDirectory
HashMap<K,V> inMemoryChannels
jdbm.PrimaryHashMap<K,V> persistedChannels
Queue<E> waitUntilQueue
groovy.lang.GroovyShell shell
jdbm.RecordManager recordManager
boolean isStarted
boolean predicateResult
Serializable actionResult
private void readObject(ObjectInputStream ois) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
TaskId taskId
JobInfo jobInfo
long startTime
long inErrorTime
long finishedTime
long scheduledTime
long executionDuration
TaskStatus taskStatus
int progress
String executionHostName
int numberOfExecutionLeft
int numberOfExecutionOnFailureLeft
TaskId taskId
Script<E> pre
Script<E> post
FlowScript flowScript
long walltime
String jobOwner
String schedulerRestUrl
String catalogRestUrl
int replicationIndex
int iterationIndex
com.google.common.collect.ImmutableMap<K,V> genericInformation
boolean authorizedForkEnvironmentScript
List<E> taskInputFiles
List<E> taskOutputFiles
org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService namingService
boolean preciousLogs
com.google.common.collect.ImmutableMap<K,V> variables
com.google.common.collect.ImmutableMap<K,V> taskVariables
int pingPeriod
int pingAttempts
ForkEnvironment forkEnvironment
Synchronization synchronizationAPI
TaskId id
byte[] serializedValue
boolean isRaw
Map<K,V> resultMap
Map<K,V> metadata
byte[] serializedException
TaskLogs output
String previewerClassName
FlowAction flowAction
long taskDuration
Map<K,V> propagatedVariables
TaskInfo taskInfo
int maxNumberOfExecutionOnFailure
int iterationIndex
int replicationIndex
SchedulerNodeClient schedulerNodeClient
IDataSpaceClient.Dataspace space
String schedulerRestUrl
NodeSet nodes
Credentials credentials
boolean runAsUser
Map<K,V> serializedArguments
TaskScript script
List<E> otherNodesURLs
List<E> nodesHosts
ExecutableContainer executableContainer
TaskLauncherInitializer initializer
Decrypter decrypter
TaskResult[] previousTasksResults
NodeDataSpacesURIs nodeDataSpacesURIs
String schedulerHome
String progressFilePath
NodeInfo nodeInfo
String ERROR_READING_VARIABLES
ForkedTaskVariablesManager forkedTaskVariablesManager
TaskId taskId
boolean runAsUser
boolean linuxOS
org.objectweb.proactive.extensions.dataspaces.core.SpaceInstanceInfo cacheSpaceInstanceInfo
ForkedJvmTaskExecutionCommandCreator forkedJvmTaskExecutionCommandCreator
TaskContextVariableExtractor taskContextVariableExtractor
ForkEnvironmentScriptExecutor forkEnvironmentScriptExecutor
ForkedProcessBuilderCreator forkedJvmProcessBuilderCreator
TaskContextSerializer taskContextSerializer
File workingDir
ForkedTaskVariablesManager forkedTaskVariablesManager
TaskContextVariableExtractor taskContextVariableExtractor
ForkedTaskVariablesManager forkedTaskVariablesManager
TaskContextVariableExtractor taskContextVariableExtractor
TaskContextVariableExtractor taskContextVariableExtractor
JavaPrefixCommandExtractor javaPrefixCommandExtractor
PrivateKey key
Credentials credentials
ForkEnvironmentScriptResultExtractor forkEnvironmentScriptResultExtractor
String[] javaPrefixCommand
String scriptEngineLookupName
String script
URL url
String id
Serializable[] parameters
String scriptName
boolean dynamic
byte[] id_
DistanceFunction function
long threshold
boolean topologyBased
int size
TopologyDescriptor topology
List<E> scripts
Map<K,V> bindings
NodeSet blackList
boolean bestEffort
Collection<E> computationDescriptors
String nodeAccessToken
Set<E> setOfAcceptableNodesUrls
Collection<E> extraNodes