|
Oracle® Data Integrator Java API Reference 11g Release 1 (11.1.1.3.0) E17060-01 |
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object oracle.odi.domain.runtime.ess.support.JobDefinitionRepositoryImpl
public final class JobDefinitionRepositoryImpl
Default IJobDefinitionRepository
implementation, storing / querying
ESS metadata according connection information from provided
OdiEnterpriseScheduler
.
This implementation makes every methods participate in surrounding ODI transaction, if one exists, using transaction synchronization mechanism.
Constructor Summary | |
---|---|
JobDefinitionRepositoryImpl(OdiInstance pOdiInstance,
OdiEnterpriseScheduler pEnterpriseScheduler)
Constructs a JobDefinitionRepositoryImpl object. |
Method Summary | |
---|---|
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
OdiScenario pScenario,
StartupParameters pVariables)
Create an store a new ODI job definition for the given scenario and execution variables. |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
OdiScenario pScenario,
StartupParameters pVariables,
java.lang.Integer pLogLevel,
OdiLogicalAgent pAgent,
OdiContext pExecutionContext,
java.lang.String pRunAsId,
boolean pIsAsync)
Create an store a new ODI job definition for the given scenario and execution parameters. |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
OdiScenario pScenario,
StartupParameters pVariables,
java.lang.Integer pLogLevel,
OdiLogicalAgent pAgent,
OdiContext pExecutionContext,
java.lang.String pOdiUsername,
oracle.odi.domain.Password pOdiPassword)
Create an store a new ODI job definition for the given scenario and execution parameters. |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
OdiScenario pScenario,
StartupParameters pVariables,
java.lang.String pRunAsId,
boolean pIsAsync)
Create an store a new ODI job definition for the given scenario and execution variables. |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
java.lang.String pScenarioName,
java.lang.String pScenarioVersion,
StartupParameters pVariables)
Same as IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters) , but allow
for specification of the scenario using its name and version (which are unique key
for OdiScenarios). |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
java.lang.String pScenarioName,
java.lang.String pScenarioVersion,
StartupParameters pVariables,
java.lang.Integer pLogLevel,
java.lang.String pLogicalAgentName,
java.lang.String pContextCode,
java.lang.String pRunAsId,
boolean pIsAsync)
Same as IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters, Integer, OdiLogicalAgent, OdiContext, String, Password)
but allow for specification of the scenario, agent and context using their unique key and code. |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
java.lang.String pScenarioName,
java.lang.String pScenarioVersion,
StartupParameters pVariables,
java.lang.Integer pLogLevel,
java.lang.String pLogicalAgentName,
java.lang.String pContextCode,
java.lang.String pOdiUsername,
oracle.odi.domain.Password pOdiPassword)
Same as IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters, Integer, OdiLogicalAgent, OdiContext, String, Password)
but allow for specification of the scenario, agent and context using their unique key and code. |
oracle.as.scheduler.JobDefinition |
createNewJobDefinition(java.lang.String pJobName,
java.lang.String pScenarioName,
java.lang.String pScenarioVersion,
StartupParameters pVariables,
java.lang.String pRunAsId,
boolean pIsAsync)
Same as IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters) , but allow
for specification of the scenario using its name and version (which are unique key
for OdiScenarios). |
java.util.Collection<oracle.as.scheduler.JobDefinition> |
getAllJobDefinitions()
Returns the all job definitions. |
oracle.as.scheduler.JobDefinition |
getJobDefinitionForId(oracle.as.scheduler.MetadataObjectId pJobId)
Obtains the job definition with the given ID from this repository instance. |
oracle.as.scheduler.JobDefinition |
getJobDefinitionForName(java.lang.String pJobName)
Obtains the job definition with the given name from this repository instance. |
java.util.Collection<oracle.as.scheduler.JobDefinition> |
getJobDefinitionForScenario(OdiScenario pScenario)
Returns the job definitions for scenario. |
java.util.Collection<oracle.as.scheduler.JobDefinition> |
getJobDefinitionsForScenarioNameAndVersion(java.lang.String pName,
java.lang.String pVersion)
Returns the job definitions for scenario. |
void |
removeJobDefinition(oracle.as.scheduler.JobDefinition pJobDefinition)
Remove the given job definition from this repository instance. |
void |
updateJobDefinition(oracle.as.scheduler.JobDefinition pJobDefinition)
Update the given job definition from this repository instance. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JobDefinitionRepositoryImpl(OdiInstance pOdiInstance, OdiEnterpriseScheduler pEnterpriseScheduler)
pOdiInstance
- an OdiInstance objectpEnterpriseScheduler
- an OdiEnterpriseScheduler objectMethod Detail |
---|
public oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, OdiScenario pScenario, StartupParameters pVariables) throws DuplicateJobDefinitionException
IJobDefinitionRepository
That is the common method to be used in order to create a design time job definition. Specific execution / runtime parameters like execution agent, execution context, ODI user, etc. have to be defined at job submission time.
Note: for consistency with the current IRepositoryDefinition
used to access the domain
layer, this method sets job's work repository parameter with the current one using
IRepositoryDefinition.getWorkRepositoryName()
. However that job parameter can be overrided
at job submission time for specific use case where job definitions and scenarios have been exported
and imported from an ODI / ESS environment to another one and possibly having another work repository
name.
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the name of the ESS jobpScenario
- the ODI scenario to be executed when submitting that jobpVariables
- the execution variables to be used during execution of the specified scenario
DuplicateJobDefinitionException
- if a job with the same name already existpublic oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, OdiScenario pScenario, StartupParameters pVariables, java.lang.Integer pLogLevel, OdiLogicalAgent pAgent, OdiContext pExecutionContext, java.lang.String pRunAsId, boolean pIsAsync) throws DuplicateJobDefinitionException
IJobDefinitionRepository
Overload IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
to allow
specification of runtime job parameters like execution agent, execution context, ODI user, etc.
However those parameters can still be overrided at job submission time.
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the ESS job namepScenario
- the ODI scenario to be executedpVariables
- the execution variables to be used during execution of the specified scenariopLogLevel
- log level of the executionpAgent
- target logical agent where to execute the specified scenariopExecutionContext
- ODI execution context for the specified agent and scenariopRunAsId
- applicationId to runAs, if null, runs as submitting userpIsAsync
- whether execution is asynchronous or not
DuplicateJobDefinitionException
- if a job with the same name already existIJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
public oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, OdiScenario pScenario, StartupParameters pVariables, java.lang.Integer pLogLevel, OdiLogicalAgent pAgent, OdiContext pExecutionContext, java.lang.String pOdiUsername, oracle.odi.domain.Password pOdiPassword) throws DuplicateJobDefinitionException
IJobDefinitionRepository
Overload IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
to allow
specification of runtime job parameters like execution agent, execution context, ODI user, etc.
However those parameters can still be overrided at job submission time.
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the ESS job namepScenario
- the ODI scenario to be executedpVariables
- the execution variables to be used during execution of the specified scenariopLogLevel
- log level of the executionpAgent
- target logical agent where to execute the specified scenariopExecutionContext
- ODI execution context for the specified agent and scenariopOdiUsername
- ODI username for executionpOdiPassword
- ODI password for execution
DuplicateJobDefinitionException
- if a job with the same name already existIJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
public oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, OdiScenario pScenario, StartupParameters pVariables, java.lang.String pRunAsId, boolean pIsAsync) throws DuplicateJobDefinitionException
IJobDefinitionRepository
That is the common method to be used in order to create a design time job definition. Specific execution / runtime parameters like execution agent, execution context, ODI user, etc. have to be defined at job submission time.
Note: for consistency with the current IRepositoryDefinition
used to access the domain
layer, this method sets job's work repository parameter with the current one using
IRepositoryDefinition.getWorkRepositoryName()
. However that job parameter can be overrided
at job submission time for specific use case where job definitions and scenarios have been exported
and imported from an ODI / ESS environment to another one and possibly having another work repository
name.
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the name of the ESS jobpScenario
- the ODI scenario to be executed when submitting that jobpVariables
- the execution variables to be used during execution of the specified scenariopRunAsId
- applicationId to runAs, if null, runs as submitting userpIsAsync
- whether execution is asynchronous or not
DuplicateJobDefinitionException
- if a job with the same name already existpublic oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, java.lang.String pScenarioName, java.lang.String pScenarioVersion, StartupParameters pVariables) throws DuplicateJobDefinitionException
IJobDefinitionRepository
IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
, but allow
for specification of the scenario using its name and version (which are unique key
for OdiScenarios).
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the name of the ESS jobpScenarioName
- the name of the scenario to be executed when submitting that jobpScenarioVersion
- the version of the scenario to be executed when submitting that jobpVariables
- the execution variables to be used during execution of the specified scenario
DuplicateJobDefinitionException
- if a job with the same name already existIJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
public oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, java.lang.String pScenarioName, java.lang.String pScenarioVersion, StartupParameters pVariables, java.lang.Integer pLogLevel, java.lang.String pLogicalAgentName, java.lang.String pContextCode, java.lang.String pRunAsId, boolean pIsAsync) throws DuplicateJobDefinitionException
IJobDefinitionRepository
IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters, Integer, OdiLogicalAgent, OdiContext, String, Password)
but allow for specification of the scenario, agent and context using their unique key and code.
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the name of the ESS jobpScenarioName
- the name of the scenario to be executed when submitting that jobpScenarioVersion
- the version of the scenario to be executed when submitting that jobpVariables
- the execution variables to be used during execution of the specified scenariopLogLevel
- log level of the executionpLogicalAgentName
- target logical agent where to execute the specified scenariopContextCode
- ODI execution context for the specified agent and scenariopRunAsId
- applicationId to runAs, if null, runs as submitting userpIsAsync
- whether execution is asynchronous or not
DuplicateJobDefinitionException
- if a job with the same name already existIJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters, Integer, OdiLogicalAgent, OdiContext, String, Password)
public oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, java.lang.String pScenarioName, java.lang.String pScenarioVersion, StartupParameters pVariables, java.lang.Integer pLogLevel, java.lang.String pLogicalAgentName, java.lang.String pContextCode, java.lang.String pOdiUsername, oracle.odi.domain.Password pOdiPassword) throws DuplicateJobDefinitionException
IJobDefinitionRepository
IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters, Integer, OdiLogicalAgent, OdiContext, String, Password)
but allow for specification of the scenario, agent and context using their unique key and code.
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the name of the ESS jobpScenarioName
- the name of the scenario to be executed when submitting that jobpScenarioVersion
- the version of the scenario to be executed when submitting that jobpVariables
- the execution variables to be used during execution of the specified scenariopLogLevel
- log level of the executionpLogicalAgentName
- target logical agent where to execute the specified scenariopContextCode
- ODI execution context for the specified agent and scenariopOdiUsername
- ODI username for executionpOdiPassword
- ODI password for execution
DuplicateJobDefinitionException
- if a job with the same name already existIJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters, Integer, OdiLogicalAgent, OdiContext, String, Password)
public oracle.as.scheduler.JobDefinition createNewJobDefinition(java.lang.String pJobName, java.lang.String pScenarioName, java.lang.String pScenarioVersion, StartupParameters pVariables, java.lang.String pRunAsId, boolean pIsAsync) throws DuplicateJobDefinitionException
IJobDefinitionRepository
IJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
, but allow
for specification of the scenario using its name and version (which are unique key
for OdiScenarios).
createNewJobDefinition
in interface IJobDefinitionRepository
pJobName
- the name of the ESS jobpScenarioName
- the name of the scenario to be executed when submitting that jobpScenarioVersion
- the version of the scenario to be executed when submitting that jobpVariables
- the execution variables to be used during execution of the specified scenariopRunAsId
- applicationId to runAs, if null, runs as submitting userpIsAsync
- whether execution is asynchronous or not
DuplicateJobDefinitionException
- if a job with the same name already existIJobDefinitionRepository.createNewJobDefinition(String, OdiScenario, StartupParameters)
public java.util.Collection<oracle.as.scheduler.JobDefinition> getAllJobDefinitions()
getAllJobDefinitions
in interface IJobDefinitionRepository
public oracle.as.scheduler.JobDefinition getJobDefinitionForId(oracle.as.scheduler.MetadataObjectId pJobId) throws JobDefinitionNotFoundException
IJobDefinitionRepository
getJobDefinitionForId
in interface IJobDefinitionRepository
pJobId
- the ID of the job
JobDefinitionNotFoundException
- if not job found with the given IDpublic oracle.as.scheduler.JobDefinition getJobDefinitionForName(java.lang.String pJobName) throws JobDefinitionNotFoundException
IJobDefinitionRepository
getJobDefinitionForName
in interface IJobDefinitionRepository
pJobName
- the name of the job
JobDefinitionNotFoundException
- if no job found with the given namepublic java.util.Collection<oracle.as.scheduler.JobDefinition> getJobDefinitionForScenario(OdiScenario pScenario)
getJobDefinitionForScenario
in interface IJobDefinitionRepository
pScenario
- scenario
public java.util.Collection<oracle.as.scheduler.JobDefinition> getJobDefinitionsForScenarioNameAndVersion(java.lang.String pName, java.lang.String pVersion)
getJobDefinitionsForScenarioNameAndVersion
in interface IJobDefinitionRepository
pName
- a StringpVersion
- a String
public void removeJobDefinition(oracle.as.scheduler.JobDefinition pJobDefinition)
IJobDefinitionRepository
Note: if this repository doesn't contains this job, this method will simply return.
removeJobDefinition
in interface IJobDefinitionRepository
pJobDefinition
- the job to removepublic void updateJobDefinition(oracle.as.scheduler.JobDefinition pJobDefinition) throws JobDefinitionNotFoundException
IJobDefinitionRepository
updateJobDefinition
in interface IJobDefinitionRepository
pJobDefinition
- the job to update
JobDefinitionNotFoundException
- if this repository doesn't contains this job
|
Oracle® Data Integrator Java API Reference 11g Release 1 (11.1.1.3.0) E17060-01 |
||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |