THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- emitValue - for batch and streaming.
- eimitUpdateWithRetract - only for streaming in ACC mode(need key definition on TableAggregateFunction, under discussion).
- emitUpdateWithoutRetract - only for streaming in ACCRetract mode(need key definition on TableAggregateFunction, under discussion).
Collector Interface
public interface Collector<T> { /** * Emits a record. * * @param record The record to collect. */ void collect(T msg); /** * Emits a retract record. * * @param record The record to retract. */ void retract(T msg); } |
...