import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
/**
 * For preview of the main data path, make sure we pass the row listener down to the Mapping Output step...
 */
public void addRowListener(RowListener rowListener)
{
    MappingOutput[] mappingOutputs = data.mappingTrans.findMappingOutput();
    if (mappingOutputs==null || mappingOutputs.length==0) return; // Nothing to do here...
    
	// Simple case: one output mapping step : add the row listener over there
	//
    /*
    if (mappingOutputs.length==1) {
    	mappingOutputs[0].addRowListener(rowListener);
    } else {
    	// Find the main data path...
    	//
    	
    	
    }
    */
    
    // Add the row listener to all the outputs in the mapping...
    //
    for (MappingOutput mappingOutput : mappingOutputs) {
    	mappingOutput.addRowListener(rowListener);
    }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
/**
 * For preview of the main data path, make sure we pass the row listener down to the Mapping Output step...
 */
public void addRowListener( RowListener rowListener ) {
  MappingOutput[] mappingOutputs = getData().getMappingTrans().findMappingOutput();
  if ( mappingOutputs == null || mappingOutputs.length == 0 ) {
    return; // Nothing to do here...
  }

  // Simple case: one output mapping step : add the row listener over there
  //
  /*
   * if (mappingOutputs.length==1) { mappingOutputs[0].addRowListener(rowListener); } else { // Find the main data
   * path... //
   *
   *
   * }
   */

  // Add the row listener to all the outputs in the mapping...
  //
  for ( MappingOutput mappingOutput : mappingOutputs ) {
    mappingOutput.addRowListener( rowListener );
  }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
/**
 * For preview of the main data path, make sure we pass the row listener down to the Mapping Output step...
 */
public void addRowListener( RowListener rowListener ) {
  MappingOutput[] mappingOutputs = getData().mappingTrans.findMappingOutput();
  if ( mappingOutputs == null || mappingOutputs.length == 0 ) {
    return; // Nothing to do here...
  }

  // Simple case: one output mapping step : add the row listener over there
  //
  /*
   * if (mappingOutputs.length==1) { mappingOutputs[0].addRowListener(rowListener); } else { // Find the main data
   * path... //
   *
   *
   * }
   */

  // Add the row listener to all the outputs in the mapping...
  //
  for ( MappingOutput mappingOutput : mappingOutputs ) {
    mappingOutput.addRowListener( rowListener );
  }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void addRowListener(RowListener rowListener)
{
    if (child == null) {
        addRowListenerImpl(rowListener);
    } else {
        child.addRowListener(rowListener);
    }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public List<RowListener> getRowListeners()
{
    if (child == null) {
        return getRowListenersImpl();
    } else {
        return child.getRowListeners();
    }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void removeRowListener(RowListener rowListener)
{
    if (child == null) {
        removeRowListenerImpl(rowListener);
    } else {
        child.removeRowListener(rowListener);
    }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void addRowListener( RowListener rowListener ) {
  if ( child == null ) {
    addRowListenerImpl( rowListener );
  } else {
    child.addRowListener( rowListener );
  }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public List<RowListener> getRowListeners() {
  if ( child == null ) {
    return getRowListenersImpl();
  } else {
    return child.getRowListeners();
  }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void removeRowListener( RowListener rowListener ) {
  if ( child == null ) {
    removeRowListenerImpl( rowListener );
  } else {
    child.removeRowListener( rowListener );
  }
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
@Override
BaseStep doCall() throws Exception {
    for ( RowListener rowListener : baseStep.getRowListeners() ) {
        rowListener.rowWrittenEvent( mock( RowMetaInterface.class ), new Object[]{} );
    }
    return null;
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void addRowListener(RowListener rowListener) {
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public List<RowListener> getRowListeners() {
	return null;
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void removeRowListener(RowListener rowListener) {
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void addRowListener(String stepname, RowListener rowListener)
{
    this.rowListenerStep = stepname;
    this.rowListener = rowListener;
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void addRowListener( RowListener arg0 ) {
  baseStep.addRowListener( arg0 );
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public List<RowListener> getRowListeners() {
  return baseStep.getRowListeners();
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void removeRowListener( RowListener arg0 ) {
  baseStep.removeRowListener( arg0 );
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void addRowListener(RowListener rowListener)
{
    parent.addRowListenerImpl(rowListener);
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public List<RowListener> getRowListeners()
{
    return parent.getRowListenersImpl();
}
 

import org.pentaho.di.trans.step.RowListener; //导入依赖的package包/类
public void removeRowListener(RowListener rowListener)
{
    parent.removeRowListenerImpl(rowListener);
}