RowSet (PDI Core 9.0.0.1-426 API)

All Known Implementing Classes:

BlockingBatchingRowSet, BlockingListeningRowSet, BlockingRowSet, QueueRowSet, SingleRowRowSet
```
public interface RowSet
```

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`clear()` Clear this rowset: remove all rows and remove the "done" flag.
`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 fromCopy, String to, int toCopy)` 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 fromCopy,
                             String to,
                             int toCopy)
```
    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.
  - clear
```
void clear()
```
    Clear this rowset: remove all rows and remove the "done" flag.

Interface RowSet

Method Summary

Method Detail

putRow

putRowWait

getRow

getRowImmediate

getRowWait

setDone

isDone

getOriginStepName

getOriginStepCopy

getDestinationStepName

getDestinationStepCopy

getName

size

setThreadNameFromToCopy

getRowMeta

setRowMeta

getRemoteSlaveServerName

setRemoteSlaveServerName

isBlocking

clear