Package org.pentaho.di.trans

Class SingleThreadedTransExecutor

java.lang.Object

org.pentaho.di.trans.SingleThreadedTransExecutor

public class SingleThreadedTransExecutor
extends Object

Constructor Summary

Constructors

Constructor	Description
SingleThreadedTransExecutor(Trans trans)

Method Summary

Modifier and Type	Method	Description
boolean	afterFinishProcessing(StepMetaInterface smi, StepDataInterface sdi)
boolean	beforeStartProcessing(StepMetaInterface smi, StepDataInterface sdi)
void	clearError()	Clear the error in the transformation, clear all the rows from all the row sets...
void	dispose()
long	getErrors()
org.pentaho.di.core.Result	getResult()
protected int	getTotalRows(List<org.pentaho.di.core.RowSet> rowSets)
Trans	getTrans()
boolean	init()
boolean	isStopped()
boolean	oneIteration()	Give all steps in the transformation the chance to process all rows on input...

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SingleThreadedTransExecutor

public SingleThreadedTransExecutor(Trans trans)

Method Detail

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...