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, Timestamp start, Timestamp end, EventStreamDesc streamDesc)
void
resetForNextPV()
void
send()
-
-
-
Method Detail
-
consumeEventStream
public void consumeEventStream(EventStream strm) throws Exception
- Specified by:
consumeEventStream
in interfaceEventStreamConsumer
- Throws:
Exception
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
-
send
public void send()
-
processingPV
public void processingPV(BasicContext retrievalContext, String PV, Timestamp start, Timestamp end, EventStreamDesc streamDesc)
-
resetForNextPV
public void resetForNextPV()
-
logNumbersAndCollectTotal
public void logNumbersAndCollectTotal()
-
-