org.pentaho.di.job.Job.getContainerObjectId()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(100)

本文整理了Java中org.pentaho.di.job.Job.getContainerObjectId()方法的一些代码示例,展示了Job.getContainerObjectId()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getContainerObjectId()方法的具体详情如下:
包路径:org.pentaho.di.job.Job
类名称:Job
方法名:getContainerObjectId

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 =

相关文章