public class PersistentEventLogLoader extends PersistentEventLogLoader
EventLogLoader
implementation which keeps tracks of the last
EventLog
instance, and always provides the next unindexed instance.
Resetting that saved value would restart indexing.Modifier and Type | Field and Description |
---|---|
protected List<long[]> |
dataPerUser |
protected long |
lowestEntityId
The lowest entity id from a single dataPerUser set.
|
protected int |
numThreads |
protected String |
repo |
key, sql, types
batchSize, DEFAULT_BATCH_SIZE, excludes, log, query, queryService
Constructor and Description |
---|
PersistentEventLogLoader(String repo,
int numThreads) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
available() |
void |
initialize()
Called when the configuration database does not contain a valid
current_id.
|
protected EventLog |
pop() |
protected EventLog |
query()
Uses data from the
dataPerUser "queue" to allow new requests to
be processed even if one user adds a large number of PIXELDATA events. |
deleteCurrentId, getCurrentId, getKey, more, setCurrentId, setKey, setSqlAction, setTypes
addEventLog, getBatchSize, hasNext, isStopSet, iterator, lastEventLog, next, nextEventLog, onApplicationEvent, remove, rollback, setBatchSize, setExcludes, setQueryService, setStop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
forEach, spliterator
protected final String repo
protected long lowestEntityId
protected final int numThreads
protected List<long[]> dataPerUser
public PersistentEventLogLoader(String repo, int numThreads)
public void initialize()
PersistentEventLogLoader
initialize
in class PersistentEventLogLoader
protected EventLog query()
dataPerUser
"queue" to allow new requests to
be processed even if one user adds a large number of PIXELDATA events.
Only the lowest event log id will be saved as the PersistentEventLogLoader.getCurrentId()
meaning that some event logs will be processed multiple times. The call
to create the pyramid must properly ignore existing pyramids.query
in class PersistentEventLogLoader
protected boolean available()
protected EventLog pop()
Version: 5.3.5-ice35-b73
Copyright © 2017 The University of Dundee & Open Microscopy Environment. All Rights Reserved.