[streampipes] branch dev updated (c7fa4e519 -> 6f15017ec)

[oe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

oehler pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


    from c7fa4e519 Bump maven-resources-plugin from 3.0.2 to 3.3.0 (#1242)
     new 7f4db355c Fix identification of the broker host
     new 3857f0b4c Merge branch 'apache:dev' into improving-sp-functions
     new e62137660 First structure for output data streams
     new bcdec31bb Add easy use for Online ML
     new 927b0eb92 Update python data model
     new f4279dc13 Add output data streams to functions
     new e2b1de34a Merge remote-tracking branch 'origin/dev' into improving-sp-functions
     new b9fe0e5ff Improve output data streams
     new b4a69cefc Add tests for Online ML
     new e9be4ce00 Merge branch 'apache:dev' into improving-sp-functions
     new a23892e0b Create function_zoo module
     new 1b2d01ccd Merge branch 'upstream/dev' into improving-sp-functions
     new 6f15017ec Merge pull request #1181 from SvenO3/improving-sp-functions

The 9898 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 ...ive-data-from-the-streampipes-data-stream.ipynb |  42 +-
 ...ine-learning-on-a-streampipes-data-stream.ipynb | 484 +++++++++++++++++++++
 .../streampipes/endpoint/endpoint.py               |  28 +-
 .../streampipes/{ => function_zoo}/__init__.py     |   0
 .../streampipes/function_zoo/river_function.py     | 184 ++++++++
 .../streampipes/functions/broker/__init__.py       |   5 +-
 .../streampipes/functions/broker/broker.py         |  53 ++-
 .../streampipes/functions/broker/broker_handler.py |  53 +++
 .../streampipes/functions/broker/nats_broker.py    |  29 +-
 .../functions/broker/output_collector.py           |  65 +++
 .../streampipes/functions/function_handler.py      |  45 +-
 .../streampipes/functions/streampipes_function.py  |  35 +-
 .../functions/utils/data_stream_generator.py       | 137 ++++++
 .../streampipes/model/common.py                    |  23 +-
 .../streampipes/model/resource/data_stream.py      |   7 +-
 .../model/resource/function_definition.py          |  31 ++
 .../tests/client/test_client.py                    |   6 +-
 .../tests/client/test_endpoint.py                  |  48 +-
 .../tests/functions/test_function_handler.py       |  92 +++-
 .../tests/functions/test_river_function.py         | 206 +++++++++
 20 files changed, 1448 insertions(+), 125 deletions(-)
 create mode 100644 streampipes-client-python/docs/examples/4-using-online-machine-learning-on-a-streampipes-data-stream.ipynb
 copy streampipes-client-python/streampipes/{ => function_zoo}/__init__.py (100%)
 create mode 100644 streampipes-client-python/streampipes/function_zoo/river_function.py
 create mode 100644 streampipes-client-python/streampipes/functions/broker/broker_handler.py
 create mode 100644 streampipes-client-python/streampipes/functions/broker/output_collector.py
 create mode 100644 streampipes-client-python/streampipes/functions/utils/data_stream_generator.py
 create mode 100644 streampipes-client-python/tests/functions/test_river_function.py