MergeDedupEventStream

java.lang.Object
- org.epics.archiverappliance.common.mergededup.MergeDedupEventStream

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Event>, EventStream, RemotableOverRaw
```
public class MergeDedupEventStream
extends Object
implements EventStream, RemotableOverRaw
```
EventStream that is constructed with two source EventStream's ( for the same PV ) and then return's a merged-deduped stream of Events. The order of the streams in the constructor is significant as the first stream is the preferred stream in case of conflicts. For example, only the description from the first stream is used as the event description for this stream. Similarly, if both streams contain an event with the same timestamp, the event from the first stream ( along with all metainfo ) is used.

Author:

mshankar

- Constructor Summary
  
  Constructors
  Constructor Description
  
  MergeDedupEventStream(EventStream stream1, EventStream stream2)
- Method Summary
  
  Modifier and Type Method Description
  
  void close()
  
  RemotableEventStreamDesc getDescription()
  
  Iterator<Event> iterator()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  - Methods inherited from interface java.lang.Iterable
    forEach, spliterator

- Constructor Detail
  - MergeDedupEventStream
```
public MergeDedupEventStream(EventStream stream1,
                             EventStream stream2)
```
- Method Detail
  - iterator
```
public Iterator<Event> iterator()
```
    Specified by:
    
    iterator in interface Iterable<Event>
  - close
```
public void close()
           throws IOException
```
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface Closeable
    
    Throws:
    
    IOException
  - getDescription
```
public RemotableEventStreamDesc getDescription()
```
    Specified by:
    
    getDescription in interface EventStream
    
    Specified by:
    
    getDescription in interface RemotableOverRaw