IBM Streams
Toolkits, Samples and Tutorials for IBM Streams. Need help? Open issues to the related project.
Pinned Repositories
administration
Umbrella project for the IBMStreams organization. This project will be used for the management of the individual projects within the IBMStreams organization.
benchmarks
Contains performance benchmark applications for IBM Streams
sample.starter_notebooks
Notebooks showing Streams applications written in Python
samples
This repository contains open-source sample applications for IBM Streams.
streamsx.health
(Incubation) Streams Healthcare Analytics Platform - To enable and inspire the next generation healthcare solutions
streamsx.jdbc
Supports Streams application to work with databases via JDBC
streamsx.kafka
Repository for integration with Apache Kafka
streamsx.messaging
This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.
streamsx.topology
Develop streaming applications for IBM Streams in Python, Java & Scala.
tutorials
A project for developing tutorials for Streams
IBM Streams's Repositories
IBMStreams/administration
Umbrella project for the IBMStreams organization. This project will be used for the management of the individual projects within the IBMStreams organization.
IBMStreams/streamsx.tcp
(Incubation) TCPServer is a multi-connection, multi-threaded operator that allows for full duplex TCP communication.
IBMStreams/streamsx.monitoring
The com.ibm.streamsx.monitoring toolkit provides capabilities to create applications that monitor IBM Streams and its applications.
IBMStreams/streamsx.parquet
(Incubation) Toolkit providing adapters to Parquet
IBMStreams/streamsx.adaptiveParser
(Incubation) The toolkit allows to parse input format producing desired hierarchical tuple (including lists, maps and sets) saving the common step of mapping the flat format to the required Streams tuple.
IBMStreams/endpoint-monitor
Nginx reverse proxy sample application to Streams REST operators.
IBMStreams/streamsx.cybersecurity.starterApps
Starter applications for IBM Streams cybersecurity toolkit
IBMStreams/sample.edge-rolling-average
Edge sample
IBMStreams/sample.forecast_with_r
Sample application using Streams Flow demonstrating the usage of R
IBMStreams/streamsx.cloudant
Allow Streams applications to read / write to Cloudant database
IBMStreams/streamsx.datetime
Toolkit providing additional functionality for dates and times.
IBMStreams/streamsx.math
(Incubation) Mathematics and statistics toolkit.
IBMStreams/streamsx.plumbing
Plumbing operators manipulate the flow of tuples in a Streams application, but are not part of the logic of the application
IBMStreams/streamsx.shell
Utility toolkit to execute shell commands in a Streams application
IBMStreams/streamsx.social
(Incubation) Toolkit for operators and functions to integrate Streams with social media sites.
IBMStreams/streamsx.tutorial.teda
Tutorials for TEDA
IBMStreams/streamsx.watsonexplorer
Toolkit for accessing data and analytics results from IBM Watson Explorer (formerly known as IBM Infosphere Data Explorer)
IBMStreams/pypi.streamsx.hbase
This is a step in allowing natural use of Streams for a Python developer. A project that will be registered with PyPi to allow 'pip install' of Python packages that support Python developers interacting with IBM Streams.
IBMStreams/pypi.streamsx.wml
This package allows a Python developer to use Streams naturally. A project that will be registered with PyPi to allow 'pip install' of Python packages that support Python developers interacting with IBM Streams.
IBMStreams/streamsx.bytes
(Incubation) Functions to manipulate data and an operator to parse a message and extract bits from it based on a JSON definition
IBMStreams/Edge-metrics-scraper
BETA - Prometheus scraper for Edge metrics.
IBMStreams/pypi.streamsx.endpoint
This repository contains communication endpoints into Streams to be naturally used by a Python developer. The project will be registered with PyPi to allow 'pip install' of Python packages that support Python developers interacting with IBM Streams.
IBMStreams/pypi.streamsx.inet
This is a step in allowing natural use of Streams for a Python developer. A project that will be registered with PyPi to allow 'pip install' of Python packages that support Python developers interacting with IBM Streams.
IBMStreams/pypi.streamsx.jms
[INCUBATION] This is a step in allowing natural use of Streams for a Python developer. A project that will be registered with PyPi to allow 'pip install' of Python packages that support Python developers interacting with IBM Streams.
IBMStreams/pypi.streamsx.toolkits
This is a step in allowing natural use of Streams for a Python developer. A project that will be registered with PyPi to allow 'pip install' of Python packages that support Python developers interacting with IBM Streams.
IBMStreams/sample.edge-mnist-flows
MNIST digit recognition sample for Streams Flows
IBMStreams/streamsx.jms
This toolkit interacts with Java Message Service (JMS) systems.
IBMStreams/streamsx.microservice
Provide documentation, utilities, examples for Streams microservices
IBMStreams/streamsx.mqtt
MQTT toolkit for for integration of IBM Streams with MQTT providers
IBMStreams/streamsx.transform
Toolkit that contains basic building block operators that efficiently transform data from one format to another