原创文章

Kettle4.0 Java API调用

刚下了4.2，用来试试public void runJob(String jobname){ try { KettleEnvironment.init(); //jobname 是Job脚本的路径及名称 JobMeta jobMeta = new JobMeta(jobname, null); Job job = new Job(null, jobMeta); //向Job 脚本传递参数，脚本中获取参数值：${参数名} job.setVariable(paraname, paravalue); job.start(); job.waitUntilFinished(); if (job.getErrors() > 0) { System.out.println("decompress fail!"); } } catch (KettleException e) { System.out.println(e); } } //调用Transformation示例： public void runTrans(String filename) throws Exception { KettleEnvironment.init(); TransMeta transMeta = new TransMeta(filename); Trans trans = new Trans(transMeta); trans.prepareExecution(null); trans.startThreads(); trans.waitUntilFinished(); if (trans.getErrors()!=0) { System.out.println("Error"); } } 4 楼 flownclouds 2012-05-03 下载不了哦，可否发个附件共享下英雄