etl kettle plugin 实例

etl kettle plugin 实例

博客分类：
• kettle etl

kettleetlstepplugin

自己开发之前看过了网络上很多文章，大多文章简单直接翻译官网或转载，不适合初学者参考。现自己已经开发成功，将个人对程序的理解贴出给大家做个参考。

有图有真相，程序结构先看图：


Step 类实际要执行的业务逻辑，真对到行级的操作实现processRow方法。
StepData 数据流操作类，可以调用前一步的数据，再把它输出的下一步。
StepMeta 资源调用类，调用设置的资源信息。
Dialog UI设计时用到的类。
StepField 转换步骤附加属性（自己添加）。

具体代码实现接口的方法就行

Step 类

public class GJStep extends BaseStep implements StepInterface {
private GJStepData data;
private GJStepMeta meta;
private static Class<?> PKG = GJStepMeta.class; // for i18n

Data 类

public class GJStepData extends BaseStepData implements StepDataInterface {
public RowMetaInterface outputRowMeta;

Meta 类

public class GJStepMeta extends BaseStepMeta implements StepMetaInterface {
private static Class<?> PKG = GJStepMeta.class;

Dialog 类

public class GJStepDialog extends BaseStepDialog implements StepDialogInterface {
private static Class<?> PKG = GJStepMeta.class; // for i18n

有图有真相，整个工程结构 再看图：

工程编译， 当代码完成后可以直接打包，放到 kettle 的运行工程中使用。

有图有真相，目录结构 还看图：

其中 *.jar 为自己制作的 step 代码， *.png 为显示图标， plugin.xml 为配置文件主要是指定显示位置等：

有图有真相，展现效果 打开 UI 效果如下：

心得总结：

Kettle 的插件开发并不难，主要是弄清楚各个部分的代码结构和作用。希望本文能给初学者一下帮助