net.quasardb.qdb.ts

Class ExpWriter

java.lang.Object

net.quasardb.qdb.ts.Writer

net.quasardb.qdb.ts.ExpWriter

All Implemented Interfaces:

Flushable, AutoCloseable

public class ExpWriter
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/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	ExpWriter(Session session, Table[] tables)
protected	ExpWriter(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	flush() Flush current local cache to server.
void	flush(TimeRange[] ranges) Flush with specific time range, only useful in the context of a truncate push mode.
void	prepareFlush()
void	prepareFlush(TimeRange[] ranges)

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, pushMode, tableByIndex, tableIndexByName, trackMinMaxTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpWriter

protected ExpWriter(Session session,
                    Table[] tables)

ExpWriter

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

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)

prepareFlush

public void prepareFlush()
                  throws IOException

Throws:

IOException

prepareFlush

public void prepareFlush(TimeRange[] ranges)

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

flush

public void flush(TimeRange[] ranges)
           throws IOException

Description copied from class: Writer

Flush with specific time range, only useful in the context of a truncate push mode.

Overrides:

flush in class Writer

Throws:

IOException