com.devexperts.qd.ng

Interface RecordSink

All Superinterfaces:

DataVisitor, SubscriptionVisitor

All Known Implementing Classes:

AbstractQTPComposer, AbstractRecordSink, BinaryQTPComposer, ByteArrayComposer, DataSink, OutputStreamComposer, RecordBuffer

public interface RecordSink
extends DataVisitor, SubscriptionVisitor

An object to which data records can be appended. This interface is replacing legacy interfaces DataVisitor and SubscriptionVisitor.

Field Summary

Fields

Modifier and Type	Field and Description
static RecordSink	VOID Record sink that just ignores all records.

Method Summary

Modifier and Type	Method and Description
void	append(RecordCursor cursor) Adds a record to this sink from the specified RecordCursor.
void	flush() Signal that it is safe to flush appended records to disk, e.g.
boolean	hasCapacity() Returns whether sink has capacity to efficiently append next record.
void	visitIntField(DataIntField field, int value) Deprecated. Use append(RecordCursor).
void	visitObjField(DataObjField field, Object value) Deprecated. Use append(RecordCursor).
void	visitRecord(DataRecord record, int cipher, String symbol) Deprecated. Use append(RecordCursor).
void	visitRecord(DataRecord record, int cipher, String symbol, long time) Deprecated. Use append(RecordCursor).

Field Detail

VOID

static final RecordSink VOID

Record sink that just ignores all records.

Method Detail

hasCapacity

boolean hasCapacity()

Returns whether sink has capacity to efficiently append next record. This method may be used to advise RecordProvider that it is desirable to stop current batch and keep remaining records. However, record provider is not obliged to adhere to this method contract.

NOTE: sink must process all records that are passed to it via append method calls no matter whether it has capacity to do it efficiently.

Specified by:

hasCapacity in interface DataVisitor

Specified by:

hasCapacity in interface SubscriptionVisitor

append

void append(RecordCursor cursor)

Adds a record to this sink from the specified RecordCursor.

flush

void flush()

Signal that it is safe to flush appended records to disk, e.g. no locks are currently held.

visitRecord

void visitRecord(DataRecord record,
                 int cipher,
                 String symbol)

Deprecated. Use append(RecordCursor).

Visits next record.

Specified by:

visitRecord in interface DataVisitor

visitRecord

void visitRecord(DataRecord record,
                 int cipher,
                 String symbol,
                 long time)

Deprecated. Use append(RecordCursor).

Visits next record.

Specified by:

visitRecord in interface SubscriptionVisitor

visitIntField

void visitIntField(DataIntField field,
                   int value)

Deprecated. Use append(RecordCursor).

Visits next Int-field within current record.

Specified by:

visitIntField in interface DataVisitor

visitObjField

void visitObjField(DataObjField field,
                   Object value)

Deprecated. Use append(RecordCursor).

Visits next Obj-field within current record.

Specified by:

visitObjField in interface DataVisitor