反正找了一天天也沒找到！?。?Kettle 6.1 相比 Kettle 3 改動太大了。下面直接上代碼，備忘！

在初始化

KettleEnvironment.init();   

添加插件如下代碼，就能夠注冊一個Step的插件了

List<String> empty = Collections.emptyList();
// 這個map別復(fù)用了，下一個插件重新new一個，不然即使clear了，下一個插件也不能注冊成功
Map<Class<?>,String> xxxxClassMap=new HashMap<Class<?>,String>();
// xxxxMeta 就是開發(fā)的插件的Meta類了
xxxxClassMap.put(StepMetaInterface.class,xxxxMeta.class.getName());
PluginInterface xxxxPlugin=new Plugin(
    new String[]{"MergeField"},
    StepPluginType.class,
    StepMetaInterface.class,
    "轉(zhuǎn)換",
    "插件的名字",
    "插件的描述，不影響java執(zhí)行",
    "插件的圖片，不影響java執(zhí)行",
    false,
    false,
    xxxxClassMap,
    empty,
    null,
    null);
PluginRegistry.getInstance().registerPlugin(StepPluginType.class,xxxxPlugin);

Map<Class<?>,String> anotherClassMap=new HashMap<Class<?>,String>();
// anotherMeta 就是開發(fā)的插件的Meta類了
xxxxClassMap.put(StepMetaInterface.class,anotherMeta.class.getName());
PluginInterface anotherPlugin=new Plugin(
    new String[]{"MergeField"},
    StepPluginType.class,
    StepMetaInterface.class,
    "轉(zhuǎn)換",
    "插件的名字",
    "插件的描述，不影響java執(zhí)行",
    "插件的圖片，不影響java執(zhí)行",
    false,
    false,
    anotherClassMap,
    empty,
    null,
    null);
PluginRegistry.getInstance().registerPlugin(StepPluginType.class,anotherPlugin);

如此這般就能運(yùn)行了
附上java調(diào)用stepMeta的完整代碼

KettleEnvironment.init();   
List<String> empty = Collections.emptyList();
// 這個map別復(fù)用了，下一個插件重新new一個，不然即使clear了，下一個插件也不能注冊成功
Map<Class<?>,String> xxxxClassMap=new HashMap<Class<?>,String>();
// xxxxMeta 就是開發(fā)的插件的Meta類了
xxxxClassMap.put(StepMetaInterface.class,xxxxMeta.class.getName());
PluginInterface xxxxPlugin=new Plugin(
    new String[]{"MergeField"},
    StepPluginType.class,
    StepMetaInterface.class,
    "轉(zhuǎn)換",
    "插件的名字",
    "插件的描述，不影響java執(zhí)行",
    "插件的圖片，不影響java執(zhí)行",
    false,
    false,
    xxxxClassMap,
    empty,
    null,
    null);
PluginRegistry.getInstance().registerPlugin(StepPluginType.class,xxxxPlugin);
// 數(shù)據(jù)庫連接元對象(連接名稱，不必與kettle中配置的保持一致：數(shù)據(jù)庫類型：連接方式（kettle支持的連接方式）：資源庫IP：資源庫實(shí)例名：資源庫端口：資源庫用戶名：資源庫用戶密碼)  
DatabaseMeta connection = new DatabaseMeta("資源庫名稱，不影響", "Oracle", DatabaseMeta.getAccessTypeDesc(0), "oracle的地址", "oracle的實(shí)例", "1521", "oracle用戶名", "oracle密碼");  
// 資源庫元對象  
KettleDatabaseRepositoryMeta repinfo = new KettleDatabaseRepositoryMeta();  
repinfo.setConnection(connection);  
// 資源庫  
KettleDatabaseRepository repository = new KettleDatabaseRepository();
repository.init(repinfo);
// 連接資源庫  
repository.connect("admin","admin",true);  
// 資源庫目錄對象 
RepositoryDirectoryInterface directoryInterface=repository.loadRepositoryDirectoryTree();
// 轉(zhuǎn)換元對象  
TransMeta transMeta=repository.loadTransformation("tran的名稱",directoryInterface,null,true,null);
// 轉(zhuǎn)換  
Trans trans = new Trans(transMeta);

// 執(zhí)行轉(zhuǎn)換  
trans.execute(null);  
// 等待轉(zhuǎn)換執(zhí)行結(jié)束  
if(trans.getErrors()>0){
    System.out.println("transformation error");
}else{
    System.out.println("transformation successfully");
}