Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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:

...