Scala support for IBM Streams 2.1