ome.services.pixeldata

Class PersistentEventLogLoader

java.lang.Object

ome.services.eventlogs.EventLogLoader

ome.services.eventlogs.PersistentEventLogLoader

ome.services.pixeldata.PersistentEventLogLoader

All Implemented Interfaces:

java.lang.Iterable<ome.model.meta.EventLog>, java.util.EventListener, java.util.Iterator<ome.model.meta.EventLog>, org.springframework.context.ApplicationListener

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.

Since:

Beta4.3

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<long[]>	dataPerUser
protected long	lowestEntityId The lowest entity id from a single dataPerUser set.
protected int	numThreads
protected java.lang.String	repo

Fields inherited from class ome.services.eventlogs.PersistentEventLogLoader

key, sql, types

Fields inherited from class ome.services.eventlogs.EventLogLoader

batchSize, DEFAULT_BATCH_SIZE, excludes, log, query, queryService

Constructor Summary

Constructors

Constructor and Description
PersistentEventLogLoader(java.lang.String repo, int numThreads)

Method Summary

Modifier and Type	Method and Description
protected boolean	available()
void	initialize() Called when the configuration database does not contain a valid current_id.
protected ome.model.meta.EventLog	pop()
protected ome.model.meta.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.

Methods inherited from class ome.services.eventlogs.PersistentEventLogLoader

deleteCurrentId, getCurrentId, getKey, more, setCurrentId, setKey, setSqlAction, setTypes

Methods inherited from class ome.services.eventlogs.EventLogLoader

addEventLog, getBatchSize, hasNext, isStopSet, iterator, lastEventLog, next, nextEventLog, onApplicationEvent, remove, rollback, setBatchSize, setExcludes, setQueryService, setStop

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

repo

protected final java.lang.String repo

lowestEntityId

protected long lowestEntityId

The lowest entity id from a single dataPerUser set.

numThreads

protected final int numThreads

dataPerUser

protected java.util.List<long[]> dataPerUser

Constructor Detail

PersistentEventLogLoader

public PersistentEventLogLoader(java.lang.String repo,
                                int numThreads)

Method Detail

initialize

public void initialize()

Description copied from class: PersistentEventLogLoader

Called when the configuration database does not contain a valid current_id.

Specified by:

initialize in class PersistentEventLogLoader

query

protected ome.model.meta.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. 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.

Overrides:

query in class PersistentEventLogLoader

available

protected boolean available()

pop

protected ome.model.meta.EventLog pop()