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

Class Replayer

java.lang.Object
com.illumon.iris.db.v2.replay.Replayer
All Implemented Interfaces:
LiveTable, ReplayerInterface, Runnable
Direct Known Subclasses:
DataDrivenReplayer, FixedStepReplayer
public class Replayer extends Object implements ReplayerInterface, LiveTable
Replay historical data as simulated real-time data.

  • Field Details

  • Constructor Details

    • Replayer

      public Replayer(DBDateTime startTime, DBDateTime endTime)
      Creates a new replayer.
      Parameters:
      startTime - start time
      endTime - end time

  • Method Details

    • start

      public void start()
      Starts replaying data.
      Specified by:
      start in interface ReplayerInterface

    • isDone

      public boolean isDone()
      Has the replayer finished replaying all data.
      Specified by:
      isDone in interface ReplayerInterface
      Returns:
      true if the replayer has finished replaying all data; false otherwise.

    • shutdown

      public void shutdown() throws IOException
      Shuts down the replayer.
      Specified by:
      shutdown in interface ReplayerInterface
      Throws:
      IOException - problem shutting down the replayer.

    • waitDone

      public void waitDone(long maxTimeMillis)
      Wait a specified interval for the replayer to complete. If the replayer has not completed by the end of the interval, the method returns.
      Specified by:
      waitDone in interface ReplayerInterface
      Parameters:
      maxTimeMillis - maximum number of milliseconds to wait.
      Throws:
      QueryCancellationException - thread was interrupted.

    • schedule

      public void schedule(TimerTask task, long delay, long period)
      Schedule a task to execute.
      Specified by:
      schedule in interface ReplayerInterface
      Parameters:
      task - task to execute
      delay - delay in milliseconds before first executing the task
      period - frequency in milliseconds to execute the task.

    • getTimeProvider

      public static TimeProvider getTimeProvider(ReplayerInterface replayer)
      Gets a time provider for the replayer. The time provider returns the current replay time.
      Parameters:
      replayer - replayer
      Returns:
      time provider that returns the current replay time.

    • currentTimeNanos

      public long currentTimeNanos()
      Simulated time in nanoseconds.
      Returns:
      simulated time in nanoseconds.

    • currentTime

      public DBDateTime currentTime()
      Simulated time.
      Specified by:
      currentTime in interface ReplayerInterface
      Returns:
      simulated time.

    • setTime

      public void setTime(long updatedTime)
      Sets the current replay time.
      Specified by:
      setTime in interface ReplayerInterface
      Parameters:
      updatedTime - new replay time.

    • replay

      public DynamicTable replay(Table dataSource, String timeColumn)
      Prepares a historical table for replaying.
      Specified by:
      replay in interface ReplayerInterface
      Parameters:
      dataSource - historical table to replay
      timeColumn - column in the table containing timestamps
      Returns:
      dynamic, replayed version of the table.

    • replayGrouped

      public DynamicTable replayGrouped(Table dataSource, String timeColumn, String groupingColumn)
      Prepares a grouped historical table for replaying. This method can be faster than the ungrouped replay, but the performance increase comes with a cost. Within a group, the data ordering is maintained. Between groups, data ordering is not maintained for a time interval.
      Specified by:
      replayGrouped in interface ReplayerInterface
      Parameters:
      dataSource - historical table to replay
      timeColumn - column in the table containing timestamps
      Returns:
      dynamic, replayed version of the table.

    • replayGroupedLastBy

      public DynamicTable replayGroupedLastBy(Table dataSource, String timeColumn, String... groupingColumns)
      Prepares a grouped historical table for replaying as a last-by table.
      Specified by:
      replayGroupedLastBy in interface ReplayerInterface
      Parameters:
      dataSource - historical table to replay
      timeColumn - column in the table containing timestamps
      groupingColumns - columns used as the key in computing last-by
      Returns:
      dynamic, replayed version of the last-by table.

    • registerTimeSource

      public void registerTimeSource(Index index, ColumnSource<DBDateTime> timestampSource)
      Register the time column and index from a new table to replay. Most users will use replay, replayGrouped, or replayGroupedLastBy instead of this function.
      Parameters:
      index - table index
      timestampSource - column source containing time information.

    • refresh

      public void refresh()
      Refresh the simulated live tables.
      Specified by:
      refresh in interface LiveTable

    • getHandle

      public ReplayerHandle getHandle()
      Gets a handle to the replayer.
      Specified by:
      getHandle in interface ReplayerInterface
      Returns:
      handle to the replayer.