com.devexperts.qd

Interface QDHistory

All Superinterfaces:

QDCollector, QDStatsContainer, SubscriptionContainer

public interface QDHistory
extends QDCollector

The QDHistory represents a history-view of the data. In the history-view, all data events in specified time period are important and are delivered to the consumers. Such contract also allows QDHistory to provide random access to available data values.

Nested Class Summary

Nested classes/interfaces inherited from interface com.devexperts.qd.QDCollector

QDCollector.Builder<T extends QDCollector>, QDCollector.Factory

Method Summary

Modifier and Type	Method and Description
boolean	examineData(DataRecord record, int cipher, String symbol, long startTime, long endTime, DataVisitor visitor) Deprecated. Use examineData(DataRecord, int, String, long, long, RecordSink)
boolean	examineData(DataRecord record, int cipher, String symbol, long startTime, long endTime, RecordSink sink) Examines available records for specified parameters via specified data visitor.
int	getAvailableCount(DataRecord record, int cipher, String symbol, long startTime, long endTime) Returns the number of available records for specified parameters.
long	getMaxAvailableTime(DataRecord record, int cipher, String symbol) Returns maximal time of available records for specified parameters.
long	getMinAvailableTime(DataRecord record, int cipher, String symbol) Returns minimal time of available records for specified parameters.

Methods inherited from interface com.devexperts.qd.QDCollector

agentBuilder, buildAgent, buildDistributor, close, createAgent, createAgent, createDistributor, createDistributor, distributorBuilder, examineData, examineData, examineDataBySubscription, executeLockBoundTask, getContract, getScheme, getStriper, getSymbol, hasEventTimeSequence, isStoreEverything, remove, setErrorHandler, setStoreEverything, setStoreEverythingFilter

Methods inherited from interface com.devexperts.qd.SubscriptionContainer

examineSubscription, examineSubscription, getSubscriptionSize, isSubscribed

Methods inherited from interface com.devexperts.qd.stats.QDStatsContainer

getStats

Method Detail

getMinAvailableTime

long getMinAvailableTime(DataRecord record,
                         int cipher,
                         String symbol)

Returns minimal time of available records for specified parameters. Returns 0 if none are available.

getMaxAvailableTime

long getMaxAvailableTime(DataRecord record,
                         int cipher,
                         String symbol)

Returns maximal time of available records for specified parameters. Returns 0 if none are available.

getAvailableCount

int getAvailableCount(DataRecord record,
                      int cipher,
                      String symbol,
                      long startTime,
                      long endTime)

Returns the number of available records for specified parameters. The records from time interval [startTime, endTime] inclusive are counted in the specified order (from startTime to endTime). Returns 0 if none are available.

examineData

boolean examineData(DataRecord record,
                    int cipher,
                    String symbol,
                    long startTime,
                    long endTime,
                    DataVisitor visitor)

Deprecated. Use examineData(DataRecord, int, String, long, long, RecordSink)

Examines available records for specified parameters via specified data visitor. The records from time interval [startTime, endTime] inclusive are examined in the specified order (from startTime to endTime). Returns true if not all available data from specified interval were examined or false if all available data were examined.

examineData

boolean examineData(DataRecord record,
                    int cipher,
                    String symbol,
                    long startTime,
                    long endTime,
                    RecordSink sink)

Examines available records for specified parameters via specified data visitor. The records from time interval [startTime, endTime] inclusive are examined in the specified order (from startTime to endTime). Returns true if not all available data from specified interval were examined or false if all available data were examined.

This method adds an empty record with REMOVE_SYMBOL flag as needed to indicate where and if the range of times contains a snapshot. If there is a data snapshot in the indicated range of times, then this method visits at least one record. TX_PENDING flag is used to indicate records that are affected by the ongoing transaction.