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 2019/02/01 19:39:38 UTC
svn commit: r1852769 [3/18] - in /samza/site: ./ archive/ blog/
case-studies/ community/ contribute/ learn/documentation/latest/
learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/
learn/documentation/latest/api/javadocs/org/apache...
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=1852769&r1=1852768&r2=1852769&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/index-all.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/index-all.html Fri Feb 1 19:39:34 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_181) on Fri Dec 21 10:55:56 PST 2018 -->
+<!-- Generated by javadoc (1.8.0_181) on Fri Feb 01 11:33:47 PST 2019 -->
<title>Index (samza-api 1.0.1-SNAPSHOT API)</title>
-<meta name="date" content="2018-12-21">
+<meta name="date" content="2019-02-01">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -101,6 +101,8 @@
<dd>
<div class="block">Add a value to the list.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html#addField-java.lang.String-org.apache.samza.sql.schema.SqlFieldSchema-">addField(String, SqlFieldSchema)</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema">SqlSchemaBuilder</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#addStoreConfig-java.lang.String-java.lang.String-java.util.Map-">addStoreConfig(String, String, Map<String, String>)</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors">LocalTableDescriptor</a></dt>
<dd>
<div class="block">Helper method to add a store level config item to table configuration</div>
@@ -109,6 +111,10 @@
<dd>
<div class="block">Helper method to add a config item to table configuration</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointListener.html#afterCheckpoint-java.util.Map-">afterCheckpoint(Map<SystemStreamPartition, String>)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint">CheckpointListener</a></dt>
+<dd>
+<div class="block">Called after writing the checkpoint for each Task in the Container processing SSPs on this system.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ProcessorLifecycleListener.html#afterFailure-java.lang.Throwable-">afterFailure(Throwable)</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorLifecycleListener.html" title="interface in org.apache.samza.runtime">ProcessorLifecycleListener</a></dt>
<dd>
<div class="block">User defined callback after a StreamProcessor is stopped with failure</div>
@@ -121,6 +127,8 @@
<dd>
<div class="block">User defined callback after a StreamProcessor is stopped successfully</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#all--">all()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#all--">all()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Returns all the entries in this metadata store.</div>
@@ -205,6 +213,21 @@
<dd>
<div class="block">Joins the provided messages and table record, returns the joined message.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt>
+<dd>
+<div class="block">Apply the visitor <a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><code>StartpointVisitor</code></a>'s register methods to the instance of this <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a>
+ class.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointCustom.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint">StartpointCustom</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointOldest.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint">StartpointOldest</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointUpcoming.html#apply-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointVisitor-">apply(SystemStreamPartition, StartpointVisitor)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint">StartpointUpcoming</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/descriptors/InputTransformer.html#apply-org.apache.samza.system.IncomingMessageEnvelope-">apply(IncomingMessageEnvelope)</a></span> - Method in interface org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/InputTransformer.html" title="interface in org.apache.samza.system.descriptors">InputTransformer</a></dt>
<dd>
<div class="block">Transforms the provided <a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><code>IncomingMessageEnvelope</code></a> with deserialized key and message into another message
@@ -217,6 +240,10 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#ASYNC_CALLBACK_POOL_SIZE">ASYNC_CALLBACK_POOL_SIZE</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a></dt>
<dd> </dd>
+<dt><a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">AsyncReadWriteTable</span></a><<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="type parameter in AsyncReadWriteTable">K</a>,<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="type parameter in AsyncReadWriteTable">V</a>> - Interface in <a href="org/apache/samza/table/package-summary.html">org.apache.samza.table</a></dt>
+<dd>
+<div class="block">A table that supports asynchronous get, put and delete by one or more keys</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>
@@ -246,6 +273,10 @@
<dd>
<div class="block">Constructs a table descriptor instance</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointListener.html#beforeCheckpoint-java.util.Map-">beforeCheckpoint(Map<SystemStreamPartition, String>)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint">CheckpointListener</a></dt>
+<dd>
+<div class="block">Called before writing the checkpoint for each Task in the Container processing SSPs on this system.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ProcessorLifecycleListener.html#beforeStart--">beforeStart()</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ProcessorLifecycleListener.html" title="interface in org.apache.samza.runtime">ProcessorLifecycleListener</a></dt>
<dd>
<div class="block">User defined initialization before a StreamProcessor is started</div>
@@ -287,6 +318,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html#BufferSizeGauge-org.apache.samza.system.SystemStreamPartition-java.lang.String-">BufferSizeGauge(SystemStreamPartition, String)</a></span> - Constructor for class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BufferSizeGauge.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BufferSizeGauge</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html#build--">build()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema">SqlSchemaBuilder</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html#build--">build()</a></span> - Method in class org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html" title="class in org.apache.samza.storage">StoreProperties.StorePropertiesBuilder</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/CommandBuilder.html#buildCommand--">buildCommand()</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>
@@ -297,6 +330,8 @@
</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/sql/schema/SqlSchemaBuilder.html#builder--">builder()</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema">SqlSchemaBuilder</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#buildKey-java.lang.String-java.lang.String-">buildKey(String, String)</a></span> - Static method in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt>
<dd>
<div class="block">Build complete config key for a config item</div>
@@ -364,8 +399,8 @@
</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>
+<div class="block">SystemConsumers that want to be notified about checkpoints for their SSPs and potentially modify them may
+ implement this interface.</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>
@@ -409,6 +444,8 @@
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#close--">close()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#close--">close()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Closes the metadata store, if applicable, relinquishing all the underlying resources
@@ -432,7 +469,7 @@
<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/ReadWriteTable.html#close--">close()</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#close--">close()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Close the table and release any resources acquired</div>
</dd>
@@ -571,6 +608,8 @@
<dd>
<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createArraySchema-org.apache.samza.sql.schema.SqlFieldSchema-">createArraySchema(SqlFieldSchema)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd> </dd>
<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/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>
@@ -585,10 +624,18 @@
<dd>
<div class="block">Create instance of task</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createMapSchema-org.apache.samza.sql.schema.SqlFieldSchema-">createMapSchema(SqlFieldSchema)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createPrimitiveSchema-org.apache.samza.sql.schema.SamzaSqlFieldType-">createPrimitiveSchema(SamzaSqlFieldType)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd>
+<div class="block">Create a primitive fi</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManager.html#createResources--">createResources()</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">Creates checkpoint stream.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#createRowFieldSchema-org.apache.samza.sql.schema.SqlSchema-">createRowFieldSchema(SqlSchema)</a></span> - Static method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd> </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>
@@ -609,6 +656,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#DEFAULT_RATE_LIMITER_CLASS_NAME">DEFAULT_RATE_LIMITER_CLASS_NAME</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#delete-java.lang.String-">delete(String)</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#delete-java.lang.String-">delete(String)</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Deletes the mapping for the specified <code>key</code> from this metadata store (if such mapping exists).</div>
@@ -642,7 +691,7 @@
<div class="block">Delete all <code>records</code> with the specified <code>keys</code> from the remote store
The default implementation calls deleteAllAsync and blocks on the completion afterwards.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#deleteAllAsync-java.util.List-">deleteAllAsync(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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#deleteAllAsync-java.util.List-">deleteAllAsync(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Asynchronously deletes the mappings for the specified <code>keys</code> from this table.</div>
</dd>
@@ -650,7 +699,7 @@
<dd>
<div class="block">Asynchronously delete all <code>records</code> with the specified <code>keys</code> from the remote store.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#deleteAsync-K-">deleteAsync(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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#deleteAsync-K-">deleteAsync(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Asynchronously deletes the mapping for the specified <code>key</code> from this table (if such mapping exists).</div>
</dd>
@@ -745,6 +794,12 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</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>
@@ -765,10 +820,6 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/TimestampedValue.html#equals-java.lang.Object-">equals(Object)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/TimestampedValue.html" title="class in org.apache.samza.util">TimestampedValue</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/descriptors/ExpandingInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">ExpandingInputDescriptorProvider</span></a><<a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html" title="type parameter in ExpandingInputDescriptorProvider">StreamExpanderType</a>> - Interface in <a href="org/apache/samza/system/descriptors/package-summary.html">org.apache.samza.system.descriptors</a></dt>
<dd>
<div class="block">Interface for advanced <code>SystemDescriptor</code>s that constrain the type of returned <code>InputDescriptor</code>s to
@@ -813,6 +864,8 @@
<dd>
<div class="block">Transforms an input message into a collection of 0 or more messages, possibly of a different type.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#flush--">flush()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#flush--">flush()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Flushes the metadata store, if applicable.</div>
@@ -830,7 +883,7 @@
<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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#flush--">flush()</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Flushes the underlying store of this table, if applicable.</div>
</dd>
@@ -910,6 +963,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#get-java.lang.Object-">get(Object)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/MapConfig.html" title="class in org.apache.samza.config">MapConfig</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#get-java.lang.String-">get(String)</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#get-java.lang.String-">get(String)</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Gets the value associated with the specified <code>key</code>.</div>
@@ -948,7 +1003,7 @@
<dd>
<div class="block">Fetch the table <code>records</code> for specified <code>keys</code>.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#getAllAsync-java.util.List-">getAllAsync(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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#getAllAsync-java.util.List-">getAllAsync(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Asynchronously gets the values with which the specified <code>keys</code> are associated.</div>
</dd>
@@ -972,7 +1027,11 @@
<dd>
<div class="block">Gets the application-defined task context for the current task.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#getAsync-K-">getAsync(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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getArrivalTime--">getArrivalTime()</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>
+<div class="block">Getter for arrival time</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#getAsync-K-">getAsync(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Asynchronously gets the value associated with the specified <code>key</code>.</div>
</dd>
@@ -1048,6 +1107,10 @@
<dd>
<div class="block">Get the values of a counter</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#getCreationTimestamp--">getCreationTimestamp()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt>
+<dd>
+<div class="block">The timestamp when this <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> was written to the storage layer.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html#getCredits-K-V-">getCredits(K, V)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a></dt>
<dd>
<div class="block">Get the number of credits required for the <code>key</code> and <code>value</code> pair.</div>
@@ -1080,6 +1143,14 @@
<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/sql/schema/SqlFieldSchema.html#getElementSchema--">getElementSchema()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd>
+<div class="block">Get the element schema if the field type is <a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html#ARRAY"><code>SamzaSqlFieldType.ARRAY</code></a></div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getEventTime--">getEventTime()</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>
+<div class="block">Getter for event time</div>
+</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/system/descriptors/SystemDescriptor.html#getExpander--">getExpander()</a></span> - Method in class org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/SystemDescriptor.html" title="class in org.apache.samza.system.descriptors">SystemDescriptor</a></dt>
@@ -1096,10 +1167,20 @@
<dd>
<div class="block">Get the value of the field corresponding to the field name.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#getFieldName--">getFieldName()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#getFieldNames--">getFieldNames()</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt>
<dd>
<div class="block">Get the field names of all the columns in the relational message.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.html#getFields--">getFields()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.html" title="class in org.apache.samza.sql.schema">SqlSchema</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#getFieldSchema--">getFieldSchema()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#getFieldType--">getFieldType()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd>
+<div class="block">Get teh Type of the Samza SQL Field.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#getFieldValues--">getFieldValues()</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt>
<dd>
<div class="block">Get the field values of all the columns in the relational message.</div>
@@ -1242,6 +1323,8 @@
<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>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html#getMetadataStore-java.lang.String-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getMetadataStore(String, Config, MetricsRegistry)</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStoreFactory</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStoreFactory.html#getMetadataStore-java.lang.String-org.apache.samza.config.Config-org.apache.samza.metrics.MetricsRegistry-">getMetadataStore(String, Config, MetricsRegistry)</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStoreFactory.html" title="interface in org.apache.samza.metadatastore">MetadataStoreFactory</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsReporterFactory.html#getMetricsReporter-java.lang.String-java.lang.String-org.apache.samza.config.Config-">getMetricsReporter(String, String, Config)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsReporterFactory.html" title="interface in org.apache.samza.metrics">MetricsReporterFactory</a></dt>
@@ -1324,6 +1407,8 @@
<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/sql/schema/SqlSchema.SqlField.html#getPosition--">getPosition()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.html#getPreviousSSP-org.apache.samza.system.SystemStreamPartition-int-int-">getPreviousSSP(SystemStreamPartition, int, int)</a></span> - Method in interface org.apache.samza.container.grouper.stream.<a href="org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.html" title="interface in org.apache.samza.container.grouper.stream">SystemStreamPartitionMapper</a></dt>
<dd>
<div class="block">Determines the previous <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a> for a <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>
@@ -1359,6 +1444,10 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getRetryPredicate--">getRetryPredicate()</a></span> - Method in class org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#getRowSchema--">getRowSchema()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd>
+<div class="block">Get the row schema if the field type is <a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html#ROW"><code>SamzaSqlFieldType.ROW</code></a></div>
+</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>
@@ -1419,6 +1508,10 @@
<dd>
<div class="block">Get the <a href="org/apache/samza/metrics/Snapshot.html" title="class in org.apache.samza.metrics"><code>Snapshot</code></a></div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#getSpecificOffset--">getSpecificOffset()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt>
+<dd>
+<div class="block">Getter for the specific offset.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#getSSPMetadata-java.util.Set-">getSSPMetadata(Set<SystemStreamPartition>)</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">Fetch metadata from a system for a set of SSPs.</div>
@@ -1429,7 +1522,7 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/ApplicationStatus.html#getStatusCode--">getStatusCode()</a></span> - Method in class org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.html" title="class in org.apache.samza.job">ApplicationStatus</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/storage/StorageEngineFactory.html#getStorageEngine-java.lang.String-java.io.File-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.task.MessageCollector-org.apache.samza.metrics.MetricsRegistry-org.apache.samza.system.SystemStreamPartition-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">getStorageEngine(String, File, Serde<K>, Serde<V>, MessageCollector, MetricsRegistry, SystemStreamPartition, JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage">StorageEngineFactory</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/storage/StorageEngineFactory.html#getStorageEngine-java.lang.String-java.io.File-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-org.apache.samza.task.MessageCollector-org.apache.samza.metrics.MetricsRegistry-org.apache.samza.system.SystemStreamPartition-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.storage.StorageEngineFactory.StoreMode-">getStorageEngine(String, File, Serde<K>, Serde<V>, MessageCollector, MetricsRegistry, SystemStreamPartition, JobContext, ContainerContext, StorageEngineFactory.StoreMode)</a></span> - Method in interface org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage">StorageEngineFactory</a></dt>
<dd>
<div class="block">Create an instance of the given storage engine.</div>
</dd>
@@ -1539,6 +1632,8 @@
<dd>
<div class="block">Gets the <a href="org/apache/samza/metrics/MetricsRegistry.html" title="interface in org.apache.samza.metrics"><code>MetricsRegistry</code></a> for this task, which can be used to register metrics that are reported per task.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/TaskModel.html#getTaskMode--">getTaskMode()</a></span> - Method in class org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model">TaskModel</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/context/TaskContext.html#getTaskModel--">getTaskModel()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/TaskContext.html" title="interface in org.apache.samza.context">TaskContext</a></dt>
<dd>
<div class="block">Gets the <a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model"><code>TaskModel</code></a> for this task, which contains this task's name and its <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>s.</div>
@@ -1561,12 +1656,14 @@
<dd>
<div class="block">Get the values of a timer</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getTimestamp--">getTimestamp()</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/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/util/TimestampedValue.html#getTimestamp--">getTimestamp()</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/TimestampedValue.html" title="class in org.apache.samza.util">TimestampedValue</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#getTimestampOffset--">getTimestampOffset()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</a></dt>
+<dd>
+<div class="block">Getter for the timestamp offset.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/descriptors/InputDescriptor.html#getTransformer--">getTransformer()</a></span> - Method in class org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="class in org.apache.samza.system.descriptors">InputDescriptor</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/descriptors/SystemDescriptor.html#getTransformer--">getTransformer()</a></span> - Method in class org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/SystemDescriptor.html" title="class in org.apache.samza.system.descriptors">SystemDescriptor</a></dt>
@@ -1597,6 +1694,10 @@
<dd>
<div class="block">Return the entire list of values</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#getValueScehma--">getValueScehma()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
+<dd>
+<div class="block">Get the schema of the value if the field type is <a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html#MAP"><code>SamzaSqlFieldType.MAP</code></a></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>
@@ -1655,6 +1756,12 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#hashCode--">hashCode()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</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>
@@ -1714,8 +1821,14 @@
<dd>
<div class="block">Constructs a new IncomingMessageEnvelope from specified components.</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-int-long-long-">IncomingMessageEnvelope(SystemStreamPartition, String, Object, Object, int, long, long)</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>
+<dd>
+<div class="block">Constructs a new IncomingMessageEnvelope from specified components</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html#incPoll--">incPoll()</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#init--">init()</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#init--">init()</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Initializes the metadata store, if applicable, setting up the underlying resources
@@ -1733,7 +1846,7 @@
<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/ReadWriteTable.html#init-org.apache.samza.context.Context-">init(Context)</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#init-org.apache.samza.context.Context-">init(Context)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Initializes the table during container initialization.</div>
</dd>
@@ -1760,6 +1873,18 @@
</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/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore"><span class="typeNameLink">InMemoryMetadataStore</span></a> - Class in <a href="org/apache/samza/metadatastore/package-summary.html">org.apache.samza.metadatastore</a></dt>
+<dd>
+<div class="block">In-memory <a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore"><code>MetadataStore</code></a> with no persistence on disk.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#InMemoryMetadataStore--">InMemoryMetadataStore()</a></span> - Constructor for class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html" title="class in org.apache.samza.metadatastore"><span class="typeNameLink">InMemoryMetadataStoreFactory</span></a> - Class in <a href="org/apache/samza/metadatastore/package-summary.html">org.apache.samza.metadatastore</a></dt>
+<dd>
+<div class="block">Factory for an in-memory <a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore"><code>MetadataStore</code></a>.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html#InMemoryMetadataStoreFactory--">InMemoryMetadataStoreFactory()</a></span> - Constructor for class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStoreFactory</a></dt>
+<dd> </dd>
<dt><a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="class in org.apache.samza.system.descriptors"><span class="typeNameLink">InputDescriptor</span></a><<a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="type parameter in InputDescriptor">StreamMessageType</a>,<a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="type parameter in InputDescriptor">SubClass</a> extends <a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="class in org.apache.samza.system.descriptors">InputDescriptor</a><<a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="type parameter in InputDescriptor">StreamMessageType</a>,<a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="type parameter in InputDescriptor">SubClass</a>>> - Class in <a href="org/apache/samza/system/descriptors/package-summary.html">org.apache.samza.system.descriptors</a></dt>
<dd>
<div class="block">An <a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="class in org.apache.samza.system.descriptors"><code>InputDescriptor</code></a> can be used for specifying Samza and system-specific properties of input streams.</div>
@@ -1826,7 +1951,7 @@
<dd>
<div class="block">Flag to indicate whether a store can be persisted to disk or not</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#isRateLimited--">isRateLimited()</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#isPrimitiveField--">isPrimitiveField()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#isRetriable-java.lang.Throwable-">isRetriable(Throwable)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a></dt>
<dd>
@@ -2115,6 +2240,8 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsVisitor.html#MetricsVisitor--">MetricsVisitor()</a></span> - Constructor for 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/storage/StorageEngineFactory.StoreMode.html#mode">mode</a></span> - Variable in enum org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.StoreMode.html" title="enum in org.apache.samza.storage">StorageEngineFactory.StoreMode</a></dt>
+<dd> </dd>
</dl>
<a name="I:N">
<!-- -->
@@ -2213,7 +2340,9 @@
<div class="block">Invoked when the corresponding schedule time is reached.</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointListener.html#onCheckpoint-java.util.Map-">onCheckpoint(Map<SystemStreamPartition, String>)</a></span> - Method in interface org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/CheckpointListener.html" title="interface in org.apache.samza.checkpoint">CheckpointListener</a></dt>
-<dd> </dd>
+<dd>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/ReadableMetricsRegistryListener.html#onCounter-java.lang.String-org.apache.samza.metrics.Counter-">onCounter(String, Counter)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/ReadableMetricsRegistryListener.html" title="interface in org.apache.samza.metrics">ReadableMetricsRegistryListener</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/task/EndOfStreamListenerTask.html#onEndOfStream-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-">onEndOfStream(MessageCollector, TaskCoordinator)</a></span> - Method in interface org.apache.samza.task.<a href="org/apache/samza/task/EndOfStreamListenerTask.html" title="interface in org.apache.samza.task">EndOfStreamListenerTask</a></dt>
@@ -2270,8 +2399,12 @@
<dd> </dd>
<dt><a href="org/apache/samza/sql/package-summary.html">org.apache.samza.sql</a> - package org.apache.samza.sql</dt>
<dd> </dd>
+<dt><a href="org/apache/samza/sql/schema/package-summary.html">org.apache.samza.sql.schema</a> - package org.apache.samza.sql.schema</dt>
+<dd> </dd>
<dt><a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a> - package org.apache.samza.sql.udfs</dt>
<dd> </dd>
+<dt><a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a> - package org.apache.samza.startpoint</dt>
+<dd> </dd>
<dt><a href="org/apache/samza/storage/package-summary.html">org.apache.samza.storage</a> - package org.apache.samza.storage</dt>
<dd> </dd>
<dt><a href="org/apache/samza/storage/kv/package-summary.html">org.apache.samza.storage.kv</a> - package org.apache.samza.storage.kv</dt>
@@ -2405,6 +2538,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#put-java.lang.String-java.lang.String-">put(String, String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html#put-java.lang.String-byte:A-">put(String, byte[])</a></span> - Method in class org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/InMemoryMetadataStore.html" title="class in org.apache.samza.metadatastore">InMemoryMetadataStore</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#put-java.lang.String-byte:A-">put(String, byte[])</a></span> - Method in interface org.apache.samza.metadatastore.<a href="org/apache/samza/metadatastore/MetadataStore.html" title="interface in org.apache.samza.metadatastore">MetadataStore</a></dt>
<dd>
<div class="block">Updates the mapping of the specified key-value pair.</div>
@@ -2446,7 +2581,7 @@
<div class="block">Place a collection of <a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><code>IncomingMessageEnvelope</code></a>
on the queue for the specified <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/table/ReadWriteTable.html#putAllAsync-java.util.List-">putAllAsync(List<Entry<K, V>>)</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#putAllAsync-java.util.List-">putAllAsync(List<Entry<K, V>>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Asynchronously updates the mappings of the specified key-value <code>entries</code>.</div>
</dd>
@@ -2454,7 +2589,7 @@
<dd>
<div class="block">Asynchronously store the table <code>records</code> with specified <code>keys</code>.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#putAsync-K-V-">putAsync(K, V)</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#putAsync-K-V-">putAsync(K, V)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt>
<dd>
<div class="block">Asynchronously updates the mapping of the specified key-value pair;
Associates the specified <code>key</code> with the specified <code>value</code>.</div>
@@ -2501,7 +2636,7 @@
</dd>
<dt><a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadWriteTable</span></a><<a href="org/apache/samza/table/ReadWriteTable.html" title="type parameter in ReadWriteTable">K</a>,<a href="org/apache/samza/table/ReadWriteTable.html" title="type parameter in ReadWriteTable">V</a>> - Interface in <a href="org/apache/samza/table/package-summary.html">org.apache.samza.table</a></dt>
<dd>
-<div class="block">A table that supports get, put and delete by one or more keys</div>
+<div class="block">A table that supports synchronous and asynchronousget, put and delete by one or more keys</div>
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#REAL_TABLE_ID">REAL_TABLE_ID</a></span> - Static variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors">CachingTableDescriptor</a></dt>
<dd> </dd>
@@ -2612,6 +2747,10 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/SamzaHistogram.html#SamzaHistogram-org.apache.samza.metrics.MetricsRegistry-java.lang.String-java.lang.String-java.util.List-">SamzaHistogram(MetricsRegistry, String, String, List<Double>)</a></span> - Constructor for class org.apache.samza.metrics.<a href="org/apache/samza/metrics/SamzaHistogram.html" title="class in org.apache.samza.metrics">SamzaHistogram</a></dt>
<dd> </dd>
+<dt><a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html" title="enum in org.apache.samza.sql.schema"><span class="typeNameLink">SamzaSqlFieldType</span></a> - Enum in <a href="org/apache/samza/sql/schema/package-summary.html">org.apache.samza.sql.schema</a></dt>
+<dd>
+<div class="block">Type of the Samza SQL field</div>
+</dd>
<dt><a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql"><span class="typeNameLink">SamzaSqlRelRecord</span></a> - Class in <a href="org/apache/samza/sql/package-summary.html">org.apache.samza.sql</a></dt>
<dd>
<div class="block">Samza sql relational record.</div>
@@ -2620,11 +2759,19 @@
<dd>
<div class="block">Creates a <a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql"><code>SamzaSqlRelRecord</code></a> from the list of relational fields and values.</div>
</dd>
+<dt><a href="org/apache/samza/sql/udfs/SamzaSqlUdf.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdf</span></a> - Annotation Type in <a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></dt>
+<dd>
+<div class="block">Java annotation to identity a Samza SQL Udf</div>
+</dd>
+<dt><a href="org/apache/samza/sql/udfs/SamzaSqlUdfMethod.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdfMethod</span></a> - Annotation Type in <a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></dt>
+<dd>
+<div class="block">Java annotation to identity the Samza SQL Udf method and it's argument types and return types.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#sanitize--">sanitize()</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#sanitize--">sanitize()</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/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a><<a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="type parameter in ScalarUdf">T</a>> - Interface in <a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></dt>
+<dt><a href="org/apache/samza/sql/udfs/ScalarUdf.html" title="interface in org.apache.samza.sql.udfs"><span class="typeNameLink">ScalarUdf</span></a> - Interface in <a href="org/apache/samza/sql/udfs/package-summary.html">org.apache.samza.sql.udfs</a></dt>
<dd>
<div class="block">The base class for the Scalar UDFs.</div>
</dd>
@@ -2727,6 +2874,10 @@
<dd>
<div class="block">Set the early triggers for this <a href="org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a>.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#setFieldName-java.lang.String-">setFieldName(String)</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#setFieldSchema-org.apache.samza.sql.schema.SqlFieldSchema-">setFieldSchema(SqlFieldSchema)</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/CommandBuilder.html#setId-java.lang.String-">setId(String)</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/util/BlockingEnvelopeMap.html#setIsAtHead-org.apache.samza.system.SystemStreamPartition-boolean-">setIsAtHead(SystemStreamPartition, boolean)</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>
@@ -2743,6 +2894,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html#setPersistedToDisk-boolean-">setPersistedToDisk(boolean)</a></span> - Method in class org.apache.samza.storage.<a href="org/apache/samza/storage/StoreProperties.StorePropertiesBuilder.html" title="class in org.apache.samza.storage">StoreProperties.StorePropertiesBuilder</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#setPosition-int-">setPosition(int)</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/context/TaskContext.html#setStartingOffset-org.apache.samza.system.SystemStreamPartition-java.lang.String-">setStartingOffset(SystemStreamPartition, String)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/TaskContext.html" title="interface in org.apache.samza.context">TaskContext</a></dt>
<dd>
<div class="block">Sets the starting offset for the given <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>.</div>
@@ -2751,8 +2904,6 @@
<dd>
<div class="block">Set up waitTimeMetric metric for latency reporting due to throttling.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#setTimestamp-long-">setTimestamp(long)</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/job/CommandBuilder.html#setUrl-java.net.URL-">setUrl(URL)</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/ControlMessage.html#setVersion-int-">setVersion(int)</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>
@@ -2840,6 +2991,24 @@
<dd>
<div class="block">Returns a snapshot of this store for a sorted range of entries specified by [<code>from</code>, <code>to</code>).</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html#SqlField-int-java.lang.String-org.apache.samza.sql.schema.SqlFieldSchema-">SqlField(int, String, SqlFieldSchema)</a></span> - Constructor for class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema">SqlSchema.SqlField</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlFieldSchema</span></a> - Class in <a href="org/apache/samza/sql/schema/package-summary.html">org.apache.samza.sql.schema</a></dt>
+<dd>
+<div class="block">Schema for the Samza SQL Field.</div>
+</dd>
+<dt><a href="org/apache/samza/sql/schema/SqlSchema.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchema</span></a> - Class in <a href="org/apache/samza/sql/schema/package-summary.html">org.apache.samza.sql.schema</a></dt>
+<dd>
+<div class="block">Representation of SQL schema which is used by Samza SQL.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlSchema.html#SqlSchema-java.util.List-java.util.List-">SqlSchema(List<String>, List<SqlFieldSchema>)</a></span> - Constructor for class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchema.html" title="class in org.apache.samza.sql.schema">SqlSchema</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/sql/schema/SqlSchema.SqlField.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchema.SqlField</span></a> - Class in <a href="org/apache/samza/sql/schema/package-summary.html">org.apache.samza.sql.schema</a></dt>
+<dd> </dd>
+<dt><a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchemaBuilder</span></a> - Class in <a href="org/apache/samza/sql/schema/package-summary.html">org.apache.samza.sql.schema</a></dt>
+<dd>
+<div class="block">Builder class to build the <a href="org/apache/samza/sql/schema/SqlSchema.html" title="class in org.apache.samza.sql.schema"><code>SqlSchema</code></a>.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManager.html#start--">start()</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">Perform startup operations.</div>
@@ -2872,6 +3041,50 @@
<dd>
<div class="block">Start the SystemProducer.</div>
</dd>
+<dt><a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">Startpoint</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">Startpoint represents a position in a stream partition.</div>
+</dd>
+<dt><a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointCustom</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents a custom startpoint.</div>
+</dd>
+<dt><a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointOldest</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents the earliest offset in a stream partition.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointOldest.html#StartpointOldest--">StartpointOldest()</a></span> - Constructor for class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint">StartpointOldest</a></dt>
+<dd>
+<div class="block">Constructs a <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents the earliest offset in a stream partition.</div>
+</dd>
+<dt><a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointSpecific</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents a specific offset in a stream partition.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#StartpointSpecific-java.lang.String-">StartpointSpecific(String)</a></span> - Constructor for class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt>
+<dd>
+<div class="block">Constructs a <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents a specific offset in a stream partition.</div>
+</dd>
+<dt><a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointTimestamp</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents a timestamp offset in a stream partition.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#StartpointTimestamp-java.lang.Long-">StartpointTimestamp(Long)</a></span> - Constructor for class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</a></dt>
+<dd>
+<div class="block">Constructs a <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents a timestamp offset in a stream partition.</div>
+</dd>
+<dt><a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointUpcoming</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents the latest offset in a stream partition.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointUpcoming.html#StartpointUpcoming--">StartpointUpcoming()</a></span> - Constructor for class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint">StartpointUpcoming</a></dt>
+<dd>
+<div class="block">Constructs a <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents the latest offset in a stream partition.</div>
+</dd>
+<dt><a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><span class="typeNameLink">StartpointVisitor</span></a> - Interface in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt>
+<dd>
+<div class="block">Visitor interface for system consumers to implement to support <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a>s.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#status--">status()</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="interface in org.apache.samza.runtime">ApplicationRunner</a></dt>
<dd>
<div class="block">Get the collective status of the Samza jobs represented by <a href="org/apache/samza/application/SamzaApplication.html" title="interface in org.apache.samza.application"><code>SamzaApplication</code></a>.</div>
@@ -2921,6 +3134,10 @@
<div class="block">An object provided by the storage engine implementation to create instances
of the given storage engine type.</div>
</dd>
+<dt><a href="org/apache/samza/storage/StorageEngineFactory.StoreMode.html" title="enum in org.apache.samza.storage"><span class="typeNameLink">StorageEngineFactory.StoreMode</span></a> - Enum in <a href="org/apache/samza/storage/package-summary.html">org.apache.samza.storage</a></dt>
+<dd>
+<div class="block">Enum to describe different modes a <a href="org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage"><code>StorageEngine</code></a> can be created in.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#STORE_KEY_SERDE">STORE_KEY_SERDE</a></span> - Static variable in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#STORE_MSG_SERDE">STORE_MSG_SERDE</a></span> - Static variable in class org.apache.samza.config.<a href="org/apache/samza/config/JavaTableConfig.html" title="class in org.apache.samza.config">JavaTableConfig</a></dt>
@@ -3227,12 +3444,22 @@
<dd>
<div class="block">The base interface for all task factories (i.e.</div>
</dd>
+<dt><a href="org/apache/samza/job/model/TaskMode.html" title="enum in org.apache.samza.job.model"><span class="typeNameLink">TaskMode</span></a> - Enum in <a href="org/apache/samza/job/model/package-summary.html">org.apache.samza.job.model</a></dt>
+<dd>
+<div class="block">This defines the logical mode of a taskInstance.</div>
+</dd>
<dt><a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model"><span class="typeNameLink">TaskModel</span></a> - Class in <a href="org/apache/samza/job/model/package-summary.html">org.apache.samza.job.model</a></dt>
<dd>
<div class="block">This contains metadata about a Samza task, such as the stream partitions that it is consuming.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/TaskModel.html#TaskModel-org.apache.samza.container.TaskName-java.util.Set-org.apache.samza.Partition-org.apache.samza.job.model.TaskMode-">TaskModel(TaskName, Set<SystemStreamPartition>, Partition, TaskMode)</a></span> - Constructor for class org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model">TaskModel</a></dt>
+<dd>
+<div class="block">Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/TaskModel.html#TaskModel-org.apache.samza.container.TaskName-java.util.Set-org.apache.samza.Partition-">TaskModel(TaskName, Set<SystemStreamPartition>, Partition)</a></span> - Constructor for class org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model">TaskModel</a></dt>
-<dd> </dd>
+<dd>
+<div class="block">Create a TaskModel for an active task with the given taskName, SSPs, and changelogPartition.</div>
+</dd>
<dt><a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container"><span class="typeNameLink">TaskName</span></a> - Class in <a href="org/apache/samza/container/package-summary.html">org.apache.samza.container</a></dt>
<dd>
<div class="block">A unique identifier of a set of a SystemStreamPartitions that have been grouped by
@@ -3368,6 +3595,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/ContainerModel.html#toString--">toString()</a></span> - Method in class org.apache.samza.job.model.<a href="org/apache/samza/job/model/ContainerModel.html" title="class in org.apache.samza.job.model">ContainerModel</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/TaskMode.html#toString--">toString()</a></span> - Method in enum org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskMode.html" title="enum in org.apache.samza.job.model">TaskMode</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/TaskModel.html#toString--">toString()</a></span> - Method in class org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskModel.html" title="class in org.apache.samza.job.model">TaskModel</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Counter.html#toString--">toString()</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>
@@ -3382,6 +3611,16 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#toString--">toString()</a></span> - Method in class org.apache.samza.sql.<a href="org/apache/samza/sql/SamzaSqlRelRecord.html" title="class in org.apache.samza.sql">SamzaSqlRelRecord</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#toString--">toString()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint">Startpoint</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointOldest.html#toString--">toString()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint">StartpointOldest</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#toString--">toString()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint">StartpointSpecific</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#toString--">toString()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint">StartpointTimestamp</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointUpcoming.html#toString--">toString()</a></span> - Method in class org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint">StartpointUpcoming</a></dt>
+<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#toString--">toString()</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#toString--">toString()</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>
@@ -3495,6 +3734,10 @@
<dd>
<div class="block">Returns the enum constant of this type with the specified name.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/job/model/TaskMode.html#valueOf-java.lang.String-">valueOf(String)</a></span> - Static method in enum org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskMode.html" title="enum in org.apache.samza.job.model">TaskMode</a></dt>
+<dd>
+<div class="block">Returns the enum constant of this type with the specified name.</div>
+</dd>
[... 75 lines stripped ...]