Чайник (Pentaho PDI): не удалось найти отправную точку в этой работе.

Я вручную создаю задание с помощью Kettle из Java, но получаю сообщение об ошибке 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();

pentaho pdi kettle
person Claudio    schedule 30.06.2016    source источник

Ответы (2)


arrow_upward
1
arrow_downward

Я обнаружил, что пропал без вести

job.setStartJobEntryCopy(startEntry);
person Claudio    schedule 01.07.2016

arrow_upward
0
arrow_downward

Класс org.pentaho.di.job.JobMeta имеет метод findJobEntry

Вы можете использовать его для поиска точки входа под названием "START

Вот как это первоисточник чайник-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();
person simar    schedule 01.07.2016