Package | Description |
---|---|
com.devexperts.qd |
This package contains basic interfaces and other API elements of QD system
which shall be sufficient for the client application programmer.
|
com.devexperts.qd.kit |
This package contains default implementations of various QD components which
do not constitute any separate module or subsystem and which can be easily replaced.
|
com.devexperts.qd.ng |
This package contains next-generation interfaces for data and subscription exchange based on
RecordCursor class. |
com.devexperts.qd.qtp |
This package contains interfaces with default implementations required
to create and operate a connection using QTP.
|
com.devexperts.qd.qtp.fieldreplacer | |
com.devexperts.qd.util |
This package contains utility classes which are used by QD, but which do not
depend on QD and which do not constitute any separate module or subsystem.
|
Modifier and Type | Method and Description |
---|---|
DataRecord |
DataScheme.findRecordByName(String name)
Returns data record by its name.
|
DataRecord |
DataField.getRecord()
Returns parent
DataRecord of this field. |
DataRecord |
SubscriptionBuffer.getRecord(int index)
Deprecated.
Returns record by its index within this buffer.
|
DataRecord |
DataScheme.getRecord(int index)
Returns data record by its index within this scheme.
|
DataRecord |
DataBuffer.getRecord(int index)
Deprecated.
Returns record by its index within this buffer.
|
DataRecord |
SubscriptionIterator.nextRecord()
Returns next record.
|
DataRecord |
SubscriptionBuffer.nextRecord()
Deprecated.
|
DataRecord |
DataIterator.nextRecord()
Returns next record.
|
DataRecord |
DataBuffer.nextRecord()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
QDFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol)
Returns true if this filter accepts a given record and symbol on the specified contract.
|
boolean |
SubscriptionFilter.acceptRecord(DataRecord record,
int cipher,
String symbol)
Determines if specified record shall be processed by corresponding subsystem.
|
boolean |
QDFilter.acceptRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
Use
QDFilter.accept(QDContract, DataRecord, int, String)
to filter taking contract into account. |
protected void |
SubscriptionBuffer.ensureCapacity(DataRecord record)
Deprecated.
Ensures that this buffer has capacity to visit and store specified record.
|
protected void |
DataBuffer.ensureCapacity(DataRecord record)
Deprecated.
Ensures that this buffer has capacity to visit and store specified record.
|
boolean |
QDHistory.examineData(DataRecord record,
int cipher,
String symbol,
long startTime,
long endTime,
DataVisitor visitor)
|
boolean |
QDHistory.examineData(DataRecord record,
int cipher,
String symbol,
long startTime,
long endTime,
RecordSink sink)
Examines available records for specified parameters via specified data visitor.
|
int |
QDHistory.getAvailableCount(DataRecord record,
int cipher,
String symbol,
long startTime,
long endTime)
Returns the number of available records for specified parameters.
|
void |
QDTicker.getData(RecordCursor.Owner owner,
DataRecord record,
int cipher,
String symbol)
Gets all data for the specified record, cipher, and symbol in a single call
and sets
RecordCursor via caller-provided
RecordCursor.Owner to the
corresponding memory storage in read-only mode. |
boolean |
QDTicker.getDataIfAvailable(RecordCursor.Owner owner,
DataRecord record,
int cipher,
String symbol)
Gets all data for the specified record, cipher, and symbol in a single call
and sets
RecordCursor via caller-provided
RecordCursor.Owner to the
corresponding memory storage in read-only mode if the corresponding data
is available in the storage. |
boolean |
QDTicker.getDataIfSubscribed(RecordCursor.Owner owner,
DataRecord record,
int cipher,
String symbol) |
long |
QDHistory.getMaxAvailableTime(DataRecord record,
int cipher,
String symbol)
Returns maximal time of available records for specified parameters.
|
int |
HistorySubscriptionFilter.getMaxRecordCount(DataRecord record,
int cipher,
String symbol) |
long |
QDHistory.getMinAvailableTime(DataRecord record,
int cipher,
String symbol)
Returns minimal time of available records for specified parameters.
|
long |
HistorySubscriptionFilter.getMinHistoryTime(DataRecord record,
int cipher,
String symbol) |
boolean |
QDTicker.isAvailable(DataRecord record,
int cipher,
String symbol)
Determines if value of specified record is available.
|
boolean |
SubscriptionContainer.isSubscribed(DataRecord record,
int cipher,
String symbol,
long time)
Returns
true if subscribed to the corresponding record and symbol with the
corresponding time. |
void |
SubscriptionBuffer.visitRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
Visits next record using
time = 0 . |
void |
DataVisitor.visitRecord(DataRecord record,
int cipher,
String symbol)
Visits next record.
|
void |
DataBuffer.visitRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
|
void |
SubscriptionVisitor.visitRecord(DataRecord record,
int cipher,
String symbol,
long time)
Visits next record.
|
void |
SubscriptionBuffer.visitRecord(DataRecord record,
int cipher,
String symbol,
long time)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultRecord
The
DefaultRecord is a basic implementation of data record. |
Modifier and Type | Method and Description |
---|---|
DataRecord |
AbstractDataField.getRecord() |
Modifier and Type | Method and Description |
---|---|
boolean |
SymbolSetFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
RecordOnlyFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
RangeFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
PatternFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
NotFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
boolean |
HashFilter.accept(QDContract contract,
DataRecord record,
int cipher,
String symbol) |
abstract boolean |
RecordOnlyFilter.acceptRecord(DataRecord record) |
void |
AbstractDataField.setRecord(DataRecord record)
Sets reference to parent data record.
|
Modifier and Type | Method and Description |
---|---|
static RecordOnlyFilter |
CompositeFilters.forRecords(Collection<DataRecord> records)
Returns filter that accepts only a specified collection of records.
|
static RecordOnlyFilter |
CompositeFilters.forRecords(DataScheme scheme,
String name,
Predicate<DataRecord> filter)
Returns named token filter that accepts only records accepted by specified predicate filter.
|
Constructor and Description |
---|
DefaultScheme(SymbolCodec codec,
DataRecord... records) |
Modifier and Type | Method and Description |
---|---|
DataRecord |
RecordMapping.getRecord()
Returns data record that this record mapping works for.
|
DataRecord |
RecordCursor.getRecord()
Returns record.
|
DataRecord |
RecordBuffer.getRecordAt(long position)
Returns record at the specified position.
|
abstract DataRecord |
RecordSource.nextRecord()
Deprecated.
Use
RecordSource.next() . |
DataRecord |
RecordBuffer.nextRecord()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RecordCursor |
RecordBuffer.add(DataRecord record,
int cipher,
String symbol)
Returns write cursor at the current limit and advances limit.
|
static RecordCursor |
RecordCursor.allocate(DataRecord record,
int cipher,
String symbol)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
int cipher,
String symbol,
RecordMode mode)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
String symbol)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol. |
static RecordCursor |
RecordCursor.allocate(DataRecord record,
String symbol,
RecordMode mode)
Allocates writable
RecordCursor that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol. |
static RecordCursor.Owner |
RecordCursor.allocateOwner(DataRecord record)
Allocates writable
RecordCursor.Owner that points to a freshly allocated storage for a given record's
integer and object field values. |
static RecordCursor.Owner |
RecordCursor.allocateOwner(DataRecord record,
int cipher,
String symbol)
Allocates writable
RecordCursor.Owner that points to a freshly allocated storage for a given record's
integer and object field values and also sets symbol. |
static RecordCursor.Owner |
RecordCursor.allocateOwner(DataRecord record,
int cipher,
String symbol,
RecordMode mode)
Allocates writable
RecordCursor.Owner that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode and also sets symbol. |
static RecordCursor.Owner |
RecordCursor.allocateOwner(DataRecord record,
RecordMode mode)
Allocates writable
RecordCursor.Owner that points to a freshly allocated storage for a given record's
integer and object field values using a specified mode. |
RecordMapping |
RecordMappingFactory.createMapping(DataRecord record)
Creates mapping for a specified record.
|
void |
RecordBuffer.replaceRecordAt(long position,
DataRecord newRecord)
Replaces record at the specified position.
|
void |
RecordCursor.setAs(DataRecord record,
int cipher,
String symbol,
int[] int_flds,
int int_offset,
Object[] obj_flds,
int obj_offset,
boolean writable)
Deprecated.
This method will be removed in the future versions.
Use one of
RecordCursor.allocateOwner(...) to get owner and use Owner's
setXXX(...) methods to configure the cursor as needed. |
void |
RecordCursor.Owner.setRecord(DataRecord record)
Changes record and sets a default mode of
DATA . |
void |
RecordCursor.Owner.setRecord(DataRecord record,
RecordMode mode)
Changes record and sets a specified mode.
|
void |
RecordSink.visitRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
|
void |
RecordBuffer.visitRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
Use
RecordBuffer.add(com.devexperts.qd.DataRecord, int, java.lang.String) to add records into this buffer. |
void |
AbstractRecordSink.visitRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
|
void |
RecordSink.visitRecord(DataRecord record,
int cipher,
String symbol,
long time)
Deprecated.
|
void |
RecordBuffer.visitRecord(DataRecord record,
int cipher,
String symbol,
long time)
Deprecated.
Use
RecordBuffer.add(com.devexperts.qd.DataRecord, int, java.lang.String) to add records into this buffer. |
void |
AbstractRecordSink.visitRecord(DataRecord record,
int cipher,
String symbol,
long time)
Deprecated.
|
Constructor and Description |
---|
RecordMapping(DataRecord record)
Creates record mapping for a specified record.
|
Modifier and Type | Field and Description |
---|---|
protected DataRecord |
BinaryRecordDesc.record |
Modifier and Type | Method and Description |
---|---|
DataRecord |
BinaryRecordDesc.getRecord()
Returns actual DataRecord that shall be used for subscription.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractQTPComposer.beginRecord(DataRecord record) |
Consumer<RecordCursor> |
FieldReplacer.createFieldReplacer(DataRecord dataRecord)
Creates consumer to be used to update fields in
RecordCursor
with specified data record . |
protected void |
BinaryQTPComposer.describeRecord(DataRecord record) |
protected void |
AbstractQTPComposer.describeRecord(DataRecord record) |
protected BinaryRecordDesc |
BinaryQTPComposer.getRequestedRecordDesc(DataRecord record) |
void |
OutputStreamComposer.visitRecord(DataRecord record,
int cipher,
String symbol) |
void |
AbstractQTPComposer.visitRecord(DataRecord record,
int cipher,
String symbol)
Deprecated.
|
void |
OutputStreamComposer.visitRecord(DataRecord record,
int cipher,
String symbol,
long time) |
void |
AbstractQTPComposer.visitRecord(DataRecord record,
int cipher,
String symbol,
long time)
Deprecated.
|
protected void |
BinaryQTPComposer.writeHistorySubscriptionTime(DataRecord record,
long time) |
protected abstract void |
AbstractQTPComposer.writeHistorySubscriptionTime(DataRecord record,
long time) |
protected int |
BinaryQTPComposer.writeRecordHeader(DataRecord record,
int cipher,
String symbol,
int eventFlags) |
protected abstract int |
AbstractQTPComposer.writeRecordHeader(DataRecord record,
int cipher,
String symbol,
int eventFlags) |
Constructor and Description |
---|
BinaryRecordDesc(DataRecord record,
boolean eventTimeSequence,
int dir,
boolean wideDecimalSupported) |
BinaryRecordDesc(DataRecord record,
int nFld,
String[] namesIn,
int[] typesIn,
boolean eventTimeSequence,
int dir) |
Modifier and Type | Method and Description |
---|---|
Consumer<RecordCursor> |
DefaultFieldReplacer.createFieldReplacer(DataRecord record) |
Modifier and Type | Method and Description |
---|---|
static int |
MappingUtil.findIntField(DataRecord record,
String localName,
boolean required) |
static int |
MappingUtil.findObjField(DataRecord record,
String localName,
boolean required) |
static void |
DataIterators.skipRecord(DataRecord record,
DataIterator it) |
Copyright © 2002–2025 Devexperts LLC. All rights reserved.