Introduction

This article lists a set of sample applications that are compatible with Streaming Analytics V2 price plans.  If you’re not sure which type of price plan you are using, see V1 and V2 Service Plans.

 

Stock Trades app

This Streams application analyzes a stream of stock quotes and produces a rolling average of the prices using the an Aggregate icon operator. You can run the starter application without modification. If you want to experiment further with the service, you can also modify the code and push your changes back to the IBM® Cloud environment. The full source for this starter application is available on GitHub.

Event Detection V2

The Event Detection V2 sample is made up of two parts:

  • A Streams app that performs both simple and complex event detection against a stream of weather data.
  • A IBM Cloud app implemented using the SDK for Node.js runtime. The Node.js app provides a simple web UI to display status and results of the event detection.

The Node.js app is bound to an instance of the Streaming Analytics service. The Node.js app controls the service via the Streaming Analytics V2 REST API, submitting the Streams app to run the analytics to detect events. The sample also demonstrates how to use IAM authentication with the V2 REST API.

You can run this starter application without modification. If you want to experiment further with the service, you can also modify the code and push your changes back to the IBM® Cloud environment. The full source for this starter application is available on GitHub.

IBM Streams Runner for Apache Beam Sample Apps

TemperatureSample Beam app

This application takes temperature readings from multiple devices. The application splits the readings into “good” (valid) and “bad” (invalid) readings based on a specific threshold. It counts the bad readings and generates some basic statistics for the good readings, and finally logs the results. You can download the TemperatureSample app from the Streaming Analytics console.

WordCount Beam app

The Apache Beam 2.0 Java SDK Quickstart WordCount sample application creates reusable and mantainable pipelines that can read from a text file, apply transforms to tokenize and count the words, and write the data to an output text file.

FileStreamSample Beam app

You can use the IBM® Streams Runner for Apache Beam FileStreamSample sample application to learn how to use IBM Cloud object storage for file input and output.

Join The Discussion