protected class RestartableSequence.QueueBufferSupplier extends Object implements CloseableSupplier<BufferManager.QueueBuffer<BufferedRows.BufferedRow>>, Iterable<BufferedRows.BufferedRow>
Modifier | Constructor and Description |
---|---|
protected |
RestartableSequence.QueueBufferSupplier(BufferManager bufferMgr) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
BufferManager.QueueBuffer<BufferedRows.BufferedRow> |
get()
Get the object.
|
Iterator<BufferedRows.BufferedRow> |
iterator() |
protected long |
size() |
protected RestartableSequence.QueueBufferSupplier(BufferManager bufferMgr)
public Iterator<BufferedRows.BufferedRow> iterator()
iterator
in interface Iterable<BufferedRows.BufferedRow>
protected long size()
public BufferManager.QueueBuffer<BufferedRows.BufferedRow> get()
Supplier
get
in interface Supplier<BufferManager.QueueBuffer<BufferedRows.BufferedRow>>
public void close()
close
in interface AutoCloseable
close
in interface CloseableSupplier<BufferManager.QueueBuffer<BufferedRows.BufferedRow>>
Copyright © 2008-2014 JBoss, a division of Red Hat. All Rights Reserved.