Java Application API

New! 0.8.0 release - 2015/07/14 - With Scala support.

The Java Application API enables a developer to create streaming applications entirely in Java and Scala for IBM Streams. The API employs a functional style of programming -- a developer may define a graph's flow and data manipulation simultaneously. 


    /*
     * Declare a source stream (hw) with String as tuples that sends two
     * tuples "Hello" and "World!", and prints them to output.
     */
    Topology topology = new Topology("HelloWorld");
    TStream<String> hw = topology.strings("Hello", "World!");
    hw.print();
    StreamsContextFactory.getEmbedded().submit(topology).get();

Open source

Streamsx.topology is an open source project that can be found on github.

Java Application API Quick Start VM

Get started now with the new Java Application API Quick Start VMware image by following this getting started guide.

Please refer to the getting started guide, FAQ page, and documentation for help.