Package deltix.qsrv.hf.tickdb.pub

Class FiltersConfigurator

java.lang.Object

deltix.qsrv.hf.tickdb.pub.FiltersConfigurator

public final class FiltersConfigurator
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
FiltersConfigurator()

Method Summary

Modifier and Type	Method	Description
static deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage>	create(TickLoader loader, long bufferedInterval, long bumpInterval, long skipInterval)
static BufferedSorter	newBufferedSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> previous, long maxDiscrepancy)
static BufferedSorter	newBufferedSorter(TickLoader loader, long maxDiscrepancy)
static BumpUpSorter	newBumpUpSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> previous, long maxDiscrepancy)
static BumpUpSorter	newBumpUpSorter(TickLoader loader, long maxDiscrepancy)
static SkipSorter	newSkipSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> previous, long maxDiscrepancy)
static SkipSorter	newSkipSorter(TickLoader loader, long maxDiscrepancy)

Methods inherited from class java.lang.Object

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

Constructor Detail

FiltersConfigurator

public FiltersConfigurator()

Method Detail

newBumpUpSorter

public static BumpUpSorter newBumpUpSorter(TickLoader loader,
                                           long maxDiscrepancy)

newBumpUpSorter

public static BumpUpSorter newBumpUpSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> previous,
                                           long maxDiscrepancy)

newSkipSorter

public static SkipSorter newSkipSorter(TickLoader loader,
                                       long maxDiscrepancy)

newSkipSorter

public static SkipSorter newSkipSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> previous,
                                       long maxDiscrepancy)

newBufferedSorter

public static BufferedSorter newBufferedSorter(TickLoader loader,
                                               long maxDiscrepancy)

newBufferedSorter

public static BufferedSorter newBufferedSorter(deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> previous,
                                               long maxDiscrepancy)

create

public static deltix.data.stream.MessageChannel<deltix.qsrv.hf.pub.InstrumentMessage> create(TickLoader loader,
                                                                                             long bufferedInterval,
                                                                                             long bumpInterval,
                                                                                             long skipInterval)