Merge branch 'dev'

apache · Aug 14, 2023 · c6304ee · c6304ee
2 parents 84796cb + e69deef
commit c6304ee
Show file tree

Hide file tree

Showing 55 changed files with 1,816 additions and 2,470 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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 @@ <h3 id="streampipes.function_zoo.river_function.OnlineML.stop" class="doc doc-he
 
 
 <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 class="p">,</span> <span class="n">on_stop</span><span class="p">)</span></code>
+<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="p">)</span></code>
 
 <a href="#streampipes.function_zoo.river_function.RiverFunction" class="headerlink" title="Permanent link">&para;</a></h2>
 
@@ -2282,20 +2268,6 @@ <h2 id="streampipes.function_zoo.river_function.RiverFunction" class="doc doc-he
             </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 @@ <h3 id="streampipes.function_zoo.river_function.RiverFunction.onServiceStopped"
 </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">&para;</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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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 @@ <h3 id="streampipes.functions.streampipes_function.StreamPipesFunction.onService
 
 <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">&para;</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
@@ -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
@@ -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
@@ -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">