Package org.epics.archiverappliance.retrieval.pva

Class PvaMergeDedupConsumer

java.lang.Object

org.epics.archiverappliance.retrieval.pva.PvaMergeDedupConsumer

All Implemented Interfaces:

AutoCloseable, EventStreamConsumer

public class PvaMergeDedupConsumer
extends Object
implements EventStreamConsumer, AutoCloseable

Implementation of the Merge/Dedup algorithm for combining EventStreams into one EventStream.

Author:

mshankar

Method Summary

Modifier and Type	Method	Description
void	close()
void	consumeEventStream(EventStream strm)
void	logNumbersAndCollectTotal()
void	processingPV(BasicContext retrievalContext, String PV, Instant start, Instant end, EventStreamDesc streamDesc)
void	resetForNextPV()
org.epics.pva.data.PVAStructure	send()

Methods inherited from class java.lang.Object

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

Method Details

consumeEventStream

public void consumeEventStream(EventStream strm)
                        throws Exception

Specified by:

consumeEventStream in interface EventStreamConsumer

Throws:

Exception

close

public void close()

Specified by:

close in interface AutoCloseable

send

public org.epics.pva.data.PVAStructure send()

processingPV

public void processingPV(BasicContext retrievalContext,
 String PV,
 Instant start,
 Instant end,
 EventStreamDesc streamDesc)

resetForNextPV

public void resetForNextPV()

logNumbersAndCollectTotal

public void logNumbersAndCollectTotal()