Package io.deephaven.enterprise.database

Class ReplayAccess

java.lang.Object

io.deephaven.enterprise.database.ReplayAccess

All Implemented Interfaces:

Database.DatabaseTableAccess<ReplayAccess.Options>, TableAccess<ReplayAccess.Options>

public final class ReplayAccess
extends Object
implements Database.DatabaseTableAccess<ReplayAccess.Options>

Replay-related access to Database tables.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ReplayAccess.Options	Replay access options.
static interface	ReplayAccess.OutputAttributes	The output Table attributes.
static interface	ReplayAccess.ReplayMode	The replay mode.
static interface	ReplayAccess.Source	The source of replayed data.

Method Summary

Modifier and Type	Method	Description
static Database.TableAccessFactory<ReplayAccess>	factory()
boolean	isRefreshing(ReplayAccess.Options options)	Return whether calling Database.DatabaseTableAccess.table(Object) with options would result in a Table.isRefreshing().
Table	table(@NotNull ReplayAccess.Options options)	Fetch the table according to the options with appropriate access controls applied.
Table	table(String namespace, String tableName, Instant startInstant)	Replays the given table from historical data starting at the given startInstant, time will advance relative to the system clock using unsorted mode, and the resulting Table will be add-only.
Table	table(String namespace, String tableName, Instant startInstant, String timestampColumnName)	Replays the given table from historical data starting at the given startInstant, time will advance relative to the system clock using unsorted mode, and the resulting Table will be add-only output.

Methods inherited from class java.lang.Object

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

Method Details

factory

public static Database.TableAccessFactory<ReplayAccess> factory()

Returns:

the replay access factory

table

public Table table(String namespace,
 String tableName,
 Instant startInstant)

Replays the given table from historical data starting at the given startInstant, time will advance relative to the system clock using unsorted mode, and the resulting Table will be add-only. The timestamp column is inferred from the schema.

Parameters:

namespace - the namespace

tableName - the table name

startInstant - the start of the replay clock

Returns:

the replay table

table

public Table table(String namespace,
 String tableName,
 Instant startInstant,
 String timestampColumnName)

Replays the given table from historical data starting at the given startInstant, time will advance relative to the system clock using unsorted mode, and the resulting Table will be add-only output.

Parameters:

namespace - the namespace

tableName - the table name

startInstant - the start of the replay clock

timestampColumnName - the timestamp column name

Returns:

the replay table

isRefreshing

public boolean isRefreshing(@NotNull
 ReplayAccess.Options options)

Description copied from interface: Database.DatabaseTableAccess

Return whether calling Database.DatabaseTableAccess.table(Object) with options would result in a Table.isRefreshing().

Specified by:

isRefreshing in interface Database.DatabaseTableAccess<ReplayAccess.Options>

Parameters:

options - the options

Returns:

if the table should be refreshing

table

public Table table(@NotNull
 @NotNull ReplayAccess.Options options)

Description copied from interface: Database.DatabaseTableAccess

Fetch the table according to the options with appropriate access controls applied.

Specified by:

table in interface Database.DatabaseTableAccess<ReplayAccess.Options>

Specified by:

table in interface TableAccess<ReplayAccess.Options>

Parameters:

options - the options

Returns:

the table