net.quasardb.qdb.ts

Class Tables

java.lang.Object

net.quasardb.qdb.ts.Tables

All Implemented Interfaces:

Serializable

public class Tables
extends Object
implements Serializable

Utility class to make working with multiple tables easier by bridging between the #Table and #Writer class. It maintains its own internal array of tables and can be serialized.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected List<Table>	tables

Constructor Summary

Constructors

Constructor and Description
Tables() Initialize empty collection of Tables.
Tables(Table[] tables) Initialize a collection of timeseries Tables.

Method Summary

Modifier and Type	Method and Description
Tables	add(Session session, String name) Returns a copy of this collection with the new table added.
Tables	add(Table table) Returns a copy of this collection with the new table added.
static AutoFlushWriter	asyncAutoFlushWriter(Session session, Table[] tables) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.
static AutoFlushWriter	asyncAutoFlushWriter(Session session, Table[] tables, long threshold) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.
static AutoFlushWriter	asyncAutoFlushWriter(Session session, Tables tables) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.
static AutoFlushWriter	asyncAutoFlushWriter(Session session, Tables tables, long threshold) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.
static Writer	asyncWriter(Session session, Table[] tables) Initializes new writer for timeseries table using hgih-speed buffered writes.
static Writer	asyncWriter(Session session, Tables tables) Initializes new writer for timeseries table using high-speed buffered writes.
static AutoFlushWriter	autoFlushWriter(Session session, Table[] tables) Initializes new writer for timeseries tables that periodically flushes its local cache.
static AutoFlushWriter	autoFlushWriter(Session session, Table[] tables, long threshold) Initializes new writer for timeseries tables that periodically flushes its local cache.
static AutoFlushWriter	autoFlushWriter(Session session, Tables tables) Initializes new writer for timeseries tables that periodically flushes its local cache.
static AutoFlushWriter	autoFlushWriter(Session session, Tables tables, long threshold) Initializes new writer for timeseries tables that periodically flushes its local cache.
static Writer	expAsyncWriter(Session session, Table[] tables) Initializes new, experimental exp columns writer for timeseries tables.
static Writer	expAsyncWriter(Session session, Tables tables) Initializes new, experimental exp columns writer for timeseries tables.
static Writer	expFastWriter(Session session, Table[] tables) Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write.
static Writer	expFastWriter(Session session, Tables tables) Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write.
static Writer	expTruncateWriter(Session session, Table[] tables) Initializes new, experimental exp columns writer for timeseries tables.
static Writer	expTruncateWriter(Session session, Tables tables) Initializes new, experimental exp columns writer for timeseries tables.
static Writer	expWriter(Session session, Table[] tables) Initializes new, experimental writer for timeseries tables.
static Writer	expWriter(Session session, Table[] tables, Writer.PushMode mode) Initializes new, experimental exp columns writer for timeseries tables.
static Writer	expWriter(Session session, Tables tables) Initializes new, experimental writer for timeseries tables.
static Writer	expWriter(Session session, Tables tables, Writer.PushMode mode) Initializes new, experimental writer for timeseries tables.
static AutoFlushWriter	fastAutoFlushWriter(Session session, Table[] tables) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.
static AutoFlushWriter	fastAutoFlushWriter(Session session, Table[] tables, long threshold) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.
static AutoFlushWriter	fastAutoFlushWriter(Session session, Tables tables) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.
static AutoFlushWriter	fastAutoFlushWriter(Session session, Tables tables, long threshold) Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.
static Writer	fastWriter(Session session, Table[] tables) Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write.
static Writer	fastWriter(Session session, Tables tables) Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write.
protected Table[]	getTables() Provides access to the internal #Table collection.
boolean	hasTableWithName(String tableName) Returns true when the collection contains a table with a certain name.
static Tables	ofTag(Session session, String tag)
static Writer	pinnedAsyncWriter(Session session, Table[] tables) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedAsyncWriter(Session session, Tables tables) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedFastWriter(Session session, Table[] tables) Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write.
static Writer	pinnedFastWriter(Session session, Tables tables) Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write.
static Writer	pinnedTruncateWriter(Session session, Table[] tables) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedTruncateWriter(Session session, Tables tables) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedWriter(Session session, Table[] tables) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedWriter(Session session, Table[] tables, Writer.PushMode mode) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedWriter(Session session, Tables tables) Initializes new, experimental pinned columns writer for timeseries tables.
static Writer	pinnedWriter(Session session, Tables tables, Writer.PushMode mode) Initializes new, experimental pinned columns writer for timeseries tables.
int	size() Returns the number of tables in this collection.
String	toString()
static Writer	truncateWriter(Session session, Table[] tables) Initializes new writer for a single table that replaces any existing data with the new data, rather than just adding.
static Writer	truncateWriter(Session session, Tables tables) Initializes new writer for a single table that replaces any existing data with the new data, rather than just adding.
static Writer	writer(Session session, Table[] tables) Initializes new writer for timeseries table.
static Writer	writer(Session session, Table[] tables, Writer.PushMode mode) Initializes new writer for timeseries table.
static Writer	writer(Session session, Tables tables) Initializes new writer for timeseries table.
static Writer	writer(Session session, Tables tables, Writer.PushMode mode) Initializes new writer for timeseries table.

Methods inherited from class java.lang.Object

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

Field Detail

tables

protected List<Table> tables

Constructor Detail

Tables

public Tables()

Initialize empty collection of Tables.

Tables

public Tables(Table[] tables)

Initialize a collection of timeseries Tables.

Parameters:

tables - Initial collection.

Method Detail

size

public int size()

Returns the number of tables in this collection.

Returns:

The number of tables in this collection.

hasTableWithName

public boolean hasTableWithName(String tableName)

Returns true when the collection contains a table with a certain name. This operation has O(N) complexity.

Parameters:

tableName - The tablename to search for.

Returns:

True when the collection contains a table with the name.

getTables

protected Table[] getTables()

Provides access to the internal #Table collection.

add

public Tables add(Table table)

Returns a copy of this collection with the new table added.

Parameters:

table - The table to add

add

public Tables add(Session session,
                  String name)

Returns a copy of this collection with the new table added.

Parameters:

session - Active session wit the QuasarDB cluster.

name - Name of the table to add

ofTag

public static Tables ofTag(Session session,
                           String tag)

writer

public static Writer writer(Session session,
                            Tables tables)

Initializes new writer for timeseries table.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

writer

public static Writer writer(Session session,
                            Tables tables,
                            Writer.PushMode mode)

Initializes new writer for timeseries table.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

writer

public static Writer writer(Session session,
                            Table[] tables)

Initializes new writer for timeseries table.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

writer

public static Writer writer(Session session,
                            Table[] tables,
                            Writer.PushMode mode)

Initializes new writer for timeseries table.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

mode - Push mode to use

pinnedWriter

public static Writer pinnedWriter(Session session,
                                  Tables tables)

Initializes new, experimental pinned columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedWriter

public static Writer pinnedWriter(Session session,
                                  Tables tables,
                                  Writer.PushMode mode)

Initializes new, experimental pinned columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedWriter

public static Writer pinnedWriter(Session session,
                                  Table[] tables)

Initializes new, experimental pinned columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedWriter

public static Writer pinnedWriter(Session session,
                                  Table[] tables,
                                  Writer.PushMode mode)

Initializes new, experimental pinned columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

mode - The pushmode to use

expWriter

public static Writer expWriter(Session session,
                               Tables tables)

Initializes new, experimental writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expWriter

public static Writer expWriter(Session session,
                               Tables tables,
                               Writer.PushMode mode)

Initializes new, experimental writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expWriter

public static Writer expWriter(Session session,
                               Table[] tables)

Initializes new, experimental writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expWriter

public static Writer expWriter(Session session,
                               Table[] tables,
                               Writer.PushMode mode)

Initializes new, experimental exp columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

mode - The pushmode to use

pinnedTruncateWriter

public static Writer pinnedTruncateWriter(Session session,
                                          Tables tables)

Initializes new, experimental pinned columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedTruncateWriter

public static Writer pinnedTruncateWriter(Session session,
                                          Table[] tables)

Initializes new, experimental pinned columns writer for timeseries tables. This makes use of the experimental, high-performance 'pinned' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expTruncateWriter

public static Writer expTruncateWriter(Session session,
                                       Tables tables)

Initializes new, experimental exp columns writer for timeseries tables.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expTruncateWriter

public static Writer expTruncateWriter(Session session,
                                       Table[] tables)

Initializes new, experimental exp columns writer for timeseries tables. This makes use of the experimental, high-performance 'exp' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedAsyncWriter

public static Writer pinnedAsyncWriter(Session session,
                                       Tables tables)

Initializes new, experimental pinned columns writer for timeseries tables. This makes use of the experimental, high-performance 'pinned' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedAsyncWriter

public static Writer pinnedAsyncWriter(Session session,
                                       Table[] tables)

Initializes new, experimental pinned columns writer for timeseries tables. This makes use of the experimental, high-performance 'pinned' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expAsyncWriter

public static Writer expAsyncWriter(Session session,
                                    Tables tables)

Initializes new, experimental exp columns writer for timeseries tables. This makes use of the experimental, high-performance 'exp' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expAsyncWriter

public static Writer expAsyncWriter(Session session,
                                    Table[] tables)

Initializes new, experimental exp columns writer for timeseries tables. This makes use of the experimental, high-performance 'exp' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

asyncWriter

public static Writer asyncWriter(Session session,
                                 Tables tables)

Initializes new writer for timeseries table using high-speed buffered writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

asyncWriter

public static Writer asyncWriter(Session session,
                                 Table[] tables)

Initializes new writer for timeseries table using hgih-speed buffered writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

fastWriter

public static Writer fastWriter(Session session,
                                Tables tables)

Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write. This is especially useful when you do lots of small, incremental pushes, such as streaming data.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

fastWriter

public static Writer fastWriter(Session session,
                                Table[] tables)

Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write. This is especially useful when you do lots of small, incremental pushes, such as streaming data.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedFastWriter

public static Writer pinnedFastWriter(Session session,
                                      Tables tables)

Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write. This is especially useful when you do lots of small, incremental pushes, such as streaming data. This makes use of the experimental, high-performance 'pinned' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

pinnedFastWriter

public static Writer pinnedFastWriter(Session session,
                                      Table[] tables)

Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write. This is especially useful when you do lots of small, incremental pushes, such as streaming data. This makes use of the experimental, high-performance 'pinned' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expFastWriter

public static Writer expFastWriter(Session session,
                                   Tables tables)

Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write. This is especially useful when you do lots of small, incremental pushes, such as streaming data. This makes use of the experimental, high-performance 'exp' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

expFastWriter

public static Writer expFastWriter(Session session,
                                   Table[] tables)

Initializes new writer for timeseries tables that makes use of in-place updates rather than copy-on-write. This is especially useful when you do lots of small, incremental pushes, such as streaming data. This makes use of the experimental, high-performance 'exp' writer API.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

truncateWriter

public static Writer truncateWriter(Session session,
                                    Tables tables)

Initializes new writer for a single table that replaces any existing data with the new data, rather than just adding. This is recommended if you want the ability to retry operations, and you are not inserting into the same table from multiple writers.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

truncateWriter

public static Writer truncateWriter(Session session,
                                    Table[] tables)

Initializes new writer for a single table that replaces any existing data with the new data, rather than just adding. This is recommended if you want the ability to retry operations, and you are not inserting into the same table from multiple writers.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables.

autoFlushWriter

public static AutoFlushWriter autoFlushWriter(Session session,
                                              Tables tables)

Initializes new writer for timeseries tables that periodically flushes its local cache.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables to write to.

autoFlushWriter

public static AutoFlushWriter autoFlushWriter(Session session,
                                              Table[] tables)

Initializes new writer for timeseries tables that periodically flushes its local cache.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries table.

autoFlushWriter

public static AutoFlushWriter autoFlushWriter(Session session,
                                              Tables tables,
                                              long threshold)

Initializes new writer for timeseries tables that periodically flushes its local cache.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables to write to.

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

autoFlushWriter

public static AutoFlushWriter autoFlushWriter(Session session,
                                              Table[] tables,
                                              long threshold)

Initializes new writer for timeseries tables that periodically flushes its local cache.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries table.

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

asyncAutoFlushWriter

public static AutoFlushWriter asyncAutoFlushWriter(Session session,
                                                   Tables tables)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables to write to.

asyncAutoFlushWriter

public static AutoFlushWriter asyncAutoFlushWriter(Session session,
                                                   Table[] tables)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries table.

asyncAutoFlushWriter

public static AutoFlushWriter asyncAutoFlushWriter(Session session,
                                                   Tables tables,
                                                   long threshold)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables to write to.

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

asyncAutoFlushWriter

public static AutoFlushWriter asyncAutoFlushWriter(Session session,
                                                   Table[] tables,
                                                   long threshold)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed buffered writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries table.

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

fastAutoFlushWriter

public static AutoFlushWriter fastAutoFlushWriter(Session session,
                                                  Tables tables)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables to write to.

fastAutoFlushWriter

public static AutoFlushWriter fastAutoFlushWriter(Session session,
                                                  Table[] tables)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries table.

fastAutoFlushWriter

public static AutoFlushWriter fastAutoFlushWriter(Session session,
                                                  Tables tables,
                                                  long threshold)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries tables to write to.

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

fastAutoFlushWriter

public static AutoFlushWriter fastAutoFlushWriter(Session session,
                                                  Table[] tables,
                                                  long threshold)

Initializes new writer for timeseries tables that periodically flushes its local cache, and makes use of high-speed in-place writes.

Parameters:

session - Active session with the QuasarDB cluster.

tables - Timeseries table.

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

toString

public String toString()

Overrides:

toString in class Object