org.pentaho.di.trans
Class RowProducer

java.lang.Object
  extended by org.pentaho.di.trans.RowProducer

public class RowProducer
extends Object

Allows you to "Inject" rows into a step.

Author:
Matt

Constructor Summary
RowProducer(StepInterface stepInterface, RowSet rowSet)
           
 
Method Summary
 void finished()
           
 RowSet getRowSet()
           
 StepInterface getStepInterface()
           
 void putRow(RowMetaInterface rowMeta, Object[] row)
          Puts a row into the underlying row set.
 boolean putRow(RowMetaInterface rowMeta, Object[] row, boolean block)
          Puts a row on to the underlying row set, optionally blocking until the row can be successfully put.
 boolean putRowWait(RowMetaInterface rowMeta, Object[] rowData, long time, TimeUnit tu)
           
 void setRowSet(RowSet rowSet)
           
 void setStepInterface(StepInterface stepInterface)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RowProducer

public RowProducer(StepInterface stepInterface,
                   RowSet rowSet)
Method Detail

putRow

public void putRow(RowMetaInterface rowMeta,
                   Object[] row)
Puts a row into the underlying row set. This will block until the row is successfully added.

See Also:
putRow(RowMetaInterface, Object[], true)

putRow

public boolean putRow(RowMetaInterface rowMeta,
                      Object[] row,
                      boolean block)
Puts a row on to the underlying row set, optionally blocking until the row can be successfully put.

Returns:
true if the row was successfully added to the rowset and false if this buffer was full. If block is true this will always return true.
See Also:
RowSet.putRow(RowMetaInterface, Object[])

putRowWait

public boolean putRowWait(RowMetaInterface rowMeta,
                          Object[] rowData,
                          long time,
                          TimeUnit tu)
See Also:
RowSet.putRowWait(RowMetaInterface, Object[], long, TimeUnit)

finished

public void finished()

getRowSet

public RowSet getRowSet()
Returns:
Returns the rowSet.

setRowSet

public void setRowSet(RowSet rowSet)
Parameters:
rowSet - The rowSet to set.

getStepInterface

public StepInterface getStepInterface()
Returns:
Returns the stepInterface.

setStepInterface

public void setStepInterface(StepInterface stepInterface)
Parameters:
stepInterface - The stepInterface to set.