DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block |
|---|
public abstract class Windows<W extends Window> {
...
public abstract Map<Long, W> windowsFor(
final long timestamp,
final long observedStreamTime
) {
return windowsFor(timestamp);
}
// as part of this KIP we will deprecate this method, which is technically public
// although users are not expected to implement this (it lives in a public package)
@Deprecated
public abstract Map<Long, W> windowsFor(final long timestamp);
} |
The implementation of BatchedWindows will then use the observedStreamTime when computing which window the current event should fall into:
...