Package com.illumon.iris.db.v2.replay

Class DataDrivenReplayer

java.lang.Object

com.illumon.iris.db.v2.replay.Replayer

com.illumon.iris.db.v2.replay.DataDrivenReplayer

All Implemented Interfaces:

LiveTable, ReplayerInterface

public class DataDrivenReplayer
extends Replayer

Field Summary

Fields inherited from class com.illumon.iris.db.v2.replay.Replayer

endTime, startTime

Constructor Summary

Constructors

Constructor	Description
DataDrivenReplayer(DBDateTime startTime, DBDateTime endTime)

Method Summary

Modifier and Type	Method	Description
DBDateTime	currentTime()	Simulated time.
void	refresh()	Refresh the simulated live tables.
void	registerTimeSource(Index index, ColumnSource<DBDateTime> timestampSource)	Register the time column and index from a new table to replay.
void	setTime(long updatedTime)	Sets the current replay time.
void	start()	Starts replaying data.

Methods inherited from class com.illumon.iris.db.v2.replay.Replayer

currentTimeNanos, getHandle, getTimeProvider, 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(DBDateTime startTime, DBDateTime endTime)

Method Details

currentTime

public DBDateTime currentTime()

Description copied from class: Replayer

Simulated time.

Specified by:

currentTime in interface ReplayerInterface

Overrides:

currentTime in class Replayer

Returns:

simulated time.

registerTimeSource

public void registerTimeSource(Index index, ColumnSource<DBDateTime> timestampSource)

Description copied from class: Replayer

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

Overrides:

registerTimeSource in class Replayer

Parameters:

index - table index

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

refresh

public void refresh()

Description copied from class: Replayer

Refresh the simulated live tables.

Specified by:

refresh in interface LiveTable

Overrides:

refresh 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.