Kettle（Pentaho PDI）：找不到这份工作的起点

Question

我正在使用来自 Java 的 Kettle 手动创建作业，但我收到错误消息 Couldn't find starting point in this job。

KettleEnvironment.init();
JobMeta jobMeta = new JobMeta();
JobEntrySpecial start = new JobEntrySpecial("START", true, false);
start.setStart(true);
JobEntryCopy startEntry = new JobEntryCopy(start);
jobMeta.addJobEntry(startEntry);                    

JobEntryTrans jet1 = new JobEntryTrans("first");
Trans trans1 = jet1.getTrans();
jet1.setFileName("file.ktr");
JobEntryCopy jc1 = new JobEntryCopy(jet1);
jobMeta.addJobEntry(jc1);

jobMeta.addJobHop(new JobHopMeta(startEntry, jc1));
Job job = new Job(null, jobMeta);
job.setInteractive(true);
job.start();

Answer 1

Class org.pentaho.di.job.JobMeta class 有方法 findJobEntry

您可以使用它来寻找名为“START

的入口点

这就是 kettle-pdi 的原始来源

private JobMeta jobMeta;
....

// Where do we start?
jobEntryCopy startpoint;
....

if ( startJobEntryCopy == null ) {
        startpoint = jobMeta.findJobEntry( JobMeta.STRING_SPECIAL_START, 0, false );

// and then 
JobEntrySpecial jes = (JobEntrySpecial) startpoint.getEntry();

Answer 2

我发现我不见了

job.setStartJobEntryCopy(startEntry);

Kettle（Pentaho PDI）：找不到这份工作的起点

Kettle (Pentaho PDI): Couldn't find starting point in this job

pentaho

kettle

pdi