Skip to content

Instantly share code, notes, and snippets.

@josep2
Created May 7, 2017 22:41
Show Gist options
  • Save josep2/7749ee0c7e1a079c075aa3b3629c1b10 to your computer and use it in GitHub Desktop.
Save josep2/7749ee0c7e1a079c075aa3b3629c1b10 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.writeAsCsv(SOME_PATH)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment