java - 从 Pentaho Kettle Job 的 java api 调用中获取数据

Question

我在 Pentaho 有一份工作。该作业有一个返回 JSON 输出的转换。我如何使用 Java API 访问它？我需要读取该 JSON 并将其打印出来。我的代码是:

    KettleEnvironment.init();
    JobMeta jobMeta = new JobMeta("Job.kjb", null);
    Job job = new Job(null, jobMeta);          
    job.start();
    job.waitUntilFinished()    
    System.out.println("dfffdgfdg: "+job.getResult());

我需要有行监听器吗？但是如何将其设置为 KTR inside job 中的步骤。我完全糊涂了。请帮忙

Answer 1

在您的最后一个转换中，即 KTR，不要忘记添加步骤 - 将行复制到结果。之后 .. 当您通过 Java 运行 JOB 时。使用以下代码访问结果:

final List<RowMetaAndData> read;
read = job.getResult().getRows();