本文整理了Java中org.pentaho.di.job.Job.getActiveJobEntryTransformations()
方法的一些代码示例,展示了Job.getActiveJobEntryTransformations()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getActiveJobEntryTransformations()
方法的具体详情如下:
包路径:org.pentaho.di.job.Job
类名称: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 );
内容来源于网络,如有侵权,请联系作者删除!