...
Code Block |
---|
Trans Trans = new Trans(transMeta); // prepare the execution of the transformation (instead of simply execute) // trans.prepareExecution(arguments); // AttachFind a step rowthread listener to a step copy(ready to run but not yet started) // You can also use method Trans.findBaseStep which gives back a list of all the step copies // StepInterface step = trans.findRunThread("Your Step Name"); // Attach a row listener to a step copy // step.addRowListener(new RowAdapter() { public void rowReadEvent(RowMetaInterface rowMeta, Object[] row) throws KettleStepException { // Here you get the rows as they are read by the step } public void rowWrittenEvent(RowMetaInterface rowMeta, Object[] row) throws KettleStepException { // Here you get the rows as they are written by the step }public void rowWrittenEvent(RowMetaInterface rowMeta, Object[] row) throws KettleStepException { } } ); // Now start the transformation threads... // trans.startThreads(); // If you want to wait until the transformation is finished... // trans.waitUntilFinished(); // // If you want to know about the execution result. // Result result = trans.getResult(); |