etl kettle plugin 实例

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

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


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