daily pastebin goal
27%
SHARE
TWEET

Untitled

a guest Feb 21st, 2019 53 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. val data: PCollection[Type] = results
  2.   .apply(
  3.   Window
  4.     .into[Type](FixedWindows.of(Duration.millis(2000)))
  5.     .withAllowedLateness(Duration.millis(1000))
  6.     .triggering(AfterPane.elementCountAtLeast(4)
  7.     .accumulatingFiredPanes()
  8. )
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top