Skip to main content

Data stream model

Project description

Data stream model helps developers to build "chains" of connected
computing nodes and run them.
A computing node has input/ouput sockets, and the "dsm runner"
is responsible to carry "data streams" through the "chains"
and feed "data streams" to computing nodes.

Usage:

Please read the main function in Composite.py for an example.

Notes:

1. Developers are responsible to
* build computing nodes (with i/o sockets)
2 Developers or Users are responsible to
* specify connections of computing nodes

Hints for developers:

1. Read tests in source codes to understand how to use dsm.
Start with Composite.py and Runner.py is a good idea

Limitations:
1. No loops are allowed.
2. Currently only a trivial implementation of "runner" exists. So data streams
are limited in one physical machine.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

danse.ins.dsm-0.1.2.tar.gz (4.0 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page