|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.core.SingleRowRowSet
public class SingleRowRowSet
A simplified rowset for steps that always only need to only have a single row on input...
Constructor Summary | |
---|---|
SingleRowRowSet()
|
Method Summary | |
---|---|
int |
compareTo(RowSet rowSet)
Compares using the target steps and copy, not the source. |
boolean |
equals(org.pentaho.di.core.BaseRowSet rowSet)
|
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()
By default we don't report blocking, only for monitored transformations. |
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()
|
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface java.lang.Comparable |
---|
compareTo |
Methods inherited from interface org.pentaho.di.core.RowSet |
---|
getDestinationStepCopy, getDestinationStepName, getName, getOriginStepCopy, getOriginStepName, getRemoteSlaveServerName, getRowMeta, isBlocking, isDone, setDone, setRemoteSlaveServerName, setRowMeta, setThreadNameFromToCopy |
Constructor Detail |
---|
public SingleRowRowSet()
Method Detail |
---|
public Object[] getRow()
RowSet
getRow
in interface RowSet
public Object[] getRowImmediate()
RowSet
getRowImmediate
in interface RowSet
public Object[] getRowWait(long timeout, TimeUnit tu)
RowSet
getRowWait
in interface RowSet
public boolean putRow(RowMetaInterface rowMeta, Object[] rowData)
RowSet
putRow
in interface RowSet
rowMeta
- The description of the row datarowData
- the row of data
public boolean putRowWait(RowMetaInterface rowMeta, Object[] rowData, long time, TimeUnit tu)
RowSet
putRowWait
in interface RowSet
rowMeta
- The description of the row datarowData
- the row of datatime
- The number of units of timetu
- The unit of time to use
public int size()
size
in interface RowSet
public int compareTo(RowSet rowSet)
compareTo
in interface Comparable<RowSet>
public boolean equals(org.pentaho.di.core.BaseRowSet rowSet)
public void setDone()
setDone
in interface RowSet
public boolean isDone()
isDone
in interface RowSet
public String getOriginStepName()
getOriginStepName
in interface RowSet
public int getOriginStepCopy()
getOriginStepCopy
in interface RowSet
public String getDestinationStepName()
getDestinationStepName
in interface RowSet
public int getDestinationStepCopy()
getDestinationStepCopy
in interface RowSet
public String getName()
getName
in interface RowSet
public void setThreadNameFromToCopy(String from, int from_copy, String to, int to_copy)
RowSet
setThreadNameFromToCopy
in interface RowSet
public String toString()
toString
in class Object
public RowMetaInterface getRowMeta()
getRowMeta
in interface RowSet
public void setRowMeta(RowMetaInterface rowMeta)
setRowMeta
in interface RowSet
rowMeta
- the rowMeta to setpublic String getRemoteSlaveServerName()
getRemoteSlaveServerName
in interface RowSet
public void setRemoteSlaveServerName(String remoteSlaveServerName)
setRemoteSlaveServerName
in interface RowSet
remoteSlaveServerName
- the remote slave server to setpublic boolean isBlocking()
isBlocking
in interface RowSet
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |