Class WindowCheck

java.lang.Object
com.illumon.iris.db.tables.utils.WindowCheck

public class WindowCheck
extends Object
Adds a Boolean column that is true if a Timestamp is within the specified window.
  • Method Details

    • addTimeWindow

      public static Table addTimeWindow​(Table table, String timestampColumn, long windowNanos, String inWindowColumn)

      Adds a Boolean column that is false when a timestamp column is older than windowNanos.

      If the timestamp is greater than or equal to the curent time - windowNanos, then the result column is true. If the timestamp is null; the InWindow value is null.

      The resultant table ticks whenever the input table ticks, or modifies a row when it passes out of the window.

      Parameters:
      table - the input table
      timestampColumn - the timestamp column to monitor in table
      windowNanos - how many nanoseconds in the past a timestamp can be before it is out of the window
      inWindowColumn - the name of the new Boolean column.
      Returns:
      a new table that contains an in-window Boolean column