net.quasardb.qdb.ts

Class AutoFlushWriter

java.lang.Object

net.quasardb.qdb.ts.Writer

net.quasardb.qdb.ts.AutoFlushWriter

All Implemented Interfaces:

Flushable, AutoCloseable

public final class AutoFlushWriter
extends Writer

An implementation of a Writer that automatically flushes the local cache when a certain threshold has been reached. As with Writer, usage of instances of this class is not thread-safe. Use an AutFlushWriter instance per Thread in multi-threaded situations.

Nested Class Summary

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	AutoFlushWriter(Session session, Table[] tables) Initialize a new auto-flushing timeseries table with a default threshold of 50000 rows.
protected	AutoFlushWriter(Session session, Table[] tables, long threshold) Initialize a new auto-flushing timeseries table.
protected	AutoFlushWriter(Session session, Table[] tables, long threshold, Writer.PushMode pushMode) Initialize a new auto-flushing timeseries table.
protected	AutoFlushWriter(Session session, Table[] tables, Writer.PushMode pushMode) Initialize a new auto-flushing timeseries table with a default threshold of 50000 rows.

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.

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AutoFlushWriter

protected AutoFlushWriter(Session session,
                          Table[] tables)

Initialize a new auto-flushing timeseries table with a default threshold of 50000 rows.

Parameters:

session - Active connection with the QdbCluster

tables - Timeseries tables we're writing to.

AutoFlushWriter

protected AutoFlushWriter(Session session,
                          Table[] tables,
                          Writer.PushMode pushMode)

Initialize a new auto-flushing timeseries table with a default threshold of 50000 rows.

Parameters:

session - Active connection with the QdbCluster

tables - Timeseries tables we're writing to.

pushMode - Determines which method of operation to use for flushing

AutoFlushWriter

protected AutoFlushWriter(Session session,
                          Table[] tables,
                          long threshold)

Initialize a new auto-flushing timeseries table.

Parameters:

session - Active connection with the QdbCluster

tables - Timeseries tables we're writing to.

threshold - The amount of rows to keep in local buffer before automatic flushing occurs.

AutoFlushWriter

protected AutoFlushWriter(Session session,
                          Table[] tables,
                          long threshold,
                          Writer.PushMode pushMode)

Initialize a new auto-flushing timeseries table.

Parameters:

session - Active connection with the QdbCluster

tables - Timeseries tables we're writing to.

threshold - The amount of rows to keep in local buffer before automatic flushing occurs.

pushMode - Determines which method of operation to use for flushing

Method Detail

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)