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

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

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

Job.getActiveJobEntryJobs介绍

[英]Gets the activeJobEntryJobs.
[中]获取activeJobEntryJobs。

代码示例

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

public Job findActiveJob( Job job, JobEntryCopy jobEntryCopy ) {
 JobEntryJob jobEntryJob = job.getActiveJobEntryJobs().get( jobEntryCopy );
 if ( jobEntryJob == null ) {
  return null;
 }
 return jobEntryJob.getJob();
}

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

@Override
public void callExtensionPoint( LogChannelInterface log, Object object ) throws KettleException {
 if ( !( object instanceof JobExecutionExtension ) ) {
  return;
 }
 JobExecutionExtension extension = (JobExecutionExtension) object;
 Job job = extension.job;
 JobMeta jobMeta = job.getJobMeta();
 final EmbeddedMetaStore embeddedMetaStore = jobMeta.getEmbeddedMetaStore();
 RunConfigurationManager embeddedRunConfigurationManager =  EmbeddedRunConfigurationManager.build( embeddedMetaStore );
 //will load and save to meta all run configurations
 for ( JobEntryTrans trans : job.getActiveJobEntryTransformations().values() ) {
  RunConfiguration loadedRunConfiguration = runConfigurationManager.load( jobMeta.environmentSubstitute( trans.getRunConfiguration() ) );
  embeddedRunConfigurationManager.save( loadedRunConfiguration );
 }
 for ( JobEntryJob subJob : job.getActiveJobEntryJobs().values() ) {
  RunConfiguration loadedRunConfiguration = runConfigurationManager.load( jobMeta.environmentSubstitute( subJob.getRunConfiguration() ) );
  embeddedRunConfigurationManager.save( loadedRunConfiguration );
 }
}

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

if ( job.getActiveJobEntryJobs().size() > 0 ) {
 activeJobEntries.addAll( job.getActiveJobEntryJobs().keySet() );

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

getActiveJobEntryJobs().put( jobEntryCopy, (JobEntryJob) cloneJei );
getActiveJobEntryJobs().remove( jobEntryCopy );

相关文章