| Package | Description |
|---|---|
| net.quasardb.qdb.ts |
| Modifier and Type | Field and Description |
|---|---|
protected List<Table> |
Tables.tables |
| Modifier and Type | Method and Description |
|---|---|
static Table |
Table.create(Session session,
String name,
Column[] columns)
Create new timeseries table with a default shard size.
|
static Table |
Table.create(Session session,
String name,
Column[] columns,
long shardSize)
Create new timeseries table.
|
static Table |
Table.create(Session session,
String name,
Table skeleton)
Create new timeseries table by copying a 'skeleton' table's schema and using
the default shard size.
|
static Table |
Table.create(Session session,
String name,
Table skeleton,
long shardSize)
Create new timeseries table by copying a 'skeleton' table's schema.
|
Table |
Reader.getTable() |
protected Table[] |
Tables.getTables()
Provides access to the internal #Table collection.
|
static Table |
Table.likeOther(Table other,
String name)
Creates a new table object with the exact same structure and shard size
as another table.
|
protected Table |
Writer.tableByIndex(int index)
Reverse of tableIndexByName, based on a (column) index, resolves the table.
|
| Modifier and Type | Method and Description |
|---|---|
Tables |
Tables.add(Table table)
Returns a copy of this collection with the new table added.
|
static AutoFlushWriter |
Table.asyncAutoFlushWriter(Session session,
Table table)
Initializes new writer for a timeseries table that periodically flushes
its local cache, and makes use of high-speed buffered writes.
|
static AutoFlushWriter |
Tables.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 |
Tables.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 |
Table.asyncAutoFlushWriter(Session session,
Table table,
long threshold)
Initializes new writer for a timeseries table that periodically flushes
its local cache, and makes use of high-speed buffered writes.
|
static Writer |
Table.asyncWriter(Session session,
Table table)
Initializes new writer for a timeseries table using high-speed
buffered writes.
|
static Writer |
Tables.asyncWriter(Session session,
Table[] tables)
Initializes new writer for timeseries table using hgih-speed
buffered writes.
|
static void |
Table.attachTag(Session session,
Table table,
String tag)
Attaches a tag to an existing table.
|
static void |
Table.attachTags(Session session,
Table table,
List<String> tags)
Attaches tags to an existing table.
|
static AutoFlushWriter |
Table.autoFlushWriter(Session session,
Table table)
Initializes new writer for a timeseries table that periodically flushes
its local cache.
|
static AutoFlushWriter |
Tables.autoFlushWriter(Session session,
Table[] tables)
Initializes new writer for timeseries tables that periodically flushes
its local cache.
|
static AutoFlushWriter |
Tables.autoFlushWriter(Session session,
Table[] tables,
long threshold)
Initializes new writer for timeseries tables that periodically flushes
its local cache.
|
static AutoFlushWriter |
Table.autoFlushWriter(Session session,
Table table,
long threshold)
Initializes new writer for a timeseries table that periodically flushes
its local cache.
|
static Table |
Table.create(Session session,
String name,
Table skeleton)
Create new timeseries table by copying a 'skeleton' table's schema and using
the default shard size.
|
static Table |
Table.create(Session session,
String name,
Table skeleton,
long shardSize)
Create new timeseries table by copying a 'skeleton' table's schema.
|
static Writer |
Table.expAsyncWriter(Session session,
Table table)
Initializes new, experimental high-performance exp columns writer
with asynchronous push mode.
|
static Writer |
Tables.expAsyncWriter(Session session,
Table[] tables)
Initializes new, experimental exp columns writer for timeseries tables.
|
static Writer |
Table.expFastWriter(Session session,
Table table)
Initializes new writer for a single table that makes use of
in-place updates rather than copy-on-write.
|
static Writer |
Tables.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 |
Table.expTruncateWriter(Session session,
Table table)
Initializes new, experimental high-performance exp columns writer.
|
static Writer |
Tables.expTruncateWriter(Session session,
Table[] tables)
Initializes new, experimental exp columns writer for timeseries tables.
|
static Writer |
Table.expWriter(Session session,
Table table)
Initializes new, experimental high-performance writer.
|
static Writer |
Tables.expWriter(Session session,
Table[] tables)
Initializes new, experimental writer for timeseries tables.
|
static Writer |
Tables.expWriter(Session session,
Table[] tables,
Writer.PushMode mode)
Initializes new, experimental exp columns writer for timeseries tables.
|
void |
Writer.extraTables(Table table) |
void |
Writer.extraTables(Table[] tables)
After a writer is already initialized, this function allows extra tables to
be added to the internal state.
|
void |
PinnedWriter.extraTables(Table[] tables) |
static AutoFlushWriter |
Table.fastAutoFlushWriter(Session session,
Table table)
Initializes new writer for a timeseries table that periodically flushes
its local cache, and makes use of high-speed buffered writes.
|
static AutoFlushWriter |
Tables.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 |
Tables.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 |
Table.fastAutoFlushWriter(Session session,
Table table,
long threshold)
Initializes new writer for a timeseries table that periodically flushes
its local cache, and makes use of high-speed buffered writes.
|
static Writer |
Table.fastWriter(Session session,
Table table)
Initializes new writer for a single table that makes use of
in-place updates rather than copy-on-write.
|
static Writer |
Tables.fastWriter(Session session,
Table[] tables)
Initializes new writer for timeseries tables that makes use of
in-place updates rather than copy-on-write.
|
static long |
Table.getShardSize(Session session,
Table table)
Returns the shard size (in seconds) of the table.
|
static long |
Table.getShardSizeMillis(Session session,
Table table)
Returns the shard size (in milliseconds) of the table.
|
static Table |
Table.likeOther(Table other,
String name)
Creates a new table object with the exact same structure and shard size
as another table.
|
static Writer |
Table.pinnedAsyncWriter(Session session,
Table table)
Initializes new, experimental high-performance pinned columns writer
with asynchronous push mode.
|
static Writer |
Tables.pinnedAsyncWriter(Session session,
Table[] tables)
Initializes new, experimental pinned columns writer for timeseries tables.
|
static Writer |
Table.pinnedFastWriter(Session session,
Table table)
Initializes new writer for a single table that makes use of
in-place updates rather than copy-on-write.
|
static Writer |
Tables.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 |
Table.pinnedTruncateWriter(Session session,
Table table)
Initializes new, experimental high-performance pinned columns writer.
|
static Writer |
Tables.pinnedTruncateWriter(Session session,
Table[] tables)
Initializes new, experimental pinned columns writer for timeseries tables.
|
static Writer |
Table.pinnedWriter(Session session,
Table table)
Initializes new, experimental high-performance pinned columns writer.
|
static Writer |
Tables.pinnedWriter(Session session,
Table[] tables)
Initializes new, experimental pinned columns writer for timeseries tables.
|
static Writer |
Tables.pinnedWriter(Session session,
Table[] tables,
Writer.PushMode mode)
Initializes new, experimental pinned columns writer for timeseries tables.
|
static Reader |
Table.reader(Session session,
Table table,
TimeRange[] ranges)
Initializes new reader for a timeseries table.
|
static void |
Table.remove(Session session,
Table table)
Remove existing timeseries table.
|
static Writer |
Table.truncateWriter(Session session,
Table table)
Initializes new writer for a single table that replaces any
existing data with the new data, rather than just adding.
|
static Writer |
Tables.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 |
Table.writer(Session session,
Table table)
Initializes new writer for a timeseries table.
|
static Writer |
Tables.writer(Session session,
Table[] tables)
Initializes new writer for timeseries table.
|
static Writer |
Tables.writer(Session session,
Table[] tables,
Writer.PushMode mode)
Initializes new writer for timeseries table.
|
| Constructor and Description |
|---|
AutoFlushWriter(Session session,
Table[] tables)
Initialize a new auto-flushing timeseries table with a default threshold of 50000 rows.
|
AutoFlushWriter(Session session,
Table[] tables,
long threshold)
Initialize a new auto-flushing timeseries table.
|
AutoFlushWriter(Session session,
Table[] tables,
long threshold,
Writer.PushMode pushMode)
Initialize a new auto-flushing timeseries table.
|
AutoFlushWriter(Session session,
Table[] tables,
Writer.PushMode pushMode)
Initialize a new auto-flushing timeseries table with a default threshold of 50000 rows.
|
ExpWriter(Session session,
Table[] tables) |
ExpWriter(Session session,
Table[] tables,
Writer.PushMode mode) |
PinnedWriter(Session session,
Table[] tables) |
PinnedWriter(Session session,
Table[] tables,
Writer.PushMode mode) |
Reader(Session session,
Table table,
TimeRange[] ranges) |
Tables(Table[] tables)
Initialize a collection of timeseries Tables.
|
Writer(Session session,
Table[] tables) |
Writer(Session session,
Table[] tables,
Writer.PushMode mode) |
Copyright © 2021. All rights reserved.