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

Interface ReplayerInterface

All Known Implementing Classes:
DataDrivenReplayer, FixedStepReplayer, ReplayClient, Replayer
public interface ReplayerInterface
An interface for replaying historical data as simulated real-time data.

  • Method Details

    • start

      void start() throws IOException
      Starts replaying data.
      Throws:
      IOException

    • isDone

      boolean isDone() throws IOException
      Has the replayer finished replaying all data.
      Returns:
      true if the replayer has finished replaying all data; false otherwise.
      Throws:
      IOException

    • shutdown

      void shutdown() throws IOException
      Shuts down the replayer.
      Throws:
      IOException - problem shutting down the replayer.

    • waitDone

      void waitDone(long maxTimeMillis) throws IOException
      Wait a specified interval for the replayer to complete. If the replayer has not completed by the end of the interval, the method returns.
      Parameters:
      maxTimeMillis - maximum number of milliseconds to wait.
      Throws:
      IOException - problems encountered

    • setTime

      void setTime(long updatedTime)
      Sets the current replay time.
      Parameters:
      updatedTime - new replay time.

    • schedule

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

    • currentTime

      DBDateTime currentTime() throws IOException
      Simulated time.
      Returns:
      simulated time.
      Throws:
      IOException

    • replay

      Table replay(Table dataSource, String timeColumn) throws IOException
      Prepares a historical table for replaying.
      Parameters:
      dataSource - historical table to replay
      timeColumn - column in the table containing timestamps
      Returns:
      dynamic, replayed version of the table.
      Throws:
      IOException

    • replayGrouped

      Table replayGrouped(Table dataSource, String timeColumn, String byColumn) throws IOException
      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.
      Parameters:
      dataSource - historical table to replay
      timeColumn - column in the table containing timestamps
      Returns:
      dynamic, replayed version of the table.
      Throws:
      IOException

    • replayGroupedLastBy

      Table replayGroupedLastBy(Table dataSource, String timeColumn, String... groupingColumns) throws IOException
      Prepares a grouped historical table for replaying as a last-by table.
      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.
      Throws:
      IOException

    • getHandle

      ReplayerHandle getHandle()
      Gets a handle to the replayer.
      Returns:
      handle to the replayer.