package com.p.serv.util; import org.pentaho.di.core.KettleEnvironment; import org.pentaho.di.core.exception.KettleException; import org.pentaho.di.core.exception.KettleXMLException; import org.pentaho.di.job.Job; import org.pentaho.di.job.JobMeta; import org.pentaho.di.trans.Trans; import org.pentaho.di.trans.TransMeta; public class KettleExecu { public static 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 static void runTrans(String filename) { try { 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"); } } catch (KettleXMLException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (KettleException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static void main(String[] args) { String jobname = "F:\\ETL\\kettle\\例子\\测试\\复制多表\\copymanytablejob.kjb"; runJob(jobname); // String filename="D:/syslog_All/spoon/csv_fm.ktr"; // runTrans(filename); } }
相关推荐
java中调用kettle中的job与转换源码,其中kettle用的是5.2.0.0的版本。已经测试过可以调用访问,并且可以传入参数调用。有需要的可直接拿去使用。
java远程调用kettle说明与代码.pdf
Java代码调用kettle任务.pdf
使用java程序调用kettle的sap组件,由于从kettle7.0版本开始,sap组件作为插件形式加载,所以在项目工程中需要修改相应的配置文件及jar才可以被加载和调用。
java调用kettle使用示例,包含数据库到数据库,csv到数据库及数据库到excel数据同步调用代码。
在java应用程序中集成应用kettle,实现调用资源库上和本地的transformation和job。
kettle使用命令行来运行ktr和kjb
使用java调用kettle的jar包,实现同步任务的调度,内含简单的demo
java调用kettle中的Job或是Trans要用到的jar包
kettle环境搭建源文件(first-job.kjb)
java调用Kettle引用jar包
kettle-engine.jar java版本 亲测好用
NULL 博文链接:https://zihai367.iteye.com/blog/2262856
java调用Kettle引用jar包.zip
1、kettle-password-encoder-plugins.xml这个文件放在src/main/resources/下边 2、执行main函数即可
本资源主要内容包括(资源有保证,都是干货,一看就会): ...2.JAVA传参调用KETTLE远程服务执行任务实现过程及注意事项说明。 3.附件包括:配套说明文档、代码包、KETLLE任务测试文件及数据库脚本。
java 调用设计好的作业(.ktr)或转换(.kjb)