Package org.pentaho.di.trans.steps.databasejoin

Class DatabaseJoin

  • 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 DatabaseJoin
extends BaseStep
implements StepInterface
    Use values from input streams to joins with values in a database. Freehand SQL can be used to do this.
    Since:
    26-apr-2003
    Author:
    Matt

    • Method Detail

      • processRow

        public boolean processRow​(StepMetaInterface smi,
                          StepDataInterface sdi)
                   throws org.pentaho.di.core.exception.KettleException
        Description copied from interface: StepInterface
        Perform the equivalent of processing one row. Typically this means reading a row from input (getRow()) and passing a row to output (putRow)).
        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 smi,
                        StepDataInterface sdi)
                 throws org.pentaho.di.core.exception.KettleException
        Stop the running query [PDI-17820] - In the Database Join step data.isCancelled is checked before synchronization and set after synchronization is completed. To cancel a prepared statement we need a valid database connection which we do not have if disposed has already been called
        Specified by:
        stopRunning in interface StepInterface
        Overrides:
        stopRunning in class BaseStep
        Parameters:
        smi - The metadata that might be needed by the step to stop running.
        sdi - 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