Package org.pentaho.di.trans.steps.transexecutor

Class TransExecutor

  • All Implemented Interfaces:
    org.pentaho.di.core.ExtensionDataInterface, HasLogChannelInterface, org.pentaho.di.core.logging.LoggingObjectInterface, org.pentaho.di.core.logging.LoggingObjectLifecycleInterface, org.pentaho.di.core.variables.VariableSpace, StepInterface
    public class TransExecutor
extends BaseStep
implements StepInterface
    Execute a transformation for every input row, set parameters.

    Note:
    Be aware, logic of the classes methods is very similar to corresponding methods of JobExecutor. If you change something in this class, consider copying your changes to JobExecutor as well.

    Since:
    18-mar-2013
    Author:
    Matt

    • Method Detail

      • processRow

        public boolean processRow​(StepMetaInterface smi,
                          StepDataInterface sdi)
                   throws org.pentaho.di.core.exception.KettleException
        Process a single row. In our case, we send one row of data to a piece of transformation. In the transformation, we look up the MappingInput step to send our rows to it. As a consequence, for the time being, there can only be one MappingInput and one MappingOutput step in the TransExecutor.
        Specified by:
        processRow in interface StepInterface
        Overrides:
        processRow in class BaseStep
        Parameters:
        smi - The steps metadata to work with
        sdi - The steps temporary working data to work with (database connections, result sets, caches, temporary variables, etc.)
        Returns:
        false if no more rows can be processed or an error occurred.
        Throws:
        org.pentaho.di.core.exception.KettleException

      • stopRunning

        public void stopRunning​(StepMetaInterface stepMetaInterface,
                        StepDataInterface stepDataInterface)
                 throws org.pentaho.di.core.exception.KettleException
        Description copied from class: BaseStep
        Perform actions to stop a running step. This can be stopping running SQL queries (cancel), etc. Default it doesn't do anything.
        Specified by:
        stopRunning in interface StepInterface
        Overrides:
        stopRunning in class BaseStep
        Parameters:
        stepMetaInterface - The metadata that might be needed by the step to stop running.
        stepDataInterface - The interface to the step data containing the connections, resultsets, open files, etc.
        Throws:
        org.pentaho.di.core.exception.KettleException - in case something goes wrong

      • getExecutorTrans

        public Trans getExecutorTrans()

      • getLastIncomingFieldValues

        protected List<String> getLastIncomingFieldValues()