removeBlink
The removeBlink method removes the blink table attribute from a table, disabling specialized blink table aggregation semantics. It returns the source table itself if it is already not a blink table.
Note
removeBlink only removes the blink attribute — rows will still disappear each update cycle. If you want rows to persist, use blinkToAppendOnly instead.
What it does:
- Disables specialized aggregation semantics for blink tables. By default, aggregations like
sumByon blink tables accumulate results over the entire history of observed rows. After callingremoveBlink, aggregations only operate on rows present in the current update cycle.
What it does NOT do:
- It does not make rows persist. The resulting table still exhibits the "blink" update pattern — all rows from the previous cycle are removed, and only new rows appear each cycle.
- It does not convert the table to an append-only or standard streaming table.
Syntax
Parameters
This method takes no arguments.
Returns
A table without the blink attribute. The table still removes all rows each update cycle.
Example
The following example demonstrates the difference in aggregation behavior. With the blink attribute, sumBy accumulates over all rows ever seen. After removeBlink, sumBy only sums rows in the current cycle.

In this example:
tBlinkSumgrows continuously as it aggregates over all historical data.tNoBlinkSumonly reflects the sum of rows present in the current update cycle (which is just one row per group per cycle in this case).
Related documentation
- blinkToAppendOnly — Convert a blink table to append-only to preserve all rows.
- Table types: Specialized semantics for blink tables — Detailed explanation of blink table aggregation behavior.
- Javadoc