protected class RestartableSequence.QueueBufferSupplier extends Object implements CloseableSupplier<BufferManager.QueueBuffer<BufferedRows.BufferedRow>>, Iterable<BufferedRows.BufferedRow>
Modifier | Constructor and Description |
---|---|
protected |
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
protected 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–2016 JBoss, a division of Red Hat. All rights reserved.