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

Constructors

Constructor and Description
RowProducer(StepInterface stepInterface, RowSet rowSet)

Method Summary

Modifier and Type	Method and Description
void	finished() Signal that we are done producing rows.
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

clone, equals, finalize, 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()

Signal that we are done producing rows. It will allow the step to which this producer is attached to know that no more rows are forthcoming.

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.