public class WindowCheck extends Object
Modifier and Type | Method and Description |
---|---|
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.
|
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.
table
- the input tabletimestampColumn
- the timestamp column to monitor in tablewindowNanos
- how many nanoseconds in the past a timestamp can be before it is out of the windowinWindowColumn
- the name of the new Boolean column.