Interface RowHandler


public interface RowHandler
Defines methods used for handling row data within steps. By default, the implementation used in BaseStep leverages the logic defined within BaseStep. (see BaseStep.handleGetRow() BaseStep.handlePutRow(RowMetaInterface, Object[]) BaseStep.handlePutError(org.pentaho.di.core.row.RowMetaInterface, java.lang.Object[], long, java.lang.String, java.lang.String, java.lang.String) BaseStep.setRowHandler(RowHandler) can be used to override this behavior.
  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final Class<?>
     
  • Method Summary

    Modifier and Type
    Method
    Description
     
    default Object[]
    getRowFrom(org.pentaho.di.core.RowSet rowSet)
     
    void
    putError(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, long nrErrors, String errorDescriptions, String fieldNames, String errorCodes)
     
    void
    putRow(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row)
     
    default void
    putRowTo(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row, org.pentaho.di.core.RowSet rowSet)
     
  • Field Details

    • PKG

      static final Class<?> PKG
  • Method Details

    • getRow

      Object[] getRow() throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException
    • putRow

      void putRow(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException
    • putError

      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
      Throws:
      org.pentaho.di.core.exception.KettleStepException
    • putRowTo

      default void putRowTo(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
    • getRowFrom

      default Object[] getRowFrom(org.pentaho.di.core.RowSet rowSet) throws org.pentaho.di.core.exception.KettleStepException
      Throws:
      org.pentaho.di.core.exception.KettleStepException