ome.services.pixeldata

Class PersistentEventLogLoader

java.lang.Object

ome.services.eventlogs.EventLogLoader

ome.services.eventlogs.PersistentEventLogLoader

ome.services.pixeldata.PersistentEventLogLoader

All Implemented Interfaces:

Iterable<EventLog>, EventListener, Iterator<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. Reseting that saved value would restart indexing.

Since:

Beta4.3

Author:

Josh Moore, josh at glencoesoftware.com

Field Summary

Fields

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

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(String repo, int numThreads)

Method Summary

Methods

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.

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

Field Detail

repo

protected final String repo

lowestEntityId

protected long lowestEntityId

The lowest entity id from a single dataPerUser set.

numThreads

protected final int numThreads

dataPerUser

protected List<long[]> dataPerUser

Constructor Detail

PersistentEventLogLoader

public PersistentEventLogLoader(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 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 EventLog pop()