本文整理了Java中org.pentaho.di.job.Job.getContainerObjectId()
方法的一些代码示例,展示了Job.getContainerObjectId()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getContainerObjectId()
方法的具体详情如下:
包路径:org.pentaho.di.job.Job
类名称:Job
方法名:getContainerObjectId
[英]Gets the carteObjectId.
[中]获取carteObjectId。
代码示例来源:origin: pentaho/pentaho-kettle
/**
* Find a job using the container/carte object ID.
*
* @param id
* the container/carte object ID
* @return The job if it's found, null if the ID couldn't be found in the job map.
*/
public synchronized Job findJob( String id ) {
for ( Job job : jobMap.values() ) {
if ( job.getContainerObjectId().equals( id ) ) {
return job;
}
}
return null;
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
WebResult generateBody( HttpServletRequest request, HttpServletResponse response, boolean useXML ) throws IOException, KettleException {
final String xml = IOUtils.toString( request.getInputStream() );
// Parse the XML, create a job configuration
JobConfiguration jobConfiguration = JobConfiguration.fromXML( xml );
Job job = createJob( jobConfiguration );
String message = "Job '" + job.getJobname() + "' was added to the list with id " + job.getContainerObjectId();
return new WebResult( WebResult.STRING_OK, message, job.getContainerObjectId() );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public synchronized void registerJob( Job job, JobConfiguration jobConfiguration ) {
job.setContainerObjectId( UUID.randomUUID().toString() );
CarteObjectEntry entry = new CarteObjectEntry( job.getJobMeta().getName(), job.getContainerObjectId() );
jobMap.put( entry, job );
configurationMap.put( entry, jobConfiguration );
}
代码示例来源:origin: pentaho/pentaho-kettle
/**
* Sets the parent job.
*
* @param parentJob
* the new parent job
*/
public void setParentJob( Job parentJob ) {
this.parentJob = parentJob;
this.logLevel = parentJob.getLogLevel();
this.log = new LogChannel( this, parentJob );
this.containerObjectId = parentJob.getContainerObjectId();
}
代码示例来源:origin: pentaho/pentaho-kettle
private static Job mockJob( int id ) {
Job job = mock( Job.class );
when( job.getContainerObjectId() ).thenReturn( JOB_NAME_STRING + id );
return job;
}
代码示例来源:origin: pentaho/pentaho-kettle
@Test
public void testNewJobWithContainerObjectId() {
Repository repository = mock( Repository.class );
JobMeta meta = mock( JobMeta.class );
String carteId = UUID.randomUUID().toString();
doReturn( carteId ).when( meta ).getContainerObjectId();
Job job = new Job( repository, meta );
assertEquals( carteId, job.getContainerObjectId() );
}
代码示例来源:origin: pentaho/pentaho-kettle
/**
* This test demonstrates the fix for PDI-17398.
* Two schedules -> two Carte object Ids -> two log channel Ids
*/
@Test
public void testTwoJobsGetDifferentLogChannelIdWithDifferentCarteId() {
Repository repository = mock( Repository.class );
JobMeta meta1 = mock( JobMeta.class );
JobMeta meta2 = mock( JobMeta.class );
String carteId1 = UUID.randomUUID().toString();
String carteId2 = UUID.randomUUID().toString();
doReturn( carteId1 ).when( meta1 ).getContainerObjectId();
doReturn( carteId2 ).when( meta2 ).getContainerObjectId();
Job job1 = new Job( repository, meta1 );
Job job2 = new Job( repository, meta2 );
assertNotEquals( job1.getContainerObjectId(), job2.getContainerObjectId() );
assertNotEquals( job1.getLogChannelId(), job2.getLogChannelId() );
}
代码示例来源:origin: pentaho/pentaho-kettle
resultId = job.getContainerObjectId();
} else {
Node node =
内容来源于网络,如有侵权,请联系作者删除!