Package org.pentaho.di.trans.steps.userdefinedjavaclass

Class UserDefinedJavaClass

  • 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 UserDefinedJavaClass
extends BaseStep
implements StepInterface

    • Method Detail

      • addResultFile

        public void addResultFile​(org.pentaho.di.core.ResultFile resultFile)
        Description copied from class: BaseStep
        Adds the result file.
        Overrides:
        addResultFile in class BaseStep
        Parameters:
        resultFile - the result file

      • addResultFileImpl

        public void addResultFileImpl​(org.pentaho.di.core.ResultFile resultFile)

      • addRowListener

        public void addRowListener​(RowListener rowListener)
        Description copied from interface: StepInterface
        Add a rowlistener to the step allowing you to inspect (or manipulate, be careful) the rows coming in or exiting the step.
        Specified by:
        addRowListener in interface StepInterface
        Overrides:
        addRowListener in class BaseStep
        Parameters:
        rowListener - the rowlistener to add

      • addRowListenerImpl

        public void addRowListenerImpl​(RowListener rowListener)

      • addStepListener

        public void addStepListener​(StepListener stepListener)
        Description copied from interface: StepInterface
        Attach a step listener to be notified when a step arrives in a certain state. (finished)
        Specified by:
        addStepListener in interface StepInterface
        Overrides:
        addStepListener in class BaseStep
        Parameters:
        stepListener - The listener to add to the step

      • addStepListenerImpl

        public void addStepListenerImpl​(StepListener stepListener)

      • checkFeedback

        public boolean checkFeedback​(long lines)
        Description copied from class: BaseStep
        Check feedback.
        Overrides:
        checkFeedback in class BaseStep
        Parameters:
        lines - the lines
        Returns:
        true, if successful

      • checkFeedbackImpl

        public boolean checkFeedbackImpl​(long lines)

      • cleanup

        public void cleanup()
        Description copied from interface: StepInterface
        Call this method typically, after ALL the slave transformations in a clustered run have finished.
        Specified by:
        cleanup in interface StepInterface
        Overrides:
        cleanup in class BaseStep

      • cleanupImpl

        public void cleanupImpl()

      • decrementLinesRead

        public long decrementLinesRead()
        Description copied from class: BaseStep
        Decrements the number of lines read from previous steps by one
        Overrides:
        decrementLinesRead in class BaseStep
        Returns:
        Returns the new value

      • decrementLinesReadImpl

        public long decrementLinesReadImpl()

      • decrementLinesWritten

        public long decrementLinesWritten()
        Description copied from class: BaseStep
        Decrements the number of lines written to next steps by one
        Overrides:
        decrementLinesWritten in class BaseStep
        Returns:
        Returns the new value

      • decrementLinesWrittenImpl

        public long decrementLinesWrittenImpl()

      • findInputRowSet

        public org.pentaho.di.core.RowSet findInputRowSet​(String sourceStep)
                                           throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        Find input row set.
        Overrides:
        findInputRowSet in class BaseStep
        Parameters:
        sourceStep - the source step
        Returns:
        the row set
        Throws:
        org.pentaho.di.core.exception.KettleStepException - the kettle step exception

      • findInputRowSet

        public org.pentaho.di.core.RowSet findInputRowSet​(String from,
                                                  int fromcopy,
                                                  String to,
                                                  int tocopy)
        Description copied from class: BaseStep
        Find input row set.
        Overrides:
        findInputRowSet in class BaseStep
        Parameters:
        from - the from
        fromcopy - the fromcopy
        to - the to
        tocopy - the tocopy
        Returns:
        the row set

      • findInputRowSetImpl

        public org.pentaho.di.core.RowSet findInputRowSetImpl​(String sourceStep)
                                               throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • findInputRowSetImpl

        public org.pentaho.di.core.RowSet findInputRowSetImpl​(String from,
                                                      int fromcopy,
                                                      String to,
                                                      int tocopy)

      • findOutputRowSet

        public org.pentaho.di.core.RowSet findOutputRowSet​(String targetStep)
                                            throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        Find output row set.
        Overrides:
        findOutputRowSet in class BaseStep
        Parameters:
        targetStep - the target step
        Returns:
        the row set
        Throws:
        org.pentaho.di.core.exception.KettleStepException - the kettle step exception

      • findOutputRowSet

        public org.pentaho.di.core.RowSet findOutputRowSet​(String from,
                                                   int fromcopy,
                                                   String to,
                                                   int tocopy)
        Description copied from class: BaseStep
        Find an output rowset in a running transformation. It will also look at the "to" step to see if this is a mapping. If it is, it will find the appropriate rowset in that transformation.
        Overrides:
        findOutputRowSet in class BaseStep
        Returns:
        The rowset or null if none is found.

      • findOutputRowSetImpl

        public org.pentaho.di.core.RowSet findOutputRowSetImpl​(String targetStep)
                                                throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • findOutputRowSetImpl

        public org.pentaho.di.core.RowSet findOutputRowSetImpl​(String from,
                                                       int fromcopy,
                                                       String to,
                                                       int tocopy)

      • getClusterSize

        public int getClusterSize()
        Description copied from class: BaseStep
        Returns the cluster size.
        Overrides:
        getClusterSize in class BaseStep
        Returns:
        the cluster size

      • getClusterSizeImpl

        public int getClusterSizeImpl()

      • getCopyImpl

        public int getCopyImpl()

      • getErrorRowMeta

        public org.pentaho.di.core.row.RowMetaInterface getErrorRowMeta()
        Overrides:
        getErrorRowMeta in class BaseStep
        Returns:
        the errorRowMeta

      • getErrorRowMetaImpl

        public org.pentaho.di.core.row.RowMetaInterface getErrorRowMetaImpl()

      • getErrorsImpl

        public long getErrorsImpl()

      • getInputRowMeta

        public org.pentaho.di.core.row.RowMetaInterface getInputRowMeta()
        Overrides:
        getInputRowMeta in class BaseStep
        Returns:
        the rowMeta

      • getInputRowMetaImpl

        public org.pentaho.di.core.row.RowMetaInterface getInputRowMetaImpl()

      • getInputRowSetsImpl

        public List<org.pentaho.di.core.RowSet> getInputRowSetsImpl()

      • getLinesInput

        public long getLinesInput()
        Specified by:
        getLinesInput in interface StepInterface
        Overrides:
        getLinesInput in class BaseStep
        Returns:
        Returns the number of lines read from an input source: database, file, socket, etc.

      • getLinesInputImpl

        public long getLinesInputImpl()

      • getLinesOutput

        public long getLinesOutput()
        Specified by:
        getLinesOutput in interface StepInterface
        Overrides:
        getLinesOutput in class BaseStep
        Returns:
        Returns the number of lines written to an output target: database, file, socket, etc.

      • getLinesOutputImpl

        public long getLinesOutputImpl()

      • getLinesReadImpl

        public long getLinesReadImpl()

      • getLinesRejectedImpl

        public long getLinesRejectedImpl()

      • getLinesSkipped

        public long getLinesSkipped()
        Overrides:
        getLinesSkipped in class BaseStep
        Returns:
        the number of lines skipped

      • getLinesSkippedImpl

        public long getLinesSkippedImpl()

      • getLinesUpdatedImpl

        public long getLinesUpdatedImpl()

      • getLinesWrittenImpl

        public long getLinesWrittenImpl()

      • getOutputRowSetsImpl

        public List<org.pentaho.di.core.RowSet> getOutputRowSetsImpl()

      • getPartitionIDImpl

        public String getPartitionIDImpl()

      • getPartitionTargets

        public Map<String,​org.pentaho.di.core.BlockingRowSet> getPartitionTargets()
        Overrides:
        getPartitionTargets in class BaseStep
        Returns:
        the partitionTargets

      • getPartitionTargetsImpl

        public Map<String,​org.pentaho.di.core.BlockingRowSet> getPartitionTargetsImpl()

      • getProcessed

        public long getProcessed()
        Specified by:
        getProcessed in interface StepInterface
        Overrides:
        getProcessed in class BaseStep
        Returns:
        The number of "processed" lines of a step. Well, a representable metric for that anyway.

      • getProcessedImpl

        public long getProcessedImpl()

      • getRepartitioning

        public int getRepartitioning()
        Overrides:
        getRepartitioning in class BaseStep
        Returns:
        the repartitioning type

      • getRepartitioningImpl

        public int getRepartitioningImpl()

      • getResultFilesImpl

        public Map<String,​org.pentaho.di.core.ResultFile> getResultFilesImpl()

      • getRow

        public Object[] getRow()
                throws org.pentaho.di.core.exception.KettleException
        Description copied from class: BaseStep
        In case of getRow, we receive data from previous steps through the input rowset. In case we split the stream, we have to copy the data to the alternate splits: rowsets 1 through n.
        Specified by:
        getRow in interface StepInterface
        Overrides:
        getRow in class BaseStep
        Returns:
        a row from the source step(s).
        Throws:
        org.pentaho.di.core.exception.KettleException

      • getRowFrom

        public Object[] getRowFrom​(org.pentaho.di.core.RowSet rowSet)
                    throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        Gets the row from.
        Overrides:
        getRowFrom in class BaseStep
        Parameters:
        rowSet - the row set
        Returns:
        the row from
        Throws:
        org.pentaho.di.core.exception.KettleStepException - the kettle step exception

      • getRowFromImpl

        public Object[] getRowFromImpl​(org.pentaho.di.core.RowSet rowSet)
                        throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • getRowImpl

        public Object[] getRowImpl()
                    throws org.pentaho.di.core.exception.KettleException
        Throws:
        org.pentaho.di.core.exception.KettleException

      • getRuntimeImpl

        public long getRuntimeImpl()

      • getSlaveNr

        public int getSlaveNr()
        Description copied from class: BaseStep
        Returns the unique slave number in the cluster.
        Overrides:
        getSlaveNr in class BaseStep
        Returns:
        the unique slave number in the cluster

      • getSlaveNrImpl

        public int getSlaveNrImpl()

      • getStatusDescription

        public String getStatusDescription()
        Description copied from class: BaseStep
        Gets the status description.
        Overrides:
        getStatusDescription in class BaseStep
        Returns:
        the status description

      • getStatusDescriptionImpl

        public String getStatusDescriptionImpl()

      • getStepIDImpl

        public String getStepIDImpl()

      • getStepMetaImpl

        public StepMeta getStepMetaImpl()

      • getStepnameImpl

        public String getStepnameImpl()

      • getTransImpl

        public Trans getTransImpl()

      • getTransMetaImpl

        public TransMeta getTransMetaImpl()

      • getTypeId

        public String getTypeId()
        Description copied from class: BaseStep
        Returns the step ID via the getStepID() method call. Support for CheckResultSourceInterface.
        Overrides:
        getTypeId in class BaseStep
        Returns:
        getStepID()

      • getTypeIdImpl

        public String getTypeIdImpl()

      • getUniqueStepCountAcrossSlaves

        public int getUniqueStepCountAcrossSlaves()
        Description copied from class: BaseStep
        Returns the number of unique steps across all slave servers.
        Overrides:
        getUniqueStepCountAcrossSlaves in class BaseStep
        Returns:
        the number of unique steps across all slave servers

      • getUniqueStepCountAcrossSlavesImpl

        public int getUniqueStepCountAcrossSlavesImpl()

      • getUniqueStepNrAcrossSlaves

        public int getUniqueStepNrAcrossSlaves()
        Description copied from class: BaseStep
        Returns a unique step number across all slave servers: slaveNr * nrCopies + copyNr.
        Overrides:
        getUniqueStepNrAcrossSlaves in class BaseStep
        Returns:
        a unique step number across all slave servers: slaveNr * nrCopies + copyNr

      • getUniqueStepNrAcrossSlavesImpl

        public int getUniqueStepNrAcrossSlavesImpl()

      • getVariable

        public String getVariable​(String variableName)
        Specified by:
        getVariable in interface org.pentaho.di.core.variables.VariableSpace
        Overrides:
        getVariable in class BaseStep

      • getVariable

        public String getVariable​(String variableName,
                          String defaultValue)
        Specified by:
        getVariable in interface org.pentaho.di.core.variables.VariableSpace
        Overrides:
        getVariable in class BaseStep

      • getVariableImpl

        public String getVariableImpl​(String variableName)

      • getVariableImpl

        public String getVariableImpl​(String variableName,
                              String defaultValue)

      • incrementLinesInput

        public long incrementLinesInput()
        Description copied from class: BaseStep
        Increments the number of lines read from an input source: database, file, socket, etc.
        Overrides:
        incrementLinesInput in class BaseStep
        Returns:
        the new incremented value

      • incrementLinesInputImpl

        public long incrementLinesInputImpl()

      • incrementLinesOutput

        public long incrementLinesOutput()
        Description copied from class: BaseStep
        Increments the number of lines written to an output target: database, file, socket, etc.
        Overrides:
        incrementLinesOutput in class BaseStep
        Returns:
        the new incremented value

      • incrementLinesOutputImpl

        public long incrementLinesOutputImpl()

      • incrementLinesRead

        public long incrementLinesRead()
        Description copied from class: BaseStep
        Increments the number of lines read from previous steps by one
        Overrides:
        incrementLinesRead in class BaseStep
        Returns:
        Returns the new value

      • incrementLinesReadImpl

        public long incrementLinesReadImpl()

      • incrementLinesRejected

        public long incrementLinesRejected()
        Description copied from class: BaseStep
        Increments the number of lines rejected to an error handling step
        Overrides:
        incrementLinesRejected in class BaseStep
        Returns:
        the new incremented value

      • incrementLinesRejectedImpl

        public long incrementLinesRejectedImpl()

      • incrementLinesSkipped

        public long incrementLinesSkipped()
        Description copied from class: BaseStep
        Increments the number of lines skipped
        Overrides:
        incrementLinesSkipped in class BaseStep
        Returns:
        the new incremented value

      • incrementLinesSkippedImpl

        public long incrementLinesSkippedImpl()

      • incrementLinesUpdated

        public long incrementLinesUpdated()
        Description copied from class: BaseStep
        Increments the number of lines updated in an output target: database, file, socket, etc.
        Overrides:
        incrementLinesUpdated in class BaseStep
        Returns:
        the new incremented value

      • incrementLinesUpdatedImpl

        public long incrementLinesUpdatedImpl()

      • incrementLinesWritten

        public long incrementLinesWritten()
        Description copied from class: BaseStep
        Increments the number of lines written to next steps by one
        Overrides:
        incrementLinesWritten in class BaseStep
        Returns:
        Returns the new value

      • incrementLinesWrittenImpl

        public long incrementLinesWrittenImpl()

      • init

        public boolean init​(StepMetaInterface stepMetaInterface,
                    StepDataInterface stepDataInterface)
        Description copied from interface: StepInterface
        Initialize and do work where other steps need to wait for...
        Specified by:
        init in interface StepInterface
        Overrides:
        init in class BaseStep
        Parameters:
        stepMetaInterface - The metadata to work with
        stepDataInterface - The data to initialize

      • initBeforeStart

        public void initBeforeStart()
                     throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        This method is executed by Trans right before the threads start and right after initialization.

        More to the point: here we open remote output step sockets.

        Specified by:
        initBeforeStart in interface StepInterface
        Overrides:
        initBeforeStart in class BaseStep
        Throws:
        org.pentaho.di.core.exception.KettleStepException - In case there is an error

      • initBeforeStartImpl

        public void initBeforeStartImpl()
                         throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • isDistributed

        public boolean isDistributed()
        Overrides:
        isDistributed in class BaseStep
        Returns:
        Returns the distributed.

      • isDistributedImpl

        public boolean isDistributedImpl()

      • isInitialising

        public boolean isInitialising()
        Description copied from class: BaseStep
        Checks if is initialising.
        Overrides:
        isInitialising in class BaseStep
        Returns:
        true, if is initialising

      • isInitialisingImpl

        public boolean isInitialisingImpl()

      • isPartitionedImpl

        public boolean isPartitionedImpl()

      • isSafeModeEnabled

        public boolean isSafeModeEnabled()

      • isSafeModeEnabledImpl

        public boolean isSafeModeEnabledImpl()

      • isStopped

        public boolean isStopped()
        Specified by:
        isStopped in interface StepInterface
        Overrides:
        isStopped in class BaseStep
        Returns:
        True if the step is marked as stopped. Execution should stop immediate.

      • isStoppedImpl

        public boolean isStoppedImpl()

      • isUsingThreadPriorityManagmentImpl

        public boolean isUsingThreadPriorityManagmentImpl()

      • logBasic

        public void logBasic​(String s)
        Description copied from class: BaseStep
        Log basic.
        Overrides:
        logBasic in class BaseStep
        Parameters:
        s - the message

      • logBasicImpl

        public void logBasicImpl​(String s)

      • logDebug

        public void logDebug​(String s)
        Description copied from class: BaseStep
        Log debug.
        Overrides:
        logDebug in class BaseStep
        Parameters:
        s - the message

      • logDebugImpl

        public void logDebugImpl​(String s)

      • logDetailed

        public void logDetailed​(String s)
        Description copied from class: BaseStep
        Log detailed.
        Overrides:
        logDetailed in class BaseStep
        Parameters:
        s - the message

      • logDetailedImpl

        public void logDetailedImpl​(String s)

      • logError

        public void logError​(String s)
        Description copied from class: BaseStep
        Log error.
        Overrides:
        logError in class BaseStep
        Parameters:
        s - the message

      • logErrorImpl

        public void logErrorImpl​(String s)

      • logMinimal

        public void logMinimal​(String s)
        Description copied from class: BaseStep
        Log minimal.
        Overrides:
        logMinimal in class BaseStep
        Parameters:
        s - the message

      • logMinimalImpl

        public void logMinimalImpl​(String s)

      • logRowlevel

        public void logRowlevel​(String s)
        Description copied from class: BaseStep
        Log rowlevel.
        Overrides:
        logRowlevel in class BaseStep
        Parameters:
        s - the message

      • logRowlevelImpl

        public void logRowlevelImpl​(String s)

      • logSummary

        public void logSummary()
        Description copied from class: BaseStep
        Log summary.
        Overrides:
        logSummary in class BaseStep

      • logSummaryImpl

        public void logSummaryImpl()

      • markStartImpl

        public void markStartImpl()

      • markStopImpl

        public void markStopImpl()

      • openRemoteInputStepSocketsOnce

        public void openRemoteInputStepSocketsOnce()
                                    throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        Opens socket connections to the remote input steps of this step.
        This method should be used by steps that don't call getRow() first in which it is executed automatically.
        This method should be called before any data is read from previous steps.
        This action is executed only once.
        Overrides:
        openRemoteInputStepSocketsOnce in class BaseStep
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • openRemoteInputStepSocketsOnceImpl

        public void openRemoteInputStepSocketsOnceImpl()
                                        throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • openRemoteOutputStepSocketsOnce

        public void openRemoteOutputStepSocketsOnce()
                                     throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        Opens socket connections to the remote output steps of this step.
        This method is called in method initBeforeStart() because it needs to connect to the server sockets (remote steps) as soon as possible to avoid time-out situations.
        This action is executed only once.
        Overrides:
        openRemoteOutputStepSocketsOnce in class BaseStep
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • openRemoteOutputStepSocketsOnceImpl

        public void openRemoteOutputStepSocketsOnceImpl()
                                         throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • outputIsDone

        public boolean outputIsDone()
        Description copied from class: BaseStep
        Output is done.
        Overrides:
        outputIsDone in class BaseStep
        Returns:
        true, if successful

      • outputIsDoneImpl

        public boolean outputIsDoneImpl()

      • 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

      • putError

        public void putError​(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                     Object[] row,
                     long nrErrors,
                     String errorDescriptions,
                     String fieldNames,
                     String errorCodes)
              throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        Put error.
        Overrides:
        putError in class BaseStep
        Parameters:
        rowMeta - the row meta
        row - the row
        nrErrors - the nr errors
        errorDescriptions - the error descriptions
        fieldNames - the field names
        errorCodes - the error codes
        Throws:
        org.pentaho.di.core.exception.KettleStepException - the kettle step exception

      • putErrorImpl

        public void putErrorImpl​(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                         Object[] row,
                         long nrErrors,
                         String errorDescriptions,
                         String fieldNames,
                         String errorCodes)
                  throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • putRow

        public void putRow​(org.pentaho.di.core.row.RowMetaInterface row,
                   Object[] data)
            throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        putRow is used to copy a row, to the alternate rowset(s) This should get priority over everything else! (synchronized) If distribute is true, a row is copied only once to the output rowsets, otherwise copies are sent to each rowset!
        Specified by:
        putRow in interface StepInterface
        Overrides:
        putRow in class BaseStep
        Parameters:
        row - The row to send to the destinations steps
        data - The row to put to the destination rowset(s).
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • putRowImpl

        public void putRowImpl​(org.pentaho.di.core.row.RowMetaInterface row,
                       Object[] data)
                throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • putRowTo

        public void putRowTo​(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                     Object[] row,
                     org.pentaho.di.core.RowSet rowSet)
              throws org.pentaho.di.core.exception.KettleStepException
        Description copied from class: BaseStep
        putRowTo is used to put a row in a certain specific RowSet.
        Overrides:
        putRowTo in class BaseStep
        Parameters:
        rowMeta - The row meta-data to put to the destination RowSet.
        row - the data to put in the RowSet
        rowSet - the RoWset to put the row into.
        Throws:
        org.pentaho.di.core.exception.KettleStepException - In case something unexpected goes wrong

      • putRowToImpl

        public void putRowToImpl​(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                         Object[] row,
                         org.pentaho.di.core.RowSet rowSet)
                  throws org.pentaho.di.core.exception.KettleStepException
        Throws:
        org.pentaho.di.core.exception.KettleStepException

      • removeRowListenerImpl

        public void removeRowListenerImpl​(RowListener rowListener)

      • rowsetInputSizeImpl

        public int rowsetInputSizeImpl()

      • rowsetOutputSizeImpl

        public int rowsetOutputSizeImpl()

      • safeModeChecking

        public void safeModeChecking​(org.pentaho.di.core.row.RowMetaInterface row)
                      throws org.pentaho.di.core.exception.KettleRowException
        Description copied from class: BaseStep
        Safe mode checking.
        Overrides:
        safeModeChecking in class BaseStep
        Parameters:
        row - the row
        Throws:
        org.pentaho.di.core.exception.KettleRowException - the kettle row exception

      • safeModeCheckingImpl

        public void safeModeCheckingImpl​(org.pentaho.di.core.row.RowMetaInterface row)
                          throws org.pentaho.di.core.exception.KettleRowException
        Throws:
        org.pentaho.di.core.exception.KettleRowException

      • setErrors

        public void setErrors​(long errors)
        Description copied from interface: StepInterface
        Sets the number of errors
        Specified by:
        setErrors in interface StepInterface
        Overrides:
        setErrors in class BaseStep
        Parameters:
        errors - the number of errors to set

      • setErrorsImpl

        public void setErrorsImpl​(long errors)

      • setInputRowMeta

        public void setInputRowMeta​(org.pentaho.di.core.row.RowMetaInterface rowMeta)
        Overrides:
        setInputRowMeta in class BaseStep
        Parameters:
        rowMeta - the rowMeta to set

      • setInputRowMetaImpl

        public void setInputRowMetaImpl​(org.pentaho.di.core.row.RowMetaInterface rowMeta)

      • setInputRowSets

        public void setInputRowSets​(List<org.pentaho.di.core.RowSet> inputRowSets)
        Overrides:
        setInputRowSets in class BaseStep
        Parameters:
        inputRowSets - The inputRowSets to set.

      • setInputRowSetsImpl

        public void setInputRowSetsImpl​(List<org.pentaho.di.core.RowSet> inputRowSets)

      • setLinesInput

        public void setLinesInput​(long newLinesInputValue)
        Overrides:
        setLinesInput in class BaseStep
        Parameters:
        newLinesInputValue - the new number of lines read from an input source: database, file, socket, etc.

      • setLinesInputImpl

        public void setLinesInputImpl​(long newLinesInputValue)

      • setLinesOutput

        public void setLinesOutput​(long newLinesOutputValue)
        Overrides:
        setLinesOutput in class BaseStep
        Parameters:
        newLinesOutputValue - the new number of lines written to an output target: database, file, socket, etc.

      • setLinesOutputImpl

        public void setLinesOutputImpl​(long newLinesOutputValue)

      • setLinesRead

        public void setLinesRead​(long newLinesReadValue)
        Overrides:
        setLinesRead in class BaseStep
        Parameters:
        newLinesReadValue - the new number of lines read from previous steps

      • setLinesReadImpl

        public void setLinesReadImpl​(long newLinesReadValue)

      • setLinesRejected

        public void setLinesRejected​(long linesRejected)
        Specified by:
        setLinesRejected in interface StepInterface
        Overrides:
        setLinesRejected in class BaseStep
        Parameters:
        linesRejected - lines number of lines rejected to an error handling step

      • setLinesRejectedImpl

        public void setLinesRejectedImpl​(long linesRejected)

      • setLinesSkipped

        public void setLinesSkipped​(long newLinesSkippedValue)
        Overrides:
        setLinesSkipped in class BaseStep
        Parameters:
        newLinesSkippedValue - lines number of lines skipped

      • setLinesSkippedImpl

        public void setLinesSkippedImpl​(long newLinesSkippedValue)

      • setLinesUpdated

        public void setLinesUpdated​(long newLinesUpdatedValue)
        Overrides:
        setLinesUpdated in class BaseStep
        Parameters:
        newLinesUpdatedValue - the new number of lines updated in an output target: database, file, socket, etc.

      • setLinesUpdatedImpl

        public void setLinesUpdatedImpl​(long newLinesUpdatedValue)

      • setLinesWritten

        public void setLinesWritten​(long newLinesWrittenValue)
        Overrides:
        setLinesWritten in class BaseStep
        Parameters:
        newLinesWrittenValue - the new number of lines written to next steps

      • setLinesWrittenImpl

        public void setLinesWrittenImpl​(long newLinesWrittenValue)

      • setOutputDoneImpl

        public void setOutputDoneImpl()

      • setOutputRowSets

        public void setOutputRowSets​(List<org.pentaho.di.core.RowSet> outputRowSets)
        Overrides:
        setOutputRowSets in class BaseStep
        Parameters:
        outputRowSets - The outputRowSets to set.

      • setOutputRowSetsImpl

        public void setOutputRowSetsImpl​(List<org.pentaho.di.core.RowSet> outputRowSets)

      • setStepListeners

        public void setStepListeners​(List<StepListener> stepListeners)
        Description copied from class: BaseStep
        Sets the step listeners.
        Overrides:
        setStepListeners in class BaseStep
        Parameters:
        stepListeners - the stepListeners to set

      • setStepListenersImpl

        public void setStepListenersImpl​(List<StepListener> stepListeners)

      • setVariable

        public void setVariable​(String variableName,
                        String variableValue)
        Specified by:
        setVariable in interface org.pentaho.di.core.variables.VariableSpace
        Overrides:
        setVariable in class BaseStep

      • setVariableImpl

        public void setVariableImpl​(String variableName,
                            String variableValue)

      • stopAllImpl

        public void stopAllImpl()

      • 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

      • stopRunningImpl

        public void stopRunningImpl​(StepMetaInterface stepMetaInterface,
                            StepDataInterface stepDataInterface)
                     throws org.pentaho.di.core.exception.KettleException
        Throws:
        org.pentaho.di.core.exception.KettleException

      • toStringImpl

        public String toStringImpl()