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/03/19 05:31:15 UTC
svn commit: r1855804 [4/25] - in /samza/site: ./ archive/ blog/
case-studies/ community/ contribute/ css/ learn/documentation/versioned/
learn/documentation/versioned/api/
learn/documentation/versioned/api/javadocs/
learn/documentation/versioned/api/ja...
Modified: samza/site/learn/documentation/versioned/api/javadocs/index-all.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/index-all.html?rev=1855804&r1=1855803&r2=1855804&view=diff
==============================================================================
--- samza/site/learn/documentation/versioned/api/javadocs/index-all.html (original)
+++ samza/site/learn/documentation/versioned/api/javadocs/index-all.html Tue Mar 19 05:31:11 2019
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_181) on Sat Dec 08 21:12:57 PST 2018 -->
-<title>Index (samza-api 1.0.0 API)</title>
-<meta name="date" content="2018-12-08">
+<!-- Generated by javadoc (1.8.0_202) on Mon Mar 18 22:29:01 PDT 2019 -->
+<title>Index (samza-api 1.0.1-SNAPSHOT API)</title>
+<meta name="date" content="2019-03-18">
<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 1.0.0 API)";
+ parent.document.title="Index (samza-api 1.0.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -101,6 +101,24 @@
<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>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#addTableConfig-java.lang.String-java.lang.String-java.util.Map-">addTableConfig(String, String, Map<String, String>)</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt>
+<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/table/descriptors/RemoteTableDescriptor.html#addTablePartConfig-org.apache.samza.table.remote.TablePart-org.apache.samza.config.Config-java.util.Map-">addTablePartConfig(TablePart, Config, Map<String, String>)</a></span> - Method 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>
+<div class="block">Helper method to add table part config items 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>
@@ -113,6 +131,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>
@@ -197,6 +217,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
@@ -207,6 +242,12 @@
<div class="block">Expands the provided <a href="org/apache/samza/system/descriptors/InputDescriptor.html" title="class in org.apache.samza.system.descriptors"><code>InputDescriptor</code></a> to a sub-DAG of one or more operators on the <a href="org/apache/samza/application/descriptors/StreamApplicationDescriptor.html" title="interface in org.apache.samza.application.descriptors"><code>StreamApplicationDescriptor</code></a>,
and returns a new <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> with the combined results.</div>
</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>
@@ -228,6 +269,18 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/chooser/BaseMessageChooser.html#BaseMessageChooser--">BaseMessageChooser()</a></span> - Constructor for class org.apache.samza.system.chooser.<a href="org/apache/samza/system/chooser/BaseMessageChooser.html" title="class in org.apache.samza.system.chooser">BaseMessageChooser</a></dt>
<dd> </dd>
+<dt><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">BaseTableDescriptor</span></a><<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">K</a>,<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">V</a>,<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">D</a> extends <a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a><<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">K</a>,<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">V</a>,<a href="org/apache/samza/table/descriptors
/BaseTableDescriptor.html" title="type parameter in BaseTableDescriptor">D</a>>> - Class in <a href="org/apache/samza/table/descriptors/package-summary.html">org.apache.samza.table.descriptors</a></dt>
+<dd>
+<div class="block">Base class for all table descriptor implementations.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#BaseTableDescriptor-java.lang.String-">BaseTableDescriptor(String)</a></span> - Constructor for class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt>
+<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>
@@ -269,6 +322,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>
@@ -279,6 +334,12 @@
</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>
+</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>
@@ -307,10 +368,31 @@
</a>
<h2 class="title">C</h2>
<dl>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CACHE_SIZE">CACHE_SIZE</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CACHE_TABLE_ID">CACHE_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>
+<dt><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">CachingTableDescriptor</span></a><<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="type parameter in CachingTableDescriptor">K</a>,<a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html" title="type parameter in CachingTableDescriptor">V</a>> - Class in <a href="org/apache/samza/table/descriptors/package-summary.html">org.apache.samza.table.descriptors</a></dt>
+<dd>
+<div class="block">Table descriptor for a caching table.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CachingTableDescriptor-java.lang.String-org.apache.samza.table.descriptors.TableDescriptor-">CachingTableDescriptor(String, TableDescriptor<K, V, ?>)</a></span> - Constructor for 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>
+<div class="block">Constructs a table descriptor instance with internal cache</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#CachingTableDescriptor-java.lang.String-org.apache.samza.table.descriptors.TableDescriptor-org.apache.samza.table.descriptors.TableDescriptor-">CachingTableDescriptor(String, TableDescriptor<K, V, ?>, TableDescriptor<K, V, ?>)</a></span> - Constructor for 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>
+<div class="block">Constructs a table descriptor instance and specify a cache (as Table descriptor)
+ to be used for caching.</div>
+</dd>
<dt><a href="org/apache/samza/scheduler/CallbackScheduler.html" title="interface in org.apache.samza.scheduler"><span class="typeNameLink">CallbackScheduler</span></a> - Interface in <a href="org/apache/samza/scheduler/package-summary.html">org.apache.samza.scheduler</a></dt>
<dd>
<div class="block">Provides a way for applications to register some logic to be executed at a future time.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#changelogReplicationFactor">changelogReplicationFactor</a></span> - Variable 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> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#changelogStream">changelogStream</a></span> - Variable 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> </dd>
<dt><a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint"><span class="typeNameLink">Checkpoint</span></a> - Class in <a href="org/apache/samza/checkpoint/package-summary.html">org.apache.samza.checkpoint</a></dt>
<dd>
<div class="block">A checkpoint is a mapping of all the streams a job is consuming and the most recent current offset for each.</div>
@@ -321,8 +403,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>
@@ -366,6 +448,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
@@ -389,13 +473,13 @@
<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/descriptors/TableProvider.html#close--">close()</a></span> - Method in interface org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableProvider.html" title="interface in org.apache.samza.table.descriptors">TableProvider</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">Shutdown the underlying table</div>
+<div class="block">Close the table and release any resources acquired</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#close--">close()</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">Close the table and release any resources acquired</div>
+<div class="block">Shutdown the underlying table</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>
@@ -441,6 +525,8 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/job/CommandBuilder.html#config">config</a></span> - Variable in class org.apache.samza.job.<a href="org/apache/samza/job/CommandBuilder.html" title="class in org.apache.samza.job">CommandBuilder</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#config">config</a></span> - Variable in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt>
+<dd> </dd>
<dt><a href="org/apache/samza/config/ConfigException.html" title="class in org.apache.samza.config"><span class="typeNameLink">ConfigException</span></a> - Exception in <a href="org/apache/samza/config/package-summary.html">org.apache.samza.config</a></dt>
<dd>
<div class="block">Specific <a href="org/apache/samza/SamzaException.html" title="class in org.apache.samza"><code>SamzaException</code></a>s thrown from <a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config"><code>Config</code></a></div>
@@ -510,14 +596,24 @@
<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/context/ApplicationContainerContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">create(JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationContainerContextFactory.html" title="interface in org.apache.samza.context">ApplicationContainerContextFactory</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationContainerContextFactory.html#create-org.apache.samza.context.ExternalContext-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">create(ExternalContext, JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationContainerContextFactory.html" title="interface in org.apache.samza.context">ApplicationContainerContextFactory</a></dt>
<dd>
<div class="block">Creates an instance of the application-defined <a href="org/apache/samza/context/ApplicationContainerContext.html" title="interface in org.apache.samza.context"><code>ApplicationContainerContext</code></a>.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationTaskContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.context.TaskContext-org.apache.samza.context.ApplicationContainerContext-">create(JobContext, ContainerContext, TaskContext, ApplicationContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationTaskContextFactory.html" title="interface in org.apache.samza.context">ApplicationTaskContextFactory</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationContainerContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-">create(JobContext, ContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationContainerContextFactory.html" title="interface in org.apache.samza.context">ApplicationContainerContextFactory</a></dt>
+<dd>
+<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationTaskContextFactory.html#create-org.apache.samza.context.ExternalContext-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.context.TaskContext-org.apache.samza.context.ApplicationContainerContext-">create(ExternalContext, JobContext, ContainerContext, TaskContext, ApplicationContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationTaskContextFactory.html" title="interface in org.apache.samza.context">ApplicationTaskContextFactory</a></dt>
<dd>
<div class="block">Creates an instance of the application-defined <a href="org/apache/samza/context/ApplicationTaskContext.html" title="interface in org.apache.samza.context"><code>ApplicationTaskContext</code></a>.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/context/ApplicationTaskContextFactory.html#create-org.apache.samza.context.JobContext-org.apache.samza.context.ContainerContext-org.apache.samza.context.TaskContext-org.apache.samza.context.ApplicationContainerContext-">create(JobContext, ContainerContext, TaskContext, ApplicationContainerContext)</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/ApplicationTaskContextFactory.html" title="interface in org.apache.samza.context">ApplicationTaskContextFactory</a></dt>
+<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>
@@ -532,10 +628,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>
@@ -554,7 +658,11 @@
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Counter.html#dec-long-">dec(long)</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Counter.html" title="class in org.apache.samza.metrics">Counter</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/metadatastore/MetadataStore.html#delete-byte:A-">delete(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>
+<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>
</dd>
@@ -570,6 +678,10 @@
<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/table/remote/TableWriteFunction.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt>
+<dd>
+<div class="block">Delete the <code>record</code> with specified <code>key</code> from the remote store.</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>
@@ -578,14 +690,27 @@
<dd>
<div class="block">Deletes the mappings for the specified <code>keys</code> from this table.</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/remote/TableWriteFunction.html#deleteAll-java.util.Collection-">deleteAll(Collection<K>)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt>
+<dd>
+<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/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>
-<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/remote/TableWriteFunction.html#deleteAllAsync-java.util.Collection-">deleteAllAsync(Collection<K>)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt>
+<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/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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#deleteAsync-K-">deleteAsync(K)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt>
+<dd>
+<div class="block">Asynchronously delete the <code>record</code> with specified <code>key</code> from the remote store</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/scheduler/CallbackScheduler.html#deleteCallback-K-">deleteCallback(K)</a></span> - Method in interface org.apache.samza.scheduler.<a href="org/apache/samza/scheduler/CallbackScheduler.html" title="interface in org.apache.samza.scheduler">CallbackScheduler</a></dt>
<dd>
<div class="block">Delete the scheduled <code>callback</code> for the <code>key</code>.</div>
@@ -598,6 +723,10 @@
<dd>
<div class="block">Describes the inputs, outputs, state, configuration and processing logic using the provided <code>appDescriptor</code>.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/utils/SerdeUtils.html#deserialize-java.lang.String-java.lang.String-">deserialize(String, String)</a></span> - Static method in class org.apache.samza.table.utils.<a href="org/apache/samza/table/utils/SerdeUtils.html" title="class in org.apache.samza.table.utils">SerdeUtils</a></dt>
+<dd>
+<div class="block">Helper method to deserialize Java objects from Base64 strings</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
@@ -623,6 +752,8 @@
</a>
<h2 class="title">E</h2>
<dl>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/LocalTableDescriptor.html#enableChangelog">enableChangelog</a></span> - Variable 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> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#END_OF_STREAM_OFFSET">END_OF_STREAM_OFFSET</a></span> - Static variable 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/task/EndOfStreamListenerTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">EndOfStreamListenerTask</span></a> - Interface in <a href="org/apache/samza/task/package-summary.html">org.apache.samza.task</a></dt>
@@ -667,6 +798,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>
@@ -685,23 +822,17 @@
<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/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
their own <code>StreamExpander</code> function result types.</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>
+<dt><a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><span class="typeNameLink">ExternalContext</span></a> - Interface in <a href="org/apache/samza/context/package-summary.html">org.apache.samza.context</a></dt>
<dd>
-<div class="block">Interface extends the more generic SystemAdmin interface
- TODO: Merge this interface method with SystemAdmin when we upgrade to JDK 1.8</div>
+<div class="block">An <a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><code>ExternalContext</code></a> can be used to pass components created and managed outside of Samza into a Samza
+ application.</div>
</dd>
</dl>
<a name="I:F">
@@ -737,6 +868,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>
@@ -754,10 +887,14 @@
<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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#flush--">flush()</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a></dt>
+<dd>
+<div class="block">Flush the remote store (optional)</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 aggregated value as messages are added.</div>
@@ -803,12 +940,6 @@
<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/descriptors/TableProvider.html#generateConfig-org.apache.samza.config.Config-java.util.Map-">generateConfig(Config, Map<String, String>)</a></span> - Method in interface org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableProvider.html" title="interface in org.apache.samza.table.descriptors">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>
@@ -836,7 +967,9 @@
<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/MetadataStore.html#get-byte:A-">get(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>
+<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>
</dd>
@@ -850,10 +983,14 @@
</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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#get-K-">get(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">Gets the value associated with the specified <code>key</code>.</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#get-K-">get(K)</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>
+<div class="block">Fetch single table record for a 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>
@@ -862,14 +999,26 @@
<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/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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#getAll-java.util.List-">getAll(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">Gets the values with which the specified <code>keys</code> are associated.</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadableTable.html#getAllAsync-java.util.List-">getAllAsync(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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#getAll-java.util.Collection-">getAll(Collection<K>)</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>
+<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/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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#getAllAsync-java.util.Collection-">getAllAsync(Collection<K>)</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>
+<div class="block">Asynchronously fetch the table <code>records</code> for specified <code>keys</code>.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#getAllSystemStreams--">getAllSystemStreams()</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 the set of all available streams</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/context/Context.html#getApplicationContainerContext--">getApplicationContainerContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt>
<dd>
<div class="block">Gets the application-defined context for the current container.</div>
@@ -882,14 +1031,24 @@
<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/ReadableTable.html#getAsync-K-">getAsync(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>
+<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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#getAsync-K-">getAsync(K)</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>
+<div class="block">Asynchronously fetch single table record for a specified <code>key</code>.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Snapshot.html#getAverage--">getAverage()</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Snapshot.html" title="class in org.apache.samza.metrics">Snapshot</a></dt>
<dd>
<div class="block">Get the average of the values in the collection</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getBackoffType--">getBackoffType()</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/config/Config.html#getBoolean-java.lang.String-boolean-">getBoolean(String, boolean)</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#getBoolean-java.lang.String-">getBoolean(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
@@ -929,10 +1088,6 @@
</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/context/Context.html#getContainerContext--">getContainerContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt>
@@ -956,6 +1111,14 @@
<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>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getDate-java.lang.String-">getDate(String)</a></span> - Method in class org.apache.samza.config.<a href="org/apache/samza/config/Config.html" title="class in org.apache.samza.config">Config</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getDate-java.lang.String-java.lang.String-">getDate(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>
@@ -984,18 +1147,44 @@
<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>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getExponentialFactor--">getExponentialFactor()</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/table/retry/TableRetryPolicy.html#getExponentialMaxSleep--">getExponentialMaxSleep()</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/context/Context.html#getExternalContext--">getExternalContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt>
+<dd>
+<div class="block">Gets the <a href="org/apache/samza/context/ExternalContext.html" title="interface in org.apache.samza.context"><code>ExternalContext</code></a> that was created outside of the application.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/sql/SamzaSqlRelRecord.html#getField-java.lang.String-">getField(String)</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 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>
@@ -1008,6 +1197,14 @@
</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/internal/WindowInternal.html#getFoldLeftFunction--">getFoldLeftFunction()</a></span> - Method in class org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowInternal.html" title="class in org.apache.samza.operators.windows.internal">WindowInternal</a></dt>
<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#getForTable-java.lang.String-java.lang.String-java.lang.String-">getForTable(String, String, String)</a></span> - 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">Get table config value for a key</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/config/JavaTableConfig.html#getForTable-java.lang.String-java.lang.String-">getForTable(String, String)</a></span> - 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">Get table config value for a key</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/metrics/MetricsAccessor.html#getGaugeValues-java.lang.String-java.lang.String-">getGaugeValues(String, String)</a></span> - Method in interface org.apache.samza.metrics.<a href="org/apache/samza/metrics/MetricsAccessor.html" title="interface in org.apache.samza.metrics">MetricsAccessor</a></dt>
<dd>
<div class="block">Get the values of a gauge</div>
@@ -1024,10 +1221,6 @@
<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/system/descriptors/ExpandingInputDescriptorProvider.html#getInputDescriptor-java.lang.String-org.apache.samza.serializers.Serde-">getInputDescriptor(String, Serde)</a></span> - Method in interface org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors">ExpandingInputDescriptorProvider</a></dt>
@@ -1052,6 +1245,10 @@
<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/table/retry/TableRetryPolicy.html#getJitter--">getJitter()</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>
+<div class="block">Introduce randomness to the sleepTime time.</div>
+</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/context/Context.html#getJobContext--">getJobContext()</a></span> - Method in interface org.apache.samza.context.<a href="org/apache/samza/context/Context.html" title="interface in org.apache.samza.context">Context</a></dt>
@@ -1080,6 +1277,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/config/JavaTableConfig.html#getKeySerde-java.lang.String-">getKeySerde(String)</a></span> - 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">Get registry keys of key serde for this table</div>
+</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>
@@ -1104,6 +1305,14 @@
<dd>
<div class="block">Get the maximum value in the collection</div>
</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getMaxAttempts--">getMaxAttempts()</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>
+<div class="block">Termination after a fix number of attempts.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#getMaxDuration--">getMaxDuration()</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>
+<div class="block">Termination after a fixed duration.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/operators/windows/WindowPane.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows">WindowPane</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getMessage--">getMessage()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
@@ -1118,6 +1327,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>
@@ -1128,6 +1339,10 @@
</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/config/JavaTableConfig.html#getMsgSerde-java.lang.String-">getMsgSerde(String)</a></span> - 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">Get registry keys of value serde for this table</div>
+</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>
@@ -1142,10 +1357,6 @@
<dd>
<div class="block">Get the name of the timer</div>
</dd>
-<dt><span class="memberNameLink"><a href="org/apache/samza/system/ExtendedSystemAdmin.html#getNewestOffset-org.apache.samza.system.SystemStreamPartition-java.lang.Integer-">getNewestOffset(SystemStreamPartition, Integer)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/ExtendedSystemAdmin.html" title="interface in org.apache.samza.system">ExtendedSystemAdmin</a></dt>
-<dd>
-<div class="block"><span class="deprecatedLabel">Deprecated.</span></div>
-</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getNewestOffset--">getNewestOffset()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#getNewInstance-java.lang.String-">getNewInstance(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>
@@ -1153,7 +1364,9 @@
<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#getNumMessagesInQueue-org.apache.samza.system.SystemStreamPartition-">getNumMessagesInQueue(SystemStreamPartition)</a></span> - Method in class org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util">BlockingEnvelopeMap</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/IncomingMessageEnvelope.html#getOffset--">getOffset()</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></dt>
-<dd> </dd>
+<dd>
+<div class="block">Offset associated with this message, provided by the system consumer that consumed the message.</div>
+</dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html#getOffset-org.apache.samza.system.SystemStreamMetadata.OffsetType-">getOffset(SystemStreamMetadata.OffsetType)</a></span> - Method in class org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html" title="class in org.apache.samza.system">SystemStreamMetadata.SystemStreamPartitionMetadata</a></dt>
<dd> </dd>
<dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/Checkpoint.html#getOffsets--">getOffsets()</a></span> - Method in class org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a></dt>
@@ -1200,12 +1413,39 @@
<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>
+ of a input stream after the stream expansion or contraction.</div>
+</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/table/descriptors/BaseTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a></dt>
+<dd>
+<div class="block">Return the fully qualified class name of the <a href="org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table"><code>TableProviderFactory</code></a></div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method 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>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method in class org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.html" title="class in org.apache.samza.table.descriptors">GuavaCacheTableDescriptor</a></dt>
+<dd> </dd>
+<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName()</a></span> - Method 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/table/retry/TableRetryPolicy.html#getRandomMax--">getRandomMax()</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/table/retry/TableRetryPolicy.html#getRandomMin--">getRandomMin()</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>
[... 1204 lines stripped ...]