You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2018/01/04 00:31:43 UTC
svn commit: r1820026 [3/24] - in /samza/site: ./
img/latest/learn/documentation/hadoop/ img/latest/learn/documentation/rest/
learn/documentation/latest/ learn/documentation/latest/api/
learn/documentation/latest/api/javadocs/ learn/documentation/latest...
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=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/index-all.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/index-all.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>Index (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Index (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.1-SNAPSHOT API)";
+ parent.document.title="Index (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -126,6 +126,10 @@
<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><span class="memberNameLink"><a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html#apply-M-R-">apply(M, R)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions">StreamTableJoinFunction</a></dt>
+<dd>
+<div class="block">Joins the provided messages and table record, returns the joined message.</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>
@@ -186,10 +190,32 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#buildEndOfStreamEnvelope-org.apache.samza.system.SystemStreamPartition-">buildEndOfStreamEnvelope(SystemStreamPartition)</a></span> - Static 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>
-<div class="block">Builds an end-of-stream envelope for an SSP.</div>
+<div class="block">This method is deprecated in favor of WatermarkManager.buildEndOfStreamEnvelope(SystemStreamPartition ssp).</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/CommandBuilder.html#buildEnvironment--">buildEnvironment()</a></span> - Method 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/system/IncomingMessageEnvelope.html#buildWatermarkEnvelope-org.apache.samza.system.SystemStreamPartition-long-">buildWatermarkEnvelope(SystemStreamPartition, long)</a></span> - Static 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><a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerde</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd>
+<div class="block">A serializer for ByteBuffers.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteBufferSerde.html#ByteBufferSerde--">ByteBufferSerde()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers">ByteBufferSerde</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/serializers/ByteBufferSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerdeFactory</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteBufferSerdeFactory.html#ByteBufferSerdeFactory--">ByteBufferSerdeFactory()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerdeFactory.html" title="class in org.apache.samza.serializers">ByteBufferSerdeFactory</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/serializers/ByteSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteSerde</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd>
+<div class="block">A serializer for bytes that is effectively a pass-through, but can be useful for binary messages.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteSerde.html#ByteSerde--">ByteSerde()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteSerde.html" title="class in org.apache.samza.serializers">ByteSerde</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/serializers/ByteSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteSerdeFactory</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteSerdeFactory.html#ByteSerdeFactory--">ByteSerdeFactory()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteSerdeFactory.html" title="class in org.apache.samza.serializers">ByteSerdeFactory</a></dt>
+<dd> </dd>
</dl>
<a name="I:C">
<!-- -->
@@ -227,6 +253,14 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Counter.html#clear--">clear()</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/checkpoint/CheckpointManager.html#clearCheckpoints--">clearCheckpoints()</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointManager.html" title="interface in org.apache.samza.checkpoint">CheckpointManager</a></dt>
+<dd>
+<div class="block">Clear the checkpoints in the checkpoint stream.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#clearStream-org.apache.samza.system.StreamSpec-">clearStream(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">Clear the stream described by the spec.</div>
+</dd>
<dt><a href="org/apache/samza/util/Clock.html" title="interface in org.apache.samza.util"><span class="typeNameLink">Clock</span></a> - Interface in <a href="org/apache/samza/util/package-summary.html">org.apache.samza.util</a></dt>
<dd>
<div class="block">Mockable interface for tracking time.</div>
@@ -235,6 +269,10 @@
<dd>
<div class="block">A function that can be closed after its execution.</div>
</dd>
+<dt><a href="org/apache/samza/storage/kv/ClosableIterator.html" title="interface in org.apache.samza.storage.kv"><span class="typeNameLink">ClosableIterator</span></a><<a href="org/apache/samza/storage/kv/ClosableIterator.html" title="type parameter in ClosableIterator">V</a>> - Interface in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt>
+<dd>
+<div class="block">An iterator that must be closed.</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
@@ -247,12 +285,20 @@
</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/ClosableIterator.html#close--">close()</a></span> - Method in interface org.apache.samza.storage.kv.<a href="org/apache/samza/storage/kv/ClosableIterator.html" title="interface in org.apache.samza.storage.kv">ClosableIterator</a></dt>
+<dd>
+<div class="block">Closes this iterator and frees resources assigned to it.</div>
+</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>
<dd>
<div class="block">Closes this key-value store, if applicable, relinquishing any underlying resources.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#close--">close()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadableTable.html" title="interface in org.apache.samza.table">ReadableTable</a></dt>
+<dd>
+<div class="block">Close the table and release any resources acquired</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/ClosableTask.html#close--">close()</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task">ClosableTask</a></dt>
<dd> </dd>
<dt><a href="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job"><span class="typeNameLink">CommandBuilder</span></a> - Class in <a href="org/apache/samza/job/package-summary.html">org.apache.samza.job</a></dt>
@@ -324,10 +370,20 @@
<dd>
<div class="block">Manages custom context that is shared across multiple operator functions in a task.</div>
</dd>
+<dt><a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">ControlMessage</span></a> - Class in <a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt>
+<dd>
+<div class="block">The abstract class of all control messages, containing
+ the task that produces the control message, the total number of producer tasks,
+ and a version number.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/ControlMessage.html#ControlMessage-java.lang.String-">ControlMessage(String)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></dt>
+<dd> </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/system/StreamSpec.html#copyWithPhysicalName-java.lang.String-">copyWithPhysicalName(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/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
@@ -346,21 +402,11 @@
<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"><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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#createChangeLogStreamSpec-java.lang.String-java.lang.String-int-">createChangeLogStreamSpec(String, String, int)</a></span> - Static 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/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"><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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/StreamSpec.html#createCheckpointStreamSpec-java.lang.String-java.lang.String-">createCheckpointStreamSpec(String, String)</a></span> - Static 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/StreamSpec.html#createCoordinatorStreamSpec-java.lang.String-java.lang.String-">createCoordinatorStreamSpec(String, String)</a></span> - Static 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/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>
@@ -386,19 +432,33 @@
<dd>
<div class="block">Deletes the mapping for the specified <code>key</code> from this key-value store (if such mapping exists).</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt>
+<dd>
+<div class="block">Deletes the mapping for the specified <code>key</code> from this table (if such mapping exists).</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#deleteAll-java.util.List-">deleteAll(List<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 mappings for the specified <code>keys</code> from this key-value store (if such mappings exist).</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.Extension.html#deleteAll-org.apache.samza.storage.kv.KeyValueStore-java.util.List-">deleteAll(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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#deleteAll-java.util.List-">deleteAll(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt>
<dd>
-<div class="block">Deletes the mappings for the specified <code>keys</code> from this key-value store (if such mappings exist).</div>
+<div class="block">Deletes the mappings for the specified <code>keys</code> from this table.</div>
</dd>
<dt><a href="org/apache/samza/serializers/Deserializer.html" title="interface in org.apache.samza.serializers"><span class="typeNameLink">Deserializer</span></a><<a href="org/apache/samza/serializers/Deserializer.html" title="type parameter in Deserializer">T</a>> - Interface in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
<dd>
<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/serializers/DoubleSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">DoubleSerde</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd>
+<div class="block">A serializer for doubles</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/DoubleSerde.html#DoubleSerde--">DoubleSerde()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/DoubleSerde.html" title="class in org.apache.samza.serializers">DoubleSerde</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/serializers/DoubleSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">DoubleSerdeFactory</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/DoubleSerdeFactory.html#DoubleSerdeFactory--">DoubleSerdeFactory()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/DoubleSerdeFactory.html" title="class in org.apache.samza.serializers">DoubleSerdeFactory</a></dt>
+<dd> </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>
@@ -416,6 +476,15 @@
<div class="block">The EndOfStreamListenerTask augments <a href="org/apache/samza/task/StreamTask.html" title="interface in org.apache.samza.task"><code>StreamTask</code></a> allowing the method implementor to specify code to be
executed when the 'end-of-stream' is reached for all input SSPs.</div>
</dd>
+<dt><a href="org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">EndOfStreamMessage</span></a> - Class in <a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt>
+<dd>
+<div class="block">The EndOfStreamMessage is a control message that is sent out to next stage
+ once the task has consumed to the end of a bounded stream.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/EndOfStreamMessage.html#EndOfStreamMessage--">EndOfStreamMessage()</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system">EndOfStreamMessage</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/EndOfStreamMessage.html#EndOfStreamMessage-java.lang.String-">EndOfStreamMessage(String)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system">EndOfStreamMessage</a></dt>
+<dd> </dd>
<dt><a href="org/apache/samza/storage/kv/Entry.html" title="class in org.apache.samza.storage.kv"><span class="typeNameLink">Entry</span></a><<a href="org/apache/samza/storage/kv/Entry.html" title="type parameter in Entry">K</a>,<a href="org/apache/samza/storage/kv/Entry.html" title="type parameter in Entry">V</a>> - Class in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt>
<dd>
<div class="block">A key and value.</div>
@@ -436,6 +505,8 @@
<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/ControlMessage.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</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>
<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>
@@ -450,6 +521,14 @@
<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><span class="memberNameLink"><a href="org/apache/samza/system/WatermarkMessage.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system">WatermarkMessage</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableSpec.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/udfs/ScalarUdf.html#execute-java.lang.Object...-">execute(Object...)</a></span> - Method in interface org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs">ScalarUdf</a></dt>
+<dd>
+<div class="block">Actual implementation of the udf function</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
@@ -502,14 +581,40 @@
<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><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#flush--">flush()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt>
+<dd>
+<div class="block">Flushes the underlying store of this table, if applicable.</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/ByteBufferSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers">ByteBufferSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteSerde.html" title="class in org.apache.samza.serializers">ByteSerde</a></dt>
+<dd> </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/serializers/DoubleSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/DoubleSerde.html" title="class in org.apache.samza.serializers">DoubleSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/IntegerSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerde.html" title="class in org.apache.samza.serializers">IntegerSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/JsonSerdeV2.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2.html" title="class in org.apache.samza.serializers">JsonSerdeV2</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/KVSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">KVSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/LongSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/LongSerde.html" title="class in org.apache.samza.serializers">LongSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/NoOpSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/NoOpSerde.html" title="class in org.apache.samza.serializers">NoOpSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/SerializableSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerializableSerde.html" title="class in org.apache.samza.serializers">SerializableSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/StringSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/StringSerde.html" title="class in org.apache.samza.serializers">StringSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/UUIDSerde.html#fromBytes-byte:A-">fromBytes(byte[])</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/UUIDSerde.html" title="class in org.apache.samza.serializers">UUIDSerde</a></dt>
+<dd> </dd>
<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 <a href="org/apache/samza/runtime/ApplicationRunner.html" title="class in org.apache.samza.runtime"><code>ApplicationRunner</code></a></div>
@@ -529,6 +634,13 @@
<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/table/TableProvider.html#generateConfig-java.util.Map-">generateConfig(Map<String, String>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></dt>
+<dd>
+<div class="block">Generate any configuration for this table, the generated configuration
+ is used by Samza container to construct this table and any components
+ necessary
+ .</div>
+</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>
@@ -543,15 +655,19 @@
</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/table/ReadableTable.html#get-K-">get(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadableTable.html" title="interface in org.apache.samza.table">ReadableTable</a></dt>
+<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/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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#getAll-java.util.List-">getAll(List<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">Gets the values with which the specified <code>keys</code> are associated.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/storage/kv/KeyValueStore.html#getAll-java.util.List-">getAll(List<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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#getAll-java.util.List-">getAll(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadableTable.html" title="interface in org.apache.samza.table">ReadableTable</a></dt>
<dd>
<div class="block">Gets the values with which the specified <code>keys</code> are associated.</div>
</dd>
@@ -581,6 +697,10 @@
</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/table/TableSpec.html#getConfig--">getConfig()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt>
+<dd>
+<div class="block">Get implementation configuration for the table</div>
+</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>
@@ -639,18 +759,29 @@
<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/table/TableSpec.html#getId--">getId()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt>
+<dd>
+<div class="block">Get the Id of the table</div>
+</dd>
<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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#getInputStream-java.lang.String-org.apache.samza.serializers.Serde-">getInputStream(String, Serde<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">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/operators/StreamGraph.html#getInputStream-java.lang.String-">getInputStream(String)</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">Same as <a href="org/apache/samza/operators/StreamGraph.html#getInputStream-java.lang.String-org.apache.samza.serializers.Serde-"><code>StreamGraph.getInputStream(String, Serde)</code></a>, but uses the default <a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><code>Serde</code></a> provided via
+ <a href="org/apache/samza/operators/StreamGraph.html#setDefaultSerde-org.apache.samza.serializers.Serde-"><code>StreamGraph.setDefaultSerde(Serde)</code></a> for deserializing input messages.</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/KV.html#getKey--">getKey()</a></span> - Method in class org.apache.samza.operators.<a href="org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a></dt>
+<dd> </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>
@@ -663,6 +794,10 @@
<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/operators/windows/internal/WindowInternal.html#getKeySerde--">getKeySerde()</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/serializers/KVSerde.html#getKeySerde--">getKeySerde()</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">KVSerde</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>
@@ -685,6 +820,10 @@
<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>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html#getMessageKey-M-">getMessageKey(M)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions">StreamTableJoinFunction</a></dt>
+<dd>
+<div class="block">Retrieve the join key from incoming messages</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/OutgoingMessageEnvelope.html#getMessageSerializerName--">getMessageSerializerName()</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/util/BlockingEnvelopeMap.html#getMessagesSizeInQueue-org.apache.samza.system.SystemStreamPartition-">getMessagesSizeInQueue(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>
@@ -697,6 +836,10 @@
<dd>
<div class="block">Get the minimum value in the collection</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getMode--">getMode()</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#getMsgSerde--">getMsgSerde()</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/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>
@@ -732,10 +875,19 @@
<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#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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/StreamGraph.html#getOutputStream-java.lang.String-org.apache.samza.serializers.Serde-">getOutputStream(String, Serde<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">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/StreamGraph.html#getOutputStream-java.lang.String-">getOutputStream(String)</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">Same as <a href="org/apache/samza/operators/StreamGraph.html#getOutputStream-java.lang.String-org.apache.samza.serializers.Serde-"><code>StreamGraph.getOutputStream(String, Serde)</code></a>, but uses the default <a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers"><code>Serde</code></a> provided via
+ <a href="org/apache/samza/operators/StreamGraph.html#setDefaultSerde-org.apache.samza.serializers.Serde-"><code>StreamGraph.setDefaultSerde(Serde)</code></a> for serializing output messages.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/functions/WatermarkFunction.html#getOutputWatermark--">getOutputWatermark()</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/WatermarkFunction.html" title="interface in org.apache.samza.operators.functions">WatermarkFunction</a></dt>
+<dd>
+<div class="block">Returns the output watermark.</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>
@@ -750,14 +902,40 @@
<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/functions/StreamTableJoinFunction.html#getRecordKey-R-">getRecordKey(R)</a></span> - Method in interface org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions">StreamTableJoinFunction</a></dt>
+<dd>
+<div class="block">Retrieve the join key from table record</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">Get the join key for messages in the second input stream.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteBufferSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerdeFactory.html" title="class in org.apache.samza.serializers">ByteBufferSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/ByteSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteSerdeFactory.html" title="class in org.apache.samza.serializers">ByteSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/DoubleSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/DoubleSerdeFactory.html" title="class in org.apache.samza.serializers">DoubleSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/IntegerSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerdeFactory.html" title="class in org.apache.samza.serializers">IntegerSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/JsonSerdeV2Factory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2Factory.html" title="class in org.apache.samza.serializers">JsonSerdeV2Factory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/LongSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/LongSerdeFactory.html" title="class in org.apache.samza.serializers">LongSerdeFactory</a></dt>
+<dd> </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/serializers/SerializableSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/SerializableSerdeFactory.html" title="class in org.apache.samza.serializers">SerializableSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/StringSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/StringSerdeFactory.html" title="class in org.apache.samza.serializers">StringSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/UUIDSerdeFactory.html#getSerde-java.lang.String-org.apache.samza.config.Config-">getSerde(String, Config)</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/UUIDSerdeFactory.html" title="class in org.apache.samza.serializers">UUIDSerdeFactory</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableSpec.html#getSerde--">getSerde()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt>
+<dd>
+<div class="block">Get the serde</div>
+</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>
@@ -830,8 +1008,32 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#getSystemStreamPartitions--">getSystemStreamPartitions()</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/StreamGraph.html#getTable-org.apache.samza.operators.TableDescriptor-">getTable(TableDescriptor<K, 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">Gets the <a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> corresponding to the <a href="org/apache/samza/operators/TableDescriptor.html" title="interface in org.apache.samza.operators"><code>TableDescriptor</code></a>.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#getTable--">getTable()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></dt>
+<dd>
+<div class="block">Get an instance of the table for read/write operations</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/task/TaskContext.html#getTable-java.lang.String-">getTable(String)</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/TableDescriptor.html#getTableId--">getTableId()</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/TableDescriptor.html" title="interface in org.apache.samza.operators">TableDescriptor</a></dt>
+<dd>
+<div class="block">Get the Id of the table</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProviderFactory.html#getTableProvider-org.apache.samza.table.TableSpec-">getTableProvider(TableSpec)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table">TableProviderFactory</a></dt>
+<dd>
+<div class="block">Constructs an instances of the table provider based on a given table spec</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableSpec.html#getTableProviderFactoryClassName--">getTableProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt>
+<dd>
+<div class="block">Get the class name of the table provider factory</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/container/TaskName.html#getTaskName--">getTaskName()</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/system/ControlMessage.html#getTaskName--">getTaskName()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></dt>
+<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>
@@ -840,6 +1042,8 @@
<dd>
<div class="block">Get the values of a timer</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/WatermarkMessage.html#getTimestamp--">getTimestamp()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system">WatermarkMessage</a></dt>
+<dd> </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>
@@ -852,6 +1056,8 @@
</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/operators/KV.html#getValue--">getValue()</a></span> - Method in class org.apache.samza.operators.<a href="org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</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>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html#getValue--">getValue()</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BufferGauge.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BufferGauge</a></dt>
@@ -862,8 +1068,14 @@
<dd>
<div class="block">Return the entire list of values</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/KVSerde.html#getValueSerde--">getValueSerde()</a></span> - Method in class org.apache.samza.serializers.<a href="org/apache/samza/serializers/KVSerde.html" title="class in org.apache.samza.serializers">KVSerde</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/ControlMessage.html#getVersion--">getVersion()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></dt>
+<dd> </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/operators/windows/internal/WindowInternal.html#getWindowValSerde--">getWindowValSerde()</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>
@@ -886,6 +1098,8 @@
<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/ControlMessage.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</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>
<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>
@@ -900,6 +1114,10 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartition.html#hashCode--">hashCode()</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/WatermarkMessage.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system">WatermarkMessage</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableSpec.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.table.<a href="org/apache/samza/table/TableSpec.html" title="class in org.apache.samza.table">TableSpec</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamPartitionIterator.html#hasNext--">hasNext()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamPartitionIterator.html" title="class in org.apache.samza.system">SystemStreamPartitionIterator</a></dt>
<dd> </dd>
</dl>
@@ -922,7 +1140,7 @@
<dd> </dd>
<dt><a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">IncomingMessageEnvelope</span></a> - Class in <a href="org/apache/samza/system/package-summary.html">org.apache.samza.system</a></dt>
<dd>
-<div class="block">This class represents a message entvelope that is received by a StreamTask for each message that is received from a
+<div class="block">This class represents a message envelope that is received by a StreamTask for each message that is received from a
partition of a specific input stream.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#IncomingMessageEnvelope-org.apache.samza.system.SystemStreamPartition-java.lang.String-java.lang.Object-java.lang.Object-">IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object)</a></span> - Constructor for class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
@@ -951,6 +1169,14 @@
<dd>
<div class="block">Initializes the function before any messages are processed.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/udfs/ScalarUdf.html#init-org.apache.samza.config.Config-">init(Config)</a></span> - Method in interface org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs">ScalarUdf</a></dt>
+<dd>
+<div class="block">Udfs can implement this method to perform any initialization that they may need.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/LocalStoreBackedTableProvider.html#init-org.apache.samza.storage.StorageEngine-">init(StorageEngine)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/LocalStoreBackedTableProvider.html" title="interface in org.apache.samza.table">LocalStoreBackedTableProvider</a></dt>
+<dd>
+<div class="block">Initializes the table provider with the backing store</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>
@@ -966,6 +1192,16 @@
</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><a href="org/apache/samza/serializers/IntegerSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">IntegerSerde</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd>
+<div class="block">A serializer for integers</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/IntegerSerde.html#IntegerSerde--">IntegerSerde()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerde.html" title="class in org.apache.samza.serializers">IntegerSerde</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/serializers/IntegerSerdeFactory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">IntegerSerdeFactory</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/IntegerSerdeFactory.html#IntegerSerdeFactory--">IntegerSerdeFactory()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/IntegerSerdeFactory.html" title="class in org.apache.samza.serializers">IntegerSerdeFactory</a></dt>
+<dd> </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,
@@ -989,6 +1225,12 @@
</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/system/StreamSpec.html#isBounded--">isBounded()</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/StreamSpec.html#isChangeLogStream--">isChangeLogStream()</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/StreamSpec.html#isCoordinatorStream--">isCoordinatorStream()</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/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>
@@ -1007,37 +1249,60 @@
</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-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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#join-org.apache.samza.operators.MessageStream-org.apache.samza.operators.functions.JoinFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-java.time.Duration-java.lang.String-">join(MessageStream<OM>, JoinFunction<? extends K, ? super M, ? super OM, ? extends JM>, Serde<K>, Serde<M>, Serde<OM>, Duration, String)</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><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#join-org.apache.samza.table.Table-org.apache.samza.operators.functions.StreamTableJoinFunction-">join(Table<R>, StreamTableJoinFunction<? extends K, ? super M, ? super R, ? extends JM>)</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/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> using the provided
+ pairwise <a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><code>StreamTableJoinFunction</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">Joins incoming messages in two streams by key.</div>
</dd>
+<dt><a href="org/apache/samza/serializers/JsonSerdeV2.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">JsonSerdeV2</span></a><<a href="org/apache/samza/serializers/JsonSerdeV2.html" title="type parameter in JsonSerdeV2">T</a>> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd>
+<div class="block">A serializer for UTF-8 encoded JSON strings.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/JsonSerdeV2.html#JsonSerdeV2--">JsonSerdeV2()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2.html" title="class in org.apache.samza.serializers">JsonSerdeV2</a></dt>
+<dd>
+<div class="block">Constructs a JsonSerdeV2 that returns a LinkedHashMap<String, Object< upon deserialization.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/JsonSerdeV2.html#JsonSerdeV2-java.lang.Class-">JsonSerdeV2(Class<T>)</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2.html" title="class in org.apache.samza.serializers">JsonSerdeV2</a></dt>
+<dd>
+<div class="block">Constructs a JsonSerdeV2 that (de)serializes POJOs of class <code>clazz</code>.</div>
+</dd>
+<dt><a href="org/apache/samza/serializers/JsonSerdeV2Factory.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">JsonSerdeV2Factory</span></a> - Class in <a href="org/apache/samza/serializers/package-summary.html">org.apache.samza.serializers</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/serializers/JsonSerdeV2Factory.html#JsonSerdeV2Factory--">JsonSerdeV2Factory()</a></span> - Constructor for class org.apache.samza.serializers.<a href="org/apache/samza/serializers/JsonSerdeV2Factory.html" title="class in org.apache.samza.serializers">JsonSerdeV2Factory</a></dt>
+<dd> </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#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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/KV.html#key">key</a></span> - Variable in class org.apache.samza.operators.<a href="org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a></dt>
+<dd> </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.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedSessionWindow(Function<? super M, ? extends K>, Duration, Supplier<? extends WV>, FoldLeftFunction<? super M, WV>, Serde<K>, Serde<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<? 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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedSessionWindow(Function<? super M, ? extends K>, Duration, Serde<K>, Serde<M>)</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.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>
+<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-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedTumblingWindow(Function<? super M, ? extends K>, Duration, Supplier<? extends WV>, FoldLeftFunction<? super M, WV>, Serde<K>, Serde<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<? 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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedTumblingWindow(Function<M, K>, Duration, Serde<K>, Serde<M>)</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>
@@ -1050,10 +1315,6 @@
<dd>
<div class="block">A key-value store that supports put, get, delete, and range queries.</div>
</dd>
-<dt><a href="org/apache/samza/storage/kv/KeyValueStore.Extension.html" title="class in org.apache.samza.storage.kv"><span class="typeNameLink">KeyValueStore.Extension</span></a> - Class in <a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a></dt>
-<dd>
-<div class="block">Represents an extension for classes that implement <a href="org/apache/samza/storage/kv/KeyValueStore.html" title="interface in org.apache.samza.storage.kv"><code>KeyValueStore</code></a>.</div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/StreamJob.html#kill--">kill()</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">Kill this job immediately.</div>
@@ -1063,6 +1324,23 @@
<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>
+<dt><a href="org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">KV</span></a><<a href="org/apache/samza/operators/KV.html" title="type parameter in KV">K</a>,<a href="org/apache/samza/operators/KV.html" title="type parameter in KV">V</a>> - Class in <a href="org/apache/samza/operators/package-summary.html">org.apache.samza.operators</a></dt>
+<dd>
+<div class="block">A key and value pair.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/operators/KV.html#KV-K-V-">KV(K, V)</a></span> - Constructor for class org.apache.samza.operators.<a href="org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a></dt>
+<dd> </dd>
[... 568 lines stripped ...]