http://git-wip-us.apache.org/repos/asf/incubator-edgent-website/blob/85b6530d/site/javadoc/r0.4.0/index-all.html ---------------------------------------------------------------------- diff --git a/site/javadoc/r0.4.0/index-all.html b/site/javadoc/r0.4.0/index-all.html index 1cd4b43..31341f7 100644 --- a/site/javadoc/r0.4.0/index-all.html +++ b/site/javadoc/r0.4.0/index-all.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0) on Mon Mar 07 09:03:19 PST 2016 --> -<title>Index (Quarks v0.4.0)</title> -<meta name="date" content="2016-03-07"> +<!-- Generated by javadoc (1.8.0_92) on Tue Jul 26 12:40:39 PDT 2016 --> +<title>Index (Edgent v0.4.0)</title> +<meta name="date" content="2016-07-26"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="Index (Quarks v0.4.0)"; + parent.document.title="Index (Edgent v0.4.0)"; } } catch(err) { @@ -23,7 +23,6 @@ <div>JavaScript is disabled on your browser.</div> </noscript> <!-- ========= START OF TOP NAVBAR ======= --> -<div role="navigation" title ="TOP_Navigation" aria-label ="Top Navigation Bar"/> <div class="topNav"><a name="navbar.top"> <!-- --> </a> @@ -70,237 +69,381 @@ <!-- --> </a></div> <!-- ========= END OF TOP NAVBAR ========= --> -<div role="main" title ="Index" aria-label ="This is index page"/> <div class="contentContainer"><a href="#I:A">A</a> <a href="#I:B">B</a> <a href="#I:C">C</a> <a href="#I:D">D</a> <a href="#I:E">E</a> <a href="#I:F">F</a> <a href="#I:G">G</a> <a href="#I:H">H</a> <a href="#I:I">I</a> <a href="#I:J">J</a> <a href="#I:K">K</a> <a href="#I:L">L</a> <a href="#I:M">M</a> <a href="#I:N">N</a> <a href="#I:O">O</a> <a href="#I:P">P</a> <a href="#I:Q">Q</a> <a href="#I:R">R</a> <a href="#I:S">S</a> <a href="#I:T">T</a> <a href="#I:U">U</a> <a href="#I:V">V</a> <a href="#I:W">W</a> <a href="#I:Z">Z</a> <a name="I:A"> <!-- --> </a> <h2 class="title">A</h2> <dl> -<dt><a href="quarks/samples/apps/AbstractApplication.html" title="class in quarks.samples.apps"><span class="typeNameLink">AbstractApplication</span></a> - Class in <a href="quarks/samples/apps/package-summary.html">quarks.samples.apps</a></dt> +<dt><a href="org/apache/edgent/samples/apps/AbstractApplication.html" title="class in org.apache.edgent.samples.apps"><span class="typeNameLink">AbstractApplication</span></a> - Class in <a href="org/apache/edgent/samples/apps/package-summary.html">org.apache.edgent.samples.apps</a></dt> <dd> <div class="block">An Application base class.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/AbstractApplication.html#AbstractApplication-java.lang.String-">AbstractApplication(String)</a></span> - Constructor for class quarks.samples.apps.<a href="quarks/samples/apps/AbstractApplication.html" title="class in quarks.samples.apps">AbstractApplication</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/apps/AbstractApplication.html#AbstractApplication-java.lang.String-">AbstractApplication(String)</a></span> - Constructor for class org.apache.edgent.samples.apps.<a href="org/apache/edgent/samples/apps/AbstractApplication.html" title="class in org.apache.edgent.samples.apps">AbstractApplication</a></dt> <dd> </dd> -<dt><a href="quarks/runtime/etiao/AbstractContext.html" title="class in quarks.runtime.etiao"><span class="typeNameLink">AbstractContext</span></a><<a href="quarks/runtime/etiao/AbstractContext.html" title="type parameter in AbstractContext">I</a>,<a href="quarks/runtime/etiao/AbstractContext.html" title="type parameter in AbstractContext">O</a>> - Class in <a href="quarks/runtime/etiao/package-summary.html">quarks.runtime.etiao</a></dt> +<dt><a href="org/apache/edgent/runtime/etiao/AbstractContext.html" title="class in org.apache.edgent.runtime.etiao"><span class="typeNameLink">AbstractContext</span></a><<a href="org/apache/edgent/runtime/etiao/AbstractContext.html" title="type parameter in AbstractContext">I</a>,<a href="org/apache/edgent/runtime/etiao/AbstractContext.html" title="type parameter in AbstractContext">O</a>> - Class in <a href="org/apache/edgent/runtime/etiao/package-summary.html">org.apache.edgent.runtime.etiao</a></dt> <dd> -<div class="block">Provides a skeletal implementation of the <a href="quarks/oplet/OpletContext.html" title="interface in quarks.oplet"><code>OpletContext</code></a> +<div class="block">Provides a skeletal implementation of the <a href="org/apache/edgent/oplet/OpletContext.html" title="interface in org.apache.edgent.oplet"><code>OpletContext</code></a> interface.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/etiao/AbstractContext.html#AbstractContext-quarks.oplet.JobContext-quarks.execution.services.RuntimeServices-">AbstractContext(JobContext, RuntimeServices)</a></span> - Constructor for class quarks.runtime.etiao.<a href="quarks/runtime/etiao/AbstractContext.html" title="class in quarks.runtime.etiao">AbstractContext</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/etiao/AbstractContext.html#AbstractContext-org.apache.edgent.oplet.JobContext-org.apache.edgent.execution.services.RuntimeServices-">AbstractContext(JobContext, RuntimeServices)</a></span> - Constructor for class org.apache.edgent.runtime.etiao.<a href="org/apache/edgent/runtime/etiao/AbstractContext.html" title="class in org.apache.edgent.runtime.etiao">AbstractContext</a></dt> <dd> </dd> -<dt><a href="quarks/samples/apps/mqtt/AbstractMqttApplication.html" title="class in quarks.samples.apps.mqtt"><span class="typeNameLink">AbstractMqttApplication</span></a> - Class in <a href="quarks/samples/apps/mqtt/package-summary.html">quarks.samples.apps.mqtt</a></dt> +<dt><a href="org/apache/edgent/graph/spi/AbstractGraph.html" title="class in org.apache.edgent.graph.spi"><span class="typeNameLink">AbstractGraph</span></a><<a href="org/apache/edgent/graph/spi/AbstractGraph.html" title="type parameter in AbstractGraph">G</a>> - Class in <a href="org/apache/edgent/graph/spi/package-summary.html">org.apache.edgent.graph.spi</a></dt> +<dd> +<div class="block">A skeletal implementation of the <a href="org/apache/edgent/graph/Graph.html" title="interface in org.apache.edgent.graph"><code>Graph</code></a> interface, + to minimize the effort required to implement the interface.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/graph/spi/AbstractGraph.html#AbstractGraph--">AbstractGraph()</a></span> - Constructor for class org.apache.edgent.graph.spi.<a href="org/apache/edgent/graph/spi/AbstractGraph.html" title="class in org.apache.edgent.graph.spi">AbstractGraph</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/graph/spi/execution/AbstractGraphJob.html" title="class in org.apache.edgent.graph.spi.execution"><span class="typeNameLink">AbstractGraphJob</span></a> - Class in <a href="org/apache/edgent/graph/spi/execution/package-summary.html">org.apache.edgent.graph.spi.execution</a></dt> +<dd> +<div class="block">Placeholder for a skeletal implementation of the <a href="org/apache/edgent/execution/Job.html" title="interface in org.apache.edgent.execution"><code>Job</code></a> interface, + to minimize the effort required to implement the interface.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/graph/spi/execution/AbstractGraphJob.html#AbstractGraphJob--">AbstractGraphJob()</a></span> - Constructor for class org.apache.edgent.graph.spi.execution.<a href="org/apache/edgent/graph/spi/execution/AbstractGraphJob.html" title="class in org.apache.edgent.graph.spi.execution">AbstractGraphJob</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/test/svt/apps/iotp/AbstractIotpApplication.html" title="class in org.apache.edgent.test.svt.apps.iotp"><span class="typeNameLink">AbstractIotpApplication</span></a> - Class in <a href="org/apache/edgent/test/svt/apps/iotp/package-summary.html">org.apache.edgent.test.svt.apps.iotp</a></dt> +<dd> +<div class="block">An IotF Application base class.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/test/svt/apps/iotp/AbstractIotpApplication.html#AbstractIotpApplication-java.lang.String-">AbstractIotpApplication(String)</a></span> - Constructor for class org.apache.edgent.test.svt.apps.iotp.<a href="org/apache/edgent/test/svt/apps/iotp/AbstractIotpApplication.html" title="class in org.apache.edgent.test.svt.apps.iotp">AbstractIotpApplication</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/samples/apps/mqtt/AbstractMqttApplication.html" title="class in org.apache.edgent.samples.apps.mqtt"><span class="typeNameLink">AbstractMqttApplication</span></a> - Class in <a href="org/apache/edgent/samples/apps/mqtt/package-summary.html">org.apache.edgent.samples.apps.mqtt</a></dt> <dd> <div class="block">An MQTT Application base class.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/mqtt/AbstractMqttApplication.html#AbstractMqttApplication-java.lang.String-">AbstractMqttApplication(String)</a></span> - Constructor for class quarks.samples.apps.mqtt.<a href="quarks/samples/apps/mqtt/AbstractMqttApplication.html" title="class in quarks.samples.apps.mqtt">AbstractMqttApplication</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/apps/mqtt/AbstractMqttApplication.html#AbstractMqttApplication-java.lang.String-">AbstractMqttApplication(String)</a></span> - Constructor for class org.apache.edgent.samples.apps.mqtt.<a href="org/apache/edgent/samples/apps/mqtt/AbstractMqttApplication.html" title="class in org.apache.edgent.samples.apps.mqtt">AbstractMqttApplication</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/oplet/core/AbstractOplet.html" title="class in org.apache.edgent.oplet.core"><span class="typeNameLink">AbstractOplet</span></a><<a href="org/apache/edgent/oplet/core/AbstractOplet.html" title="type parameter in AbstractOplet">I</a>,<a href="org/apache/edgent/oplet/core/AbstractOplet.html" title="type parameter in AbstractOplet">O</a>> - Class in <a href="org/apache/edgent/oplet/core/package-summary.html">org.apache.edgent.oplet.core</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/core/AbstractOplet.html#AbstractOplet--">AbstractOplet()</a></span> - Constructor for class org.apache.edgent.oplet.core.<a href="org/apache/edgent/oplet/core/AbstractOplet.html" title="class in org.apache.edgent.oplet.core">AbstractOplet</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/topology/spi/tester/AbstractTester.html" title="class in org.apache.edgent.topology.spi.tester"><span class="typeNameLink">AbstractTester</span></a> - Class in <a href="org/apache/edgent/topology/spi/tester/package-summary.html">org.apache.edgent.topology.spi.tester</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/tester/AbstractTester.html#AbstractTester--">AbstractTester()</a></span> - Constructor for class org.apache.edgent.topology.spi.tester.<a href="org/apache/edgent/topology/spi/tester/AbstractTester.html" title="class in org.apache.edgent.topology.spi.tester">AbstractTester</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/topology/spi/AbstractTopology.html" title="class in org.apache.edgent.topology.spi"><span class="typeNameLink">AbstractTopology</span></a><<a href="org/apache/edgent/topology/spi/AbstractTopology.html" title="type parameter in AbstractTopology">X</a> extends <a href="org/apache/edgent/topology/tester/Tester.html" title="interface in org.apache.edgent.topology.tester">Tester</a>> - Class in <a href="org/apache/edgent/topology/spi/package-summary.html">org.apache.edgent.topology.spi</a></dt> +<dd> +<div class="block">Topology implementation that uses the basic functions to implement most + sources streams.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/AbstractTopology.html#AbstractTopology-java.lang.String-">AbstractTopology(String)</a></span> - Constructor for class org.apache.edgent.topology.spi.<a href="org/apache/edgent/topology/spi/AbstractTopology.html" title="class in org.apache.edgent.topology.spi">AbstractTopology</a></dt> <dd> </dd> -<dt><a href="quarks/oplet/core/AbstractOplet.html" title="class in quarks.oplet.core"><span class="typeNameLink">AbstractOplet</span></a><<a href="quarks/oplet/core/AbstractOplet.html" title="type parameter in AbstractOplet">I</a>,<a href="quarks/oplet/core/AbstractOplet.html" title="type parameter in AbstractOplet">O</a>> - Class in <a href="quarks/oplet/core/package-summary.html">quarks.oplet.core</a></dt> +<dt><a href="org/apache/edgent/topology/spi/AbstractTopologyProvider.html" title="class in org.apache.edgent.topology.spi"><span class="typeNameLink">AbstractTopologyProvider</span></a><<a href="org/apache/edgent/topology/spi/AbstractTopologyProvider.html" title="type parameter in AbstractTopologyProvider">T</a> extends <a href="org/apache/edgent/topology/Topology.html" title="interface in org.apache.edgent.topology">Topology</a>> - Class in <a href="org/apache/edgent/topology/spi/package-summary.html">org.apache.edgent.topology.spi</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/core/AbstractOplet.html#AbstractOplet--">AbstractOplet()</a></span> - Constructor for class quarks.oplet.core.<a href="quarks/oplet/core/AbstractOplet.html" title="class in quarks.oplet.core">AbstractOplet</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/AbstractTopologyProvider.html#AbstractTopologyProvider--">AbstractTopologyProvider()</a></span> - Constructor for class org.apache.edgent.topology.spi.<a href="org/apache/edgent/topology/spi/AbstractTopologyProvider.html" title="class in org.apache.edgent.topology.spi">AbstractTopologyProvider</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/wsclient/javax/websocket/runtime/WebSocketClientBinarySender.html#accept-T-">accept(T)</a></span> - Method in class quarks.connectors.wsclient.javax.websocket.runtime.<a href="quarks/connectors/wsclient/javax/websocket/runtime/WebSocketClientBinarySender.html" title="class in quarks.connectors.wsclient.javax.websocket.runtime">WebSocketClientBinarySender</a></dt> +<dt><a href="org/apache/edgent/topology/spi/AbstractTStream.html" title="class in org.apache.edgent.topology.spi"><span class="typeNameLink">AbstractTStream</span></a><<a href="org/apache/edgent/topology/spi/AbstractTStream.html" title="type parameter in AbstractTStream">G</a> extends <a href="org/apache/edgent/topology/Topology.html" title="interface in org.apache.edgent.topology">Topology</a>,<a href="org/apache/edgent/topology/spi/AbstractTStream.html" title="type parameter in AbstractTStream">T</a>> - Class in <a href="org/apache/edgent/topology/spi/package-summary.html">org.apache.edgent.topology.spi</a></dt> +<dd> +<div class="block">Abstract stream that uses the functional primitives to implement most + methods.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/AbstractTStream.html#AbstractTStream-G-">AbstractTStream(G)</a></span> - Constructor for class org.apache.edgent.topology.spi.<a href="org/apache/edgent/topology/spi/AbstractTStream.html" title="class in org.apache.edgent.topology.spi">AbstractTStream</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/topology/spi/graph/AbstractTWindow.html" title="class in org.apache.edgent.topology.spi.graph"><span class="typeNameLink">AbstractTWindow</span></a><<a href="org/apache/edgent/topology/spi/graph/AbstractTWindow.html" title="type parameter in AbstractTWindow">T</a>,<a href="org/apache/edgent/topology/spi/graph/AbstractTWindow.html" title="type parameter in AbstractTWindow">K</a>> - Class in <a href="org/apache/edgent/topology/spi/graph/package-summary.html">org.apache.edgent.topology.spi.graph</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="class in org.apache.edgent.graph.spi"><span class="typeNameLink">AbstractVertex</span></a><<a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="type parameter in AbstractVertex">OP</a> extends <a href="org/apache/edgent/oplet/Oplet.html" title="interface in org.apache.edgent.oplet">Oplet</a><<a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="type parameter in AbstractVertex">I</a>,<a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="type parameter in AbstractVertex">O</a>>,<a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="type parameter in AbstractVertex">I</a>,<a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="type parameter in AbstractVertex">O</a>> - Class in <a href="org/apache/edgent/graph/spi/package-summary.html">org.apache.edgent.graph.spi</a></dt> +<dd> +<div class="block">Placeholder for a skeletal implementation of the <a href="org/apache/edgent/graph/Vertex.html" title="interface in org.apache.edgent.graph"><code>Vertex</code></a> interface, + to minimize the effort required to implement the interface.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/graph/spi/AbstractVertex.html#AbstractVertex--">AbstractVertex()</a></span> - Constructor for class org.apache.edgent.graph.spi.<a href="org/apache/edgent/graph/spi/AbstractVertex.html" title="class in org.apache.edgent.graph.spi">AbstractVertex</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/wsclient/javax/websocket/runtime/WebSocketClientReceiver.html#accept-quarks.function.Consumer-">accept(Consumer<T>)</a></span> - Method in class quarks.connectors.wsclient.javax.websocket.runtime.<a href="quarks/connectors/wsclient/javax/websocket/runtime/WebSocketClientReceiver.html" title="class in quarks.connectors.wsclient.javax.websocket.runtime">WebSocketClientReceiver</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/wsclient/javax/websocket/runtime/WebSocketClientBinarySender.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.runtime.<a href="org/apache/edgent/connectors/wsclient/javax/websocket/runtime/WebSocketClientBinarySender.html" title="class in org.apache.edgent.connectors.wsclient.javax.websocket.runtime">WebSocketClientBinarySender</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/wsclient/javax/websocket/runtime/WebSocketClientSender.html#accept-T-">accept(T)</a></span> - Method in class quarks.connectors.wsclient.javax.websocket.runtime.<a href="quarks/connectors/wsclient/javax/websocket/runtime/WebSocketClientSender.html" title="class in quarks.connectors.wsclient.javax.websocket.runtime">WebSocketClientSender</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/wsclient/javax/websocket/runtime/WebSocketClientReceiver.html#accept-org.apache.edgent.function.Consumer-">accept(Consumer<T>)</a></span> - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.runtime.<a href="org/apache/edgent/connectors/wsclient/javax/websocket/runtime/WebSocketClientReceiver.html" title="class in org.apache.edgent.connectors.wsclient.javax.websocket.runtime">WebSocketClientReceiver</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/BiConsumer.html#accept-T-U-">accept(T, U)</a></span> - Method in interface quarks.function.<a href="quarks/function/BiConsumer.html" title="interface in quarks.function">BiConsumer</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/wsclient/javax/websocket/runtime/WebSocketClientSender.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.connectors.wsclient.javax.websocket.runtime.<a href="org/apache/edgent/connectors/wsclient/javax/websocket/runtime/WebSocketClientSender.html" title="class in org.apache.edgent.connectors.wsclient.javax.websocket.runtime">WebSocketClientSender</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/BiConsumer.html#accept-T-U-">accept(T, U)</a></span> - Method in interface org.apache.edgent.function.<a href="org/apache/edgent/function/BiConsumer.html" title="interface in org.apache.edgent.function">BiConsumer</a></dt> <dd> <div class="block">Consume the two arguments.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/Consumer.html#accept-T-">accept(T)</a></span> - Method in interface quarks.function.<a href="quarks/function/Consumer.html" title="interface in quarks.function">Consumer</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/Consumer.html#accept-T-">accept(T)</a></span> - Method in interface org.apache.edgent.function.<a href="org/apache/edgent/function/Consumer.html" title="interface in org.apache.edgent.function">Consumer</a></dt> <dd> <div class="block">Apply the function to <code>value</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/core/FanOut.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.core.<a href="quarks/oplet/core/FanOut.html" title="class in quarks.oplet.core">FanOut</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/core/FanOut.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.core.<a href="org/apache/edgent/oplet/core/FanOut.html" title="class in org.apache.edgent.oplet.core">FanOut</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/core/Peek.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.core.<a href="org/apache/edgent/oplet/core/Peek.html" title="class in org.apache.edgent.oplet.core">Peek</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/core/Peek.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.core.<a href="quarks/oplet/core/Peek.html" title="class in quarks.oplet.core">Peek</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/core/Split.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.core.<a href="org/apache/edgent/oplet/core/Split.html" title="class in org.apache.edgent.oplet.core">Split</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/core/Split.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.core.<a href="quarks/oplet/core/Split.html" title="class in quarks.oplet.core">Split</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/functional/Events.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.functional.<a href="org/apache/edgent/oplet/functional/Events.html" title="class in org.apache.edgent.oplet.functional">Events</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/functional/Events.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.functional.<a href="quarks/oplet/functional/Events.html" title="class in quarks.oplet.functional">Events</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/functional/Filter.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.functional.<a href="org/apache/edgent/oplet/functional/Filter.html" title="class in org.apache.edgent.oplet.functional">Filter</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/functional/Filter.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.functional.<a href="quarks/oplet/functional/Filter.html" title="class in quarks.oplet.functional">Filter</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/functional/FlatMap.html#accept-I-">accept(I)</a></span> - Method in class org.apache.edgent.oplet.functional.<a href="org/apache/edgent/oplet/functional/FlatMap.html" title="class in org.apache.edgent.oplet.functional">FlatMap</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/functional/FlatMap.html#accept-I-">accept(I)</a></span> - Method in class quarks.oplet.functional.<a href="quarks/oplet/functional/FlatMap.html" title="class in quarks.oplet.functional">FlatMap</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/functional/Map.html#accept-I-">accept(I)</a></span> - Method in class org.apache.edgent.oplet.functional.<a href="org/apache/edgent/oplet/functional/Map.html" title="class in org.apache.edgent.oplet.functional">Map</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/functional/Map.html#accept-I-">accept(I)</a></span> - Method in class quarks.oplet.functional.<a href="quarks/oplet/functional/Map.html" title="class in quarks.oplet.functional">Map</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/plumbing/Barrier.html#accept-T-int-">accept(T, int)</a></span> - Method in class org.apache.edgent.oplet.plumbing.<a href="org/apache/edgent/oplet/plumbing/Barrier.html" title="class in org.apache.edgent.oplet.plumbing">Barrier</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/plumbing/Isolate.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.plumbing.<a href="quarks/oplet/plumbing/Isolate.html" title="class in quarks.oplet.plumbing">Isolate</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/plumbing/Isolate.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.plumbing.<a href="org/apache/edgent/oplet/plumbing/Isolate.html" title="class in org.apache.edgent.oplet.plumbing">Isolate</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/plumbing/PressureReliever.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.plumbing.<a href="quarks/oplet/plumbing/PressureReliever.html" title="class in quarks.oplet.plumbing">PressureReliever</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/plumbing/PressureReliever.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.plumbing.<a href="org/apache/edgent/oplet/plumbing/PressureReliever.html" title="class in org.apache.edgent.oplet.plumbing">PressureReliever</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/plumbing/UnorderedIsolate.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.plumbing.<a href="quarks/oplet/plumbing/UnorderedIsolate.html" title="class in quarks.oplet.plumbing">UnorderedIsolate</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/plumbing/UnorderedIsolate.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.plumbing.<a href="org/apache/edgent/oplet/plumbing/UnorderedIsolate.html" title="class in org.apache.edgent.oplet.plumbing">UnorderedIsolate</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/window/Aggregate.html#accept-T-">accept(T)</a></span> - Method in class quarks.oplet.window.<a href="quarks/oplet/window/Aggregate.html" title="class in quarks.oplet.window">Aggregate</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/window/Aggregate.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.oplet.window.<a href="org/apache/edgent/oplet/window/Aggregate.html" title="class in org.apache.edgent.oplet.window">Aggregate</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/etiao/SettableForwarder.html#accept-T-">accept(T)</a></span> - Method in class quarks.runtime.etiao.<a href="quarks/runtime/etiao/SettableForwarder.html" title="class in quarks.runtime.etiao">SettableForwarder</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/etiao/SettableForwarder.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.runtime.etiao.<a href="org/apache/edgent/runtime/etiao/SettableForwarder.html" title="class in org.apache.edgent.runtime.etiao">SettableForwarder</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/window/InsertionTimeList.html#add-T-">add(T)</a></span> - Method in class quarks.window.<a href="quarks/window/InsertionTimeList.html" title="class in quarks.window">InsertionTimeList</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/streamscope/StreamScope.html#accept-T-">accept(T)</a></span> - Method in class org.apache.edgent.streamscope.<a href="org/apache/edgent/streamscope/StreamScope.html" title="class in org.apache.edgent.streamscope">StreamScope</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/sensorAnalytics/Sensor1.html#addAnalytics--">addAnalytics()</a></span> - Method in class quarks.samples.apps.sensorAnalytics.<a href="quarks/samples/apps/sensorAnalytics/Sensor1.html" title="class in quarks.samples.apps.sensorAnalytics">Sensor1</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/window/InsertionTimeList.html#add-T-">add(T)</a></span> - Method in class org.apache.edgent.window.<a href="org/apache/edgent/window/InsertionTimeList.html" title="class in org.apache.edgent.window">InsertionTimeList</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/apps/sensorAnalytics/Sensor1.html#addAnalytics--">addAnalytics()</a></span> - Method in class org.apache.edgent.samples.apps.sensorAnalytics.<a href="org/apache/edgent/samples/apps/sensorAnalytics/Sensor1.html" title="class in org.apache.edgent.samples.apps.sensorAnalytics">Sensor1</a></dt> <dd> <div class="block">Add the sensor's analytics to the topology.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/execution/services/ServiceContainer.html#addCleaner-quarks.function.BiConsumer-">addCleaner(BiConsumer<String, String>)</a></span> - Method in class quarks.execution.services.<a href="quarks/execution/services/ServiceContainer.html" title="class in quarks.execution.services">ServiceContainer</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/test/svt/apps/GpsAnalyticsApplication.html#addAnalytics--">addAnalytics()</a></span> - Method in class org.apache.edgent.test.svt.apps.<a href="org/apache/edgent/test/svt/apps/GpsAnalyticsApplication.html" title="class in org.apache.edgent.test.svt.apps">GpsAnalyticsApplication</a></dt> +<dd> +<div class="block">Add the GPS sensor analytics to the topology.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/test/svt/apps/ObdAnalyticsApplication.html#addAnalytics--">addAnalytics()</a></span> - Method in class org.apache.edgent.test.svt.apps.<a href="org/apache/edgent/test/svt/apps/ObdAnalyticsApplication.html" title="class in org.apache.edgent.test.svt.apps">ObdAnalyticsApplication</a></dt> +<dd> +<div class="block">Add the ODB sensor's analytics to the topology.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/execution/services/ServiceContainer.html#addCleaner-org.apache.edgent.function.BiConsumer-">addCleaner(BiConsumer<String, String>)</a></span> - Method in class org.apache.edgent.execution.services.<a href="org/apache/edgent/execution/services/ServiceContainer.html" title="class in org.apache.edgent.execution.services">ServiceContainer</a></dt> <dd> <div class="block">Registers a new cleaner.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/Options.html#addHandler-java.lang.String-quarks.function.Function-">addHandler(String, Function<String, T>)</a></span> - Method in class quarks.samples.connectors.<a href="quarks/samples/connectors/Options.html" title="class in quarks.samples.connectors">Options</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/Options.html#addHandler-java.lang.String-org.apache.edgent.function.Function-">addHandler(String, Function<String, T>)</a></span> - Method in class org.apache.edgent.samples.connectors.<a href="org/apache/edgent/samples/connectors/Options.html" title="class in org.apache.edgent.samples.connectors">Options</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/Options.html#addHandler-java.lang.String-org.apache.edgent.function.Function-T-">addHandler(String, Function<String, T>, T)</a></span> - Method in class org.apache.edgent.samples.connectors.<a href="org/apache/edgent/samples/connectors/Options.html" title="class in org.apache.edgent.samples.connectors">Options</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/Options.html#addHandler-java.lang.String-quarks.function.Function-T-">addHandler(String, Function<String, T>, T)</a></span> - Method in class quarks.samples.connectors.<a href="quarks/samples/connectors/Options.html" title="class in quarks.samples.connectors">Options</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/iot/HeartBeat.html#addHeartBeat-org.apache.edgent.connectors.iot.IotDevice-long-java.util.concurrent.TimeUnit-java.lang.String-">addHeartBeat(IotDevice, long, TimeUnit, String)</a></span> - Static method in class org.apache.edgent.connectors.iot.<a href="org/apache/edgent/connectors/iot/HeartBeat.html" title="class in org.apache.edgent.connectors.iot">HeartBeat</a></dt> +<dd> +<div class="block">Add IoT device heart beat processing to a topology.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/apps/iot/IotDevicePubSub.html#addIotDevice-org.apache.edgent.topology.TopologyElement-">addIotDevice(TopologyElement)</a></span> - Static method in class org.apache.edgent.apps.iot.<a href="org/apache/edgent/apps/iot/IotDevicePubSub.html" title="class in org.apache.edgent.apps.iot">IotDevicePubSub</a></dt> +<dd> +<div class="block">Add a proxy <code>IotDevice</code> for the topology containing <code>te</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/jmxcontrol/JMXControlService.html#additionalNameKeys-java.util.Hashtable-">additionalNameKeys(Hashtable<String, String>)</a></span> - Method in class org.apache.edgent.runtime.jmxcontrol.<a href="org/apache/edgent/runtime/jmxcontrol/JMXControlService.html" title="class in org.apache.edgent.runtime.jmxcontrol">JMXControlService</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/jmxcontrol/JMXControlService.html#additionalNameKeys-java.util.Hashtable-">additionalNameKeys(Hashtable<String, String>)</a></span> - Method in class quarks.runtime.jmxcontrol.<a href="quarks/runtime/jmxcontrol/JMXControlService.html" title="class in quarks.runtime.jmxcontrol">JMXControlService</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/execution/services/JobRegistryService.html#addJob-org.apache.edgent.execution.Job-">addJob(Job)</a></span> - Method in interface org.apache.edgent.execution.services.<a href="org/apache/edgent/execution/services/JobRegistryService.html" title="interface in org.apache.edgent.execution.services">JobRegistryService</a></dt> +<dd> +<div class="block">Adds the specified job.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/jobregistry/JobRegistry.html#addJob-org.apache.edgent.execution.Job-">addJob(Job)</a></span> - Method in class org.apache.edgent.runtime.jobregistry.<a href="org/apache/edgent/runtime/jobregistry/JobRegistry.html" title="class in org.apache.edgent.runtime.jobregistry">JobRegistry</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/metrics/MetricObjectNameFactory.html#addKeyProperties-java.lang.String-java.util.Map-">addKeyProperties(String, Map<String, String>)</a></span> - Method in class quarks.metrics.<a href="quarks/metrics/MetricObjectNameFactory.html" title="class in quarks.metrics">MetricObjectNameFactory</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/metrics/MetricObjectNameFactory.html#addKeyProperties-java.lang.String-java.util.Map-">addKeyProperties(String, Map<String, String>)</a></span> - Method in class org.apache.edgent.metrics.<a href="org/apache/edgent/metrics/MetricObjectNameFactory.html" title="class in org.apache.edgent.metrics">MetricObjectNameFactory</a></dt> <dd> <div class="block">Extracts job and oplet identifier values from the specified buffer and - adds the <a href="quarks/metrics/MetricObjectNameFactory.html#KEY_JOBID"><code>MetricObjectNameFactory.KEY_JOBID</code></a> and <a href="quarks/metrics/MetricObjectNameFactory.html#KEY_OPID"><code>MetricObjectNameFactory.KEY_OPID</code></a> key properties to the + adds the <a href="org/apache/edgent/metrics/MetricObjectNameFactory.html#KEY_JOBID"><code>MetricObjectNameFactory.KEY_JOBID</code></a> and <a href="org/apache/edgent/metrics/MetricObjectNameFactory.html#KEY_OPID"><code>MetricObjectNameFactory.KEY_OPID</code></a> key properties to the specified properties map.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/etiao/Executable.html#addOpletInvocation-T-int-int-">addOpletInvocation(T, int, int)</a></span> - Method in class quarks.runtime.etiao.<a href="quarks/runtime/etiao/Executable.html" title="class in quarks.runtime.etiao">Executable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/execution/services/JobRegistryService.html#addListener-org.apache.edgent.function.BiConsumer-">addListener(BiConsumer<JobRegistryService.EventType, Job>)</a></span> - Method in interface org.apache.edgent.execution.services.<a href="org/apache/edgent/execution/services/JobRegistryService.html" title="interface in org.apache.edgent.execution.services">JobRegistryService</a></dt> +<dd> +<div class="block">Adds a handler to a collection of listeners that will be notified + on job registration and state changes.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/jobregistry/JobRegistry.html#addListener-org.apache.edgent.function.BiConsumer-">addListener(BiConsumer<JobRegistryService.EventType, Job>)</a></span> - Method in class org.apache.edgent.runtime.jobregistry.<a href="org/apache/edgent/runtime/jobregistry/JobRegistry.html" title="class in org.apache.edgent.runtime.jobregistry">JobRegistry</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/etiao/Executable.html#addOpletInvocation-T-int-int-">addOpletInvocation(T, int, int)</a></span> - Method in class org.apache.edgent.runtime.etiao.<a href="org/apache/edgent/runtime/etiao/Executable.html" title="class in org.apache.edgent.runtime.etiao">Executable</a></dt> <dd> <div class="block">Creates a new <code>Invocation</code> associated with the specified oplet.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/graph/Vertex.html#addOutput--">addOutput()</a></span> - Method in interface quarks.graph.<a href="quarks/graph/Vertex.html" title="interface in quarks.graph">Vertex</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/graph/Vertex.html#addOutput--">addOutput()</a></span> - Method in interface org.apache.edgent.graph.<a href="org/apache/edgent/graph/Vertex.html" title="interface in org.apache.edgent.graph">Vertex</a></dt> <dd> <div class="block">Add an output port to the vertex.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/etiao/graph/ExecutableVertex.html#addOutput--">addOutput()</a></span> - Method in class quarks.runtime.etiao.graph.<a href="quarks/runtime/etiao/graph/ExecutableVertex.html" title="class in quarks.runtime.etiao.graph">ExecutableVertex</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/etiao/graph/ExecutableVertex.html#addOutput--">addOutput()</a></span> - Method in class org.apache.edgent.runtime.etiao.graph.<a href="org/apache/edgent/runtime/etiao/graph/ExecutableVertex.html" title="class in org.apache.edgent.runtime.etiao.graph">ExecutableVertex</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/etiao/Invocation.html#addOutput--">addOutput()</a></span> - Method in class quarks.runtime.etiao.<a href="quarks/runtime/etiao/Invocation.html" title="class in quarks.runtime.etiao">Invocation</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/etiao/Invocation.html#addOutput--">addOutput()</a></span> - Method in class org.apache.edgent.runtime.etiao.<a href="org/apache/edgent/runtime/etiao/Invocation.html" title="class in org.apache.edgent.runtime.etiao">Invocation</a></dt> <dd> <div class="block">Adds a new output.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/execution/services/ServiceContainer.html#addService-java.lang.Class-T-">addService(Class<T>, T)</a></span> - Method in class quarks.execution.services.<a href="quarks/execution/services/ServiceContainer.html" title="class in quarks.execution.services">ServiceContainer</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/execution/services/ServiceContainer.html#addService-java.lang.Class-T-">addService(Class<T>, T)</a></span> - Method in class org.apache.edgent.execution.services.<a href="org/apache/edgent/execution/services/ServiceContainer.html" title="class in org.apache.edgent.execution.services">ServiceContainer</a></dt> <dd> <div class="block">Adds the specified service to this <code>ServiceContainer</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/pubsub/service/ProviderPubSub.html#addSubscriber-java.lang.String-java.lang.Class-quarks.function.Consumer-">addSubscriber(String, Class<T>, Consumer<T>)</a></span> - Method in class quarks.connectors.pubsub.service.<a href="quarks/connectors/pubsub/service/ProviderPubSub.html" title="class in quarks.connectors.pubsub.service">ProviderPubSub</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/streamscope/StreamScopeSetup.html#addStreamScopes-org.apache.edgent.topology.Topology-">addStreamScopes(Topology)</a></span> - Static method in class org.apache.edgent.streamscope.<a href="org/apache/edgent/streamscope/StreamScopeSetup.html" title="class in org.apache.edgent.streamscope">StreamScopeSetup</a></dt> +<dd> +<div class="block">Add StreamScope instances to the topology</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/pubsub/service/ProviderPubSub.html#addSubscriber-java.lang.String-java.lang.Class-org.apache.edgent.function.Consumer-">addSubscriber(String, Class<T>, Consumer<T>)</a></span> - Method in class org.apache.edgent.connectors.pubsub.service.<a href="org/apache/edgent/connectors/pubsub/service/ProviderPubSub.html" title="class in org.apache.edgent.connectors.pubsub.service">ProviderPubSub</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/pubsub/service/PublishSubscribeService.html#addSubscriber-java.lang.String-java.lang.Class-quarks.function.Consumer-">addSubscriber(String, Class<T>, Consumer<T>)</a></span> - Method in interface quarks.connectors.pubsub.service.<a href="quarks/connectors/pubsub/service/PublishSubscribeService.html" title="interface in quarks.connectors.pubsub.service">PublishSubscribeService</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/pubsub/service/PublishSubscribeService.html#addSubscriber-java.lang.String-java.lang.Class-org.apache.edgent.function.Consumer-">addSubscriber(String, Class<T>, Consumer<T>)</a></span> - Method in interface org.apache.edgent.connectors.pubsub.service.<a href="org/apache/edgent/connectors/pubsub/service/PublishSubscribeService.html" title="interface in org.apache.edgent.connectors.pubsub.service">PublishSubscribeService</a></dt> <dd> <div class="block">Add a subscriber to a published topic.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/etiao/TrackingScheduledExecutor.html#afterExecute-java.lang.Runnable-java.lang.Throwable-">afterExecute(Runnable, Throwable)</a></span> - Method in class quarks.runtime.etiao.<a href="quarks/runtime/etiao/TrackingScheduledExecutor.html" title="class in quarks.runtime.etiao">TrackingScheduledExecutor</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/etiao/TrackingScheduledExecutor.html#afterExecute-java.lang.Runnable-java.lang.Throwable-">afterExecute(Runnable, Throwable)</a></span> - Method in class org.apache.edgent.runtime.etiao.<a href="org/apache/edgent/runtime/etiao/TrackingScheduledExecutor.html" title="class in org.apache.edgent.runtime.etiao">TrackingScheduledExecutor</a></dt> <dd> <div class="block">Invoked by the super class after each task execution.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/analytics/math3/json/JsonAnalytics.html#aggregate-quarks.topology.TWindow-java.lang.String-java.lang.String-quarks.analytics.math3.json.JsonUnivariateAggregate...-">aggregate(TWindow<JsonObject, K>, String, String, JsonUnivariateAggregate...)</a></span> - Static method in class quarks.analytics.math3.json.<a href="quarks/analytics/math3/json/JsonAnalytics.html" title="class in quarks.analytics.math3.json">JsonAnalytics</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/analytics/math3/json/JsonAnalytics.html#aggregate-org.apache.edgent.topology.TWindow-java.lang.String-java.lang.String-org.apache.edgent.analytics.math3.json.JsonUnivariateAggregate...-">aggregate(TWindow<JsonObject, K>, String, String, JsonUnivariateAggregate...)</a></span> - Static method in class org.apache.edgent.analytics.math3.json.<a href="org/apache/edgent/analytics/math3/json/JsonAnalytics.html" title="class in org.apache.edgent.analytics.math3.json">JsonAnalytics</a></dt> <dd> <div class="block">Aggregate against a single <code>Numeric</code> variable contained in an JSON object.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/analytics/math3/json/JsonAnalytics.html#aggregate-quarks.topology.TWindow-java.lang.String-java.lang.String-quarks.function.ToDoubleFunction-quarks.analytics.math3.json.JsonUnivariateAggregate...-">aggregate(TWindow<JsonObject, K>, String, String, ToDoubleFunction<JsonObject>, JsonUnivariateAggregate...)</a></span> - Static method in class quarks.analytics.math3.json.<a href="quarks/analytics/math3/json/JsonAnalytics.html" title="class in quarks.analytics.math3.json">JsonAnalytics</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/analytics/math3/json/JsonAnalytics.html#aggregate-org.apache.edgent.topology.TWindow-java.lang.String-java.lang.String-org.apache.edgent.function.ToDoubleFunction-org.apache.edgent.analytics.math3.json.JsonUnivariateAggregate...-">aggregate(TWindow<JsonObject, K>, String, String, ToDoubleFunction<JsonObject>, JsonUnivariateAggregate...)</a></span> - Static method in class org.apache.edgent.analytics.math3.json.<a href="org/apache/edgent/analytics/math3/json/JsonAnalytics.html" title="class in org.apache.edgent.analytics.math3.json">JsonAnalytics</a></dt> <dd> <div class="block">Aggregate against a single <code>Numeric</code> variable contained in an JSON object.</div> </dd> -<dt><a href="quarks/oplet/window/Aggregate.html" title="class in quarks.oplet.window"><span class="typeNameLink">Aggregate</span></a><<a href="quarks/oplet/window/Aggregate.html" title="type parameter in Aggregate">T</a>,<a href="quarks/oplet/window/Aggregate.html" title="type parameter in Aggregate">U</a>,<a href="quarks/oplet/window/Aggregate.html" title="type parameter in Aggregate">K</a>> - Class in <a href="quarks/oplet/window/package-summary.html">quarks.oplet.window</a></dt> +<dt><a href="org/apache/edgent/oplet/window/Aggregate.html" title="class in org.apache.edgent.oplet.window"><span class="typeNameLink">Aggregate</span></a><<a href="org/apache/edgent/oplet/window/Aggregate.html" title="type parameter in Aggregate">T</a>,<a href="org/apache/edgent/oplet/window/Aggregate.html" title="type parameter in Aggregate">U</a>,<a href="org/apache/edgent/oplet/window/Aggregate.html" title="type parameter in Aggregate">K</a>> - Class in <a href="org/apache/edgent/oplet/window/package-summary.html">org.apache.edgent.oplet.window</a></dt> <dd> <div class="block">Aggregate a window.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/oplet/window/Aggregate.html#Aggregate-quarks.window.Window-quarks.function.BiFunction-">Aggregate(Window<T, K, ? extends List<T>>, BiFunction<List<T>, K, U>)</a></span> - Constructor for class quarks.oplet.window.<a href="quarks/oplet/window/Aggregate.html" title="class in quarks.oplet.window">Aggregate</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/window/Aggregate.html#Aggregate-org.apache.edgent.window.Window-org.apache.edgent.function.BiFunction-">Aggregate(Window<T, K, ? extends List<T>>, BiFunction<List<T>, K, U>)</a></span> - Constructor for class org.apache.edgent.oplet.window.<a href="org/apache/edgent/oplet/window/Aggregate.html" title="class in org.apache.edgent.oplet.window">Aggregate</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/graph/TWindowImpl.html#aggregate-org.apache.edgent.function.BiFunction-">aggregate(BiFunction<List<T>, K, U>)</a></span> - Method in class org.apache.edgent.topology.spi.graph.<a href="org/apache/edgent/topology/spi/graph/TWindowImpl.html" title="class in org.apache.edgent.topology.spi.graph">TWindowImpl</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/TWindow.html#aggregate-quarks.function.BiFunction-">aggregate(BiFunction<List<T>, K, U>)</a></span> - Method in interface quarks.topology.<a href="quarks/topology/TWindow.html" title="interface in quarks.topology">TWindow</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/graph/TWindowTimeImpl.html#aggregate-org.apache.edgent.function.BiFunction-">aggregate(BiFunction<List<T>, K, U>)</a></span> - Method in class org.apache.edgent.topology.spi.graph.<a href="org/apache/edgent/topology/spi/graph/TWindowTimeImpl.html" title="class in org.apache.edgent.topology.spi.graph">TWindowTimeImpl</a></dt> +<dd> +<div class="block">Window behaviour here is that: + + Tuples are always inserted into the partition.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/TWindow.html#aggregate-org.apache.edgent.function.BiFunction-">aggregate(BiFunction<List<T>, K, U>)</a></span> - Method in interface org.apache.edgent.topology.<a href="org/apache/edgent/topology/TWindow.html" title="interface in org.apache.edgent.topology">TWindow</a></dt> <dd> -<div class="block">Declares a stream that is a continuous aggregation of +<div class="block">Declares a stream that is a continuous, sliding, aggregation of partitions in this window.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/analytics/math3/json/JsonAnalytics.html#aggregateList-java.lang.String-java.lang.String-quarks.function.ToDoubleFunction-quarks.analytics.math3.json.JsonUnivariateAggregate...-">aggregateList(String, String, ToDoubleFunction<JsonObject>, JsonUnivariateAggregate...)</a></span> - Static method in class quarks.analytics.math3.json.<a href="quarks/analytics/math3/json/JsonAnalytics.html" title="class in quarks.analytics.math3.json">JsonAnalytics</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/analytics/math3/json/JsonAnalytics.html#aggregateList-java.lang.String-java.lang.String-org.apache.edgent.function.ToDoubleFunction-org.apache.edgent.analytics.math3.json.JsonUnivariateAggregate...-">aggregateList(String, String, ToDoubleFunction<JsonObject>, JsonUnivariateAggregate...)</a></span> - Static method in class org.apache.edgent.analytics.math3.json.<a href="org/apache/edgent/analytics/math3/json/JsonAnalytics.html" title="class in org.apache.edgent.analytics.math3.json">JsonAnalytics</a></dt> <dd> <div class="block">Create a Function that aggregates against a single <code>Numeric</code> variable contained in an JSON object.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/console/ConsoleWaterDetector.html#alertFilter-quarks.topology.TStream-int-boolean-">alertFilter(TStream<JsonObject>, int, boolean)</a></span> - Static method in class quarks.samples.console.<a href="quarks/samples/console/ConsoleWaterDetector.html" title="class in quarks.samples.console">ConsoleWaterDetector</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/console/ConsoleWaterDetector.html#alertFilter-org.apache.edgent.topology.TStream-int-boolean-">alertFilter(TStream<JsonObject>, int, boolean)</a></span> - Static method in class org.apache.edgent.samples.console.<a href="org/apache/edgent/samples/console/ConsoleWaterDetector.html" title="class in org.apache.edgent.samples.console">ConsoleWaterDetector</a></dt> <dd> <div class="block">Look through the stream and check to see if any of the measurements cause concern.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/jsoncontrol/JsonControlService.html#ALIAS_KEY">ALIAS_KEY</a></span> - Static variable in class quarks.runtime.jsoncontrol.<a href="quarks/runtime/jsoncontrol/JsonControlService.html" title="class in quarks.runtime.jsoncontrol">JsonControlService</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/graph/Connector.html#alias-java.lang.String-">alias(String)</a></span> - Method in interface org.apache.edgent.graph.<a href="org/apache/edgent/graph/Connector.html" title="interface in org.apache.edgent.graph">Connector</a></dt> +<dd> +<div class="block">Set the alias for the connector.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/services/ApplicationService.html#ALIAS">ALIAS</a></span> - Static variable in interface org.apache.edgent.topology.services.<a href="org/apache/edgent/topology/services/ApplicationService.html" title="interface in org.apache.edgent.topology.services">ApplicationService</a></dt> +<dd> +<div class="block">Default alias a service registers its control MBean as.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/graph/ConnectorStream.html#alias-java.lang.String-">alias(String)</a></span> - Method in class org.apache.edgent.topology.spi.graph.<a href="org/apache/edgent/topology/spi/graph/ConnectorStream.html" title="class in org.apache.edgent.topology.spi.graph">ConnectorStream</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/TStream.html#alias-java.lang.String-">alias(String)</a></span> - Method in interface org.apache.edgent.topology.<a href="org/apache/edgent/topology/TStream.html" title="interface in org.apache.edgent.topology">TStream</a></dt> +<dd> +<div class="block">Set an alias for the stream.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/jsoncontrol/JsonControlService.html#ALIAS_KEY">ALIAS_KEY</a></span> - Static variable in class org.apache.edgent.runtime.jsoncontrol.<a href="org/apache/edgent/runtime/jsoncontrol/JsonControlService.html" title="class in org.apache.edgent.runtime.jsoncontrol">JsonControlService</a></dt> <dd> <div class="block">Key for the alias of the control MBean in a JSON request.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/Functions.html#alwaysFalse--">alwaysFalse()</a></span> - Static method in class quarks.function.<a href="quarks/function/Functions.html" title="class in quarks.function">Functions</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/Functions.html#alwaysFalse--">alwaysFalse()</a></span> - Static method in class org.apache.edgent.function.<a href="org/apache/edgent/function/Functions.html" title="class in org.apache.edgent.function">Functions</a></dt> <dd> <div class="block">A Predicate that is always false</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/window/Policies.html#alwaysInsert--">alwaysInsert()</a></span> - Static method in class quarks.window.<a href="quarks/window/Policies.html" title="class in quarks.window">Policies</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/window/Policies.html#alwaysInsert--">alwaysInsert()</a></span> - Static method in class org.apache.edgent.window.<a href="org/apache/edgent/window/Policies.html" title="class in org.apache.edgent.window">Policies</a></dt> <dd> <div class="block">Returns an insertion policy that indicates the tuple is to be inserted into the partition.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/Functions.html#alwaysTrue--">alwaysTrue()</a></span> - Static method in class quarks.function.<a href="quarks/function/Functions.html" title="class in quarks.function">Functions</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/Functions.html#alwaysTrue--">alwaysTrue()</a></span> - Static method in class org.apache.edgent.function.<a href="org/apache/edgent/function/Functions.html" title="class in org.apache.edgent.function">Functions</a></dt> <dd> <div class="block">A Predicate that is always true</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/tester/Tester.html#and-quarks.topology.tester.Condition...-">and(Condition<?>...)</a></span> - Method in interface quarks.topology.tester.<a href="quarks/topology/tester/Tester.html" title="interface in quarks.topology.tester">Tester</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/tester/AbstractTester.html#and-org.apache.edgent.topology.tester.Condition...-">and(Condition<?>...)</a></span> - Method in class org.apache.edgent.topology.spi.tester.<a href="org/apache/edgent/topology/spi/tester/AbstractTester.html" title="class in org.apache.edgent.topology.spi.tester">AbstractTester</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/tester/Tester.html#and-org.apache.edgent.topology.tester.Condition...-">and(Condition<?>...)</a></span> - Method in interface org.apache.edgent.topology.tester.<a href="org/apache/edgent/topology/tester/Tester.html" title="interface in org.apache.edgent.topology.tester">Tester</a></dt> <dd> <div class="block">Return a condition that is valid only if all of <code>conditions</code> are valid.</div> </dd> -<dt><a href="quarks/samples/apps/ApplicationUtilities.html" title="class in quarks.samples.apps"><span class="typeNameLink">ApplicationUtilities</span></a> - Class in <a href="quarks/samples/apps/package-summary.html">quarks.samples.apps</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/apps/iot/IotDevicePubSub.html#APP_NAME">APP_NAME</a></span> - Static variable in class org.apache.edgent.apps.iot.<a href="org/apache/edgent/apps/iot/IotDevicePubSub.html" title="class in org.apache.edgent.apps.iot">IotDevicePubSub</a></dt> +<dd> +<div class="block">IotDevicePubSub application name.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/apps/runtime/JobMonitorApp.html#APP_NAME">APP_NAME</a></span> - Static variable in class org.apache.edgent.apps.runtime.<a href="org/apache/edgent/apps/runtime/JobMonitorApp.html" title="class in org.apache.edgent.apps.runtime">JobMonitorApp</a></dt> +<dd> +<div class="block">Job monitoring application name.</div> +</dd> +<dt><a href="org/apache/edgent/topology/services/ApplicationService.html" title="interface in org.apache.edgent.topology.services"><span class="typeNameLink">ApplicationService</span></a> - Interface in <a href="org/apache/edgent/topology/services/package-summary.html">org.apache.edgent.topology.services</a></dt> +<dd> +<div class="block">Application registration service.</div> +</dd> +<dt><a href="org/apache/edgent/topology/mbeans/ApplicationServiceMXBean.html" title="interface in org.apache.edgent.topology.mbeans"><span class="typeNameLink">ApplicationServiceMXBean</span></a> - Interface in <a href="org/apache/edgent/topology/mbeans/package-summary.html">org.apache.edgent.topology.mbeans</a></dt> +<dd> +<div class="block">Control MBean for the application service.</div> +</dd> +<dt><a href="org/apache/edgent/samples/apps/ApplicationUtilities.html" title="class in org.apache.edgent.samples.apps"><span class="typeNameLink">ApplicationUtilities</span></a> - Class in <a href="org/apache/edgent/samples/apps/package-summary.html">org.apache.edgent.samples.apps</a></dt> <dd> <div class="block">Some general purpose application configuration driven utilities.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/ApplicationUtilities.html#ApplicationUtilities-java.util.Properties-">ApplicationUtilities(Properties)</a></span> - Constructor for class quarks.samples.apps.<a href="quarks/samples/apps/ApplicationUtilities.html" title="class in quarks.samples.apps">ApplicationUtilities</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/apps/ApplicationUtilities.html#ApplicationUtilities-java.util.Properties-">ApplicationUtilities(Properties)</a></span> - Constructor for class org.apache.edgent.samples.apps.<a href="org/apache/edgent/samples/apps/ApplicationUtilities.html" title="class in org.apache.edgent.samples.apps">ApplicationUtilities</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/jdbc/CheckedFunction.html#apply-T-">apply(T)</a></span> - Method in interface quarks.connectors.jdbc.<a href="quarks/connectors/jdbc/CheckedFunction.html" title="interface in quarks.connectors.jdbc">CheckedFunction</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/jdbc/CheckedFunction.html#apply-T-">apply(T)</a></span> - Method in interface org.apache.edgent.connectors.jdbc.<a href="org/apache/edgent/connectors/jdbc/CheckedFunction.html" title="interface in org.apache.edgent.connectors.jdbc">CheckedFunction</a></dt> <dd> <div class="block">Apply a function to <code>t</code> and return the result.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/BiFunction.html#apply-T-U-">apply(T, U)</a></span> - Method in interface quarks.function.<a href="quarks/function/BiFunction.html" title="interface in quarks.function">BiFunction</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/BiFunction.html#apply-T-U-">apply(T, U)</a></span> - Method in interface org.apache.edgent.function.<a href="org/apache/edgent/function/BiFunction.html" title="interface in org.apache.edgent.function">BiFunction</a></dt> <dd> <div class="block">Apply a function to <code>t</code> and <code>u</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/Function.html#apply-T-">apply(T)</a></span> - Method in interface quarks.function.<a href="quarks/function/Function.html" title="interface in quarks.function">Function</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/Function.html#apply-T-">apply(T)</a></span> - Method in interface org.apache.edgent.function.<a href="org/apache/edgent/function/Function.html" title="interface in org.apache.edgent.function">Function</a></dt> <dd> <div class="block">Apply a function to <code>value</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/ToDoubleFunction.html#applyAsDouble-T-">applyAsDouble(T)</a></span> - Method in interface quarks.function.<a href="quarks/function/ToDoubleFunction.html" title="interface in quarks.function">ToDoubleFunction</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/ToDoubleFunction.html#applyAsDouble-T-">applyAsDouble(T)</a></span> - Method in interface org.apache.edgent.function.<a href="org/apache/edgent/function/ToDoubleFunction.html" title="interface in org.apache.edgent.function">ToDoubleFunction</a></dt> <dd> <div class="block">Apply a function to <code>value</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/function/ToIntFunction.html#applyAsInt-T-">applyAsInt(T)</a></span> - Method in interface quarks.function.<a href="quarks/function/ToIntFunction.html" title="interface in quarks.function">ToIntFunction</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/function/ToIntFunction.html#applyAsInt-T-">applyAsInt(T)</a></span> - Method in interface org.apache.edgent.function.<a href="org/apache/edgent/function/ToIntFunction.html" title="interface in org.apache.edgent.function">ToIntFunction</a></dt> <dd> <div class="block">Apply a function to <code>value</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/runtime/jsoncontrol/JsonControlService.html#ARGS_KEY">ARGS_KEY</a></span> - Static variable in class quarks.runtime.jsoncontrol.<a href="quarks/runtime/jsoncontrol/JsonControlService.html" title="class in quarks.runtime.jsoncontrol">JsonControlService</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/plumbing/LoadBalancedSplitter.html#applyAsInt-T-">applyAsInt(T)</a></span> - Method in class org.apache.edgent.topology.plumbing.<a href="org/apache/edgent/topology/plumbing/LoadBalancedSplitter.html" title="class in org.apache.edgent.topology.plumbing">LoadBalancedSplitter</a></dt> +<dd> </dd> +<dt><a href="org/apache/edgent/runtime/appservice/AppService.html" title="class in org.apache.edgent.runtime.appservice"><span class="typeNameLink">AppService</span></a> - Class in <a href="org/apache/edgent/runtime/appservice/package-summary.html">org.apache.edgent.runtime.appservice</a></dt> +<dd> +<div class="block">Application service for a <code>TopologyProvider</code>.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/appservice/AppService.html#AppService-org.apache.edgent.topology.TopologyProvider-org.apache.edgent.execution.DirectSubmitter-java.lang.String-">AppService(TopologyProvider, DirectSubmitter<Topology, Job>, String)</a></span> - Constructor for class org.apache.edgent.runtime.appservice.<a href="org/apache/edgent/runtime/appservice/AppService.html" title="class in org.apache.edgent.runtime.appservice">AppService</a></dt> +<dd> +<div class="block">Create an <code>ApplicationService</code> instance.</div> +</dd> +<dt><a href="org/apache/edgent/runtime/appservice/AppServiceControl.html" title="class in org.apache.edgent.runtime.appservice"><span class="typeNameLink">AppServiceControl</span></a> - Class in <a href="org/apache/edgent/runtime/appservice/package-summary.html">org.apache.edgent.runtime.appservice</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/runtime/jsoncontrol/JsonControlService.html#ARGS_KEY">ARGS_KEY</a></span> - Static variable in class org.apache.edgent.runtime.jsoncontrol.<a href="org/apache/edgent/runtime/jsoncontrol/JsonControlService.html" title="class in org.apache.edgent.runtime.jsoncontrol">JsonControlService</a></dt> <dd> <div class="block">Key for the argument list.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/json/JsonFunctions.html#asBytes--">asBytes()</a></span> - Static method in class quarks.topology.json.<a href="quarks/topology/json/JsonFunctions.html" title="class in quarks.topology.json">JsonFunctions</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/json/JsonFunctions.html#asBytes--">asBytes()</a></span> - Static method in class org.apache.edgent.topology.json.<a href="org/apache/edgent/topology/json/JsonFunctions.html" title="class in org.apache.edgent.topology.json">JsonFunctions</a></dt> <dd> <div class="block">Get the UTF-8 bytes representation of the JSON for a JsonObject.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/json/JsonFunctions.html#asString--">asString()</a></span> - Static method in class quarks.topology.json.<a href="quarks/topology/json/JsonFunctions.html" title="class in quarks.topology.json">JsonFunctions</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/json/JsonFunctions.html#asString--">asString()</a></span> - Static method in class org.apache.edgent.topology.json.<a href="org/apache/edgent/topology/json/JsonFunctions.html" title="class in org.apache.edgent.topology.json">JsonFunctions</a></dt> <dd> <div class="block">Get the JSON for a JsonObject.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/TStream.html#asString--">asString()</a></span> - Method in interface quarks.topology.<a href="quarks/topology/TStream.html" title="interface in quarks.topology">TStream</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/AbstractTStream.html#asString--">asString()</a></span> - Method in class org.apache.edgent.topology.spi.<a href="org/apache/edgent/topology/spi/AbstractTStream.html" title="class in org.apache.edgent.topology.spi">AbstractTStream</a></dt> +<dd> +<div class="block">Convert this stream to a stream of <code>String</code> tuples by calling + <code>toString()</code> on each tuple.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/TStream.html#asString--">asString()</a></span> - Method in interface org.apache.edgent.topology.<a href="org/apache/edgent/topology/TStream.html" title="interface in org.apache.edgent.topology">TStream</a></dt> <dd> <div class="block">Convert this stream to a stream of <code>String</code> tuples by calling <code>toString()</code> on each tuple.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/iot/QoS.html#AT_LEAST_ONCE">AT_LEAST_ONCE</a></span> - Static variable in interface quarks.connectors.iot.<a href="quarks/connectors/iot/QoS.html" title="interface in quarks.connectors.iot">QoS</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/iot/QoS.html#AT_LEAST_ONCE">AT_LEAST_ONCE</a></span> - Static variable in interface org.apache.edgent.connectors.iot.<a href="org/apache/edgent/connectors/iot/QoS.html" title="interface in org.apache.edgent.connectors.iot">QoS</a></dt> <dd> <div class="block">The message containing the event arrives at the message hub at least once.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/iot/QoS.html#AT_MOST_ONCE">AT_MOST_ONCE</a></span> - Static variable in interface quarks.connectors.iot.<a href="quarks/connectors/iot/QoS.html" title="interface in quarks.connectors.iot">QoS</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/iot/QoS.html#AT_MOST_ONCE">AT_MOST_ONCE</a></span> - Static variable in interface org.apache.edgent.connectors.iot.<a href="org/apache/edgent/connectors/iot/QoS.html" title="interface in org.apache.edgent.connectors.iot">QoS</a></dt> <dd> <div class="block">The message containing the event arrives at the message hub either once or not at all.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/Range.html#atLeast-T-">atLeast(T)</a></span> - Static method in class quarks.samples.apps.<a href="quarks/samples/apps/Range.html" title="class in quarks.samples.apps">Range</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/analytics/sensors/Ranges.html#atLeast-T-">atLeast(T)</a></span> - Static method in class org.apache.edgent.analytics.sensors.<a href="org/apache/edgent/analytics/sensors/Ranges.html" title="class in org.apache.edgent.analytics.sensors">Ranges</a></dt> <dd> -<div class="block">[a..+INF) (inclusive)</div> +<div class="block">Create a Range [lowerEndpoint..*) (inclusive/CLOSED)</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/tester/Tester.html#atLeastTupleCount-quarks.topology.TStream-long-">atLeastTupleCount(TStream<?>, long)</a></span> - Method in interface quarks.topology.tester.<a href="quarks/topology/tester/Tester.html" title="interface in quarks.topology.tester">Tester</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/tester/Tester.html#atLeastTupleCount-org.apache.edgent.topology.TStream-long-">atLeastTupleCount(TStream<?>, long)</a></span> - Method in interface org.apache.edgent.topology.tester.<a href="org/apache/edgent/topology/tester/Tester.html" title="interface in org.apache.edgent.topology.tester">Tester</a></dt> <dd> <div class="block">Return a condition that evaluates if <code>stream</code> has submitted at least <code>expectedCount</code> number of tuples.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/Range.html#atMost-T-">atMost(T)</a></span> - Static method in class quarks.samples.apps.<a href="quarks/samples/apps/Range.html" title="class in quarks.samples.apps">Range</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/analytics/sensors/Ranges.html#atMost-T-">atMost(T)</a></span> - Static method in class org.apache.edgent.analytics.sensors.<a href="org/apache/edgent/analytics/sensors/Ranges.html" title="class in org.apache.edgent.analytics.sensors">Ranges</a></dt> <dd> -<div class="block">(-INF..b] (inclusive)</div> +<div class="block">Create a Range (*..upperEndpoint] (inclusive/CLOSED)</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/Util.html#awaitState-quarks.execution.Job-quarks.execution.Job.State-long-java.util.concurrent.TimeUnit-">awaitState(Job, Job.State, long, TimeUnit)</a></span> - Static method in class quarks.samples.connectors.<a href="quarks/samples/connectors/Util.html" title="class in quarks.samples.connectors">Util</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/Util.html#awaitState-org.apache.edgent.execution.Job-org.apache.edgent.execution.Job.State-long-java.util.concurrent.TimeUnit-">awaitState(Job, Job.State, long, TimeUnit)</a></span> - Static method in class org.apache.edgent.samples.connectors.<a href="org/apache/edgent/samples/connectors/Util.html" title="class in org.apache.edgent.samples.connectors">Util</a></dt> <dd> <div class="block">Wait for the job to reach the specified state.</div> </dd> @@ -310,69 +453,95 @@ </a> <h2 class="title">B</h2> <dl> -<dt><span class="memberNameLink"><a href="quarks/connectors/http/HttpClients.html#basic-java.lang.String-java.lang.String-">basic(String, String)</a></span> - Static method in class quarks.connectors.http.<a href="quarks/connectors/http/HttpClients.html" title="class in quarks.connectors.http">HttpClients</a></dt> +<dt><a href="org/apache/edgent/oplet/plumbing/Barrier.html" title="class in org.apache.edgent.oplet.plumbing"><span class="typeNameLink">Barrier</span></a><<a href="org/apache/edgent/oplet/plumbing/Barrier.html" title="type parameter in Barrier">T</a>> - Class in <a href="org/apache/edgent/oplet/plumbing/package-summary.html">org.apache.edgent.oplet.plumbing</a></dt> <dd> -<div class="block">Create a basic authentication HTTP client with a fixed user and password.</div> +<div class="block">A tuple synchronization barrier.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/connectors/http/HttpClients.html#basic-quarks.function.Supplier-quarks.function.Supplier-">basic(Supplier<String>, Supplier<String>)</a></span> - Static method in class quarks.connectors.http.<a href="quarks/connectors/http/HttpClients.html" title="class in quarks.connectors.http">HttpClients</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/oplet/plumbing/Barrier.html#Barrier-int-">Barrier(int)</a></span> - Constructor for class org.apache.edgent.oplet.plumbing.<a href="org/apache/edgent/oplet/plumbing/Barrier.html" title="class in org.apache.edgent.oplet.plumbing">Barrier</a></dt> <dd> -<div class="block">Method to create a basic authentication HTTP client.</div> +<div class="block">Create a new instance.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/apps/JsonTuples.html#batch-quarks.topology.TStream-int-quarks.function.BiFunction-">batch(TStream<JsonObject>, int, BiFunction<List<JsonObject>, String, JsonObject>)</a></span> - Static method in class quarks.samples.apps.<a href="quarks/samples/apps/JsonTuples.html" title="class in quarks.samples.apps">JsonTuples</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html#barrier-java.util.List-">barrier(List<TStream<T>>)</a></span> - Static method in class org.apache.edgent.topology.plumbing.<a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html" title="class in org.apache.edgent.topology.plumbing">PlumbingStreams</a></dt> <dd> -<div class="block">Process a window of tuples in batches.</div> +<div class="block">A tuple synchronization barrier.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html#barrier-java.util.List-int-">barrier(List<TStream<T>>, int)</a></span> - Static method in class org.apache.edgent.topology.plumbing.<a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html" title="class in org.apache.edgent.topology.plumbing">PlumbingStreams</a></dt> +<dd> +<div class="block">A tuple synchronization barrier.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/http/HttpClients.html#basic-java.lang.String-java.lang.String-">basic(String, String)</a></span> - Static method in class org.apache.edgent.connectors.http.<a href="org/apache/edgent/connectors/http/HttpClients.html" title="class in org.apache.edgent.connectors.http">HttpClients</a></dt> +<dd> +<div class="block">Create a basic authentication HTTP client with a fixed user and password.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/connectors/http/HttpClients.html#basic-org.apache.edgent.function.Supplier-org.apache.edgent.function.Supplier-">basic(Supplier<String>, Supplier<String>)</a></span> - Static method in class org.apache.edgent.connectors.http.<a href="org/apache/edgent/connectors/http/HttpClients.html" title="class in org.apache.edgent.connectors.http">HttpClients</a></dt> +<dd> +<div class="block">Method to create a basic authentication HTTP client.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/TWindow.html#batch-quarks.function.BiFunction-">batch(BiFunction<List<T>, K, U>)</a></span> - Method in interface quarks.topology.<a href="quarks/topology/TWindow.html" title="interface in quarks.topology">TWindow</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/graph/TWindowImpl.html#batch-org.apache.edgent.function.BiFunction-">batch(BiFunction<List<T>, K, U>)</a></span> - Method in class org.apache.edgent.topology.spi.graph.<a href="org/apache/edgent/topology/spi/graph/TWindowImpl.html" title="class in org.apache.edgent.topology.spi.graph">TWindowImpl</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/spi/graph/TWindowTimeImpl.html#batch-org.apache.edgent.function.BiFunction-">batch(BiFunction<List<T>, K, U>)</a></span> - Method in class org.apache.edgent.topology.spi.graph.<a href="org/apache/edgent/topology/spi/graph/TWindowTimeImpl.html" title="class in org.apache.edgent.topology.spi.graph">TWindowTimeImpl</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/TWindow.html#batch-org.apache.edgent.function.BiFunction-">batch(BiFunction<List<T>, K, U>)</a></span> - Method in interface org.apache.edgent.topology.<a href="org/apache/edgent/topology/TWindow.html" title="interface in org.apache.edgent.topology">TWindow</a></dt> <dd> <div class="block">Declares a stream that represents a batched aggregation of partitions in this window.</div> </dd> -<dt><a href="quarks/function/BiConsumer.html" title="interface in quarks.function"><span class="typeNameLink">BiConsumer</span></a><<a href="quarks/function/BiConsumer.html" title="type parameter in BiConsumer">T</a>,<a href="quarks/function/BiConsumer.html" title="type parameter in BiConsumer">U</a>> - Interface in <a href="quarks/function/package-summary.html">quarks.function</a></dt> +<dt><a href="org/apache/edgent/function/BiConsumer.html" title="interface in org.apache.edgent.function"><span class="typeNameLink">BiConsumer</span></a><<a href="org/apache/edgent/function/BiConsumer.html" title="type parameter in BiConsumer">T</a>,<a href="org/apache/edgent/function/BiConsumer.html" title="type parameter in BiConsumer">U</a>> - Interface in <a href="org/apache/edgent/function/package-summary.html">org.apache.edgent.function</a></dt> <dd> <div class="block">Consumer function that takes two arguments.</div> </dd> -<dt><a href="quarks/function/BiFunction.html" title="interface in quarks.function"><span class="typeNameLink">BiFunction</span></a><<a href="quarks/function/BiFunction.html" title="type parameter in BiFunction">T</a>,<a href="quarks/function/BiFunction.html" title="type parameter in BiFunction">U</a>,<a href="quarks/function/BiFunction.html" title="type parameter in BiFunction">R</a>> - Interface in <a href="quarks/function/package-summary.html">quarks.function</a></dt> +<dt><a href="org/apache/edgent/function/BiFunction.html" title="interface in org.apache.edgent.function"><span class="typeNameLink">BiFunction</span></a><<a href="org/apache/edgent/function/BiFunction.html" title="type parameter in BiFunction">T</a>,<a href="org/apache/edgent/function/BiFunction.html" title="type parameter in BiFunction">U</a>,<a href="org/apache/edgent/function/BiFunction.html" title="type parameter in BiFunction">R</a>> - Interface in <a href="org/apache/edgent/function/package-summary.html">org.apache.edgent.function</a></dt> <dd> <div class="block">Function that takes two arguments and returns a value.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/plumbing/PlumbingStreams.html#blockingDelay-quarks.topology.TStream-long-java.util.concurrent.TimeUnit-">blockingDelay(TStream<T>, long, TimeUnit)</a></span> - Static method in class quarks.topology.plumbing.<a href="quarks/topology/plumbing/PlumbingStreams.html" title="class in quarks.topology.plumbing">PlumbingStreams</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/elm327/runtime/CommandExecutor.html#binary-byte:A-int-int-">binary(byte[], int, int)</a></span> - Static method in class org.apache.edgent.samples.connectors.elm327.runtime.<a href="org/apache/edgent/samples/connectors/elm327/runtime/CommandExecutor.html" title="class in org.apache.edgent.samples.connectors.elm327.runtime">CommandExecutor</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html#blockingDelay-org.apache.edgent.topology.TStream-long-java.util.concurrent.TimeUnit-">blockingDelay(TStream<T>, long, TimeUnit)</a></span> - Static method in class org.apache.edgent.topology.plumbing.<a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html" title="class in org.apache.edgent.topology.plumbing">PlumbingStreams</a></dt> <dd> <div class="block">Insert a blocking delay between tuples.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/plumbing/PlumbingStreams.html#blockingOneShotDelay-quarks.topology.TStream-long-java.util.concurrent.TimeUnit-">blockingOneShotDelay(TStream<T>, long, TimeUnit)</a></span> - Static method in class quarks.topology.plumbing.<a href="quarks/topology/plumbing/PlumbingStreams.html" title="class in quarks.topology.plumbing">PlumbingStreams</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html#blockingOneShotDelay-org.apache.edgent.topology.TStream-long-java.util.concurrent.TimeUnit-">blockingOneShotDelay(TStream<T>, long, TimeUnit)</a></span> - Static method in class org.apache.edgent.topology.plumbing.<a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html" title="class in org.apache.edgent.topology.plumbing">PlumbingStreams</a></dt> <dd> <div class="block">Insert a blocking delay before forwarding the first tuple and no delay for subsequent tuples.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/topology/plumbing/PlumbingStreams.html#blockingThrottle-quarks.topology.TStream-long-java.util.concurrent.TimeUnit-">blockingThrottle(TStream<T>, long, TimeUnit)</a></span> - Static method in class quarks.topology.plumbing.<a href="quarks/topology/plumbing/PlumbingStreams.html" title="class in quarks.topology.plumbing">PlumbingStreams</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html#blockingThrottle-org.apache.edgent.topology.TStream-long-java.util.concurrent.TimeUnit-">blockingThrottle(TStream<T>, long, TimeUnit)</a></span> - Static method in class org.apache.edgent.topology.plumbing.<a href="org/apache/edgent/topology/plumbing/PlumbingStreams.html" title="class in org.apache.edgent.topology.plumbing">PlumbingStreams</a></dt> <dd> <div class="block">Maintain a constant blocking delay between tuples.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/kafka/PublisherApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class quarks.samples.connectors.kafka.<a href="quarks/samples/connectors/kafka/PublisherApp.html" title="class in quarks.samples.connectors.kafka">PublisherApp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/streamscope/StreamScope.BufferManager.html#BufferManager--">BufferManager()</a></span> - Constructor for class org.apache.edgent.streamscope.<a href="org/apache/edgent/streamscope/StreamScope.BufferManager.html" title="class in org.apache.edgent.streamscope">StreamScope.BufferManager</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/streamscope/StreamScope.html#bufferMgr--">bufferMgr()</a></span> - Method in class org.apache.edgent.streamscope.<a href="org/apache/edgent/streamscope/StreamScope.html" title="class in org.apache.edgent.streamscope">StreamScope</a></dt> +<dd> +<div class="block">Get the <a href="org/apache/edgent/streamscope/StreamScope.BufferManager.html" title="class in org.apache.edgent.streamscope"><code>StreamScope.BufferManager</code></a></div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/kafka/PublisherApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class org.apache.edgent.samples.connectors.kafka.<a href="org/apache/edgent/samples/connectors/kafka/PublisherApp.html" title="class in org.apache.edgent.samples.connectors.kafka">PublisherApp</a></dt> <dd> <div class="block">Create a topology for the publisher application.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/kafka/SubscriberApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class quarks.samples.connectors.kafka.<a href="quarks/samples/connectors/kafka/SubscriberApp.html" title="class in quarks.samples.connectors.kafka">SubscriberApp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/kafka/SubscriberApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class org.apache.edgent.samples.connectors.kafka.<a href="org/apache/edgent/samples/connectors/kafka/SubscriberApp.html" title="class in org.apache.edgent.samples.connectors.kafka">SubscriberApp</a></dt> <dd> <div class="block">Create a topology for the subscriber application.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/mqtt/PublisherApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class quarks.samples.connectors.mqtt.<a href="quarks/samples/connectors/mqtt/PublisherApp.html" title="class in quarks.samples.connectors.mqtt">PublisherApp</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/edgent/samples/connectors/mqtt/PublisherApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class org.apache.edgent.samples.connectors.mqtt.<a href="org/apache/edgent/samples/connectors/mqtt/PublisherApp.html" title="class in org.apache.edgent.samples.connectors.mqtt">PublisherApp</a></dt> <dd> <div class="block">Create a topology for the publisher application.</div> </dd> -<dt><span class="memberNameLink"><a href="quarks/samples/connectors/mqtt/SubscriberApp.html#buildAppTopology--">buildAppTopology()</a></span> - Method in class quarks.samples.connectors.mqtt.<a href="quarks/samples/connectors/mqtt/SubscriberApp.html" title="class in quarks
<TRUNCATED>
