import org.codehaus.janino.CompileException; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void cookClasses()
{
    cookErrors.clear();
    for (UserDefinedJavaClassDef def : getDefinitions())
    {
        if (def.isActive())
        {
            try
            {
                Class<?> cookedClass = cookClass(def);
                if (def.isTransformClass())
                {
                    cookedTransformClass = (Class<TransformClassBase>)cookedClass;
                }
            }
            catch (Exception e)
            {
                CompileException exception = new CompileException(e.getMessage(), null);
                exception.setStackTrace(new StackTraceElement[] {});
                cookErrors.add(exception);
            }
        }
    }
    changed=false;
}
 

import org.codehaus.janino.CompileException; //导入依赖的package包/类
@SuppressWarnings( "unchecked" )
public void cookClasses() {
  cookErrors.clear();
  for ( UserDefinedJavaClassDef def : getDefinitions() ) {
    if ( def.isActive() ) {
      try {
        Class<?> cookedClass = cookClass( def );
        if ( def.isTransformClass() ) {
          cookedTransformClass = (Class<TransformClassBase>) cookedClass;
        }
      } catch ( Throwable e ) {
        CompileException exception = new CompileException( e.getMessage(), null );
        exception.setStackTrace( new StackTraceElement[] {} );
        cookErrors.add( exception );
      }
    }
  }
  changed = false;
}
 

import org.codehaus.janino.CompileException; //导入依赖的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.CompileException; //导入依赖的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();
}