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

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

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

Job.getActiveJobEntryTransformations介绍

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

代码示例

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

public Trans findActiveTrans( Job job, JobEntryCopy jobEntryCopy ) {
 JobEntryTrans jobEntryTrans = job.getActiveJobEntryTransformations().get( jobEntryCopy );
 if ( jobEntryTrans == null ) {
  return null;
 }
 return jobEntryTrans.getTrans();
}

代码示例来源: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

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

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

getActiveJobEntryTransformations().put( jobEntryCopy, (JobEntryTrans) cloneJei );
if ( interactive ) {
 if ( jobEntryCopy.isTransformation() ) {
  getActiveJobEntryTransformations().remove( jobEntryCopy );

相关文章