Skip to content

Instantly share code, notes, and snippets.

@josep2

josep2/flinkexample3.scala

Created May 7, 2017 23:48
Show Gist options
  • Save josep2/b79745b35c17e1bd98547722b3718f52 to your computer and use it in GitHub Desktop.
Save josep2/b79745b35c17e1bd98547722b3718f52 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
flinkexample3.scala
case class Sale(id: String, amount: Double)
val sales: DataStream[Sale] = env.addSource( SOME_STREAMING_SOURCE) // Read in a stream that is typed as a Sale
sales.window(Count.of(50)).every(Time.of(1, TimeUnit.SECONDS)).sum("amount") // Every second sum the sales
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment