Package deltix.qsrv.hf.tickdb.tool

Class StreamComparer

java.lang.Object

deltix.qsrv.hf.tickdb.tool.StreamComparer

public class StreamComparer
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamComparer.ComparerType

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Comparator<RawMessage>	comparator

Constructor Summary

Constructors

Constructor	Description
StreamComparer()
StreamComparer(java.util.Comparator<RawMessage> comparator)

Method Summary

Modifier and Type	Method	Description
boolean	compare(DXTickStream first, DXTickStream second, deltix.qsrv.hf.pub.InstrumentIdentity[] entities)
boolean	compare(StreamStorage first, StreamStorage second)
protected boolean	compareMessages(long counter, deltix.qsrv.hf.pub.TimeStamp prevTimestamp, RawMessage firstMessage, RawMessage secondMessage)
static StreamComparer	create(StreamComparer.ComparerType type)
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

comparator

protected final java.util.Comparator<RawMessage> comparator

Constructor Detail

StreamComparer

public StreamComparer(java.util.Comparator<RawMessage> comparator)

StreamComparer

public StreamComparer()

Method Detail

create

public static StreamComparer create(StreamComparer.ComparerType type)

compare

public boolean compare(StreamStorage first,
                       StreamStorage second)

compare

public boolean compare(DXTickStream first,
                       DXTickStream second,
                       deltix.qsrv.hf.pub.InstrumentIdentity[] entities)

compareMessages

protected boolean compareMessages(long counter,
                                  deltix.qsrv.hf.pub.TimeStamp prevTimestamp,
                                  RawMessage firstMessage,
                                  RawMessage secondMessage)

main

public static void main(java.lang.String[] args)