topology

Value Members

1. package functions

   

   Implicit conversions for IBM Streams Scala applications.

   Implicit conversions for IBM Streams Scala applications.

   Importing com.ibm.streamsx.topology.functions.FunctionConversions, allows Scala functions to be used as functions used to transform, filter tuples etc.

   import com.ibm.streamsx.topology.functions.FunctionConversions._

   Here's a code extract (from simple.FilterEchoScala) that implicitly converts the Scala anonymous function (v:String) => v.startsWith("d") to a com.ibm.streamsx.topology.function.Predicate instance required by the TStream.filter method.

   // Implicit conversions of Scala anonymous functions
   // to functions for the Java Application API
   import com.ibm.streamsx.topology.functions.FunctionConversions._
   
   object FilterEchoScala {
     def main(args: Array[String]) {
       val topology = new Topology("FilterEchoScala")
   
       var echo = topology.strings(args:_*)
   
       echo = echo.filter((v:String) => v.startsWith("d"))