Package org.pentaho.di.trans.steps.simplemapping

Class RowOutputDataMapper

java.lang.Object

org.pentaho.di.trans.step.RowAdapter

org.pentaho.di.trans.steps.simplemapping.RowOutputDataMapper

All Implemented Interfaces:

RowListener

public class RowOutputDataMapper
extends RowAdapter

This class takes care of mapping output data from the mapping step back to the parent transformation, renaming columns mainly.

Author:

matt

Constructor Summary

Constructors

Constructor	Description
RowOutputDataMapper(MappingIODefinition inputDefinition, MappingIODefinition outputDefinition, PutRowInterface putRowInterface)

Method Summary

Modifier and Type	Method	Description
void	rowWrittenEvent(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row)	Empty method implementing the RowListener.rowWrittenEvent interface method

Methods inherited from class org.pentaho.di.trans.step.RowAdapter

errorRowWrittenEvent, rowReadEvent

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RowOutputDataMapper

public RowOutputDataMapper(MappingIODefinition inputDefinition,
                           MappingIODefinition outputDefinition,
                           PutRowInterface putRowInterface)

Method Detail

rowWrittenEvent

public void rowWrittenEvent(org.pentaho.di.core.row.RowMetaInterface rowMeta,
                            Object[] row)
                     throws org.pentaho.di.core.exception.KettleStepException

Description copied from class: RowAdapter

Empty method implementing the RowListener.rowWrittenEvent interface method

Specified by:

rowWrittenEvent in interface RowListener

Overrides:

rowWrittenEvent in class RowAdapter

Parameters:

rowMeta - the metadata of the row

row - the data of the row

Throws:

org.pentaho.di.core.exception.KettleStepException - an exception that can be thrown to hard stop the step

See Also:

RowListener.rowWrittenEvent(org.pentaho.di.core.row.RowMetaInterface, java.lang.Object[])