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
RowProducer
public RowProducer(StepInterface stepInterface,
RowSet rowSet)
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.