Package org.pentaho.di.trans

Class SingleThreadedTransExecutor

java.lang.Object
org.pentaho.di.trans.SingleThreadedTransExecutor
public class SingleThreadedTransExecutor extends Object

  • Constructor Details

    • SingleThreadedTransExecutor

      public SingleThreadedTransExecutor(Trans trans)

  • Method Details

    • init

      public boolean init() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • oneIteration

      public boolean oneIteration() throws org.pentaho.di.core.exception.KettleException
      Give all steps in the transformation the chance to process all rows on input...
      Returns:
      true if more iterations can be performed. False if this is not the case.
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTotalRows

      protected int getTotalRows(List<org.pentaho.di.core.RowSet> rowSets)

    • getErrors

      public long getErrors()

    • getResult

      public org.pentaho.di.core.Result getResult()

    • isStopped

      public boolean isStopped()

    • beforeStartProcessing

      public boolean beforeStartProcessing(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • afterFinishProcessing

      public boolean afterFinishProcessing(StepMetaInterface smi, StepDataInterface sdi) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • dispose

      public void dispose() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

    • getTrans

      public Trans getTrans()

    • clearError

      public void clearError()
      Clear the error in the transformation, clear all the rows from all the row sets...