public class REpiceaRecordSet extends java.util.concurrent.LinkedBlockingQueue<GExportRecord>
Constructor and Description |
---|
REpiceaRecordSet()
General constructor for this class.
|
Modifier and Type | Method and Description |
---|---|
boolean |
add(GExportRecord record) |
REpiceaRecordSet |
selectSubsetInRecordSet(java.lang.String field,
java.lang.Object value)
This method makes it possible to select records that match particular value in a given field.
|
void |
setSaveThread(java.lang.Thread saveThread)
This method specifies that the record set is linked to a save thread.
|
GExportRecord |
take() |
clear, contains, drainTo, drainTo, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, spliterator, toArray, toArray, toString
containsAll, isEmpty, removeAll, retainAll
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public REpiceaRecordSet selectSubsetInRecordSet(java.lang.String field, java.lang.Object value)
field
- the String that represents the field namevalue
- the Object instancepublic void setSaveThread(java.lang.Thread saveThread)
saveThread
- a Thread instancepublic boolean add(GExportRecord record)
add
in interface java.util.Collection<GExportRecord>
add
in interface java.util.concurrent.BlockingQueue<GExportRecord>
add
in interface java.util.Queue<GExportRecord>
add
in class java.util.AbstractQueue<GExportRecord>
public GExportRecord take() throws java.lang.InterruptedException
take
in interface java.util.concurrent.BlockingQueue<GExportRecord>
take
in class java.util.concurrent.LinkedBlockingQueue<GExportRecord>
java.lang.InterruptedException