Package deltix.qsrv.hf.tickdb.quotes

Class QuoteUtils

java.lang.Object

deltix.qsrv.hf.tickdb.quotes.QuoteUtils

public final class QuoteUtils
extends java.lang.Object

Description: deltix.qsrv.hf.framework.util.quotes.QuoteUtils Date: Mar 11, 2010

Field Summary

Fields

Modifier and Type	Field	Description
static UniqueQuoteCursor	EMPTY_QUOTE_CURSOR
static java.util.logging.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
QuoteUtils()

Method Summary

Modifier and Type	Method	Description
static UniqueQuoteCursor	createQuoteCursor(DXTickDB timebase, deltix.qsrv.hf.pub.TimeRange timeRange, boolean isRaw, TypeLoader typeLoader, QuoteFilter filter)
static UniqueQuoteCursor	createQuoteCursor(DXTickDB timebase, QuoteCursorRequest request)
static QuoteFilter	createQuoteFilter(java.util.Collection<? extends TickStream> streams, java.lang.String[] entityTypes, deltix.qsrv.hf.pub.InstrumentIdentity[] entities, MessageStatefullFilter statefullFilter)
static QuoteCursorRequest	createQuoteRequest(QuoteFilter quoteFilter, long currentTime, long maxQuoteAge, boolean useRaw, TypeLoader typeLoader)
static QuoteCursorRequest	createQuoteRequest(java.util.Collection<? extends TickStream> streams, long currentTime, long maxQuoteAge, boolean useRaw, TypeLoader typeLoader, MessageStatefullFilter statefullFilter, java.lang.String[] entityTypes, deltix.qsrv.hf.pub.InstrumentIdentity[] entities)
static java.util.Set<java.lang.String>	getStreamsTypes(java.lang.Iterable<DXTickStream> streams, java.lang.Class<?> cls)
static java.lang.String[]	getTypes(deltix.timebase.api.MarketMessageType messageType)
static UniqueQuoteCursor	selectCurrents(long timestamp, long agelimit, boolean useRaw, TypeLoader typeLoader, java.lang.String[] messageTypes, deltix.qsrv.hf.pub.InstrumentIdentity[] entities, TickStream... streams)
static UniqueQuoteCursor	selectCurrents(long timestamp, long agelimit, boolean useRaw, TypeLoader typeLoader, java.lang.String[] messageTypes, deltix.qsrv.hf.pub.InstrumentIdentity[] entities, MessageStatefullFilter statefullFilter, TickStream... streams)
static java.lang.String	toString(java.util.Collection<? extends TickStream> streams, java.lang.String[] entityTypes, deltix.qsrv.hf.pub.InstrumentIdentity[] entities)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

public static final java.util.logging.Logger LOGGER

EMPTY_QUOTE_CURSOR

public static final UniqueQuoteCursor EMPTY_QUOTE_CURSOR

Constructor Detail

QuoteUtils

public QuoteUtils()

Method Detail

createQuoteRequest

public static QuoteCursorRequest createQuoteRequest(java.util.Collection<? extends TickStream> streams,
                                                    long currentTime,
                                                    long maxQuoteAge,
                                                    boolean useRaw,
                                                    TypeLoader typeLoader,
                                                    MessageStatefullFilter statefullFilter,
                                                    java.lang.String[] entityTypes,
                                                    deltix.qsrv.hf.pub.InstrumentIdentity[] entities)

createQuoteRequest

public static QuoteCursorRequest createQuoteRequest(QuoteFilter quoteFilter,
                                                    long currentTime,
                                                    long maxQuoteAge,
                                                    boolean useRaw,
                                                    TypeLoader typeLoader)

createQuoteFilter

public static QuoteFilter createQuoteFilter(java.util.Collection<? extends TickStream> streams,
                                            java.lang.String[] entityTypes,
                                            deltix.qsrv.hf.pub.InstrumentIdentity[] entities,
                                            MessageStatefullFilter statefullFilter)

toString

public static java.lang.String toString(java.util.Collection<? extends TickStream> streams,
                                        java.lang.String[] entityTypes,
                                        deltix.qsrv.hf.pub.InstrumentIdentity[] entities)

createQuoteCursor

public static UniqueQuoteCursor createQuoteCursor(DXTickDB timebase,
                                                  QuoteCursorRequest request)

createQuoteCursor

public static UniqueQuoteCursor createQuoteCursor(DXTickDB timebase,
                                                  deltix.qsrv.hf.pub.TimeRange timeRange,
                                                  boolean isRaw,
                                                  TypeLoader typeLoader,
                                                  QuoteFilter filter)

getTypes

public static java.lang.String[] getTypes(deltix.timebase.api.MarketMessageType messageType)

getStreamsTypes

public static java.util.Set<java.lang.String> getStreamsTypes(java.lang.Iterable<DXTickStream> streams,
                                                              java.lang.Class<?> cls)

selectCurrents

public static UniqueQuoteCursor selectCurrents(long timestamp,
                                               long agelimit,
                                               boolean useRaw,
                                               TypeLoader typeLoader,
                                               java.lang.String[] messageTypes,
                                               deltix.qsrv.hf.pub.InstrumentIdentity[] entities,
                                               TickStream... streams)

selectCurrents

public static UniqueQuoteCursor selectCurrents(long timestamp,
                                               long agelimit,
                                               boolean useRaw,
                                               TypeLoader typeLoader,
                                               java.lang.String[] messageTypes,
                                               deltix.qsrv.hf.pub.InstrumentIdentity[] entities,
                                               MessageStatefullFilter statefullFilter,
                                               TickStream... streams)