You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by jm...@apache.org on 2017/06/09 18:46:24 UTC
svn commit: r1798258 [2/22] - in /samza/site: ./ archive/ community/
contribute/ img/latest/learn/documentation/introduction/
img/latest/learn/tutorials/
img/latest/learn/tutorials/hello-samza-high-level/
learn/documentation/latest/ learn/documentation...
Modified: samza/site/learn/documentation/latest/api/javadocs/index-all.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index-all.html?rev=1798258&r1=1798257&r2=1798258&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/index-all.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/index-all.html Fri Jun 9 18:46:20 2017
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_74) on Wed Feb 22 13:00:21 PST 2017 -->
-<title>Index (samza-api 0.13.0-SNAPSHOT API)</title>
-<meta name="date" content="2017-02-22">
+<!-- Generated by javadoc (1.8.0_60) on Fri Jun 09 11:41:36 PDT 2017 -->
+<title>Index (samza-api 0.13.1-SNAPSHOT API)</title>
+<meta name="date" content="2017-06-09">
<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 (samza-api 0.13.0-SNAPSHOT API)";
+ parent.document.title="Index (samza-api 0.13.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -89,10 +89,18 @@
<dd>
<div class="block">A <a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers"><code>Trigger</code></a> fires as soon as any of its individual triggers has fired.</div>
</dd>
-<dt><a href="org/apache/samza/job/ApplicationStatus.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus</span></a> - Enum in <a href="org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt>
+<dt><a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime"><span class="typeNameLink">ApplicationRunner</span></a> - Class in <a href="org/apache/samza/runtime/package-summary.html">org.apache.samza.runtime</a></dt>
+<dd>
+<div class="block">The primary means of managing execution of the <a href="org/apache/samza/application/StreamApplication.html" title="interface in org.apache.samza.application"><code>StreamApplication</code></a> at runtime.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#ApplicationRunner-org.apache.samza.config.Config-">ApplicationRunner(Config)</a></span> - Constructor for class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus</span></a> - Class in <a href="org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt>
<dd>
<div class="block">Status of a <a href="org/apache/samza/job/StreamJob.html" title="interface in org.apache.samza.job"><code>StreamJob</code></a> during and after its run.</div>
</dd>
+<dt><a href="org/apache/samza/job/ApplicationStatus.StatusCode.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus.StatusCode</span></a> - Enum in <a href="org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/FilterFunction.html#apply-M-">apply(M)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions">FilterFunction</a></dt>
<dd>
<div class="block">Returns a boolean indicating whether this message should be retained or filtered out.</div>
@@ -101,13 +109,17 @@
<dd>
<div class="block">Transforms the provided message into a collection of 0 or more messages.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/FoldLeftFunction.html#apply-M-WV-">apply(M, WV)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a></dt>
+<dd>
+<div class="block">Incrementally updates the window value as messages are added to the window.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/JoinFunction.html#apply-M-JM-">apply(M, JM)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a></dt>
<dd>
-<div class="block">Join the provided input messages and produces the joined messages.</div>
+<div class="block">Joins the provided messages and returns the joined message.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/MapFunction.html#apply-M-">apply(M)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions">MapFunction</a></dt>
<dd>
-<div class="block">Transforms the provided message into another message</div>
+<div class="block">Transforms the provided message into another message.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/SinkFunction.html#apply-M-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-">apply(M, MessageCollector, TaskCoordinator)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions">SinkFunction</a></dt>
<dd>
@@ -154,7 +166,7 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap-org.apache.samza.metrics.MetricsRegistry-org.apache.samza.util.Clock-">BlockingEnvelopeMap(MetricsRegistry, Clock)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap-org.apache.samza.metrics.MetricsRegistry-org.apache.samza.util.Clock-java.lang.String-boolean-">BlockingEnvelopeMap(MetricsRegistry, Clock, String, boolean)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#BlockingEnvelopeMap-org.apache.samza.metrics.MetricsRegistry-org.apache.samza.util.Clock-java.lang.String-">BlockingEnvelopeMap(MetricsRegistry, Clock, String)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
<dt><a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</span></a> - Class in <a href="org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt>
<dd> </dd>
@@ -219,12 +231,22 @@
<dd>
<div class="block">Mockable interface for tracking time.</div>
</dd>
+<dt><a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">ClosableFunction</span></a> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt>
+<dd>
+<div class="block">A function that can be closed after its execution.</div>
+</dd>
<dt><a href="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">ClosableTask</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
<dd>
<div class="block">A ClosableTask augments <a href="org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a>, allowing the method implementer to specify
code that will be called when the StreamTask is being shut down by the framework, providing to emit final metrics,
clean or close resources, etc.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/ContextManager.html#close--">close()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators">ContextManager</a></dt>
+<dd>
+<div class="block">Allows closing the custom context that is shared across multiple operator functions in a task.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/ClosableFunction.html#close--">close()</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueIterator.html#close--">close()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="interface in org.apache.samza.storage.kv">KeyValueIterator</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#close--">close()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt>
@@ -251,8 +273,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/container/TaskName.html#compareTo-org.apache.samza.container.TaskName-">compareTo(TaskName)</a></span> - Method in class org.apache.samza.container.<a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/LongOffset.html#compareTo-org.apache.samza.operators.data.Offset-">compareTo(Offset)</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data">LongOffset</a></dt>
-<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/Partition.html#compareTo-org.apache.samza.Partition-">compareTo(Partition)</a></span> - Method in class org.apache.samza.<a href="org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartition.html#compareTo-org.apache.samza.system.SystemStreamPartition-">compareTo(SystemStreamPartition)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a></dt>
@@ -275,6 +295,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/CommandBuilder.html#config">config</a></span> - Variable in class org.apache.samza.job.<a href="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job">CommandBuilder</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#config">config</a></span> - Variable in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt>
+<dd> </dd>
<dt><a href="org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config"><span class="typeNameLink">ConfigException</span></a> - Exception in <a href="org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
<dd>
<div class="block">Specific <a href="org/apache/samza/SamzaException.html" title="class in org.apache.samza"><code>SamzaException</code></a>s thrown from <a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><code>Config</code></a></div>
@@ -300,7 +322,7 @@
<dd> </dd>
<dt><a href="org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">ContextManager</span></a> - Interface in <a href="org/apache/samza/operators/package-summary.html">org.apache.samza.operators</a></dt>
<dd>
-<div class="block">Interface class defining methods to initialize and finalize the context used by the transformation functions.</div>
+<div class="block">Manages custom context that is shared across multiple operator functions in a task.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#copyWithPartitionCount-int-">copyWithPartitionCount(int)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
<dd>
@@ -344,18 +366,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/StreamTaskFactory.html#createInstance--">createInstance()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/StreamTaskFactory.html" title="interface in org.apache.samza.task">StreamTaskFactory</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#createInStream-org.apache.samza.operators.StreamSpec-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">createInStream(StreamSpec, Serde<K>, Serde<V>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
-<dd>
-<div class="block">Method to add an input <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> from the system</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#createIntStream-org.apache.samza.operators.StreamSpec-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">createIntStream(StreamSpec, Serde<K>, Serde<V>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
-<dd>
-<div class="block">Method to add an intermediate <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> from the system</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#createOutStream-org.apache.samza.operators.StreamSpec-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">createOutStream(StreamSpec, Serde<K>, Serde<V>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
-<dd>
-<div class="block">Method to add an output <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> from the system</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#createStream-org.apache.samza.system.StreamSpec-">createStream(StreamSpec)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system">SystemAdmin</a></dt>
<dd>
<div class="block">Create a stream described by the spec.</div>
@@ -372,8 +382,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Counter.html#dec-long-">dec(long)</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExecutionEnvironment.html#DEFAULT_ENVIRONMENT_CLASS">DEFAULT_ENVIRONMENT_CLASS</a></span> - Static variable in interface org.apache.samza.system.<a href="org/apache/samza/system/ExecutionEnvironment.html" title="interface in org.apache.samza.system">ExecutionEnvironment</a></dt>
-<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt>
<dd>
<div class="block">Deletes the mapping for the specified <code>key</code> from this key-value store (if such mapping exists).</div>
@@ -416,15 +424,15 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#entrySet--">entrySet()</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExecutionEnvironment.html#ENVIRONMENT_CONFIG">ENVIRONMENT_CONFIG</a></span> - Static variable in interface org.apache.samza.system.<a href="org/apache/samza/system/ExecutionEnvironment.html" title="interface in org.apache.samza.system">ExecutionEnvironment</a></dt>
-<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/Checkpoint.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/container/TaskName.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.container.<a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/LongOffset.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data">LongOffset</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/ApplicationStatus.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job">ApplicationStatus</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowKey.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowKey.html" title="class in org.apache.samza.operators.windows">WindowKey</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/Partition.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.<a href="org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a></dt>
<dd> </dd>
@@ -432,6 +440,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/OutgoingMessageEnvelope.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStream.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata</a></dt>
@@ -440,10 +450,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartition.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a></dt>
<dd> </dd>
-<dt><a href="org/apache/samza/system/ExecutionEnvironment.html" title="interface in org.apache.samza.system"><span class="typeNameLink">ExecutionEnvironment</span></a> - Interface in <a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt>
-<dd>
-<div class="block">Interface to be implemented by physical execution engine to deploy the config and jobs to run the <a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators"><code>StreamGraph</code></a></div>
-</dd>
<dt><a href="org/apache/samza/system/ExtendedSystemAdmin.html" title="interface in org.apache.samza.system"><span class="typeNameLink">ExtendedSystemAdmin</span></a> - Interface in <a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt>
<dd>
<div class="block">Interface extends the more generic SystemAdmin interface
@@ -459,32 +465,29 @@
<dd>
<div class="block">Invoke when the asynchronous process failed with an error.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#fetchLimitByBytesEnabled">fetchLimitByBytesEnabled</a></span> - Variable in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#filter-org.apache.samza.operators.functions.FilterFunction-">filter(FilterFunction<M>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#filter-org.apache.samza.operators.functions.FilterFunction-">filter(FilterFunction<? super M>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt>
<dd>
<div class="block">Applies the provided function to messages in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> and returns the
- transformed <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.</div>
+ filtered <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartitionMatcher.html#filter-java.util.Set-org.apache.samza.config.Config-">filter(Set<SystemStreamPartition>, Config)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionMatcher.html" title="interface in org.apache.samza.system">SystemStreamPartitionMatcher</a></dt>
<dd> </dd>
<dt><a href="org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FilterFunction</span></a><<a href="org/apache/samza/operators/functions/FilterFunction.html" title="type parameter in FilterFunction">M</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt>
<dd>
-<div class="block">A function that specifies whether a message should be retained for further processing or filtered out.</div>
+<div class="block">Specifies whether a message should be retained for further processing.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/ContextManager.html#finalizeTaskContext--">finalizeTaskContext()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators">ContextManager</a></dt>
+<dt><a href="org/apache/samza/operators/triggers/FiringType.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">FiringType</span></a> - Enum in <a href="org/apache/samza/operators/triggers/package-summary.html">org.apache.samza.operators.triggers</a></dt>
<dd>
-<div class="block">The finalize method to allow users to close resource initialized in <a href="org/apache/samza/operators/ContextManager.html#initTaskContext-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-"><code>ContextManager.initTaskContext(org.apache.samza.config.Config, org.apache.samza.task.TaskContext)</code></a> method.</div>
+<div class="block">The type of the <a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers"><code>Trigger</code></a> firing.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#flatMap-org.apache.samza.operators.functions.FlatMapFunction-">flatMap(FlatMapFunction<M, TM>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#flatMap-org.apache.samza.operators.functions.FlatMapFunction-">flatMap(FlatMapFunction<? super M, ? extends OM>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt>
<dd>
<div class="block">Applies the provided 1:n function to transform a message in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>
to n messages in the transformed <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a></div>
</dd>
<dt><a href="org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FlatMapFunction</span></a><<a href="org/apache/samza/operators/functions/FlatMapFunction.html" title="type parameter in FlatMapFunction">M</a>,<a href="org/apache/samza/operators/functions/FlatMapFunction.html" title="type parameter in FlatMapFunction">OM</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt>
<dd>
-<div class="block">A function that transforms an input message into a collection of 0 or more messages,
- possibly of a different type.</div>
+<div class="block">Transforms an input message into a collection of 0 or more messages, possibly of a different type.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#flush--">flush()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv">KeyValueStore</a></dt>
<dd>
@@ -499,13 +502,17 @@
<div class="block">If the SystemProducer buffers messages before sending them to its underlying system, it should flush those
messages and leave no messages remaining to be sent.</div>
</dd>
+<dt><a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FoldLeftFunction</span></a><<a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="type parameter in FoldLeftFunction">M</a>,<a href="org/apache/samza/operators/functions/FoldLeftFunction.html" title="type parameter in FoldLeftFunction">WV</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt>
+<dd>
+<div class="block">Incrementally updates the window value as messages are added to the window.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/Deserializer.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in interface org.apache.samza.serializers.<a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers">Deserializer</a></dt>
<dd>
<div class="block">Deserializes given serialized object from an array of bytes to its original form.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExecutionEnvironment.html#fromConfig-org.apache.samza.config.Config-">fromConfig(Config)</a></span> - Static method in interface org.apache.samza.system.<a href="org/apache/samza/system/ExecutionEnvironment.html" title="interface in org.apache.samza.system">ExecutionEnvironment</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#fromConfig-org.apache.samza.config.Config-">fromConfig(Config)</a></span> - Static method in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt>
<dd>
-<div class="block">Static method to load the non-standalone environment.</div>
+<div class="block">Static method to load the <a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime"><code>ApplicationRunner</code></a></div>
</dd>
</dl>
<a name="I:G">
@@ -522,6 +529,10 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsVisitor.html#gauge-org.apache.samza.metrics.Gauge-">gauge(Gauge<T>)</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsVisitor.html" title="class in org.apache.samza.metrics">MetricsVisitor</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ProcessorIdGenerator.html#generateProcessorId-org.apache.samza.config.Config-">generateProcessorId(Config)</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorIdGenerator.html" title="interface in org.apache.samza.runtime">ProcessorIdGenerator</a></dt>
+<dd>
+<div class="block">Generates a String representation to identify a single instance of StreamProcessor.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#get-java.lang.String-java.lang.String-">get(String, String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#get-java.lang.Object-">get(Object)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt>
@@ -532,6 +543,8 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#get-java.lang.String-">get(String)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getAccumulationMode--">getAccumulationMode()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemFactory.html#getAdmin-java.lang.String-org.apache.samza.config.Config-">getAdmin(String, Config)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.Extension.html#getAll-org.apache.samza.storage.kv.KeyValueStore-java.util.List-">getAll(KeyValueStore<K, V>, List<K>)</a></span> - Static method in class org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/KeyValueStore.Extension.html" title="class in org.apache.samza.storage.kv">KeyValueStore.Extension</a></dt>
@@ -596,6 +609,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getDouble-java.lang.String-">getDouble(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/TimeBasedTrigger.html#getDuration--">getDuration()</a></span> - Method in interface org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeBasedTrigger.html" title="interface in org.apache.samza.operators.triggers">TimeBasedTrigger</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html#getDuration--">getDuration()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html" title="class in org.apache.samza.operators.triggers">TimeSinceFirstMessageTrigger</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html#getDuration--">getDuration()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html" title="class in org.apache.samza.operators.triggers">TimeSinceLastMessageTrigger</a></dt>
@@ -606,11 +621,13 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getEventTimeExtractor--">getEventTimeExtractor()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowPane.html#getFiringType--">getFiringType()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/JoinFunction.html#getFirstKey-M-">getFirstKey(M)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a></dt>
<dd>
-<div class="block">Method to get the join key in the messages from the first input stream</div>
+<div class="block">Get the join key for messages in the first input stream.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getFoldFunction--">getFoldFunction()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getFoldLeftFunction--">getFoldLeftFunction()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsAccessor.html#getGaugeValues-java.lang.String-java.lang.String-">getGaugeValues(String, String)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsAccessor.html" title="interface in org.apache.samza.metrics">MetricsAccessor</a></dt>
<dd>
@@ -622,9 +639,11 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getId--">getId()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#getInStreams--">getInStreams()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getInitializer--">getInitializer()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#getInputStream-java.lang.String-java.util.function.BiFunction-">getInputStream(String, BiFunction<? super K, ? super V, ? extends M>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
<dd>
-<div class="block">Method to get the input <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s</div>
+<div class="block">Gets the input <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> corresponding to the <code>streamId</code>.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getInt-java.lang.String-int-">getInt(String, int)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
@@ -632,12 +651,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/StreamJobFactory.html#getJob-org.apache.samza.config.Config-">getJob(Config)</a></span> - Method in interface org.apache.samza.job.<a href="org/apache/samza/job/StreamJobFactory.html" title="interface in org.apache.samza.job">StreamJobFactory</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/InputMessageEnvelope.html#getKey--">getKey()</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data">InputMessageEnvelope</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/MessageEnvelope.html#getKey--">getKey()</a></span> - Method in interface org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a></dt>
-<dd>
-<div class="block">Get the key for this <a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>.</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowKey.html#getKey--">getKey()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowKey.html" title="class in org.apache.samza.operators.windows">WindowKey</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowPane.html#getKey--">getKey()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a></dt>
@@ -658,10 +671,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getList-java.lang.String-">getList(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExecutionEnvironment.html#getLocalEnvironment-org.apache.samza.config.Config-">getLocalEnvironment(Config)</a></span> - Static method in interface org.apache.samza.system.<a href="org/apache/samza/system/ExecutionEnvironment.html" title="interface in org.apache.samza.system">ExecutionEnvironment</a></dt>
-<dd>
-<div class="block">Static method to load the local standalone environment</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getLong-java.lang.String-long-">getLong(String, long)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getLong-java.lang.String-">getLong(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
@@ -670,16 +679,6 @@
<dd>
<div class="block">Get the maximum value in the collection</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/LongOffset.html#getMaxOffset--">getMaxOffset()</a></span> - Static method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data">LongOffset</a></dt>
-<dd>
-<div class="block">Helper method to get the maximum offset</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/InputMessageEnvelope.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data">InputMessageEnvelope</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/MessageEnvelope.html#getMessage--">getMessage()</a></span> - Method in interface org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a></dt>
-<dd>
-<div class="block">Get the message in this <a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>.</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowPane.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
@@ -698,10 +697,6 @@
<dd>
<div class="block">Get the minimum value in the collection</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/LongOffset.html#getMinOffset--">getMinOffset()</a></span> - Static method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data">LongOffset</a></dt>
-<dd>
-<div class="block">Helper method to get the minimum offset</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Counter.html#getName--">getName()</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Gauge.html#getName--">getName()</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></dt>
@@ -718,8 +713,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#getNumMessagesInQueue-org.apache.samza.system.SystemStreamPartition-">getNumMessagesInQueue(SystemStreamPartition)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/InputMessageEnvelope.html#getOffset--">getOffset()</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data">InputMessageEnvelope</a></dt>
-<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getOffset--">getOffset()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getOffset-org.apache.samza.system.SystemStreamMetadata.OffsetType-">getOffset(SystemStreamMetadata.OffsetType)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a></dt>
@@ -739,9 +732,9 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getOrDefault-java.lang.String-java.lang.String-">getOrDefault(String, String)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#getOutStreams--">getOutStreams()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#getOutputStream-java.lang.String-java.util.function.Function-java.util.function.Function-">getOutputStream(String, Function<? super M, ? extends K>, Function<? super M, ? extends V>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></dt>
<dd>
-<div class="block">Method to get the <a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>s</div>
+<div class="block">Gets the <a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a> corresponding to the <code>streamId</code>.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowKey.html#getPaneId--">getPaneId()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowKey.html" title="class in org.apache.samza.operators.windows">WindowKey</a></dt>
<dd> </dd>
@@ -757,15 +750,11 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemFactory.html#getProducer-java.lang.String-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getProducer(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemFactory.html" title="interface in org.apache.samza.system">SystemFactory</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamSpec.html#getProperties--">getProperties()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamSpec.html" title="interface in org.apache.samza.operators">StreamSpec</a></dt>
-<dd>
-<div class="block">Get the physical properties of the <a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a></div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#getSamzaContainerContext--">getSamzaContainerContext()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/JoinFunction.html#getSecondKey-JM-">getSecondKey(JM)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a></dt>
<dd>
-<div class="block">Method to get the join key in the messages from the second input stream</div>
+<div class="block">Get the join key for messages in the second input stream.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/SerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in interface org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerdeFactory.html" title="interface in org.apache.samza.serializers">SerdeFactory</a></dt>
<dd> </dd>
@@ -773,10 +762,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getShort-java.lang.String-">getShort(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/OutputStream.html#getSinkFunction--">getSinkFunction()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a></dt>
-<dd>
-<div class="block">Returns the specific <a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><code>SinkFunction</code></a> for this output stream.</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Snapshot.html#getSize--">getSize()</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Snapshot.html" title="class in org.apache.samza.metrics">Snapshot</a></dt>
<dd>
<div class="block">Get the number of values in the collection</div>
@@ -795,8 +780,10 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/StreamJob.html#getStatus--">getStatus()</a></span> - Method in interface org.apache.samza.job.<a href="org/apache/samza/job/StreamJob.html" title="interface in org.apache.samza.job">StreamJob</a></dt>
<dd>
-<div class="block">Get current <a href="org/apache/samza/job/ApplicationStatus.html" title="enum in org.apache.samza.job"><code>ApplicationStatus</code></a> of the job</div>
+<div class="block">Get current <a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job"><code>ApplicationStatus</code></a> of the job</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/ApplicationStatus.html#getStatusCode--">getStatusCode()</a></span> - Method in class org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job">ApplicationStatus</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/StorageEngineFactory.html#getStorageEngine-java.lang.String-java.io.File-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.task.MessageCollector-org.apache.samza.metrics.MetricsRegistry-org.apache.samza.system.SystemStreamPartition-org.apache.samza.container.SamzaContainerContext-">getStorageEngine(String, File, Serde<K>, Serde<V>, MessageCollector, MetricsRegistry, SystemStreamPartition, SamzaContainerContext)</a></span> - Method in interface org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage">StorageEngineFactory</a></dt>
<dd>
<div class="block">Create an instance of the given storage engine.</div>
@@ -811,14 +798,14 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.html#getStreamName--">getStreamName()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#getStreamSpec-java.lang.String-">getStreamSpec(String)</a></span> - Method in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt>
+<dd>
+<div class="block">Constructs a <a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system"><code>StreamSpec</code></a> from the configuration for the specified streamId.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStream.html#getSystem--">getSystem()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getSystemName--">getSystemName()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamSpec.html#getSystemStream--">getSystemStream()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamSpec.html" title="interface in org.apache.samza.operators">StreamSpec</a></dt>
-<dd>
-<div class="block">Get the <a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a></div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/OutgoingMessageEnvelope.html#getSystemStream--">getSystemStream()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartition.html#getSystemStream--">getSystemStream()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a></dt>
@@ -829,8 +816,6 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html#getSystemStreamMetadata-java.util.Set-">getSystemStreamMetadata(Set<String>)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html" title="class in org.apache.samza.util">SinglePartitionWithoutOffsetsSystemAdmin</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/InputMessageEnvelope.html#getSystemStreamPartition--">getSystemStreamPartition()</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data">InputMessageEnvelope</a></dt>
-<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getSystemStreamPartition--">getSystemStreamPartition()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExtendedSystemAdmin.html#getSystemStreamPartitionCounts-java.util.Set-long-">getSystemStreamPartitionCounts(Set<String>, long)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/ExtendedSystemAdmin.html" title="interface in org.apache.samza.system">ExtendedSystemAdmin</a></dt>
@@ -845,17 +830,21 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#getTaskName--">getTaskName()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/ApplicationStatus.html#getThrowable--">getThrowable()</a></span> - Method in class org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job">ApplicationStatus</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsAccessor.html#getTimerValues-java.lang.String-java.lang.String-">getTimerValues(String, String)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsAccessor.html" title="interface in org.apache.samza.metrics">MetricsAccessor</a></dt>
<dd>
<div class="block">Get the values of a timer</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/RepeatingTrigger.html#getTrigger--">getTrigger()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/RepeatingTrigger.html" title="class in org.apache.samza.operators.triggers">RepeatingTrigger</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/AnyTrigger.html#getTriggers--">getTriggers()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/AnyTrigger.html" title="class in org.apache.samza.operators.triggers">AnyTrigger</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getUpcomingOffset--">getUpcomingOffset()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#getUserDefinedContext--">getUserDefinedContext()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#getUserContext--">getUserContext()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/TaskContext.html" title="interface in org.apache.samza.task">TaskContext</a></dt>
<dd>
-<div class="block">Method to allow user to return customized context</div>
+<div class="block">Gets the user-defined context.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Gauge.html#getValue--">getValue()</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Gauge.html" title="class in org.apache.samza.metrics">Gauge</a></dt>
<dd> </dd>
@@ -869,14 +858,8 @@
<dd>
<div class="block">Return the entire list of values</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#globalWindow-java.util.function.BiFunction-">globalWindow(BiFunction<M, WV, WV>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
-<dd>
-<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into a single global window.</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#globalWindow--">globalWindow()</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
-<dd>
-<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into a single global window.</div>
-</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getWindowType--">getWindowType()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html#group-java.util.Set-">group(Set<SystemStreamPartition>)</a></span> - Method in interface org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.html" title="interface in org.apache.samza.container.grouper.stream">SystemStreamPartitionGrouper</a></dt>
<dd> </dd>
</dl>
@@ -893,7 +876,9 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/container/TaskName.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.container.<a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/LongOffset.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data">LongOffset</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/ApplicationStatus.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job">ApplicationStatus</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowKey.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowKey.html" title="class in org.apache.samza.operators.windows">WindowKey</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/Partition.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.<a href="org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a></dt>
<dd> </dd>
@@ -901,6 +886,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/OutgoingMessageEnvelope.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/OutgoingMessageEnvelope.html" title="class in org.apache.samza.system">OutgoingMessageEnvelope</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/StreamSpec.html" title="class in org.apache.samza.system">StreamSpec</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStream.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata</a></dt>
@@ -944,18 +931,21 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#incPoll--">incPoll()</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/application/StreamApplication.html#init-org.apache.samza.operators.StreamGraph-org.apache.samza.config.Config-">init(StreamGraph, Config)</a></span> - Method in interface org.apache.samza.application.<a href="org/apache/samza/application/StreamApplication.html" title="interface in org.apache.samza.application">StreamApplication</a></dt>
+<dd>
+<div class="block">Describes and initializes the transforms for processing message streams and generating results.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsValidator.html#init-org.apache.samza.config.Config-">init(Config)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsValidator.html" title="interface in org.apache.samza.metrics">MetricsValidator</a></dt>
<dd>
<div class="block">Initialize with config.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init(Config, TaskContext)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/ContextManager.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init(Config, TaskContext)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators">ContextManager</a></dt>
<dd>
-<div class="block">Interface method to initialize the context for a specific message transformation function.</div>
+<div class="block">Allows initializing and setting a custom context that is shared across multiple operator functions in a task.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraphBuilder.html#init-org.apache.samza.operators.StreamGraph-org.apache.samza.config.Config-">init(StreamGraph, Config)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/StreamGraphBuilder.html" title="interface in org.apache.samza.operators">StreamGraphBuilder</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init(Config, TaskContext)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dt>
<dd>
-<div class="block">Users are required to implement this abstract method to initialize the processing logic of the application, in terms
- of a DAG of <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and operators</div>
+<div class="block">Initializes the function before any messages are processed.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/InitableTask.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init(Config, TaskContext)</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task">InitableTask</a></dt>
<dd>
@@ -963,7 +953,7 @@
</dd>
<dt><a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">InitableFunction</span></a> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt>
<dd>
-<div class="block">interface defined to initalize the context of message transformation functions</div>
+<div class="block">A function that can be initialized before execution.</div>
</dd>
<dt><a href="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">InitableTask</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
<dd>
@@ -972,19 +962,6 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#initMetrics-org.apache.samza.system.SystemStreamPartition-">initMetrics(SystemStreamPartition)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/ContextManager.html#initTaskContext-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">initTaskContext(Config, TaskContext)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators">ContextManager</a></dt>
-<dd>
-<div class="block">The initialization method to create shared context for the whole task in Samza.</div>
-</dd>
-<dt><a href="org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data"><span class="typeNameLink">InputMessageEnvelope</span></a> - Class in <a href="org/apache/samza/operators/data/package-summary.html">org.apache.samza.operators.data</a></dt>
-<dd>
-<div class="block">A <a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> that provides additional information about its input <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>
- and its <a href="org/apache/samza/operators/data/Offset.html" title="interface in org.apache.samza.operators.data"><code>Offset</code></a> within the <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>.</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/InputMessageEnvelope.html#InputMessageEnvelope-org.apache.samza.system.IncomingMessageEnvelope-">InputMessageEnvelope(IncomingMessageEnvelope)</a></span> - Constructor for class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data">InputMessageEnvelope</a></dt>
-<dd>
-<div class="block">Creates an <code>InputMessageEnvelope</code> from the <a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><code>IncomingMessageEnvelope</code></a>.</div>
-</dd>
<dt><a href="org/apache/samza/annotation/InterfaceStability.html" title="class in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability</span></a> - Class in <a href="org/apache/samza/annotation/package-summary.html">org.apache.samza.annotation</a></dt>
<dd>
<div class="block">Annotation to inform users of how much to rely on a particular package,
@@ -1008,10 +985,6 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#isAtHead-org.apache.samza.system.SystemStreamPartition-">isAtHead(SystemStreamPartition)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/MessageEnvelope.html#isDelete--">isDelete()</a></span> - Method in interface org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a></dt>
-<dd>
-<div class="block">Whether this <a href="org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> indicates deletion of a previous message with this key.</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#isEmpty--">isEmpty()</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#isEndOfStream--">isEndOfStream()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
@@ -1030,14 +1003,14 @@
</a>
<h2 class="title">J</h2>
<dl>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-">join(MessageStream<OM>, JoinFunction<K, M, OM, RM>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-java.time.Duration-">join(MessageStream<JM>, JoinFunction<? extends K, ? super M, ? super JM, ? extends OM>, Duration)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt>
<dd>
-<div class="block">Joins this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with another <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> using the provided pairwise <a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>JoinFunction</code></a>.</div>
+<div class="block">Joins this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with another <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> using the provided
+ pairwise <a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>JoinFunction</code></a>.</div>
</dd>
<dt><a href="org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">JoinFunction</span></a><<a href="org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">K</a>,<a href="org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">M</a>,<a href="org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">JM</a>,<a href="org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">RM</a>> - Interface in <a href="org/apache/samza/operators/functions/package-summary.html">org.apache.samza.operators.functions</a></dt>
<dd>
-<div class="block">A function that joins messages from two <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and produces
- a joined message.</div>
+<div class="block">Joins incoming messages in two streams by key.</div>
</dd>
</dl>
<a name="I:K">
@@ -1045,29 +1018,22 @@
</a>
<h2 class="title">K</h2>
<dl>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedGlobalWindow-java.util.function.Function-java.util.function.BiFunction-">keyedGlobalWindow(Function<M, K>, BiFunction<M, WV, WV>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
-<dd>
-<div class="block">Returns a global <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages using the provided keyFn.</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedGlobalWindow-java.util.function.Function-">keyedGlobalWindow(Function<M, K>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
-<dd>
-<div class="block">Returns a global <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages using the provided keyFn.</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-java.util.function.BiFunction-">keyedSessionWindow(Function<M, K>, Duration, BiFunction<M, WV, WV>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">keyedSessionWindow(Function<? super M, ? extends K>, Duration, Supplier<? extends WV>, FoldLeftFunction<? super M, WV>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
<dd>
-<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided <code>sessionGap</code>
- and applies the provided fold function to them.</div>
+<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided
+ <code>sessionGap</code> and applies the provided fold function to them.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-">keyedSessionWindow(Function<M, K>, Duration)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-">keyedSessionWindow(Function<? super M, ? extends K>, Duration)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
<dd>
-<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided <code>sessionGap</code>.</div>
+<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided
+ <code>sessionGap</code>.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-java.util.function.BiFunction-">keyedTumblingWindow(Function<M, K>, Duration, BiFunction<M, WV, WV>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">keyedTumblingWindow(Function<? super M, ? extends K>, Duration, Supplier<? extends WV>, FoldLeftFunction<? super M, WV>)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
<dd>
<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping processing
time based windows based on the provided keyFn and applies the provided fold function to them.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-">keyedTumblingWindow(Function<M, K>, Duration)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-">keyedTumblingWindow(Function<? super M, ? extends K>, Duration)</a></span> - Static method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/Windows.html" title="class in org.apache.samza.operators.windows">Windows</a></dt>
<dd>
<div class="block">Creates a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping
processing time based windows using the provided keyFn.</div>
@@ -1088,6 +1054,11 @@
<dd>
<div class="block">Kill this job immediately.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#kill-org.apache.samza.application.StreamApplication-">kill(StreamApplication)</a></span> - Method in class org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime">ApplicationRunner</a></dt>
+<dd>
+<div class="block">Kill the Samza jobs represented by <a href="org/apache/samza/application/StreamApplication.html" title="interface in org.apache.samza.application"><code>StreamApplication</code></a>
+ It is non-blocking so it doesn't wait for the application stopping.</div>
+</dd>
</dl>
<a name="I:L">
<!-- -->
@@ -1096,19 +1067,13 @@
<dl>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/ReadableMetricsRegistry.html#listen-org.apache.samza.metrics.ReadableMetricsRegistryListener-">listen(ReadableMetricsRegistryListener)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/ReadableMetricsRegistry.html" title="interface in org.apache.samza.metrics">ReadableMetricsRegistry</a></dt>
<dd> </dd>
-<dt><a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data"><span class="typeNameLink">LongOffset</span></a> - Class in <a href="org/apache/samza/operators/data/package-summary.html">org.apache.samza.operators.data</a></dt>
-<dd>
-<div class="block">An implementation of <a href="org/apache/samza/operators/data/Offset.html" title="interface in org.apache.samza.operators.data"><code>Offset</code></a>, w/ <code>long</code> value as the offset</div>
-</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/operators/data/LongOffset.html#LongOffset-java.lang.String-">LongOffset(String)</a></span> - Constructor for class org.apache.samza.operators.data.<a href="org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data">LongOffset</a></dt>
-<dd> </dd>
</dl>
<a name="I:M">
<!-- -->
</a>
<h2 class="title">M</h2>
<dl>
[... 414 lines stripped ...]