You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2017/02/22 21:01:24 UTC
svn commit: r1784062 [2/17] - in /samza/site: ./ archive/ community/
contribute/ learn/documentation/latest/ learn/documentation/latest/api/
learn/documentation/latest/api/javadocs/
learn/documentation/latest/api/javadocs/org/apache/samza/ learn/docume...
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=1784062&r1=1784061&r2=1784062&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/index-all.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/index-all.html Wed Feb 22 21:01:21 2017
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_40) on Wed Oct 19 10:25:20 PDT 2016 -->
-<title>Index (samza-api 0.11.1-SNAPSHOT API)</title>
-<meta name="date" content="2016-10-19">
+<!-- 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">
<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.11.1-SNAPSHOT API)";
+ parent.document.title="Index (samza-api 0.13.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -68,23 +68,60 @@
<!-- -->
</a></div>
<!-- ========= END OF TOP NAVBAR ========= -->
-<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: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: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 name="I:A">
+<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: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 name="I:A">
<!-- -->
</a>
<h2 class="title">A</h2>
<dl>
+<dt><a href="org/apache/samza/operators/windows/AccumulationMode.html" title="enum in org.apache.samza.operators.windows"><span class="typeNameLink">AccumulationMode</span></a> - Enum in <a href="org/apache/samza/operators/windows/package-summary.html">org.apache.samza.operators.windows</a></dt>
+<dd>
+<div class="block">Specifies how a <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> should process its previously emitted <a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a>s.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#all--">all()</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">Returns an iterator for all entries in this key-value store.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/Triggers.html#any-org.apache.samza.operators.triggers.Trigger...-">any(Trigger<M>...)</a></span> - Static method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Triggers.html" title="class in org.apache.samza.operators.triggers">Triggers</a></dt>
+<dd>
+<div class="block">Creates a trigger that fires when any of the provided triggers fire.</div>
+</dd>
+<dt><a href="org/apache/samza/operators/triggers/AnyTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">AnyTrigger</span></a><<a href="org/apache/samza/operators/triggers/AnyTrigger.html" title="type parameter in AnyTrigger">M</a>> - Class in <a href="org/apache/samza/operators/triggers/package-summary.html">org.apache.samza.operators.triggers</a></dt>
+<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>
<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><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>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/FlatMapFunction.html#apply-M-">apply(M)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions">FlatMapFunction</a></dt>
+<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/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>
+</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>
+</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>
+<div class="block">Allows sending the provided message to an output <a href="org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> using
+ the provided <a href="org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a>.</div>
+</dd>
<dt><a href="org/apache/samza/task/AsyncStreamTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">AsyncStreamTask</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
<dd>
<div class="block">An AsyncStreamTask is the basic class to support multithreading execution in Samza container.</div>
</dd>
+<dt><a href="org/apache/samza/task/AsyncStreamTaskFactory.html" title="interface in org.apache.samza.task"><span class="typeNameLink">AsyncStreamTaskFactory</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
+<dd>
+<div class="block">Build <a href="org/apache/samza/task/AsyncStreamTask.html" title="interface in org.apache.samza.task"><code>AsyncStreamTask</code></a> instances.</div>
+</dd>
</dl>
<a name="I:B">
<!-- -->
@@ -155,6 +192,11 @@
<dd>
<div class="block">Constructs a new checkpoint based off a map of Samza stream offsets.</div>
</dd>
+<dt><a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint"><span class="typeNameLink">CheckpointListener</span></a> - Interface in <a href="org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt>
+<dd>
+<div class="block">This interface should be implemented by SystemConsumers which want to be notified about checkpoint values
+ of the most recent checkpoint.</div>
+</dd>
<dt><a href="org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint"><span class="typeNameLink">CheckpointManager</span></a> - Interface in <a href="org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt>
<dd>
<div class="block">CheckpointManagers read and write <a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><code>Checkpoint</code></a> to some
@@ -209,6 +251,8 @@
<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>
@@ -254,6 +298,19 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#containsValue-java.lang.Object-">containsValue(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><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>
+</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>
+<div class="block">Copies this StreamSpec, but applies a new partitionCount.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/Triggers.html#count-long-">count(long)</a></span> - Static method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/Triggers.html" title="class in org.apache.samza.operators.triggers">Triggers</a></dt>
+<dd>
+<div class="block">Creates a <a href="org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers"><code>Trigger</code></a> that fires when the number of messages in the pane
+ reaches the specified count.</div>
+</dd>
<dt><a href="org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics"><span class="typeNameLink">Counter</span></a> - Class in <a href="org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt>
<dd>
<div class="block">A counter is a <a href="org/apache/samza/metrics/Metric.html" title="interface in org.apache.samza.metrics"><code>Metric</code></a> that represents a cumulative value.</div>
@@ -262,18 +319,47 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsVisitor.html#counter-org.apache.samza.metrics.Counter-">counter(Counter)</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><a href="org/apache/samza/operators/triggers/CountTrigger.html" title="class in org.apache.samza.operators.triggers"><span class="typeNameLink">CountTrigger</span></a><<a href="org/apache/samza/operators/triggers/CountTrigger.html" title="type parameter in CountTrigger">M</a>> - Class in <a href="org/apache/samza/operators/triggers/package-summary.html">org.apache.samza.operators.triggers</a></dt>
+<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> that fires when the number of messages in the <a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a>
+ reaches the specified count.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#createChangelogStream-java.lang.String-int-">createChangelogStream(String, int)</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">An API to create a change log stream</div>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span>
+<div class="block"><span class="deprecationComment">since 0.12.1, use <a href="org/apache/samza/system/SystemAdmin.html#createStream-org.apache.samza.system.StreamSpec-"><code>SystemAdmin.createStream(StreamSpec)</code></a></span></div>
+</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html#createChangelogStream-java.lang.String-int-">createChangelogStream(String, int)</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/system/SystemAdmin.html#createCoordinatorStream-java.lang.String-">createCoordinatorStream(String)</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 for the job coordinator.</div>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span>
+<div class="block"><span class="deprecationComment">since 0.12.1, use <a href="org/apache/samza/system/SystemAdmin.html#createStream-org.apache.samza.system.StreamSpec-"><code>SystemAdmin.createStream(StreamSpec)</code></a></span></div>
+</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.html#createCoordinatorStream-java.lang.String-">createCoordinatorStream(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/task/AsyncStreamTaskFactory.html#createInstance--">createInstance()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/AsyncStreamTaskFactory.html" title="interface in org.apache.samza.task">AsyncStreamTaskFactory</a></dt>
+<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>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/Clock.html#currentTimeMillis--">currentTimeMillis()</a></span> - Method in interface org.apache.samza.util.<a href="org/apache/samza/util/Clock.html" title="interface in org.apache.samza.util">Clock</a></dt>
<dd> </dd>
</dl>
@@ -286,6 +372,8 @@
<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>
@@ -303,6 +391,10 @@
<div class="block">A standard interface for Samza compatible deserializers, used for deserializing serialized objects back to their
original form.</div>
</dd>
+<dt><a href="org/apache/samza/operators/triggers/DurationCharacteristic.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">DurationCharacteristic</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">Indicates whether the associated time duration is in event time or processing time.</div>
+</dd>
</dl>
<a name="I:E">
<!-- -->
@@ -324,12 +416,16 @@
<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>
+<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>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#equals-java.lang.Object-">equals(Object)</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>
@@ -344,6 +440,10 @@
<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
@@ -361,8 +461,31 @@
</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>
+<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>
+</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>
+</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>
+<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>
+</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>
+<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>
+</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>
<div class="block">Flushes this key-value store, if applicable.</div>
@@ -380,6 +503,10 @@
<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>
+<dd>
+<div class="block">Static method to load the non-standalone environment.</div>
+</dd>
</dl>
<a name="I:G">
<!-- -->
@@ -403,6 +530,8 @@
<dd>
<div class="block">Gets the value associated with the specified <code>key</code>.</div>
</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/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>
@@ -421,6 +550,12 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getBoolean-java.lang.String-">getBoolean(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/TimeSinceFirstMessageTrigger.html#getCharacteristic--">getCharacteristic()</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#getCharacteristic--">getCharacteristic()</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>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/TimeTrigger.html#getCharacteristic--">getCharacteristic()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeTrigger.html" title="class in org.apache.samza.operators.triggers">TimeTrigger</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManagerFactory.html#getCheckpointManager-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getCheckpointManager(Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointManagerFactory.html" title="interface in org.apache.samza.checkpoint">CheckpointManagerFactory</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/chooser/MessageChooserFactory.html#getChooser-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getChooser(Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/MessageChooserFactory.html" title="interface in org.apache.samza.system.chooser">MessageChooserFactory</a></dt>
@@ -431,10 +566,14 @@
<dd>
<div class="block">Build a specific Config.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getConfig--">getConfig()</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/SystemFactory.html#getConsumer-java.lang.String-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getConsumer(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/metrics/Counter.html#getCount--">getCount()</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/operators/triggers/CountTrigger.html#getCount--">getCount()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/CountTrigger.html" title="class in org.apache.samza.operators.triggers">CountTrigger</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsAccessor.html#getCounterValues-java.lang.String-java.lang.String-">getCounterValues(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 counter</div>
@@ -451,10 +590,28 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getDate-java.lang.String-java.text.SimpleDateFormat-java.util.Date-">getDate(String, SimpleDateFormat, Date)</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/windows/internal/WindowInternal.html#getDefaultTrigger--">getDefaultTrigger()</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/config/Config.html#getDouble-java.lang.String-double-">getDouble(String, double)</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#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/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>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/triggers/TimeTrigger.html#getDuration--">getDuration()</a></span> - Method in class org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/TimeTrigger.html" title="class in org.apache.samza.operators.triggers">TimeTrigger</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getEarlyTrigger--">getEarlyTrigger()</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/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/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>
+</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>
+<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>
<div class="block">Get the values of a gauge</div>
@@ -463,24 +620,48 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/ReadableMetricsRegistry.html#getGroups--">getGroups()</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><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>
+<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>
+</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>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getInt-java.lang.String-">getInt(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/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>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/Entry.html#getKey--">getKey()</a></span> - Method in class org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/Entry.html" title="class in org.apache.samza.storage.kv">Entry</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getKey--">getKey()</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/OutgoingMessageEnvelope.html#getKey--">getKey()</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/operators/windows/internal/WindowInternal.html#getKeyExtractor--">getKeyExtractor()</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/OutgoingMessageEnvelope.html#getKeySerializerName--">getKeySerializerName()</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/operators/windows/internal/WindowInternal.html#getLateTrigger--">getLateTrigger()</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/config/Config.html#getList-java.lang.String-java.util.List-">getList(String, List<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/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>
@@ -489,6 +670,18 @@
<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>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/OutgoingMessageEnvelope.html#getMessage--">getMessage()</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>
@@ -505,6 +698,10 @@
<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>
@@ -521,6 +718,8 @@
<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>
@@ -538,22 +737,46 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getOldestOffset--">getOldestOffset()</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/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>
+<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>
+</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>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartition.html#getPartition--">getPartition()</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><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#getPartitionCount--">getPartitionCount()</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/Partition.html#getPartitionId--">getPartitionId()</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/OutgoingMessageEnvelope.html#getPartitionKey--">getPartitionKey()</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#getPhysicalName--">getPhysicalName()</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/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>
+</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>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getShort-java.lang.String-short-">getShort(String, short)</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#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>
@@ -590,6 +813,12 @@
<dd> </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>
@@ -600,6 +829,8 @@
</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>
@@ -618,8 +849,14 @@
<dd>
<div class="block">Get the values of a timer</div>
</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>
+<dd>
+<div class="block">Method to allow user to return customized 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>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/Entry.html#getValue--">getValue()</a></span> - Method in class org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/Entry.html" title="class in org.apache.samza.storage.kv">Entry</a></dt>
@@ -632,6 +869,14 @@
<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/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>
@@ -648,6 +893,8 @@
<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>
+<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>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#hashCode--">hashCode()</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>
@@ -701,10 +948,23 @@
<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>
+<dd>
+<div class="block">Interface method to initialize the context for a specific message transformation function.</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>
+<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>
+</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>
<div class="block">Called by TaskRunner each time an implementing task is created.</div>
</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>
+</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>
<div class="block">Used as an interface for user processing StreamTasks that need to have specific functionality performed as their StreamTasks
@@ -712,8 +972,46 @@
</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,
+ class or method not changing over time.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/annotation/InterfaceStability.html#InterfaceStability--">InterfaceStability()</a></span> - Constructor for class org.apache.samza.annotation.<a href="org/apache/samza/annotation/InterfaceStability.html" title="class in org.apache.samza.annotation">InterfaceStability</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Evolving</span></a> - Annotation Type in <a href="org/apache/samza/annotation/package-summary.html">org.apache.samza.annotation</a></dt>
+<dd>
+<div class="block">Evolving, but can break compatibility at minor release (i.e.</div>
+</dd>
+<dt><a href="org/apache/samza/annotation/InterfaceStability.Stable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Stable</span></a> - Annotation Type in <a href="org/apache/samza/annotation/package-summary.html">org.apache.samza.annotation</a></dt>
+<dd>
+<div class="block">Can evolve while retaining compatibility for minor release boundaries.;
+ can break compatibility only at major release (ie.</div>
+</dd>
+<dt><a href="org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Unstable</span></a> - Annotation Type in <a href="org/apache/samza/annotation/package-summary.html">org.apache.samza.annotation</a></dt>
+<dd>
+<div class="block">No guarantee is provided as to reliability or stability across any
+ level of release granularity.</div>
+</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>
@@ -727,11 +1025,53 @@
<div class="block">Flag to indicate whether a store can be persisted to disk or not</div>
</dd>
</dl>
+<a name="I:J">
+<!-- -->
+</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>
+<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>
+</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>
+</dd>
+</dl>
<a name="I:K">
<!-- -->
</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>
+<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>
+</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>
+<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>
+</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>
+<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>
+<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>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#keySet--">keySet()</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><a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueIterator</span></a><<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="type parameter in KeyValueIterator">K</a>,<a href="org/apache/samza/storage/kv/KeyValueIterator.html" title="type parameter in KeyValueIterator">V</a>> - Interface in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt>
@@ -756,12 +1096,23 @@
<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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#map-org.apache.samza.operators.functions.MapFunction-">map(MapFunction<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>
+<dd>
+<div class="block">Applies the provided 1:1 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>
+</dd>
<dt><a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config"><span class="typeNameLink">MapConfig</span></a> - Class in <a href="org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
<dd>
<div class="block">A <a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><code>Config</code></a> backed by a Java <code>Map</code></div>
@@ -772,6 +1123,14 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#MapConfig-java.util.List-">MapConfig(List<Map<String, String>>)</a></span> - Constructor for 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><a href="org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">MapFunction</span></a><<a href="org/apache/samza/operators/functions/MapFunction.html" title="type parameter in MapFunction">M</a>,<a href="org/apache/samza/operators/functions/MapFunction.html" title="type parameter in MapFunction">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 another message, possibly of a different type.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#merge-java.util.Collection-">merge(Collection<MessageStream<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">Merge all <code>otherStreams</code> with this <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/system/chooser/MessageChooser.html" title="interface in org.apache.samza.system.chooser"><span class="typeNameLink">MessageChooser</span></a> - Interface in <a href="org/apache/samza/system/chooser/package-summary.html">org.apache.samza.system.chooser</a></dt>
<dd>
<div class="block">MessageChooser is an interface for programmatic fine-grain control over
@@ -785,6 +1144,14 @@
<dd>
<div class="block">Used as an interface for the means of sending message envelopes to an output stream.</div>
</dd>
[... 374 lines stripped ...]