public abstract class ReduceWindow<T> extends BaseWindowedSink<T>
allowedLateness, collectiveEvents, collectiveOutput, DEFAULT_MAX_LAG, DEFAULT_WATERMARK_INTERVAL, evictionPolicy, iTimestampExtractor, iWindow, maxLagMs, watermarkEventGenerator, watermarkInterval, windowingPolicy, windowLifeCycleListener, windowManager, windowParameter
Constructor and Description |
---|
ReduceWindow(ReduceWindowedFunction<T> reduceWindowedFunction) |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(IWindowMessage<T> windowMessage) |
boolean |
getExpire(IWindowMessage<T> expiredMessages) |
boolean |
getLateMessages(IMessage<T> lateMessages) |
abstract boolean |
reduce(T content) |
abstract boolean |
reduceLateMessage(T content) |
close, execute, getEvictionPolicy, getWindowingPolicy, initialize, isTimestamped, newWindowLifeCycleListener, prepare, reset, setPolicies, start, withAllowedLateness, withCustomTimestampExtractor, withSlidingCountWindow, withSlidingDurationWindow, withTimestampExtractor, withTumblingCountWindow, withTumblingDurationWindow, withWatermarkInterval, withWindow
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
endExecute
public ReduceWindow(ReduceWindowedFunction<T> reduceWindowedFunction)
public abstract boolean reduce(T content)
public abstract boolean reduceLateMessage(T content)
public boolean execute(IWindowMessage<T> windowMessage)
execute
in class BaseWindowedSink<T>
public boolean getLateMessages(IMessage<T> lateMessages)
getLateMessages
in class BaseWindowedSink<T>
public boolean getExpire(IWindowMessage<T> expiredMessages)
getExpire
in class BaseWindowedSink<T>