public class GenericBatchJobInfrastructure extends BatchJobInfrastructure
BatchJobInfrastructure.InfrastructureManager.PersistedInfraVariablesHandler<T>, InfrastructureManager.RMDeployingNodeAccessor| Modifier and Type | Field and Description |
|---|---|
protected String |
implementationClassname |
protected String |
implementationFile |
javaOptions, javaPath, maxNodes, nodeTimeOut, rmCredentialsPath, schedulingPath, serverName, sshOptions, submitJobOptELASTIC, logger, nodeSource, persistedInfraVariables, readLock, RM_URL_KEY, writeLock| Constructor and Description |
|---|
GenericBatchJobInfrastructure() |
| Modifier and Type | Method and Description |
|---|---|
void |
configure(Object... parameters)
Configures this infrastructure manager parameters[0] = java path
parameters[1] = ssh options parameters[2] = scheduling path parameters[3]
= java options parameters[4] = max node parameters[5] = node timeout
parameters[6] = scheduler server name parameters[7] = PA scheduler
credentials parameters[8] = submit job options
|
protected String |
extractSubmitOutput(String output)
Parses the submit (
BatchJobInfrastructure.getSubmitJobCommand()) command output to
extract job's ID. |
protected String |
getBatchinJobSystemName()
Return a string to identify the type of the target Batching Job System.
|
protected String |
getDeleteJobCommand()
To be able to get from implementations the command that will be used to
delete a job
|
protected String |
getSubmitJobCommand()
To be able to get from implementations the command that will be used to
submit a new Job
|
protected void |
initializePersistedInfraVariables()
This method should initialize a value in the runtime variables map for all the runtime variables that will be
used in the class.
|
acquireAllNodes, acquireNode, getDescription, getSectionDescriptions, notifyAcquiredNode, notifyDeployingNodeLost, notifyDownNode, removeNode, shutDown, toStringacquireAllNodes, acquireNodes, acquireNodes, addDeployingNode, addDeployingNodeWithLockAndPersist, addLostNodeWithLockAndPersist, addMultipleDeployingNodes, buildDeployingNodeURL, checkAllNodesAreAcquiredAndDo, checkNodeIsAcquiredAndDo, declareDeployingNodeLost, getDefaultCommandLineBuilder, getDeployingAndLostNodes, getDeployingNodesWithLock, getDeployingOrLostNode, getEmptyCommandLineBuilder, getLostNodesWithLock, getMeta, getPersistedDeployingNodesUrl, getPersistedInfraVariable, getPersistedLostNodesUrl, getRmUrl, internalConfigure, internalNotifyDownNode, internalRegisterAcquiredNode, internalRemoveDeployingNode, internalRemoveNode, internalShutDown, isShutDown, isUsingDeployingNode, multipleDeclareDeployingNodeLost, onDownNodeReconnection, persistInfrastructureVariables, reconfigure, recoverPersistedInfraVariables, removeDownNodePriorToNotify, searchForNotAcquiredRmNode, setNodeSource, setPersistedInfraVariable, setPersistedNodeSourceData, setRmDbManager, setRmUrl, update, updateDeployingNodeDescriptionprotected String implementationClassname
protected String implementationFile
public void configure(Object... parameters)
BatchJobInfrastructureconfigure in class BatchJobInfrastructureparameters - of the infrastructure managerprotected String extractSubmitOutput(String output)
BatchJobInfrastructureBatchJobInfrastructure.getSubmitJobCommand()) command output to
extract job's ID.extractSubmitOutput in class BatchJobInfrastructureoutput - the submit command outputprotected String getBatchinJobSystemName()
BatchJobInfrastructuregetBatchinJobSystemName in class BatchJobInfrastructureprotected String getDeleteJobCommand()
BatchJobInfrastructuregetDeleteJobCommand in class BatchJobInfrastructureprotected String getSubmitJobCommand()
BatchJobInfrastructuregetSubmitJobCommand in class BatchJobInfrastructureprotected void initializePersistedInfraVariables()
InfrastructureManagerInfrastructureManager.configure(Object...) method.
This method runs with the write lock acquired.initializePersistedInfraVariables in class BatchJobInfrastructure