|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.pentaho.di.core.RowSet
public class RowSet
Contains a buffer of rows. Getting rows from the buffer or putting rows in the buffer is synchronised to allow concurrent use of multiple Threads.
Field Summary | |
---|---|
static int |
ERR_NO_ERROR
|
static int |
ERR_ROW_IS_BUSY
|
Constructor Summary | |
---|---|
RowSet(int maxSize)
Create new non-blocking-queue with maxSize capacity. |
Method Summary | |
---|---|
int |
compareTo(RowSet rowSet)
Compares using the target steps and copy, not the source. |
boolean |
equals(RowSet rowSet)
|
int |
getDestinationStepCopy()
|
String |
getDestinationStepName()
|
String |
getName()
|
int |
getOriginStepCopy()
|
String |
getOriginStepName()
|
String |
getRemoteSlaveServerName()
|
Object[] |
getRow()
|
Object[] |
getRowImmediate()
get the first row in the list immediately. |
RowMetaInterface |
getRowMeta()
|
Object[] |
getRowUnitlSuccess()
Wait forever until successfully receive a row. |
Object[] |
getRowWait(long timeout,
TimeUnit tu)
get the first row in the list immediately if it is available or wait until timeout |
boolean |
isDone()
|
boolean |
putRow(RowMetaInterface rowMeta,
Object[] rowData)
|
boolean |
putRowImmediate(RowMetaInterface rowMeta,
Object[] rowData)
|
boolean |
putRowWait(RowMetaInterface rowMeta,
Object[] rowData,
long time,
TimeUnit tu)
|
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 |
Field Detail |
---|
public static final int ERR_NO_ERROR
public static final int ERR_ROW_IS_BUSY
Constructor Detail |
---|
public RowSet(int maxSize)
maxSize
- Method Detail |
---|
public int compareTo(RowSet rowSet)
compareTo
in interface Comparable<RowSet>
public boolean equals(RowSet rowSet)
public boolean putRow(RowMetaInterface rowMeta, Object[] rowData)
public boolean putRowImmediate(RowMetaInterface rowMeta, Object[] rowData)
public boolean putRowWait(RowMetaInterface rowMeta, Object[] rowData, long time, TimeUnit tu)
public Object[] getRow()
public Object[] getRowImmediate()
public Object[] getRowWait(long timeout, TimeUnit tu)
public Object[] getRowUnitlSuccess()
public void setDone()
public boolean isDone()
public String getOriginStepName()
public int getOriginStepCopy()
public String getDestinationStepName()
public int getDestinationStepCopy()
public String getName()
public int size()
public void setThreadNameFromToCopy(String from, int from_copy, String to, int to_copy)
public String toString()
toString
in class Object
public RowMetaInterface getRowMeta()
public void setRowMeta(RowMetaInterface rowMeta)
rowMeta
- the rowMeta to setpublic String getRemoteSlaveServerName()
public void setRemoteSlaveServerName(String remoteSlaveServerName)
remoteSlaveServerName
- the remote slave server to set
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |