long id
String readableName
long startTime
long inErrorTime
long finishedTime
long submittedTime
long removedTime
JobStatusData status
JobIdData jobId
int totalNumberOfTasks
int numberOfPendingTasks
int numberOfRunningTasks
int numberOfFinishedTasks
int numberOfFailedTasks
int numberOfFaultyTasks
int numberOfInErrorTasks
JobPriorityData priority
String jobOwner
String tenant
String domain
String projectName
String description
String bucketName
String label
boolean toBeRemoved
Map<K,V> genericInformation
Map<K,V> variables
Map<K,V> detailedVariables
Set<E> signals
Map<K,V> detailedSignals
Map<K,V> visualizationConnectionStrings
Map<K,V> visualizationIcons
Map<K,V> attachedServices
Map<K,V> externalEndpointUrls
boolean resultMapPresent
List<E> preciousTasks
Long parentId
int childrenCount
long cumulatedCoreTime
int numberOfNodes
int numberOfNodesInParallel
String submissionMode
Long startAt
long id
String label
int nodesNumber
long id
String readableName
JobIdData jobId
TaskIdData taskId
long startTime
long finishedTime
long inErrorTime
long scheduledTime
long executionDuration
TaskStatusData taskStatus
String executionHostName
int numberOfExecutionLeft
int numberOfExecutionOnFailureLeft
boolean visualizationActivated
String visualizationConnectionString
Map<K,V> variables
int progress
String name
String description
String tag
int iterationIndex
int replicationIndex
int maxNumberOfExecution
int maxNumberOfExecutionOnFailure
TaskInfoData taskInfo
ParallelEnvironmentData parallelEnvironment
Map<K,V> genericInformation
String name
int count
int countFinished
int countErrors
long avgExecutionTime
TaskStatusData taskStatus
JobInfoData jobInfo
String userName
Set<E> groups
String tenant
String domain
boolean filterByTenant
boolean allTenantPermission
boolean allJobPlannerPermission
boolean canCreateAssociationPermission
boolean pcaAdminPermission
boolean notificationAdminPermission
boolean rmCoreAllPermission
boolean schedulerAdminPermission
boolean handleOnlyMyJobsPermission
boolean otherUsersJobReadPermission
List<E> prioritiesPermission
List<E> portalAccessPermission
List<E> portalAccessPermissionDisplay
List<E> adminRoles
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
RMCore rmcore
RMStateNodeUrls rmNodeUrls
Long maxNumberOfNodes
int freeNodesCount
int busyNodesCount
int deployingNodesCount
int configNodesCount
int downNodesCount
int lostNodesCount
int toBeRemovedNodesCount
int availableNodesCount
int neededNodesCount
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
String VnName
String hostName
String VMName
NodeState nodeState
NodeState previousNodeState
String nodeProvider
String nodeOwner
String description
String defaultJMXUrl
String proactiveJMXUrl
boolean isLocked
long lockTime
String nodeLocker
Map<K,V> usageInfo
List<E> tokens
String nodeSourceName
String nodeSourceDescription
LinkedHashMap<K,V> additionalInformation
String nodeSourceAdmin
String nodeSourceStatus
String infrastructureType
String policyType
List<E> accessTokens
RuntimeException exception
String name
String infrastructureType
List<E> infrastructureParameters
String policyType
List<E> policyParameters
Client provider
boolean nodesRecoverable
NodeSourceStatus status
LinkedHashMap<K,V> additionalInformation
Map<K,V> infrastructureVariables
String nodeUrl
String name
Client owner
Client provider
Permission userPermission
NodeState state
long stateChangeTime
NodeSourceData nodeSource
String hostname
String[] jmxUrls
String jvmName
Map<K,V> usageInfo
Set<E> tags
String name
String value
ConfigurableAdapter.ConfigurableWrapper meta
HashMap<K,V> distances
HashMap<K,V> hosts
Long long0
Long longMax
String name
String infrastructureType
String policyType
Client provider
boolean nodesRecoverable
List<E> infrastructureParameters
List<E> policyParameters
NodeSourceStatus status
LinkedHashMap<K,V> additionalInformation
Map<K,V> lastRecoveredInfrastructureVariables
String notFoundPluginClassName
ConfigurableAdapter.ConfigurableValues type
String description
boolean dynamic
int sectionSelector
boolean important
String name
String value
Configurable meta
String nodeSourceName
boolean nodesRecoverable
PluginDescriptor infrastructurePluginDescriptor
PluginDescriptor policyPluginDescriptor
String command
String javaPath
String sshOptions
SSHClient
)String schedulingPath
String javaOptions
int maxNodes
int nodeTimeOut
String serverName
File rmCredentialsPath
String submitJobOpt
BatchJobInfrastructure.serverName
File hostsList
int nodeTimeOut
int maxDeploymentFailure
long waitBetweenDeploymentFailures
HostsFileBasedInfrastructureManager.NodeNameBuilder nodeNameBuilder
String configuredAddress
int configuredNodeNumber
InetAddress resolvedAddress
Map<K,V> nodeStatusPerNodeUrl
AtomicInteger aliveNodesCounter
AtomicInteger downNodesCounter
AtomicInteger removedNodesCounter
AtomicBoolean needsNodesFlag
AtomicInteger lostNodeNotificationsCounter
NodeSource nodeSource
Map<K,V> deployingNodesMap
Map<K,V> lostNodesMap
AtomicBoolean shutDown
Map<K,V> persistedInfraVariables
RMDBManager dbManager
NodeSourceData nodeSourceData
Map<K,V> meta
Credentials credentials
int maxNodes
long nodeTimeout
String paProperties
Map<K,V> meta
String sshOptions
SSHClient
)String javaPath
String schedulingPath
String targetOs
String javaOptions
File rmCredentialsPath
int sshPort
String sshUsername
String sshPassword
byte[] sshPrivateKey
Properties sshOptions
String javaPath
String schedulingPath
String targetOs
String javaOptions
String deploymentMode
String nodeJarUrl
String startupScriptStandard
String startupScriptWithNodeJarDownload
AtomicBoolean shutDown
String nodeAcquision
String nodeRemoval
boolean preemptive
boolean forceDeployment
it.sauronsoftware.cron4j.Scheduler cronScheduler
CronPolicy thisStub
AtomicInteger handledNodes
RMCore rmCore
NodeSource nodeSource
AccessType userAccessType
AccessType providerAccessType
Map<K,V> meta
int checkNodeStateEach
org.apache.log4j.Logger logger
boolean rmShuttingDown
RMInitialState initialState
RMMonitoring rmMonitoring
String acquireTime
String releaseTime
Long period
boolean preemptive
TimeSlotPolicy thisStub
RMNodeEvent addEvent
boolean isLocked
RMNodeEvent lastEvent
Client lockedBy
isLocked
is true
only.long lockTime
isLocked
is true
only.String nodeName
NodeSource nodeSource
NodeSource
Stub that handles the nodeString nodeSourceName
String nodeURL
Client provider
NodeState state
long stateChangeTime
Map<K,V> usageInfo
HashMap<K,V> scriptStatus
org.objectweb.proactive.core.node.Node node
String vnodeName
VirtualNode
name of the nodeString hostName
String jvmName
ScriptHandler handler
Client owner
Permission nodeAccessPermission
String[] jmxUrls
boolean protectedByToken
Set<E> tags
String schedulerRestUrl
CredData userCreds
RMRestInterface rm
ConnectionInfo connectionInfo
String sessionId
boolean myJobsOnly
boolean pending
boolean running
boolean finished
boolean withIssuesOnly
boolean childJobs
String jobName
String projectName
String bucketName
String label
String userName
String tenant
Long parentId
String submissionMode
long submittedTimeLessThan
long submittedTimeGreater
long startAtTimeLessThan
long startAtTimeGreater
Long jobId
JobStatus status
SchedulerEvent eventType
Object data
Set<E> users
UserIdentification.compareTo(UserIdentification)
method !SchedulerEventListener internalListener
String taskName
Stack<E> tags
XMLAttributes attribute
boolean isSchemaException
Map<K,V> updatedVariables
Map<K,V> updatedModels
Map<K,V> updatedDescriptions
Map<K,V> updatedGroups
Map<K,V> updatedAdvanced
Map<K,V> updatedHidden
JobId jobId
long currentJobs
long runningJobs
long pausedJobs
long stalledJobs
long pendingJobs
long currentJobsWithoutIssues
long runningJobsWithoutIssues
long pausedJobsWithoutIssues
long stalledJobsWithoutIssues
long currentJobsWithIssues
long inErrorJobs
long runningJobsWithIssues
long pausedJobsWithIssues
long stalledJobsWithIssues
long pastJobsWithIssues
long canceledJobs
long killedJobs
long failedJobs
long finishedJobsWithIssues
long successfulJobs
long totalJobs
long successfulRate
String name
String description
String projectName
String bucketName
String label
Set<E> workflowTags
JobPriority priority
String inputSpace
String outputSpace
String globalSpace
String userSpace
String visualization
Map<K,V> variables
Map<K,V> unresolvedVariables
Map<K,V> globalVariables
Map<K,V> globalGenericInformation
String jobContent
Long parentId
String submissionMode
Long startAt
long id
String readableName
String errorMessage
String stackTrace
boolean isError
boolean isFetchError
long id
String label
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> taskRetryDelay
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
List<E> preJavaCommand
boolean isDockerWindowsToLinux
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
Boolean fork
List<E> dependences
long wallTime
ForkEnvironment forkEnvironment
Map<K,V> variables
Map<K,V> unresolvedVariables
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
Long value
String path
String taskId
String taskName
long taskStartTime
long taskFinishedTime
long taskExecutionDuration
int taskNodeNumber
String taskStatus
String taskTag
String taskDescription
String executionHostName
int numberOfExecutionLeft
int numberOfExecutionOnFailureLeft
int maxNumberOfExecution
int maxNumberOfExecutionOnFailure
boolean sessionListenerAdded
URI remoteCollectorURI
String hostname
int port
String hostname
int port
int remoteSSHPort
Map<K,V> spacesConfigurations
Map<K,V> userSpaceFolderLocks
String namingServiceURL
String localhostname
org.objectweb.proactive.core.node.NodeImpl schedulerNode
boolean serviceStarted
String appidConfigured
ArrayList<E> servers
String emailTarget
private void readObject(ObjectInputStream aInputStream) throws ClassNotFoundException, IOException
ClassNotFoundException
IOException
private void writeObject(ObjectOutputStream aOutputStream) throws IOException
IOException
Set<E> pendingJobs
Set<E> runningJobs
Map<K,V> 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
String tenant
String domain
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
SignalApiImpl signalAPI
int currentNumberOfNodesUsedInParallel
long id
String readableName
JobId jobId
String owner
String tenant
String domain
String projectName
String description
String bucketName
String label
long submittedTime
long startTime
long inErrorTime
long finishedTime
long removedTime
long scheduledTimeForRemoval
long lastUpdatedTime
long cumulatedCoreTime
int numberOfNodes
int numberOfNodesInParallel
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
Map<K,V> detailedVariables
Set<E> signals
Map<K,V> detailedSignals
Map<K,V> visualizationConnectionStrings
Map<K,V> visualizationIcons
Map<K,V> attachedServices
Map<K,V> externalEndpointUrls
boolean resultMapPresent
List<E> preciousTasks
Long parentId
Long startAt
int childrenCount
String submissionMode
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
int[] priorities
boolean handleOnlyMyJobsPermissionAllowed
long submittedTime
long startTime
long inErrorTime
long finishedTime
long removedTime
long lastUpdatedTime
long cumulatedCoreTime
int numberOfNodes
int numberOfNodesInParallel
JobId jobId
String jobOwner
String tenant
String domain
String projectName
String bucketName
String description
String label
String submissionMode
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
Map<K,V> detailedVariables
Set<E> signals
Map<K,V> detailedSignals
Map<K,V> visualizationConnectionStrings
Map<K,V> visualizationIcons
Map<K,V> attachedServices
Map<K,V> externalEndpointUrls
boolean resultMapPresent
List<E> preciousTasks
Long parentId
Long startAt
int childrenCount
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
boolean visualizationActivated
String visualizationConnectionString
Map<K,V> variables
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
TaskStateData d
SynchronizationWrapper synchronization
String jobId
boolean isInitialized
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
ConcurrentHashMap<K,V> inMemoryChannels
jdbm.PrimaryHashMap<K,V> persistedChannels
Map<K,V> synchronizedPersistedChannels
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
boolean visualizationActivated
String visualizationConnectionString
Map<K,V> variables
TaskId taskId
Script<E> pre
TaskScript post
FlowScript flowScript
long walltime
String jobOwner
String schedulerRestUrl
String schedulerRestPublicUrl
String catalogRestUrl
String catalogRestPublicUrl
String cloudAutomationRestUrl
String cloudAutomationRestPublicUrl
String jobPlannerRestUrl
String jobPlannerRestPublicUrl
String notificationServiceRestUrl
String notificationServiceRestPublicUrl
int replicationIndex
int iterationIndex
com.google.common.collect.ImmutableMap<K,V> genericInformation
com.google.common.collect.ImmutableMap<K,V> globalGenericInformation
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
com.google.common.collect.ImmutableMap<K,V> globalVariables
int pingPeriod
int pingAttempts
ForkEnvironment forkEnvironment
Synchronization synchronizationAPI
SignalApi signalAPI
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
Decrypter decrypter
String schedulerRestUrl
String schedulerRestPublicUrl
JobId parentJobId
Map<K,V> globalGenericInformation
Map<K,V> globalVariables
Map<K,V> globalJobVariables
NodeSet nodes
Credentials credentials
boolean runAsUser
Map<K,V> serializedArguments
TaskScript script
List<E> otherNodesURLs
Set<E> allNodesURLs
List<E> nodesHosts
ExecutableContainer executableContainer
TaskLauncherInitializer initializer
Decrypter decrypter
TaskResult[] previousTasksResults
NodeDataSpacesURIs nodeDataSpacesURIs
String schedulerHome
String progressFilePath
NodeInfo nodeInfo
String ERROR_READING_VARIABLES
String ERROR_READING_CREDENTIALS
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
File progressFile
PrivateKey key
Credentials credentials
ForkEnvironmentScriptResultExtractor forkEnvironmentScriptResultExtractor
String[] javaPrefixCommand
String scriptEngineLookupName
String script
URL url
String id
Serializable[] parameters
String scriptName
String sessionid
String owner
boolean dynamic
byte[] hash
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
String nodeSourceRestriction
Set<E> setOfAcceptableNodesUrls
List<E> listUsageInfo
Collection<E> extraNodes
TaskId taskId