Package org.teiid.common.buffer
Class TupleBuffer.TupleBufferTupleSource
- java.lang.Object
-
- org.teiid.common.buffer.AbstractTupleSource
-
- org.teiid.common.buffer.TupleBuffer.TupleBufferTupleSource
-
- All Implemented Interfaces:
IndexedTupleSource
,TupleSource
- Enclosing class:
- TupleBuffer
public class TupleBuffer.TupleBufferTupleSource extends AbstractTupleSource
-
-
Field Summary
-
Fields inherited from class org.teiid.common.buffer.AbstractTupleSource
batch, currentTuple
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected long
available()
void
closeSource()
Closes the Tuple Source.protected List<?>
finalRow()
protected TupleBatch
getBatch(long row)
long
getCurrentIndex()
Get the current position.void
setNoBlocking(boolean noBlocking)
void
setReverse(boolean reverse)
-
Methods inherited from class org.teiid.common.buffer.AbstractTupleSource
getCurrentTuple, hasNext, mark, nextTuple, reset, setPosition
-
-
-
-
Method Detail
-
finalRow
protected List<?> finalRow() throws TeiidComponentException, TeiidProcessingException
- Specified by:
finalRow
in classAbstractTupleSource
- Throws:
TeiidComponentException
TeiidProcessingException
-
available
protected long available()
- Specified by:
available
in classAbstractTupleSource
-
getBatch
protected TupleBatch getBatch(long row) throws TeiidComponentException
- Specified by:
getBatch
in classAbstractTupleSource
- Throws:
TeiidComponentException
-
closeSource
public void closeSource()
Description copied from interface:TupleSource
Closes the Tuple Source.- Specified by:
closeSource
in interfaceTupleSource
- Overrides:
closeSource
in classAbstractTupleSource
-
setNoBlocking
public void setNoBlocking(boolean noBlocking)
-
setReverse
public void setReverse(boolean reverse)
-
getCurrentIndex
public long getCurrentIndex()
Description copied from interface:IndexedTupleSource
Get the current position. The position is 1 based and reports the position of the tuple that will be retrieved with a call toTupleSource.nextTuple()
- Specified by:
getCurrentIndex
in interfaceIndexedTupleSource
- Overrides:
getCurrentIndex
in classAbstractTupleSource
- Returns:
-
-