Package deltix.qsrv.hf.tickdb.pub

Interface WritableTickStream

All Superinterfaces:

deltix.util.security.AuthorizationController.ProtectedResource, DXChannel<deltix.qsrv.hf.pub.InstrumentMessage>, TickStream

All Known Subinterfaces:

DXTickStream

public interface WritableTickStream
extends TickStream

Writeable stream.

See Also:

TickStream

Method Summary

Modifier and Type	Method	Description
void	clear(deltix.qsrv.hf.pub.InstrumentIdentity... ids)	Clear stream data for the given entities.
TickLoader	createLoader()	Creates a channel for loading data.
TickLoader	createLoader(LoadingOptions options)	Creates a channel for loading data.
void	delete(deltix.qsrv.hf.pub.TimeStamp from, deltix.qsrv.hf.pub.TimeStamp to, deltix.qsrv.hf.pub.InstrumentIdentity... ids)	Deletes stream data for the given entities using specified time range
WritableTickDB	getDB()	Returns the parent database object.
void	truncate(long time, deltix.qsrv.hf.pub.InstrumentIdentity... ids)	Truncates stream data for the given entities from given time

Methods inherited from interface deltix.data.stream.DXChannel

createConsumer, createPublisher, getTypes

Methods inherited from interface deltix.qsrv.hf.tickdb.pub.TickStream

createCursor, getAllDescriptors, getDescription, getFixedType, getFormatVersion, getKey, getName, getPolymorphicDescriptors, getTimeRange, getTimeRange, getTypeVersion, isFixedType, isPolymorphic, listEntities, listEntities, listSpaces, listTimeRange, select, select, select, select

Method Detail

getDB

WritableTickDB getDB()

Description copied from interface: TickStream

Returns the parent database object.

Specified by:

getDB in interface TickStream

Returns:

Parent database object.

createLoader

TickLoader createLoader()

Creates a channel for loading data. The loader must be closed when the loading process is finished.

Returns:

A consumer of messages to be loaded into the stream.

createLoader

TickLoader createLoader(LoadingOptions options)

Creates a channel for loading data. The loader must be closed when the loading process is finished.

Returns:

A consumer of messages to be loaded into the stream.

truncate

void truncate(long time,
              deltix.qsrv.hf.pub.InstrumentIdentity... ids)

Truncates stream data for the given entities from given time

Parameters:

time - Timestamp. If time less than stream start time, then all stream data will be deleted.

ids - A list of entities. If unknown, all stream entities will be used.

delete

void delete(deltix.qsrv.hf.pub.TimeStamp from,
            deltix.qsrv.hf.pub.TimeStamp to,
            deltix.qsrv.hf.pub.InstrumentIdentity... ids)

Deletes stream data for the given entities using specified time range

Parameters:

from - start timestamp (inclusive). Time is measured in milliseconds or nanoseconds that passed since January 1, 1970 UTC.

to - end timestamp (inclusive). Time is measured in milliseconds or nanoseconds that passed since January 1, 1970 UTC. If time more than stream end time, then all stream data will be deleted for the given stream.

ids - A list of entities. If unknown, all stream entities will be used.

clear

void clear(deltix.qsrv.hf.pub.InstrumentIdentity... ids)

Clear stream data for the given entities.

Parameters:

ids - A list of entities. If unknown, all stream entities will be used.