org.pentaho.di.trans.step

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 and Description
static Class<?>	PKG

Method Summary

Modifier and Type	Method and Description
Object[]	getRow()
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 Detail

PKG

static final Class<?> PKG

Method Detail

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