Class 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 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

      • 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()