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

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

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

Job.setActive介绍

暂无

代码示例

代码示例来源:origin: pentaho/pentaho-kettle

private void executeWithPreviousResultsTest( boolean repeat ) {
 setupJobMockExecution();
 try {
  when( mockedJobEntrySpecial.execute( any( Result.class ), anyInt() ) ).thenReturn( new Result(  ) );
  when( mockedJob.execute( anyInt(), any( Result.class ) ) ).thenCallRealMethod();
  when( mockedJobEntrySpecial.isRepeat() ).thenReturn( repeat );
  if ( repeat ) {
   //The job will repeat its execution until it is stopped
   scheduleStopJobExecution();
  }
  mockedJob.execute( 0, new Result(  ) );
  //Test expected invocations. If repeat setActive(false) will be called at least twice. With no repeat, only once.
  verify( mockedJob, repeat ? atLeast( 2 ) : times( 1 ) ).setActive( false );
 } catch ( KettleException e ) {
  Assert.fail( "Could not execute job" );
 }
}

代码示例来源:origin: pentaho/pentaho-kettle

setActive( true );
setInitialized( true );
KettleEnvironment.setExecutionInformation( this, rep );
do {
 res = execute( nr, result, startpoint, null, BaseMessages.getString( PKG, "Job.Reason.StartOfJobentry" ) );
 setActive( false );
} while ( jes.isRepeat() && !isStopped() );
return res;

代码示例来源:origin: pentaho/pentaho-kettle

setActive( false );
setFinished( true );
setStopped( false );

代码示例来源:origin: pentaho/pentaho-kettle

jobTracker.addJobTracker( new JobTracker( jobMeta, jerStart ) );
setActive( true );
log.logMinimal( BaseMessages.getString( PKG, "Job.Comment.JobFinished" ) );
setActive( false );
if ( !isStopped() ) {
 setFinished( true );

相关文章