Package io.deephaven.engine.table.impl.replay

Class DataDrivenReplayer

java.lang.Object

io.deephaven.engine.table.impl.replay.Replayer

io.deephaven.engine.table.impl.replay.DataDrivenReplayer

All Implemented Interfaces:

ReplayerInterface, Runnable

public class DataDrivenReplayer
extends Replayer

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.replay.Replayer

endTime, startTime

Constructor Summary

Constructors

Constructor	Description
DataDrivenReplayer(Instant startTime, Instant endTime)

Method Summary

Modifier and Type	Method	Description
Clock	clock()
void	registerTimeSource(RowSet rowSet, ColumnSource<Instant> timestampSource)	Register the time column and row set from a new table to replay.
void	run()	Refresh the simulated live tables.
void	setTime(long updatedTime)	Sets the current replay time.
void	start()	Starts replaying data.

Methods inherited from class io.deephaven.engine.table.impl.replay.Replayer

getClock, getHandle, isDone, replay, replayGrouped, replayGroupedLastBy, schedule, shutdown, waitDone

Methods inherited from class java.lang.Object

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

Constructor Details

DataDrivenReplayer

public DataDrivenReplayer(Instant startTime,
 Instant endTime)

Method Details

registerTimeSource

public void registerTimeSource(RowSet rowSet,
 ColumnSource<Instant> timestampSource)

Description copied from class: Replayer

Register the time column and row set from a new table to replay. Most users will use replay, replayGrouped, or replayGroupedLastBy instead of this function.

Overrides:

registerTimeSource in class Replayer

Parameters:

rowSet - table row set

timestampSource - column source containing time information.

start

public void start()

Description copied from class: Replayer

Starts replaying data.

Specified by:

start in interface ReplayerInterface

Overrides:

start in class Replayer

run

public void run()

Description copied from class: Replayer

Refresh the simulated live tables.

Specified by:

run in interface Runnable

Overrides:

run in class Replayer

setTime

public void setTime(long updatedTime)

Description copied from class: Replayer

Sets the current replay time.

Specified by:

setTime in interface ReplayerInterface

Overrides:

setTime in class Replayer

Parameters:

updatedTime - new replay time.

clock

public Clock clock()

Specified by:

clock in interface ReplayerInterface

Overrides:

clock in class Replayer