@InterfaceStability.Unstable @FunctionalInterface public interface FoldLeftFunction<M,WV> extends InitableFunction, ClosableFunction, java.io.Serializable
Window
operator.Modifier and Type | Method and Description |
---|---|
WV |
apply(M message,
WV oldValue)
Incrementally updates the aggregated value as messages are added.
|
init
close