You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by aj...@apache.org on 2023/01/18 19:33:31 UTC
svn commit: r1906774 [20/49] - in /samza/site: ./ archive/ blog/ case-studies/ community/ contribute/ img/latest/learn/documentation/api/ learn/documentation/latest/ learn/documentation/latest/api/ learn/documentation/latest/api/javadocs/ learn/documen...
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/LocalTableDescriptor.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/LocalTableDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/LocalTableDescriptor.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/LocalTableDescriptor.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>LocalTableDescriptor (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>LocalTableDescriptor (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="LocalTableDescriptor (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="LocalTableDescriptor (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/RemoteTableDescriptor.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>RemoteTableDescriptor (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>RemoteTableDescriptor (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="RemoteTableDescriptor (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="RemoteTableDescriptor (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -92,17 +91,17 @@ var activeTableTab = "activeTableTab";
<!-- ======== START OF CLASS DATA ======== -->
<div class="header">
<div class="subTitle">org.apache.samza.table.descriptors</div>
-<h2 title="Class RemoteTableDescriptor" class="title">Class RemoteTableDescriptor<K,V></h2>
+<h2 title="Class RemoteTableDescriptor" class="title">Class RemoteTableDescriptor<K,V,U></h2>
</div>
<div class="contentContainer">
<ul class="inheritance">
<li>java.lang.Object</li>
<li>
<ul class="inheritance">
-<li><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">org.apache.samza.table.descriptors.BaseTableDescriptor</a><K,V,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V>></li>
+<li><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">org.apache.samza.table.descriptors.BaseTableDescriptor</a><K,V,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V,U>></li>
<li>
<ul class="inheritance">
-<li>org.apache.samza.table.descriptors.RemoteTableDescriptor<K,V></li>
+<li>org.apache.samza.table.descriptors.RemoteTableDescriptor<K,V,U></li>
</ul>
</li>
</ul>
@@ -115,15 +114,16 @@ var activeTableTab = "activeTableTab";
<dt><span class="paramLabel">Type Parameters:</span></dt>
<dd><code>K</code> - the type of the key</dd>
<dd><code>V</code> - the type of the value</dd>
+<dd><code>U</code> - the type of the update</dd>
</dl>
<dl>
<dt>All Implemented Interfaces:</dt>
-<dd><a href="../../../../../org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors">TableDescriptor</a><K,V,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V>></dd>
+<dd><a href="../../../../../org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors">TableDescriptor</a><K,V,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V,U>></dd>
</dl>
<hr>
<br>
-<pre>public class <span class="typeNameLabel">RemoteTableDescriptor<K,V></span>
-extends <a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a><K,V,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V>></pre>
+<pre>public class <span class="typeNameLabel">RemoteTableDescriptor<K,V,U></span>
+extends <a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html" title="class in org.apache.samza.table.descriptors">BaseTableDescriptor</a><K,V,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V,U>></pre>
<div class="block">Table descriptor for remote store backed tables</div>
</li>
</ul>
@@ -278,18 +278,20 @@ extends <a href="../../../../../org/apac
</td>
</tr>
<tr id="i4" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withAsyncCallbackExecutorPoolSize-int-">withAsyncCallbackExecutorPoolSize</a></span>(int poolSize)</code>
<div class="block">Specify the size of the thread pool for the executor used to execute
callbacks of CompletableFutures of async Table operations.</div>
</td>
</tr>
<tr id="i5" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withBatchProvider-org.apache.samza.table.batching.BatchProvider-">withBatchProvider</a></span>(<a href="../../../../../org/apache/samza/table/batching/BatchProvider.html" title="class in org.apache.samza.table.batching">BatchProvider</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> batchProvider)</code> </td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withBatchProvider-org.apache.samza.table.batching.BatchProvider-">withBatchProvider</a></span>(<a href="../../../../../org/apache/samza/table/batching/BatchProvider.html" title="class in org.apache.samza.table.batching">BatchProvider</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> batchProvider)</code>
+<div class="block">Specifies a batch provider inorder to batch Table operations.</div>
+</td>
</tr>
<tr id="i6" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiter-org.apache.samza.util.RateLimiter-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-">withRateLimiter</a></span>(<a href="../../../../../org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a> rateLimiter,
<a href="../../../../../org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> readCreditFn,
<a href="../../../../../org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> writeCreditFn)</code>
@@ -298,55 +300,55 @@ extends <a href="../../../../../org/apac
</td>
</tr>
<tr id="i7" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiterDisabled--">withRateLimiterDisabled</a></span>()</code>
<div class="block">Disable both read and write rate limiter.</div>
</td>
</tr>
<tr id="i8" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadFunction-org.apache.samza.table.remote.TableReadFunction-">withReadFunction</a></span>(<a href="../../../../../org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> readFn)</code>
<div class="block">Use specified TableReadFunction with remote table and a retry policy.</div>
</td>
</tr>
<tr id="i9" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRateLimit-int-">withReadRateLimit</a></span>(int creditsPerSec)</code>
<div class="block">Specify the rate limit for table read operations.</div>
</td>
</tr>
<tr id="i10" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRateLimiterDisabled--">withReadRateLimiterDisabled</a></span>()</code>
<div class="block">Disable the read rate limiter.</div>
</td>
</tr>
<tr id="i11" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRetryPolicy-org.apache.samza.table.retry.TableRetryPolicy-">withReadRetryPolicy</a></span>(<a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a> retryPolicy)</code>
<div class="block">Use specified <a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry"><code>TableRetryPolicy</code></a> with the <a href="../../../../../org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><code>TableReadFunction</code></a>.</div>
</td>
</tr>
<tr id="i12" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteFunction-org.apache.samza.table.remote.TableWriteFunction-">withWriteFunction</a></span>(<a href="../../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> writeFn)</code>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteFunction-org.apache.samza.table.remote.TableWriteFunction-">withWriteFunction</a></span>(<a href="../../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> writeFn)</code>
<div class="block">Use specified TableWriteFunction with remote table and a retry policy.</div>
</td>
</tr>
<tr id="i13" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRateLimit-int-">withWriteRateLimit</a></span>(int creditsPerSec)</code>
<div class="block">Specify the rate limit for table write operations.</div>
</td>
</tr>
<tr id="i14" class="altColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRateLimiterDisabled--">withWriteRateLimiterDisabled</a></span>()</code>
<div class="block">Disable the write rate limiter.</div>
</td>
</tr>
<tr id="i15" class="rowColor">
-<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>></code></td>
+<td class="colFirst"><code><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>></code></td>
<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRetryPolicy-org.apache.samza.table.retry.TableRetryPolicy-">withWriteRetryPolicy</a></span>(<a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a> retryPolicy)</code>
<div class="block">Use specified <a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry"><code>TableRetryPolicy</code></a> with the <a href="../../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><code>TableWriteFunction</code></a>.</div>
</td>
@@ -619,7 +621,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withReadFunction</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withReadFunction(<a href="../../../../../org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> readFn)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withReadFunction(<a href="../../../../../org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTab
leDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> readFn)</pre>
<div class="block">Use specified TableReadFunction with remote table and a retry policy.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -635,7 +637,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withWriteFunction</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withWriteFunction(<a href="../../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> writeFn)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withWriteFunction(<a href="../../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote">TableWriteFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/Remote
TableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> writeFn)</pre>
<div class="block">Use specified TableWriteFunction with remote table and a retry policy.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -651,7 +653,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withReadRetryPolicy</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withReadRetryPolicy(<a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a> retryPolicy)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withReadRetryPolicy(<a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a> retryPolicy)</pre>
<div class="block">Use specified <a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry"><code>TableRetryPolicy</code></a> with the <a href="../../../../../org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><code>TableReadFunction</code></a>.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -667,7 +669,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withWriteRetryPolicy</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withWriteRetryPolicy(<a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a> retryPolicy)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withWriteRetryPolicy(<a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry">TableRetryPolicy</a> retryPolicy)</pre>
<div class="block">Use specified <a href="../../../../../org/apache/samza/table/retry/TableRetryPolicy.html" title="class in org.apache.samza.table.retry"><code>TableRetryPolicy</code></a> with the <a href="../../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><code>TableWriteFunction</code></a>.</div>
<dl>
<dt><span class="paramLabel">Parameters:</span></dt>
@@ -683,9 +685,9 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withRateLimiter</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withRateLimiter(<a href="../../../../../org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a> rateLimiter,
- <a href="../../../../../org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> readCreditFn,
- <a href="../../../../../org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> writeCreditFn)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withRateLimiter(<a href="../../../../../org/apache/samza/util/RateLimiter.html" title="interface in org.apache.samza.util">RateLimiter</a> rateLimiter,
+ <a href="../../../../../org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> readCreditFn,
+ <a href="../../../../../org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote">TableRateLimiter.CreditFunction</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> writeCreditFn)</pre>
<div class="block">Specify a rate limiter along with credit functions to map a table record (as KV) to the amount
of credits to be charged from the rate limiter for table read and write operations.
This is an advanced API that provides greater flexibility to throttle each record in the table
@@ -708,12 +710,13 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withRateLimiterDisabled</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withRateLimiterDisabled()</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withRateLimiterDisabled()</pre>
<div class="block">Disable both read and write rate limiter. If the read rate limiter is enabled, the user must provide a rate limiter
by calling <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiter-org.apache.samza.util.RateLimiter-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-"><code>withRateLimiter(RateLimiter, TableRateLimiter.CreditFunction, TableRateLimiter.CreditFunction)</code></a>
- or <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRateLimit-int-"><code>withReadRateLimit(int)</code></a>. If the write rate limiter is enabled, the user must provide a rate limiter
- by calling <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiter-org.apache.samza.util.RateLimiter-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-"><code>withRateLimiter(RateLimiter, TableRateLimiter.CreditFunction, TableRateLimiter.CreditFunction)</code></a>
- or <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRateLimit-int-"><code>withWriteRateLimit(int)</code></a>. By default, both read and write rate limiters are enabled.</div>
+ or <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRateLimit-int-"><code>withReadRateLimit(int)</code></a>. If the write rate limiter is enabled,
+ the user must provide a rate limiter by calling <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiter-org.apache.samza.util.RateLimiter-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-"><code>withRateLimiter(RateLimiter, TableRateLimiter.CreditFunction,
+ TableRateLimiter.CreditFunction)</code></a> or <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRateLimit-int-"><code>withWriteRateLimit(int)</code></a>.
+ By default, both read and write rate limiters are enabled.</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>this table descriptor instance.</dd>
@@ -726,7 +729,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withReadRateLimiterDisabled</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withReadRateLimiterDisabled()</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withReadRateLimiterDisabled()</pre>
<div class="block">Disable the read rate limiter.</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -740,7 +743,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withWriteRateLimiterDisabled</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withWriteRateLimiterDisabled()</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withWriteRateLimiterDisabled()</pre>
<div class="block">Disable the write rate limiter.</div>
<dl>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -754,7 +757,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withReadRateLimit</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withReadRateLimit(int creditsPerSec)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withReadRateLimit(int creditsPerSec)</pre>
<div class="block">Specify the rate limit for table read operations. If the read rate limit is set with this method
it is invalid to call <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiter-org.apache.samza.util.RateLimiter-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-"><code>withRateLimiter(RateLimiter,
TableRateLimiter.CreditFunction, TableRateLimiter.CreditFunction)</code></a>
@@ -775,7 +778,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withWriteRateLimit</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withWriteRateLimit(int creditsPerSec)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withWriteRateLimit(int creditsPerSec)</pre>
<div class="block">Specify the rate limit for table write operations. If the write rate limit is set with this method
it is invalid to call <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiter-org.apache.samza.util.RateLimiter-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-org.apache.samza.table.remote.TableRateLimiter.CreditFunction-"><code>withRateLimiter(RateLimiter,
TableRateLimiter.CreditFunction, TableRateLimiter.CreditFunction)</code></a>
@@ -796,7 +799,7 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withAsyncCallbackExecutorPoolSize</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withAsyncCallbackExecutorPoolSize(int poolSize)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withAsyncCallbackExecutorPoolSize(int poolSize)</pre>
<div class="block">Specify the size of the thread pool for the executor used to execute
callbacks of CompletableFutures of async Table operations. By default, these
futures are completed (called) by the threads of the native store client. Depending
@@ -818,7 +821,8 @@ extends <a href="../../../../../org/apac
<ul class="blockList">
<li class="blockList">
<h4>withBatchProvider</h4>
-<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> withBatchProvider(<a href="../../../../../org/apache/samza/table/batching/BatchProvider.html" title="class in org.apache.samza.table.batching">BatchProvider</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>> batchProvider)</pre>
+<pre>public <a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> withBatchProvider(<a href="../../../../../org/apache/samza/table/batching/BatchProvider.html" title="class in org.apache.samza.table.batching">BatchProvider</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescr
iptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>> batchProvider)</pre>
+<div class="block">Specifies a batch provider inorder to batch Table operations.</div>
</li>
</ul>
<a name="getProviderFactoryClassName--">
@@ -832,7 +836,7 @@ extends <a href="../../../../../org/apac
<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>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName</a></code> in class <code><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/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descri
ptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>>></code></dd>
+<dd><code><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html#getProviderFactoryClassName--">getProviderFactoryClassName</a></code> in class <code><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/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descri
ptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>>></code></dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>class name of the <a href="../../../../../org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table"><code>TableProviderFactory</code></a></dd>
</dl>
@@ -856,9 +860,9 @@ extends <a href="../../../../../org/apac
is expected to have already been generated and stored in the <code>jobConfig</code>.</div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/samza/table/descriptors/TableDescriptor.html#toConfig-org.apache.samza.config.Config-">toConfig</a></code> in interface <code><a href="../../../../../org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors">TableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/Remote
TableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>>></code></dd>
+<dd><code><a href="../../../../../org/apache/samza/table/descriptors/TableDescriptor.html#toConfig-org.apache.samza.config.Config-">toConfig</a></code> in interface <code><a href="../../../../../org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors">TableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/Remote
TableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>>></code></dd>
<dt><span class="overrideSpecifyLabel">Overrides:</span></dt>
-<dd><code><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html#toConfig-org.apache.samza.config.Config-">toConfig</a></code> in class <code><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/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/Re
moteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>>></code></dd>
+<dd><code><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html#toConfig-org.apache.samza.config.Config-">toConfig</a></code> in class <code><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/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/Re
moteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>>></code></dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>jobConfig</code> - job configuration</dd>
<dt><span class="returnLabel">Returns:</span></dt>
@@ -877,7 +881,7 @@ extends <a href="../../../../../org/apac
<div class="block">Validate that this table descriptor is constructed properly; this method is used internally.</div>
<dl>
<dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
-<dd><code><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html#validate--">validate</a></code> in class <code><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/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" titl
e="type parameter in RemoteTableDescriptor">V</a>>></code></dd>
+<dd><code><a href="../../../../../org/apache/samza/table/descriptors/BaseTableDescriptor.html#validate--">validate</a></code> in class <code><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/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">K</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" titl
e="type parameter in RemoteTableDescriptor">V</a>,<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="type parameter in RemoteTableDescriptor">U</a>>></code></dd>
</dl>
</li>
</ul>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/TableDescriptor.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/TableDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/TableDescriptor.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/TableDescriptor.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>TableDescriptor (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>TableDescriptor (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="TableDescriptor (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="TableDescriptor (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -127,10 +126,10 @@ public interface <span class="typeNameLa
</pre>
For High Level API <a href="../../../../../org/apache/samza/application/StreamApplication.html" title="interface in org.apache.samza.application"><code>StreamApplication</code></a>s, use <a href="../../../../../org/apache/samza/application/descriptors/StreamApplicationDescriptor.html#getTable-org.apache.samza.table.descriptors.TableDescriptor-"><code>StreamApplicationDescriptor.getTable(TableDescriptor)</code></a> to
obtain the corresponding <a href="../../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> instance that can be used with the <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> operators like
- <a href="../../../../../org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.table.Table-java.lang.Object...-"><code>MessageStream.sendTo(Table, Object[])</code></a>. Alternatively, use <a href="../../../../../org/apache/samza/context/TaskContext.html#getTable-java.lang.String-"><code>TaskContext.getTable(String)</code></a> in
- <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.context.Context-"><code>InitableFunction.init(org.apache.samza.context.Context)</code></a> to get the table instance for use within operator functions. For Low Level API
- <a href="../../../../../org/apache/samza/application/TaskApplication.html" title="interface in org.apache.samza.application"><code>TaskApplication</code></a>s, use <a href="../../../../../org/apache/samza/context/TaskContext.html#getTable-java.lang.String-"><code>TaskContext.getTable(String)</code></a> in <a href="../../../../../org/apache/samza/task/InitableTask.html#init-org.apache.samza.context.Context-"><code>InitableTask.init(org.apache.samza.context.Context)</code></a> to get the
- table instance for use within the Task.</div>
+ <a href="../../../../../org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.table.Table-"><code>MessageStream.sendTo(Table)</code></a>. Alternatively, use <a href="../../../../../org/apache/samza/context/TaskContext.html#getTable-java.lang.String-"><code>TaskContext.getTable(String)</code></a> or
+ <a href="../../../../../org/apache/samza/context/TaskContext.html#getUpdatableTable-java.lang.String-"><code>TaskContext.getUpdatableTable(String)</code></a> in <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.context.Context-"><code>InitableFunction.init(org.apache.samza.context.Context)</code></a> to get the table instance for use
+ within operator functions. For Low Level API <a href="../../../../../org/apache/samza/application/TaskApplication.html" title="interface in org.apache.samza.application"><code>TaskApplication</code></a>s, use <a href="../../../../../org/apache/samza/context/TaskContext.html#getTable-java.lang.String-"><code>TaskContext.getTable(String)</code></a> in
+ <a href="../../../../../org/apache/samza/task/InitableTask.html#init-org.apache.samza.context.Context-"><code>InitableTask.init(org.apache.samza.context.Context)</code></a> to get the table instance for use within the Task.</div>
</li>
</ul>
</div>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-frame.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-frame.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-frame.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>org.apache.samza.table.descriptors (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>org.apache.samza.table.descriptors (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-summary.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-summary.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-summary.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>org.apache.samza.table.descriptors (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>org.apache.samza.table.descriptors (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.samza.table.descriptors (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.table.descriptors (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -129,7 +128,7 @@
</td>
</tr>
<tr class="rowColor">
-<td class="colFirst"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V></td>
+<td class="colFirst"><a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors">RemoteTableDescriptor</a><K,V,U></td>
<td class="colLast">
<div class="block">Table descriptor for remote store backed tables</div>
</td>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-tree.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-tree.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/descriptors/package-tree.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>org.apache.samza.table.descriptors Class Hierarchy (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>org.apache.samza.table.descriptors Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.samza.table.descriptors Class Hierarchy (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.table.descriptors Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -89,7 +88,7 @@
</ul>
</li>
<li type="circle">org.apache.samza.table.descriptors.<a href="../../../../../org/apache/samza/table/descriptors/LocalTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">LocalTableDescriptor</span></a><K,V,D></li>
-<li type="circle">org.apache.samza.table.descriptors.<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">RemoteTableDescriptor</span></a><K,V></li>
+<li type="circle">org.apache.samza.table.descriptors.<a href="../../../../../org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">RemoteTableDescriptor</span></a><K,V,U></li>
</ul>
</li>
</ul>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-frame.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-frame.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-frame.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>org.apache.samza.table (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>org.apache.samza.table (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -13,12 +12,17 @@
<div class="indexContainer">
<h2 title="Interfaces">Interfaces</h2>
<ul title="Interfaces">
-<li><a href="AsyncReadWriteTable.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">AsyncReadWriteTable</span></a></li>
+<li><a href="AsyncReadWriteUpdateTable.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">AsyncReadWriteUpdateTable</span></a></li>
<li><a href="ReadWriteTable.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">ReadWriteTable</span></a></li>
+<li><a href="ReadWriteUpdateTable.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">ReadWriteUpdateTable</span></a></li>
<li><a href="Table.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">Table</span></a></li>
<li><a href="TableProvider.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">TableProvider</span></a></li>
<li><a href="TableProviderFactory.html" title="interface in org.apache.samza.table" target="classFrame"><span class="interfaceName">TableProviderFactory</span></a></li>
</ul>
+<h2 title="Exceptions">Exceptions</h2>
+<ul title="Exceptions">
+<li><a href="RecordNotFoundException.html" title="class in org.apache.samza.table" target="classFrame">RecordNotFoundException</a></li>
+</ul>
</div>
</body>
</html>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-summary.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-summary.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-summary.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>org.apache.samza.table (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>org.apache.samza.table (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.samza.table (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.table (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -82,36 +81,61 @@
</tr>
<tbody>
<tr class="altColor">
-<td class="colFirst"><a href="../../../../org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a><K,V></td>
+<td class="colFirst"><a href="../../../../org/apache/samza/table/AsyncReadWriteUpdateTable.html" title="interface in org.apache.samza.table">AsyncReadWriteUpdateTable</a><K,V,U></td>
<td class="colLast">
-<div class="block">A table that supports asynchronous get, put and delete by one or more keys</div>
+<div class="block">A table that supports asynchronous get, put, update and delete by one or more keys</div>
</td>
</tr>
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a><K,V></td>
<td class="colLast">
-<div class="block">A table that supports synchronous and asynchronousget, put and delete by one or more keys</div>
+<div class="block">A table that supports synchronous and asynchronous get, put and delete by one or more keys</div>
</td>
</tr>
<tr class="altColor">
+<td class="colFirst"><a href="../../../../org/apache/samza/table/ReadWriteUpdateTable.html" title="interface in org.apache.samza.table">ReadWriteUpdateTable</a><K,V,U></td>
+<td class="colLast">
+<div class="block">A table that supports synchronous and asynchronous get, put, update and delete by one or more keys</div>
+</td>
+</tr>
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table">Table</a><R></td>
<td class="colLast">
<div class="block">A <a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> is an abstraction for data sources that support random access by key.</div>
</td>
</tr>
-<tr class="rowColor">
+<tr class="altColor">
<td class="colFirst"><a href="../../../../org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table">TableProvider</a></td>
<td class="colLast">
<div class="block">A table provider provides the implementation for a table.</div>
</td>
</tr>
-<tr class="altColor">
+<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table">TableProviderFactory</a></td>
<td class="colLast">
<div class="block">Factory of a table provider object</div>
</td>
</tr>
</tbody>
+</table>
+</li>
+<li class="blockList">
+<table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Exception Summary table, listing exceptions, and an explanation">
+<caption><span>Exception Summary</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Exception</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="../../../../org/apache/samza/table/RecordNotFoundException.html" title="class in org.apache.samza.table">RecordNotFoundException</a></td>
+<td class="colLast">
+<div class="block">Custom exception which can be thrown by implementations of <a href="../../../../org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><code>TableWriteFunction</code></a>
+ when <a href="../../../../org/apache/samza/table/AsyncReadWriteUpdateTable.html#updateAsync-K-U-"><code>AsyncReadWriteUpdateTable.updateAsync(Object, Object)</code></a> fails due an existing record not being
+ present for the given key.</div>
+</td>
+</tr>
+</tbody>
</table>
</li>
</ul>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-tree.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-tree.html?rev=1906774&r1=1906773&r2=1906774&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/table/package-tree.html Wed Jan 18 19:33:25 2023
@@ -2,9 +2,8 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 -->
-<title>org.apache.samza.table Class Hierarchy (samza-api 1.7.0-SNAPSHOT API)</title>
-<meta name="date" content="2021-02-04">
+<!-- Generated by javadoc -->
+<title>org.apache.samza.table Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)</title>
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -12,7 +11,7 @@
<script type="text/javascript"><!--
try {
if (location.href.indexOf('is-external=true') == -1) {
- parent.document.title="org.apache.samza.table Class Hierarchy (samza-api 1.7.0-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.table Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)";
}
}
catch(err) {
@@ -76,16 +75,40 @@
</ul>
</div>
<div class="contentContainer">
+<h2 title="Class Hierarchy">Class Hierarchy</h2>
+<ul>
+<li type="circle">java.lang.Object
+<ul>
+<li type="circle">java.lang.Throwable (implements java.io.Serializable)
+<ul>
+<li type="circle">java.lang.Exception
+<ul>
+<li type="circle">java.lang.RuntimeException
+<ul>
+<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/RecordNotFoundException.html" title="class in org.apache.samza.table"><span class="typeNameLink">RecordNotFoundException</span></a></li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
<h2 title="Interface Hierarchy">Interface Hierarchy</h2>
<ul>
<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><span class="typeNameLink">Table</span></a><R>
<ul>
-<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">AsyncReadWriteTable</span></a><K,V>
+<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/AsyncReadWriteUpdateTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">AsyncReadWriteUpdateTable</span></a><K,V,U>
+<ul>
+<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/ReadWriteUpdateTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadWriteUpdateTable</span></a><K,V,U>
<ul>
<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table"><span class="typeNameLink">ReadWriteTable</span></a><K,V></li>
</ul>
</li>
</ul>
+</li>
+</ul>
</li>
<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/TableProvider.html" title="interface in org.apache.samza.table"><span class="typeNameLink">TableProvider</span></a></li>
<li type="circle">org.apache.samza.table.<a href="../../../../org/apache/samza/table/TableProviderFactory.html" title="interface in org.apache.samza.table"><span class="typeNameLink">TableProviderFactory</span></a></li>