Class OrderIterator.SerializedQueue<E extends Serializable>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

org.eclipse.rdf4j.query.algebra.evaluation.iterator.OrderIterator.SerializedQueue<E>

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<E>, Collection<E>, Queue<E>

Enclosing class:

OrderIterator

private static class OrderIterator.SerializedQueue<E extends Serializable>
extends AbstractQueue<E>
implements Closeable

Field Summary

Fields

Modifier and Type	Field	Description
private final File	file
private ObjectInputStream	input
private E	last
private E	next
private final ObjectOutputStream	output
private int	size

Constructor Summary

Constructors

Constructor	Description
SerializedQueue(String prefix)
SerializedQueue(String prefix, File directory)

Method Summary

Modifier and Type	Method	Description
void	close()
Iterator<E>	iterator()
boolean	offer(E e)
E	peek()
E	peekLast()
E	poll()
int	size()

Methods inherited from class AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Collection

contains, containsAll, equals, hashCode, isEmpty, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface Iterable

forEach

Field Details

file

private final File file

output

private final ObjectOutputStream output

input

private ObjectInputStream input

size

private int size

next

private E extends Serializable next

last

private E extends Serializable last

Constructor Details

SerializedQueue

public SerializedQueue(String prefix)
                throws IOException

Throws:

IOException

SerializedQueue

public SerializedQueue(String prefix,
 File directory)
                throws IOException

Throws:

IOException

Method Details

peekLast

public E peekLast()

offer

public boolean offer(E e)

Specified by:

offer in interface Queue<E extends Serializable>

poll

public E poll()

Specified by:

poll in interface Queue<E extends Serializable>

peek

public E peek()

Specified by:

peek in interface Queue<E extends Serializable>

iterator

public Iterator<E> iterator()

Specified by:

iterator in interface Collection<E extends Serializable>

Specified by:

iterator in interface Iterable<E extends Serializable>

Specified by:

iterator in class AbstractCollection<E extends Serializable>

size

public int size()

Specified by:

size in interface Collection<E extends Serializable>

Specified by:

size in class AbstractCollection<E extends Serializable>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException