org.pentaho.di.core
Interface RowSet

All Known Implementing Classes:

BlockingBatchingRowSet, BlockingListeningRowSet, BlockingRowSet, QueueRowSet, SingleRowRowSet

public interface RowSet

Method Summary

int	getDestinationStepCopy()
String	getDestinationStepName()
String	getName()
int	getOriginStepCopy()
String	getOriginStepName()
String	getRemoteSlaveServerName()
Object[]	getRow() Get a row from the input buffer, it blocks for a short period until a new row becomes available.
Object[]	getRowImmediate() Get the first row in the list immediately.
RowMetaInterface	getRowMeta()
Object[]	getRowWait(long timeout, TimeUnit tu) get the first row in the list immediately if it is available or wait until timeout
boolean	isBlocking()
boolean	isDone()
boolean	putRow(RowMetaInterface rowMeta, Object[] rowData) Offer a row of data to this rowset providing for the description (metadata) of the row.
boolean	putRowWait(RowMetaInterface rowMeta, Object[] rowData, long time, TimeUnit tu) Offer a row of data to this rowset providing for the description (metadata) of the row.
void	setDone()
void	setRemoteSlaveServerName(String remoteSlaveServerName)
void	setRowMeta(RowMetaInterface rowMeta)
void	setThreadNameFromToCopy(String from, int from_copy, String to, int to_copy) This method is used only in Trans.java when created RowSet at line 333.
int	size()

Method Detail

putRow

boolean putRow(RowMetaInterface rowMeta,
               Object[] rowData)

Offer a row of data to this rowset providing for the description (metadata) of the row. If the buffer is full, wait (block) for a small period of time.

Parameters:

rowMeta - The description of the row data

rowData - the row of data

Returns:

true if the row was successfully added to the rowset and false if this buffer was full.

putRowWait

boolean putRowWait(RowMetaInterface rowMeta,
                   Object[] rowData,
                   long time,
                   TimeUnit tu)

Offer a row of data to this rowset providing for the description (metadata) of the row. If the buffer is full, wait (block) for a period of time defined in this call.

Parameters:

rowMeta - The description of the row data

rowData - the row of data

time - The number of units of time

tu - The unit of time to use

Returns:

true if the row was successfully added to the rowset and false if this buffer was full.

getRow

Object[] getRow()

Get a row from the input buffer, it blocks for a short period until a new row becomes available. Otherwise, it returns null.

Returns:

a row of data or null if no row is available.

getRowImmediate

Object[] getRowImmediate()

Get the first row in the list immediately.

Returns:

a row of data or null if no row is available.

getRowWait

Object[] getRowWait(long timeout,
                    TimeUnit tu)

get the first row in the list immediately if it is available or wait until timeout

Returns:

a row of data or null if no row is available.

setDone

void setDone()

isDone

boolean isDone()

Returns:

Returns true if there is no more input and vice versa

getOriginStepName

String getOriginStepName()

Returns:

Returns the originStepName.

getOriginStepCopy

int getOriginStepCopy()

Returns:

Returns the originStepCopy.

getDestinationStepName

String getDestinationStepName()

Returns:

Returns the destinationStepName.

getDestinationStepCopy

int getDestinationStepCopy()

Returns:

Returns the destinationStepCopy.

getName

String getName()

size

int size()

Returns:

Return the size (or max capacity) of the RowSet

setThreadNameFromToCopy

void setThreadNameFromToCopy(String from,
                             int from_copy,
                             String to,
                             int to_copy)

This method is used only in Trans.java when created RowSet at line 333. Don't need any synchronization on this method

getRowMeta

RowMetaInterface getRowMeta()

Returns:

the rowMeta

setRowMeta

void setRowMeta(RowMetaInterface rowMeta)

Parameters:

rowMeta - the rowMeta to set

getRemoteSlaveServerName

String getRemoteSlaveServerName()

Returns:

the targetSlaveServer

setRemoteSlaveServerName

void setRemoteSlaveServerName(String remoteSlaveServerName)

Parameters:

remoteSlaveServerName - the remote slave server to set

isBlocking

boolean isBlocking()

Returns:

true if this row set is blocking.