xxl.relational
Class NestedLoopsJoin

java.lang.Object
  |
  +--xxl.relational.AbstractResultSet
        |
        +--xxl.relational.Join
              |
              +--xxl.relational.NestedLoopsJoin
public class NestedLoopsJoin
extends Join

Field Summary
protected  int maxOuterBagSize
           
protected  Tuple[] outerBag
           
protected  int outerBagPointer
           
protected  int outerBagSize
           
protected  boolean r1Next
           
protected  BufferedResultSet r2
           
protected  boolean r2Next
           
protected  boolean storingRequired
           
protected  Tuple t2
           
protected  boolean wasNull
           
 
Fields inherited from class xxl.relational.Join
columnsFrom2, l1, metaData, r1, r2
 
Constructor Summary
NestedLoopsJoin(Bag innerBag, int maxTuplesInMemory, java.sql.ResultSet r1, java.sql.ResultSet r2)
           
NestedLoopsJoin(java.sql.ResultSet r1, java.sql.ResultSet r2)
           
 
Method Summary
 void close()
           
 byte[] getBytes(int columnIndex)
           
 java.lang.Object getObject(int columnIndex)
           
 boolean next()
           
 boolean wasNull()
           
 
Methods inherited from class xxl.relational.Join
equalInJoinedColumns, findColumn, getMetaData, originalColumnIndexFrom1, originalColumnIndexFrom2, originalResultSet
 
Methods inherited from class xxl.relational.AbstractResultSet
absolute, afterLast, beforeFirst, cancelRowUpdates, clearWarnings, deleteRow, first, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getColumnCount, getConcurrency, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getInt, getInt, getLong, getLong, getObject, getObject, getObject, getRef, getRef, getRow, getShort, getShort, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getWarnings, insertRow, isAfterLast, isBeforeFirst, isFirst, isLast, last, moveToCurrentRow, moveToInsertRow, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRow, updateShort, updateShort, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

r2

protected BufferedResultSet r2

outerBag

protected Tuple[] outerBag

maxOuterBagSize

protected int maxOuterBagSize

outerBagSize

protected int outerBagSize

outerBagPointer

protected int outerBagPointer

t2

protected Tuple t2

storingRequired

protected boolean storingRequired

r1Next

protected boolean r1Next

r2Next

protected boolean r2Next

wasNull

protected boolean wasNull
Constructor Detail

NestedLoopsJoin

public NestedLoopsJoin(java.sql.ResultSet r1,
                       java.sql.ResultSet r2)

NestedLoopsJoin

public NestedLoopsJoin(Bag innerBag,
                       int maxTuplesInMemory,
                       java.sql.ResultSet r1,
                       java.sql.ResultSet r2)
Method Detail

next

public boolean next()
             throws java.sql.SQLException
Overrides:
next in class Join

getObject

public java.lang.Object getObject(int columnIndex)
                           throws java.sql.SQLException
Overrides:
getObject in class Join

getBytes

public byte[] getBytes(int columnIndex)
                throws java.sql.SQLException
Overrides:
getBytes in class Join

wasNull

public boolean wasNull()
                throws java.sql.SQLException
Overrides:
wasNull in class Join

close

public void close()
           throws java.sql.SQLException
Overrides:
close in class Join