deephaven.replay

This module provides support for replaying historical data.

class TableReplayer(start_time, end_time)[source]

Bases: JObjectWrapper

The TableReplayer is used to replay historical data.

Tables to be replayed are registered with the replayer. The resulting dynamic replay tables all update in sync, using the same simulated clock. Each registered table must contain a timestamp column.

Initializes the replayer.

Parameters:
  • start_time (Union[dtypes.Instant, int, str, datetime.datetime, np.datetime64, pd.Timestamp]) – replay start time. Integer values are nanoseconds since the Epoch.

  • end_time (Union[dtypes.Instant, int, str, datetime.datetime, np.datetime64, pd.Timestamp]) – replay end time. Integer values are nanoseconds since the Epoch.

Raises:

DHError

add_table(table, col)[source]

Registers a table for replaying and returns the associated replay table.

Parameters:
  • table (Table) – the table to be replayed

  • col (str) – column in the table containing timestamps

Return type:

Table

Returns:

a replay Table

Raises:

DHError

j_object_type

alias of Replayer

shutdown()[source]

Shuts down and invalidates the replayer. After this call, the replayer can no longer be used.

Return type:

None

start()[source]

Starts replaying.

Raises:

DHError

Return type:

None