Skip to content

Instantly share code, notes, and snippets.

@josep2
Created May 7, 2017 22:07
Show Gist options
  • Save josep2/b579911421e0030b4f9c0087e2aeeb2b to your computer and use it in GitHub Desktop.
Save josep2/b579911421e0030b4f9c0087e2aeeb2b to your computer and use it in GitHub Desktop.
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.map{ r => r.amount+1} // Add one
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment