A DSL in Scala for generating streaming applications