net.quasardb.qdb.ts

Class PinnedWriter

java.lang.Object

net.quasardb.qdb.ts.Writer

net.quasardb.qdb.ts.PinnedWriter

All Implemented Interfaces:

Flushable, AutoCloseable

public class PinnedWriter
extends Writer

Experimental, high-performance bulk writer for a QuasarDB timeseries table. Usage of instances of this class is not thread-safe. Use a Writer instance per Thread in multi-threaded situations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PinnedWriter.PinnedMatrix

Nested classes/interfaces inherited from class net.quasardb.qdb.ts.Writer

Writer.PushMode, Writer.TableColumn

Field Summary

Fields inherited from class net.quasardb.qdb.ts.Writer

columns, pointsSinceFlush

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PinnedWriter(Session session, Table[] tables)
protected	PinnedWriter(Session session, Table[] tables, Writer.PushMode mode)

Method Summary

Modifier and Type	Method and Description
void	append(Integer offset, Timespec timestamp, Value[] values) Append a new row to the local table cache.
void	extraTables(Table[] tables) After a writer is already initialized, this function allows extra tables to be added to the internal state.
void	flush() Flush current local cache to server.
void	prepareFlush()

Methods inherited from class net.quasardb.qdb.ts.Writer

append, append, append, append, append, append, append, append, append, append, append, close, extraTables, finalize, flush, flush, pushMode, tableByIndex, tableIndexByName, trackMinMaxTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

PinnedWriter

protected PinnedWriter(Session session,
                       Table[] tables)

PinnedWriter

protected PinnedWriter(Session session,
                       Table[] tables,
                       Writer.PushMode mode)

Method Detail

extraTables

public void extraTables(Table[] tables)

Description copied from class: Writer

After a writer is already initialized, this function allows extra tables to be added to the internal state. Blocking function that needs to communicate with the QuasarDB daemon to retrieve metadata.

Overrides:

extraTables in class Writer

append

public void append(Integer offset,
                   Timespec timestamp,
                   Value[] values)
            throws IOException

Description copied from class: Writer

Append a new row to the local table cache. Should be periodically flushed, unless an AutoFlushWriter is used.

Overrides:

append in class Writer

Parameters:

offset - Relative offset of the table inside the batch. Use #tableIndexByName to determine the appropriate value.

timestamp - Timestamp of the row

values - Values being inserted, mapped to columns by their relative offset.

Throws:

IOException

See Also:

Writer.tableIndexByName(java.lang.String), Writer.flush(), Table.autoFlushWriter(net.quasardb.qdb.Session, java.lang.String)

prepareFlush

public void prepareFlush()
                  throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Description copied from class: Writer

Flush current local cache to server.

Specified by:

flush in interface Flushable

Overrides:

flush in class Writer

Throws:

IOException