This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes-website.git
The following commit(s) were added to refs/heads/dev by this push:
new 3d7bc48e chore(python-docs): update python doc assets to recent
development state (#98)
3d7bc48e is described below
commit 3d7bc48e244befe736f02c69032a5aee73fb6f23
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Aug 5 07:15:23 2023 +0200
chore(python-docs): update python doc assets to recent development state
(#98)
---
docs-python/dev/404.html | 2 +-
.../dev/getting-started/developing/index.html | 2 +-
.../dev/getting-started/first-steps/index.html | 2 +-
.../dev/getting-started/quickstart/index.html | 2 +-
docs-python/dev/index.html | 2 +-
docs-python/dev/objects.inv | Bin 1927 -> 1920 bytes
docs-python/dev/reference/client/client/index.html | 2 +-
docs-python/dev/reference/client/config/index.html | 2 +-
.../client/credential_provider/index.html | 2 +-
.../endpoint/api/data_lake_measure/index.html | 2 +-
.../reference/endpoint/api/data_stream/index.html | 2 +-
.../dev/reference/endpoint/api/version/index.html | 2 +-
.../dev/reference/endpoint/endpoint/index.html | 2 +-
.../dev/reference/endpoint/exceptions/index.html | 2 +-
.../function_zoo/river_function/index.html | 80 +----------------
.../reference/functions/broker/broker/index.html | 2 +-
.../functions/broker/broker_handler/index.html | 2 +-
.../reference/functions/broker/consumer/index.html | 2 +-
.../broker/kafka/kafka_consumer/index.html | 2 +-
.../broker/kafka/kafka_message_fetcher/index.html | 2 +-
.../broker/kafka/kafka_publisher/index.html | 2 +-
.../functions/broker/nats/nats_consumer/index.html | 2 +-
.../broker/nats/nats_publisher/index.html | 2 +-
.../functions/broker/output_collector/index.html | 2 +-
.../functions/broker/publisher/index.html | 2 +-
.../functions/function_handler/index.html | 2 +-
.../reference/functions/registration/index.html | 2 +-
.../functions/streampipes_function/index.html | 6 +-
.../functions/utils/async_iter_handler/index.html | 2 +-
.../functions/utils/data_stream_context/index.html | 2 +-
.../utils/data_stream_generator/index.html | 2 +-
.../functions/utils/function_context/index.html | 2 +-
docs-python/dev/reference/model/common/index.html | 2 +-
.../model/container/data_lake_measures/index.html | 2 +-
.../model/container/data_streams/index.html | 2 +-
.../model/container/resource_container/index.html | 2 +-
.../reference/model/container/versions/index.html | 2 +-
.../model/resource/data_lake_measure/index.html | 2 +-
.../model/resource/data_series/index.html | 2 +-
.../model/resource/data_stream/index.html | 2 +-
.../reference/model/resource/exceptions/index.html | 2 +-
.../model/resource/function_definition/index.html | 2 +-
.../model/resource/query_result/index.html | 2 +-
.../reference/model/resource/resource/index.html | 2 +-
.../reference/model/resource/version/index.html | 2 +-
docs-python/dev/scripts/gen_ref_pages/index.html | 14 +--
docs-python/dev/search/search_index.json | 2 +-
docs-python/dev/sitemap.xml | 96 ++++++++++-----------
docs-python/dev/sitemap.xml.gz | Bin 705 -> 705 bytes
.../index.html | 2 +-
.../index.html | 2 +-
.../index.html | 44 +++++-----
.../index.html | 2 +-
53 files changed, 128 insertions(+), 204 deletions(-)
diff --git a/docs-python/dev/404.html b/docs-python/dev/404.html
index e45bb05f..3152604e 100644
--- a/docs-python/dev/404.html
+++ b/docs-python/dev/404.html
@@ -52,7 +52,7 @@
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/getting-started/developing/index.html
b/docs-python/dev/getting-started/developing/index.html
index 2d1d8d8a..c0e0f740 100644
--- a/docs-python/dev/getting-started/developing/index.html
+++ b/docs-python/dev/getting-started/developing/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../quickstart/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/getting-started/first-steps/index.html
b/docs-python/dev/getting-started/first-steps/index.html
index 642b0070..054e8b8a 100644
--- a/docs-python/dev/getting-started/first-steps/index.html
+++ b/docs-python/dev/getting-started/first-steps/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../developing/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/getting-started/quickstart/index.html
b/docs-python/dev/getting-started/quickstart/index.html
index a0dd70b0..156d8634 100644
--- a/docs-python/dev/getting-started/quickstart/index.html
+++ b/docs-python/dev/getting-started/quickstart/index.html
@@ -40,7 +40,7 @@
<link rel="next"
href="../../tutorials/1-introduction-to-streampipes-python-client/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/index.html b/docs-python/dev/index.html
index 881762fc..4ae2bdbe 100644
--- a/docs-python/dev/index.html
+++ b/docs-python/dev/index.html
@@ -38,7 +38,7 @@
<link rel="next" href="getting-started/first-steps/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/objects.inv b/docs-python/dev/objects.inv
index 70d7510b..34f54698 100644
Binary files a/docs-python/dev/objects.inv and b/docs-python/dev/objects.inv
differ
diff --git a/docs-python/dev/reference/client/client/index.html
b/docs-python/dev/reference/client/client/index.html
index 9dbf584e..87f18f7e 100644
--- a/docs-python/dev/reference/client/client/index.html
+++ b/docs-python/dev/reference/client/client/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../config/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/client/config/index.html
b/docs-python/dev/reference/client/config/index.html
index aa6816a3..5940f050 100644
--- a/docs-python/dev/reference/client/config/index.html
+++ b/docs-python/dev/reference/client/config/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../credential_provider/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/client/credential_provider/index.html
b/docs-python/dev/reference/client/credential_provider/index.html
index 7de34563..d0250ecb 100644
--- a/docs-python/dev/reference/client/credential_provider/index.html
+++ b/docs-python/dev/reference/client/credential_provider/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../endpoint/endpoint/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/endpoint/api/data_lake_measure/index.html
b/docs-python/dev/reference/endpoint/api/data_lake_measure/index.html
index b4b5fd05..da6dcb55 100644
--- a/docs-python/dev/reference/endpoint/api/data_lake_measure/index.html
+++ b/docs-python/dev/reference/endpoint/api/data_lake_measure/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../data_stream/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/endpoint/api/data_stream/index.html
b/docs-python/dev/reference/endpoint/api/data_stream/index.html
index e5cbde36..503893f5 100644
--- a/docs-python/dev/reference/endpoint/api/data_stream/index.html
+++ b/docs-python/dev/reference/endpoint/api/data_stream/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../version/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/endpoint/api/version/index.html
b/docs-python/dev/reference/endpoint/api/version/index.html
index 176f0a7d..ef1ba222 100644
--- a/docs-python/dev/reference/endpoint/api/version/index.html
+++ b/docs-python/dev/reference/endpoint/api/version/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../../function_zoo/river_function/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/endpoint/endpoint/index.html
b/docs-python/dev/reference/endpoint/endpoint/index.html
index f154dcae..45a7a1d4 100644
--- a/docs-python/dev/reference/endpoint/endpoint/index.html
+++ b/docs-python/dev/reference/endpoint/endpoint/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../exceptions/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/endpoint/exceptions/index.html
b/docs-python/dev/reference/endpoint/exceptions/index.html
index e871ebd2..acf25b43 100644
--- a/docs-python/dev/reference/endpoint/exceptions/index.html
+++ b/docs-python/dev/reference/endpoint/exceptions/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../api/data_lake_measure/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/function_zoo/river_function/index.html
b/docs-python/dev/reference/function_zoo/river_function/index.html
index 08b78cba..c9029a54 100644
--- a/docs-python/dev/reference/function_zoo/river_function/index.html
+++ b/docs-python/dev/reference/function_zoo/river_function/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../functions/function_handler/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
@@ -993,13 +993,6 @@
onServiceStopped()
</a>
-</li>
-
- <li class="md-nav__item">
- <a
href="#streampipes.function_zoo.river_function.RiverFunction.requiredStreamIds"
class="md-nav__link">
- requiredStreamIds()
- </a>
-
</li>
</ul>
@@ -1901,13 +1894,6 @@
onServiceStopped()
</a>
-</li>
-
- <li class="md-nav__item">
- <a
href="#streampipes.function_zoo.river_function.RiverFunction.requiredStreamIds"
class="md-nav__link">
- requiredStreamIds()
- </a>
-
</li>
</ul>
@@ -2244,7 +2230,7 @@ Is only needed when you continue to work with the
prediction in StreamPipes.</p>
<h2 id="streampipes.function_zoo.river_function.RiverFunction" class="doc
doc-heading">
-<code class="highlight language-python"><span
class="n">RiverFunction</span><span class="p">(</span><span
class="n">function_definition</span><span class="p">,</span> <span
class="n">stream_ids</span><span class="p">,</span> <span
class="n">model</span><span class="p">,</span> <span
class="n">supervised</span><span class="p">,</span> <span
class="n">target_label</span><span class="p">,</span> <span
class="n">on_start</span><span class="p">,</span> <span
class="n">on_event</span><span cla [...]
+<code class="highlight language-python"><span
class="n">RiverFunction</span><span class="p">(</span><span
class="n">function_definition</span><span class="p">,</span> <span
class="n">model</span><span class="p">,</span> <span
class="n">supervised</span><span class="p">,</span> <span
class="n">target_label</span><span class="p">,</span> <span
class="n">on_start</span><span class="p">,</span> <span
class="n">on_event</span><span class="p">,</span> <span
class="n">on_stop</span><span class= [...]
<a href="#streampipes.function_zoo.river_function.RiverFunction"
class="headerlink" title="Permanent link">¶</a></h2>
@@ -2282,20 +2268,6 @@ for Online Machine Learning models of the <a
href="https://riverml.xyz/";>River l
</p>
</td>
</tr>
- <tr>
- <td><code>stream_ids</code></td>
- <td class="doc-param-details">
- <div class="doc-md-description">
- <p>The ids of the data stream to train the model.</p>
- </div>
- <p>
- <span class="doc-param-annotation">
- <b>TYPE:</b>
- <code><span title="typing.List">List</span>[str]</code>
- </span>
- </p>
- </td>
- </tr>
<tr>
<td><code>model</code></td>
<td class="doc-param-details">
@@ -2573,54 +2545,6 @@ but can be every model with a 'learn_one' and
'predict_one' method.</p>
</div>
-<div class="doc doc-object doc-function">
-
-
-
-<h3
id="streampipes.function_zoo.river_function.RiverFunction.requiredStreamIds"
class="doc doc-heading">
-<code class="highlight language-python"><span
class="n">requiredStreamIds</span><span class="p">()</span></code>
-
-<a
href="#streampipes.function_zoo.river_function.RiverFunction.requiredStreamIds"
class="headerlink" title="Permanent link">¶</a></h3>
-
-
- <div class="doc doc-contents ">
-
- <p>Returns the stream ids required by this function.</p>
-
-
-
- <table>
- <thead>
- <tr>
- <th><b>RETURNS</b></th>
- <th><b>DESCRIPTION</b></th>
- </tr>
- </thead>
- <tbody>
- <tr>
- <td>
- <code>stream_ids</code>
- </td>
- <td class="doc-returns-details">
- <div class="doc-md-description">
- <p>List of stream ids required by the function</p>
- </div>
- <p>
- <span class="doc-returns-annotation">
- <b>TYPE:</b>
- <code><span title="typing.List">List</span>[str]</code>
- </span>
- </p>
- </td>
- </tr>
- </tbody>
- </table>
-
- </div>
-
-</div>
-
-
</div>
diff --git a/docs-python/dev/reference/functions/broker/broker/index.html
b/docs-python/dev/reference/functions/broker/broker/index.html
index 27edcdcf..38560e4f 100644
--- a/docs-python/dev/reference/functions/broker/broker/index.html
+++ b/docs-python/dev/reference/functions/broker/broker/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../broker_handler/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/broker_handler/index.html
b/docs-python/dev/reference/functions/broker/broker_handler/index.html
index 5b333db0..44784018 100644
--- a/docs-python/dev/reference/functions/broker/broker_handler/index.html
+++ b/docs-python/dev/reference/functions/broker/broker_handler/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../consumer/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/functions/broker/consumer/index.html
b/docs-python/dev/reference/functions/broker/consumer/index.html
index f98bae1f..7dfe368f 100644
--- a/docs-python/dev/reference/functions/broker/consumer/index.html
+++ b/docs-python/dev/reference/functions/broker/consumer/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../output_collector/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/kafka/kafka_consumer/index.html
b/docs-python/dev/reference/functions/broker/kafka/kafka_consumer/index.html
index bbd2794a..d2888f72 100644
--- a/docs-python/dev/reference/functions/broker/kafka/kafka_consumer/index.html
+++ b/docs-python/dev/reference/functions/broker/kafka/kafka_consumer/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../kafka_message_fetcher/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/kafka/kafka_message_fetcher/index.html
b/docs-python/dev/reference/functions/broker/kafka/kafka_message_fetcher/index.html
index cdf4a56b..cfc776f9 100644
---
a/docs-python/dev/reference/functions/broker/kafka/kafka_message_fetcher/index.html
+++
b/docs-python/dev/reference/functions/broker/kafka/kafka_message_fetcher/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../kafka_publisher/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/kafka/kafka_publisher/index.html
b/docs-python/dev/reference/functions/broker/kafka/kafka_publisher/index.html
index e6711ebf..855ad15f 100644
---
a/docs-python/dev/reference/functions/broker/kafka/kafka_publisher/index.html
+++
b/docs-python/dev/reference/functions/broker/kafka/kafka_publisher/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../nats/nats_consumer/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/nats/nats_consumer/index.html
b/docs-python/dev/reference/functions/broker/nats/nats_consumer/index.html
index e1de4a80..a9613773 100644
--- a/docs-python/dev/reference/functions/broker/nats/nats_consumer/index.html
+++ b/docs-python/dev/reference/functions/broker/nats/nats_consumer/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../nats_publisher/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/nats/nats_publisher/index.html
b/docs-python/dev/reference/functions/broker/nats/nats_publisher/index.html
index 054a4e4c..7fe5a606 100644
--- a/docs-python/dev/reference/functions/broker/nats/nats_publisher/index.html
+++ b/docs-python/dev/reference/functions/broker/nats/nats_publisher/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../../utils/async_iter_handler/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/broker/output_collector/index.html
b/docs-python/dev/reference/functions/broker/output_collector/index.html
index 5bb92b90..9ee4e50a 100644
--- a/docs-python/dev/reference/functions/broker/output_collector/index.html
+++ b/docs-python/dev/reference/functions/broker/output_collector/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../publisher/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/functions/broker/publisher/index.html
b/docs-python/dev/reference/functions/broker/publisher/index.html
index 25bc0682..4c04e4ad 100644
--- a/docs-python/dev/reference/functions/broker/publisher/index.html
+++ b/docs-python/dev/reference/functions/broker/publisher/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../kafka/kafka_consumer/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/functions/function_handler/index.html
b/docs-python/dev/reference/functions/function_handler/index.html
index 459a09d1..e919c9c1 100644
--- a/docs-python/dev/reference/functions/function_handler/index.html
+++ b/docs-python/dev/reference/functions/function_handler/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../registration/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/functions/registration/index.html
b/docs-python/dev/reference/functions/registration/index.html
index 16168d81..cc5db6e6 100644
--- a/docs-python/dev/reference/functions/registration/index.html
+++ b/docs-python/dev/reference/functions/registration/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../streampipes_function/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/streampipes_function/index.html
b/docs-python/dev/reference/functions/streampipes_function/index.html
index dbdeb60d..1134250a 100644
--- a/docs-python/dev/reference/functions/streampipes_function/index.html
+++ b/docs-python/dev/reference/functions/streampipes_function/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../broker/broker/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
@@ -2369,10 +2369,6 @@ data analytics libraries there.</p>
<h3
id="streampipes.functions.streampipes_function.StreamPipesFunction.requiredStreamIds"
class="doc doc-heading">
<code class="highlight language-python"><span
class="n">requiredStreamIds</span><span class="p">()</span></code>
-
- <span class="doc doc-labels">
- <small class="doc doc-label
doc-label-abstractmethod"><code>abstractmethod</code></small>
- </span>
<a
href="#streampipes.functions.streampipes_function.StreamPipesFunction.requiredStreamIds"
class="headerlink" title="Permanent link">¶</a></h3>
diff --git
a/docs-python/dev/reference/functions/utils/async_iter_handler/index.html
b/docs-python/dev/reference/functions/utils/async_iter_handler/index.html
index 67502a90..6f223c51 100644
--- a/docs-python/dev/reference/functions/utils/async_iter_handler/index.html
+++ b/docs-python/dev/reference/functions/utils/async_iter_handler/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../data_stream_context/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/utils/data_stream_context/index.html
b/docs-python/dev/reference/functions/utils/data_stream_context/index.html
index 9c5b3df4..d477a6db 100644
--- a/docs-python/dev/reference/functions/utils/data_stream_context/index.html
+++ b/docs-python/dev/reference/functions/utils/data_stream_context/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../data_stream_generator/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/utils/data_stream_generator/index.html
b/docs-python/dev/reference/functions/utils/data_stream_generator/index.html
index 3f0dc5fd..0d2a95a3 100644
--- a/docs-python/dev/reference/functions/utils/data_stream_generator/index.html
+++ b/docs-python/dev/reference/functions/utils/data_stream_generator/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../function_context/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/functions/utils/function_context/index.html
b/docs-python/dev/reference/functions/utils/function_context/index.html
index 2de5bbde..618c0881 100644
--- a/docs-python/dev/reference/functions/utils/function_context/index.html
+++ b/docs-python/dev/reference/functions/utils/function_context/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../../model/common/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/common/index.html
b/docs-python/dev/reference/model/common/index.html
index 5f8e01ba..d612a34c 100644
--- a/docs-python/dev/reference/model/common/index.html
+++ b/docs-python/dev/reference/model/common/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../container/data_lake_measures/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/model/container/data_lake_measures/index.html
b/docs-python/dev/reference/model/container/data_lake_measures/index.html
index 3a95729d..4aa9decd 100644
--- a/docs-python/dev/reference/model/container/data_lake_measures/index.html
+++ b/docs-python/dev/reference/model/container/data_lake_measures/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../data_streams/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/container/data_streams/index.html
b/docs-python/dev/reference/model/container/data_streams/index.html
index 8aba7ecd..26cdebad 100644
--- a/docs-python/dev/reference/model/container/data_streams/index.html
+++ b/docs-python/dev/reference/model/container/data_streams/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../resource_container/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/model/container/resource_container/index.html
b/docs-python/dev/reference/model/container/resource_container/index.html
index c3f869a9..21d882c9 100644
--- a/docs-python/dev/reference/model/container/resource_container/index.html
+++ b/docs-python/dev/reference/model/container/resource_container/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../versions/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/container/versions/index.html
b/docs-python/dev/reference/model/container/versions/index.html
index 708a1114..cd85b80d 100644
--- a/docs-python/dev/reference/model/container/versions/index.html
+++ b/docs-python/dev/reference/model/container/versions/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../resource/data_lake_measure/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/model/resource/data_lake_measure/index.html
b/docs-python/dev/reference/model/resource/data_lake_measure/index.html
index 952246ef..ebe223af 100644
--- a/docs-python/dev/reference/model/resource/data_lake_measure/index.html
+++ b/docs-python/dev/reference/model/resource/data_lake_measure/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../data_series/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/resource/data_series/index.html
b/docs-python/dev/reference/model/resource/data_series/index.html
index c00d817a..25ec843b 100644
--- a/docs-python/dev/reference/model/resource/data_series/index.html
+++ b/docs-python/dev/reference/model/resource/data_series/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../data_stream/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/resource/data_stream/index.html
b/docs-python/dev/reference/model/resource/data_stream/index.html
index 05c6cd08..17342d6b 100644
--- a/docs-python/dev/reference/model/resource/data_stream/index.html
+++ b/docs-python/dev/reference/model/resource/data_stream/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../exceptions/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/resource/exceptions/index.html
b/docs-python/dev/reference/model/resource/exceptions/index.html
index e84113dd..bb6cee85 100644
--- a/docs-python/dev/reference/model/resource/exceptions/index.html
+++ b/docs-python/dev/reference/model/resource/exceptions/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../function_definition/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/reference/model/resource/function_definition/index.html
b/docs-python/dev/reference/model/resource/function_definition/index.html
index 662e4225..6013893c 100644
--- a/docs-python/dev/reference/model/resource/function_definition/index.html
+++ b/docs-python/dev/reference/model/resource/function_definition/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../query_result/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/resource/query_result/index.html
b/docs-python/dev/reference/model/resource/query_result/index.html
index f71e5280..c3a30c14 100644
--- a/docs-python/dev/reference/model/resource/query_result/index.html
+++ b/docs-python/dev/reference/model/resource/query_result/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../resource/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/resource/resource/index.html
b/docs-python/dev/reference/model/resource/resource/index.html
index 22e7910c..3af5bf43 100644
--- a/docs-python/dev/reference/model/resource/resource/index.html
+++ b/docs-python/dev/reference/model/resource/resource/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../version/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/reference/model/resource/version/index.html
b/docs-python/dev/reference/model/resource/version/index.html
index 43e2c0a9..01a3a9bc 100644
--- a/docs-python/dev/reference/model/resource/version/index.html
+++ b/docs-python/dev/reference/model/resource/version/index.html
@@ -38,7 +38,7 @@
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git a/docs-python/dev/scripts/gen_ref_pages/index.html
b/docs-python/dev/scripts/gen_ref_pages/index.html
index b9547261..707b745d 100644
--- a/docs-python/dev/scripts/gen_ref_pages/index.html
+++ b/docs-python/dev/scripts/gen_ref_pages/index.html
@@ -36,7 +36,7 @@
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
@@ -2739,7 +2739,7 @@ Licensed under the Apache License, Version 2.0.
init_mathjax();
</script>
<!-- End of mathjax configuration --><div class="jupyter-wrapper">
-<div class="jp-Cell jp-MarkdownCell jp-Notebook-cell" id="cell-id=3087b524">
+<div class="jp-Cell jp-MarkdownCell jp-Notebook-cell" id="cell-id=9e4fb75d">
<div class="jp-Cell-inputWrapper">
<div class="jp-Collapser jp-InputCollapser jp-Cell-inputCollapser">
</div>
@@ -2761,7 +2761,7 @@ limitations under the License.</p>
</div>
</div>
</div><div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs">
-<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=becba0c3">
+<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=dc902b78">
<div class="jp-Cell-inputWrapper">
<div class="jp-Collapser jp-InputCollapser jp-Cell-inputCollapser">
</div>
@@ -2788,7 +2788,7 @@ limitations under the License.</p>
</div>
</div>
</div><div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs">
-<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=97d6a597">
+<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=47719ee9">
<div class="jp-Cell-inputWrapper">
<div class="jp-Collapser jp-InputCollapser jp-Cell-inputCollapser">
</div>
@@ -2815,7 +2815,7 @@ limitations under the License.</p>
</div>
</div>
</div><div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs">
-<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=58872b40">
+<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=b13c4806">
<div class="jp-Cell-inputWrapper">
<div class="jp-Collapser jp-InputCollapser jp-Cell-inputCollapser">
</div>
@@ -2842,7 +2842,7 @@ limitations under the License.</p>
</div>
</div>
</div><div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs">
-<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=e4231b3d">
+<div class="jp-Cell jp-CodeCell jp-Notebook-cell jp-mod-noOutputs"
id="cell-id=0643c5eb">
<div class="jp-Cell-inputWrapper">
<div class="jp-Collapser jp-InputCollapser jp-Cell-inputCollapser">
</div>
@@ -2915,7 +2915,7 @@ limitations under the License.</p>
</div>
</div>
</div>
-<div class="jp-Cell jp-MarkdownCell jp-Notebook-cell" id="cell-id=c464b019">
+<div class="jp-Cell jp-MarkdownCell jp-Notebook-cell" id="cell-id=1877c0fe">
<div class="jp-Cell-inputWrapper">
<div class="jp-Collapser jp-InputCollapser jp-Cell-inputCollapser">
</div>
diff --git a/docs-python/dev/search/search_index.json
b/docs-python/dev/search/search_index.json
index 76f9ed20..a460eb96 100644
--- a/docs-python/dev/search/search_index.json
+++ b/docs-python/dev/search/search_index.json
@@ -1 +1 @@
-{"config":{"lang":["en"],"separator":"[\\s\\-]+","pipeline":["stopWordFilter"]},"docs":[{"location":"","title":"\ud83c\udfe1
Home","text":"StreamPipes is a self-service (Industrial) IoT toolbox to enable
non-technical users to connect, analyze and explore IoT data streams.
<p>Dependency issue with StreamPipes Python 0.92.0</p> <p>In StreamPipes Python
<code>0.92.0</code> there is a problem with the required dependencies. Pydantic
has recently released the new version <code>2.0</code> wit [...]
\ No newline at end of file
+{"config":{"lang":["en"],"separator":"[\\s\\-]+","pipeline":["stopWordFilter"]},"docs":[{"location":"","title":"\ud83c\udfe1
Home","text":"StreamPipes is a self-service (Industrial) IoT toolbox to enable
non-technical users to connect, analyze and explore IoT data streams.
<p>Dependency issue with StreamPipes Python 0.92.0</p> <p>In StreamPipes Python
<code>0.92.0</code> there is a problem with the required dependencies. Pydantic
has recently released the new version <code>2.0</code> wit [...]
\ No newline at end of file
diff --git a/docs-python/dev/sitemap.xml b/docs-python/dev/sitemap.xml
index b18b2ca6..548c967b 100644
--- a/docs-python/dev/sitemap.xml
+++ b/docs-python/dev/sitemap.xml
@@ -2,242 +2,242 @@
<urlset xmlns="http://www.sitemaps.org/schemas/sitemap/0.9";>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/getting-started/developing/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/getting-started/first-steps/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/getting-started/quickstart/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/client/client/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/client/config/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/client/credential_provider/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/endpoint/endpoint/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/endpoint/exceptions/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/endpoint/api/data_lake_measure/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/endpoint/api/data_stream/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/endpoint/api/version/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/function_zoo/river_function/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/function_handler/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/registration/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/streampipes_function/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/broker/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/broker_handler/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/consumer/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/output_collector/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/publisher/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/kafka/kafka_consumer/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/kafka/kafka_message_fetcher/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/kafka/kafka_publisher/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/nats/nats_consumer/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/broker/nats/nats_publisher/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/utils/async_iter_handler/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/utils/data_stream_context/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/utils/data_stream_generator/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/functions/utils/function_context/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/common/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/container/data_lake_measures/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/container/data_streams/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/container/resource_container/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/container/versions/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/data_lake_measure/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/data_series/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/data_stream/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/exceptions/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/function_definition/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/query_result/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/resource/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/reference/model/resource/version/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/scripts/gen_ref_pages/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/tutorials/1-introduction-to-streampipes-python-client/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/tutorials/2-extracting-data-from-the-streampipes-data-lake/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/tutorials/3-getting-live-data-from-the-streampipes-data-stream/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
<url>
<loc>https://streampipes.apache.org/docs/docs/python/latest/latest/tutorials/4-using-online-machine-learning-on-a-streampipes-data-stream/</loc>
- <lastmod>2023-07-22</lastmod>
+ <lastmod>2023-08-05</lastmod>
<changefreq>daily</changefreq>
</url>
</urlset>
\ No newline at end of file
diff --git a/docs-python/dev/sitemap.xml.gz b/docs-python/dev/sitemap.xml.gz
index 00aede72..7464af57 100644
Binary files a/docs-python/dev/sitemap.xml.gz and
b/docs-python/dev/sitemap.xml.gz differ
diff --git
a/docs-python/dev/tutorials/1-introduction-to-streampipes-python-client/index.html
b/docs-python/dev/tutorials/1-introduction-to-streampipes-python-client/index.html
index 23f28cce..dfc20bf2 100644
---
a/docs-python/dev/tutorials/1-introduction-to-streampipes-python-client/index.html
+++
b/docs-python/dev/tutorials/1-introduction-to-streampipes-python-client/index.html
@@ -40,7 +40,7 @@
<link rel="next"
href="../2-extracting-data-from-the-streampipes-data-lake/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/tutorials/2-extracting-data-from-the-streampipes-data-lake/index.html
b/docs-python/dev/tutorials/2-extracting-data-from-the-streampipes-data-lake/index.html
index 52f6a1f8..87f219be 100644
---
a/docs-python/dev/tutorials/2-extracting-data-from-the-streampipes-data-lake/index.html
+++
b/docs-python/dev/tutorials/2-extracting-data-from-the-streampipes-data-lake/index.html
@@ -40,7 +40,7 @@
<link rel="next"
href="../3-getting-live-data-from-the-streampipes-data-stream/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
diff --git
a/docs-python/dev/tutorials/3-getting-live-data-from-the-streampipes-data-stream/index.html
b/docs-python/dev/tutorials/3-getting-live-data-from-the-streampipes-data-stream/index.html
index f16814f3..ed8a2133 100644
---
a/docs-python/dev/tutorials/3-getting-live-data-from-the-streampipes-data-stream/index.html
+++
b/docs-python/dev/tutorials/3-getting-live-data-from-the-streampipes-data-stream/index.html
@@ -40,7 +40,7 @@
<link rel="next"
href="../4-using-online-machine-learning-on-a-streampipes-data-stream/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
@@ -3096,14 +3096,14 @@ client =
StreamPipesClient(client_config=client_config)</div>
</div>
<div class="jp-InputArea jp-Cell-inputArea"><div class="jp-InputPrompt
jp-InputArea-prompt">
</div><div class="jp-RenderedHTMLCommon jp-RenderedMarkdown jp-MarkdownOutput"
data-mime-type="text/markdown">
-<p>Next we can create a StreamPipesFunction. For this we need to implement the
4 following methods:</p>
+<p>Next we can create a StreamPipesFunction. For this we need to implement the
3 following methods:</p>
<ul>
-<li>In <code>requiredStreamIds</code> you need to insert the
<code>element_id</code> of the required streams.</li>
<li><code>onServiceStarted</code> is called when the function gets started.
There you can use the given meta information of the
<code>FunctionContext</code> to initialize the function.</li>
<li><code>onEvent</code> is called when ever a new event arrives. The
<code>event</code> contains the live data and you can use the
<code>streamId</code> to identify a stream if the function is connected to
multiple data streams.</li>
<li><code>onServiceStopped</code> is called when the function gets
stopped.</li>
</ul>
<p>For this tutorial we just create a function that saves every new event in a
<code>pandas DataFrame</code> and plots the first column of the
<code>DataFrame</code> when the function gets stopped.</p>
+<p>(If you want to use the same structure as in Java you can overwrite the
<code>getFunctionId</code> and <code>requiredStreamIds</code> methods instead
of using the <code>FunctionDefinition</code>)</p>
</div>
</div>
</div>
@@ -3126,7 +3126,7 @@ client =
StreamPipesClient(client_config=client_config)</div>
</div>
</clipboard-copy>
</div>
-<div class="highlight-ipynb hl-python"><pre><span></span><span
class="kn">from</span> <span class="nn">typing</span> <span
class="kn">import</span> <span class="n">List</span><span class="p">,</span>
<span class="n">Dict</span><span class="p">,</span> <span class="n">Any</span>
+<div class="highlight-ipynb hl-python"><pre><span></span><span
class="kn">from</span> <span class="nn">typing</span> <span
class="kn">import</span> <span class="n">Dict</span><span class="p">,</span>
<span class="n">Any</span>
<span class="kn">import</span> <span class="nn">pandas</span> <span
class="k">as</span> <span class="nn">pd</span>
<span class="kn">from</span> <span class="nn">datetime</span> <span
class="kn">import</span> <span class="n">datetime</span>
<span class="kn">import</span> <span class="nn">matplotlib.pyplot</span> <span
class="k">as</span> <span class="nn">plt</span>
@@ -3134,17 +3134,14 @@ client =
StreamPipesClient(client_config=client_config)</div>
<span class="kn">from</span> <span
class="nn">streampipes.functions.registration</span> <span
class="kn">import</span> <span class="n">Registration</span>
<span class="kn">from</span> <span
class="nn">streampipes.functions.streampipes_function</span> <span
class="kn">import</span> <span class="n">StreamPipesFunction</span>
<span class="kn">from</span> <span
class="nn">streampipes.functions.utils.function_context</span> <span
class="kn">import</span> <span class="n">FunctionContext</span>
-
+<span class="kn">from</span> <span
class="nn">streampipes.model.resource.function_definition</span> <span
class="kn">import</span> <span class="n">FunctionDefinition</span><span
class="p">,</span> <span class="n">FunctionId</span>
<span class="k">class</span> <span class="nc">ExampleFunction</span><span
class="p">(</span><span class="n">StreamPipesFunction</span><span
class="p">):</span>
- <span class="k">def</span> <span class="fm">__init__</span><span
class="p">(</span><span class="bp">self</span><span class="p">)</span> <span
class="o">-></span> <span class="kc">None</span><span class="p">:</span>
- <span class="nb">super</span><span class="p">()</span><span
class="o">.</span><span class="fm">__init__</span><span class="p">()</span>
+ <span class="k">def</span> <span class="fm">__init__</span><span
class="p">(</span><span class="bp">self</span><span class="p">,</span> <span
class="n">function_definition</span><span class="p">:</span> <span
class="n">FunctionDefinition</span><span class="p">)</span> <span
class="o">-></span> <span class="kc">None</span><span class="p">:</span>
+ <span class="nb">super</span><span class="p">()</span><span
class="o">.</span><span class="fm">__init__</span><span class="p">(</span><span
class="n">function_definition</span><span class="p">)</span>
<span class="c1"># Create the Dataframe to save the live data</span>
<span class="bp">self</span><span class="o">.</span><span
class="n">df</span> <span class="o">=</span> <span class="n">pd</span><span
class="o">.</span><span class="n">DataFrame</span><span class="p">()</span>
- <span class="k">def</span> <span class="nf">requiredStreamIds</span><span
class="p">(</span><span class="bp">self</span><span class="p">)</span> <span
class="o">-></span> <span class="n">List</span><span class="p">[</span><span
class="nb">str</span><span class="p">]:</span>
- <span class="k">return</span> <span class="p">[</span><span
class="s2">"urn:streampipes.apache.org:eventstream:uPDKLI"</span><span
class="p">]</span>
-
<span class="k">def</span> <span class="nf">onServiceStarted</span><span
class="p">(</span><span class="bp">self</span><span class="p">,</span> <span
class="n">context</span><span class="p">:</span> <span
class="n">FunctionContext</span><span class="p">):</span>
<span class="c1"># Get the name of the timestamp field</span>
<span class="k">for</span> <span class="n">event_property</span> <span
class="ow">in</span> <span class="n">context</span><span
class="o">.</span><span class="n">schema</span><span class="p">[</span><span
class="n">context</span><span class="o">.</span><span
class="n">streams</span><span class="p">[</span><span class="mi">0</span><span
class="p">]]</span><span class="o">.</span><span
class="n">event_schema</span><span class="o">.</span><span
class="n">event_properties</span><span [...]
@@ -3167,7 +3164,7 @@ client =
StreamPipesClient(client_config=client_config)</div>
<span class="n">plt</span><span class="o">.</span><span
class="n">plot</span><span class="p">(</span><span class="bp">self</span><span
class="o">.</span><span class="n">df</span><span class="o">.</span><span
class="n">iloc</span><span class="p">[:,</span> <span class="mi">0</span><span
class="p">])</span>
<span class="n">plt</span><span class="o">.</span><span
class="n">show</span><span class="p">()</span>
</pre></div>
-<div class="clipboard-copy-txt" id="cell-6">from typing import List, Dict, Any
+<div class="clipboard-copy-txt" id="cell-6">from typing import Dict, Any
import pandas as pd
from datetime import datetime
import matplotlib.pyplot as plt
@@ -3175,17 +3172,14 @@ from streampipes.functions.function_handler import
FunctionHandler
from streampipes.functions.registration import Registration
from streampipes.functions.streampipes_function import StreamPipesFunction
from streampipes.functions.utils.function_context import FunctionContext
-
+from streampipes.model.resource.function_definition import FunctionDefinition,
FunctionId
class ExampleFunction(StreamPipesFunction):
- def __init__(self) -> None:
- super().__init__()
+ def __init__(self, function_definition: FunctionDefinition) -> None:
+ super().__init__(function_definition)
# Create the Dataframe to save the live data
self.df = pd.DataFrame()
- def requiredStreamIds(self) -> List[str]:
- return ["urn:streampipes.apache.org:eventstream:uPDKLI"]
-
def onServiceStarted(self, context: FunctionContext):
# Get the name of the timestamp field
for event_property in
context.schema[context.streams[0]].event_schema.event_properties:
@@ -3219,7 +3213,7 @@ class ExampleFunction(StreamPipesFunction):
</div>
<div class="jp-InputArea jp-Cell-inputArea"><div class="jp-InputPrompt
jp-InputArea-prompt">
</div><div class="jp-RenderedHTMLCommon jp-RenderedMarkdown jp-MarkdownOutput"
data-mime-type="text/markdown">
-<p>Now we can start the function. We have to register an instance of the
<code>StreamPipesFunction</code> and them we can start the functions by
initializing the <code>FunctionHandler</code>. (it's also possible to register
multiple functions with <code>.register(...).register(...)</code>)</p>
+<p>Now we can start the function. First we create an instance of the
<code>ExampleFunction</code> and insert the <code>element_id</code> of the
stream which data we want to consume. Then we have to register this function
and we can start all functions by initializing the
<code>FunctionHandler</code>. (it's also possible to register multiple
functions with <code>.register(...).register(...)</code>)</p>
</div>
</div>
</div>
@@ -3242,7 +3236,12 @@ class ExampleFunction(StreamPipesFunction):
</div>
</clipboard-copy>
</div>
-<div class="highlight-ipynb hl-python"><pre><span></span><span
class="n">example_function</span> <span class="o">=</span> <span
class="n">ExampleFunction</span><span class="p">()</span>
+<div class="highlight-ipynb hl-python"><pre><span></span><span
class="n">example_function</span> <span class="o">=</span> <span
class="n">ExampleFunction</span><span class="p">(</span>
+ <span class="n">FunctionDefinition</span><span class="p">(</span>
+ <span class="n">function_id</span><span class="o">=</span><span
class="n">FunctionId</span><span class="p">(</span><span
class="nb">id</span><span class="o">=</span><span
class="s2">"example-function"</span><span class="p">),</span>
+ <span class="n">consumed_streams</span><span class="o">=</span><span
class="p">[</span><span
class="s2">"urn:streampipes.apache.org:eventstream:uPDKLI"</span><span
class="p">]</span>
+ <span class="p">)</span>
+<span class="p">)</span>
<span class="n">registration</span> <span class="o">=</span> <span
class="n">Registration</span><span class="p">()</span>
<span class="n">registration</span><span class="o">.</span><span
class="n">register</span><span class="p">(</span><span
class="n">example_function</span><span class="p">)</span>
@@ -3250,7 +3249,12 @@ class ExampleFunction(StreamPipesFunction):
<span class="n">function_handler</span> <span class="o">=</span> <span
class="n">FunctionHandler</span><span class="p">(</span><span
class="n">registration</span><span class="p">,</span> <span
class="n">client</span><span class="p">)</span>
<span class="n">function_handler</span><span class="o">.</span><span
class="n">initializeFunctions</span><span class="p">()</span>
</pre></div>
-<div class="clipboard-copy-txt" id="cell-7">example_function =
ExampleFunction()
+<div class="clipboard-copy-txt" id="cell-7">example_function = ExampleFunction(
+ FunctionDefinition(
+ function_id=FunctionId(id="example-function"),
+ consumed_streams=["urn:streampipes.apache.org:eventstream:uPDKLI"]
+ )
+)
registration = Registration()
registration.register(example_function)
diff --git
a/docs-python/dev/tutorials/4-using-online-machine-learning-on-a-streampipes-data-stream/index.html
b/docs-python/dev/tutorials/4-using-online-machine-learning-on-a-streampipes-data-stream/index.html
index c8720275..bdfd2462 100644
---
a/docs-python/dev/tutorials/4-using-online-machine-learning-on-a-streampipes-data-stream/index.html
+++
b/docs-python/dev/tutorials/4-using-online-machine-learning-on-a-streampipes-data-stream/index.html
@@ -40,7 +40,7 @@
<link rel="next" href="../../reference/client/client/">
<link rel="icon"
href="https://streampipes.apache.org/img/favicon/favicon.png";>
- <meta name="generator" content="mkdocs-1.4.2, mkdocs-material-9.1.3">
+ <meta name="generator" content="mkdocs-1.5.1, mkdocs-material-9.1.3">
![https://streampipes.apache.org/img/favicon/favicon.png"](https://streampipes.apache.org/img/favicon/favicon.png"){kind=link}