import org.codehaus.janino.Scanner.ScanException; //导入依赖的package包/类
private Class<?> cookClass(UserDefinedJavaClassDef def) throws CompileException, ParseException, ScanException, IOException, RuntimeException, KettleStepException {
	
    ClassBodyEvaluator cbe = new ClassBodyEvaluator();
    cbe.setClassName(def.getClassName());

    StringReader sr;
    if (def.isTransformClass())
    {
        cbe.setExtendedType(TransformClassBase.class);
        sr = new StringReader(def.getTransformedSource());
    }
    else
    {
        sr = new StringReader(def.getSource());
    }

    cbe.setDefaultImports(new String[] {
            "org.pentaho.di.trans.steps.userdefinedjavaclass.*",
            "org.pentaho.di.trans.step.*",
            "org.pentaho.di.core.row.*",
            "org.pentaho.di.core.*",
            "org.pentaho.di.core.exception.*"
    });
    cbe.cook(new Scanner(null, sr));

    return cbe.getClazz();
}
 

import org.codehaus.janino.Scanner.ScanException; //导入依赖的package包/类
private Class<?> cookClass( UserDefinedJavaClassDef def ) throws CompileException, ParseException,
  ScanException, IOException, RuntimeException, KettleStepException {

  if ( Thread.currentThread().getContextClassLoader() == null ) {
    Thread.currentThread().setContextClassLoader( this.getClass().getClassLoader() );
  }

  ClassBodyEvaluator cbe = new ClassBodyEvaluator();
  cbe.setParentClassLoader( Thread.currentThread().getContextClassLoader() );
  cbe.setClassName( def.getClassName() );

  StringReader sr;
  if ( def.isTransformClass() ) {
    cbe.setExtendedType( TransformClassBase.class );
    sr = new StringReader( def.getTransformedSource() );
  } else {
    sr = new StringReader( def.getSource() );
  }

  cbe.setDefaultImports( new String[] {
    "org.pentaho.di.trans.steps.userdefinedjavaclass.*", "org.pentaho.di.trans.step.*",
    "org.pentaho.di.core.row.*", "org.pentaho.di.core.*", "org.pentaho.di.core.exception.*" } );

  cbe.cook( new Scanner( null, sr ) );

  return cbe.getClazz();
}