Silk is an open-source workflow description and execution framework, written in Scala. With Silk you can create a workflow consisting of SQL, Unix commands, Scala programs.
def appleStock = nasdaq.filter(_.symbol is "APPL") .select(_.time, _.close) .orderBy(_.time) // show the latest 10 stock price information appleStock.limit(10).print
A workflow in Silk is a class (or trait in Scala). As in object-oriented programming style, you can encapsulate complex workflows within a class, override tasks in the workflow and reuse existing workflows.
Windowing for stream queries