ETL工具Pentaho Kettle的transformation和job集成

KettleEnvironment.init();//资源库类型插件初始化PluginRegistry.init();//资源库对象实例化Repository repository=null;RepositoriesMeta repositoriesMeta = new RepositoriesMeta();//读取资源库repositoriesMeta.readData();//遍历资源库/*for ( int i = 0; i < repositoriesMeta.nrRepositories(); i++ ) {RepositoryMeta rinfo = repositoriesMeta.getRepository( i );System.out.println( "#"+ ( i + 1 ) + " : " + rinfo.getName() + " [" + rinfo.getDescription() + "] id=" + rinfo.getId() );}*/RepositoryMeta repositoryMeta = repositoriesMeta.findRepository( "1.0" );PluginRegistry registry = PluginRegistry.getInstance();//加载资源库repository = registry.loadClass(RepositoryPluginType.class,repositoryMeta, Repository.class);//资源库初始化repository.init(repositoryMeta);//获取资源库路径RepositoryDirectoryInterface directory = repository.loadRepositoryDirectoryTree();// JobMeta实例化JobMeta jobmeta = new JobMeta();jobmeta = repository.loadJob("job2", directory, null, null);//job实例化Job job = null;job = new Job(repository, jobmeta);job.start();job.waitUntilFinished();//获取执行结果Result result=job.getResult();

,不要等待机会,而要创造机会。

ETL工具Pentaho Kettle的transformation和job集成

相关文章:

你感兴趣的文章:

标签云: