com.devexperts.qd.ng

Class AbstractRecordSink

java.lang.Object

com.devexperts.qd.ng.AbstractRecordSink

All Implemented Interfaces:

DataVisitor, RecordSink, SubscriptionVisitor

Direct Known Subclasses:

DataSink

public abstract class AbstractRecordSink
extends Object
implements RecordSink

Bridge class that adapts DataVisitor and SubscriptionVisitor APIs to RecordSink API. All you have to do is to implement append(RecordCursor) method, while all the methods of DataVisitor and SubscriptionVisitor interfaces are already implemented and invoke append(RecordCursor) implementation.

Field Summary

Fields inherited from interface com.devexperts.qd.ng.RecordSink

VOID

Constructor Summary

Constructors

Constructor and Description
AbstractRecordSink()

Method Summary

Modifier and Type	Method and Description
abstract 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).

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractRecordSink

public AbstractRecordSink()

Method Detail

hasCapacity

public 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.

This implementation returns true.

Specified by:

hasCapacity in interface DataVisitor

Specified by:

hasCapacity in interface RecordSink

Specified by:

hasCapacity in interface SubscriptionVisitor

append

public abstract void append(RecordCursor cursor)

Adds a record to this sink from the specified RecordCursor.

Specified by:

append in interface RecordSink

flush

public void flush()

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

This implementation does nothing.

Specified by:

flush in interface RecordSink

visitRecord

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

Deprecated. Use append(RecordCursor).

Visits next record.

Specified by:

visitRecord in interface DataVisitor

Specified by:

visitRecord in interface RecordSink

visitRecord

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

Deprecated. Use append(RecordCursor).

Visits next record.

Specified by:

visitRecord in interface RecordSink

Specified by:

visitRecord in interface SubscriptionVisitor

visitIntField

public final void visitIntField(DataIntField field,
                                int value)

Deprecated. Use append(RecordCursor).

Visits next Int-field within current record.

Specified by:

visitIntField in interface DataVisitor

Specified by:

visitIntField in interface RecordSink

visitObjField

public final void visitObjField(DataObjField field,
                                Object value)

Deprecated. Use append(RecordCursor).

Visits next Obj-field within current record.

Specified by:

visitObjField in interface DataVisitor

Specified by:

visitObjField in interface RecordSink