org.pentaho.di.trans
Class RowProducer

java.lang.Object
  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.