|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.core.BlockingBatchingRowSet
public class BlockingBatchingRowSet
Contains a buffer of rows. Instead of passing rows along the chain immediately we will batch them up to lower locking overhead. The row set will start in accepting mode (accepting = true) It will remain there until the buffer is full. Then it will switch to delivering mode (accepting = false) It will remain there until the buffer is empty. When the row set is done and no more rows will be entering the row set we will switch to delivering mode.
Constructor Summary | |
---|---|
BlockingBatchingRowSet(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(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)
We need to wait until |
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, setRemoteSlaveServerName, setRowMeta, setThreadNameFromToCopy |
Constructor Detail |
---|
public BlockingBatchingRowSet(int maxSize)
maxSize
- Method Detail |
---|
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)
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 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 int size()
size
in interface RowSet
public void setDone()
setDone
in interface RowSet
public int compareTo(RowSet rowSet)
compareTo
in interface Comparable<RowSet>
public boolean equals(org.pentaho.di.core.BaseRowSet 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 |