Modified: samza/site/learn/documentation/latest/api/javadocs/index-all.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index-all.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/index-all.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/index-all.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:36 PDT 2019 --> -<title>Index (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:03 PDT 2019 --> +<title>Index (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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.1.1-SNAPSHOT API)"; + parent.document.title="Index (samza-api 1.2.0 API)"; } } catch(err) { @@ -111,7 +111,7 @@ <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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#addTablePartConfig-java.lang.String-org.apache.samza.table.remote.TablePart-org.apache.samza.config.Config-java.util.Map-">addTablePartConfig(String, 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> @@ -221,20 +221,18 @@ <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> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/Startpoint.html#apply-IN-org.apache.samza.startpoint.StartpointVisitor-">apply(IN, StartpointVisitor<IN, OUT>)</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> +<div class="block">Applies the <a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><code>StartpointVisitor</code></a>'s visit methods to the <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> + and returns the result of that operation.</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointOldest.html#apply-IN-org.apache.samza.startpoint.StartpointVisitor-">apply(IN, StartpointVisitor<IN, OUT>)</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/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointSpecific.html#apply-IN-org.apache.samza.startpoint.StartpointVisitor-">apply(IN, StartpointVisitor<IN, OUT>)</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/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointTimestamp.html#apply-IN-org.apache.samza.startpoint.StartpointVisitor-">apply(IN, StartpointVisitor<IN, OUT>)</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/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointUpcoming.html#apply-IN-org.apache.samza.startpoint.StartpointVisitor-">apply(IN, StartpointVisitor<IN, OUT>)</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> @@ -286,6 +284,12 @@ <dd> <div class="block">Constructs a table descriptor instance</div> </dd> +<dt><a href="org/apache/samza/table/remote/BaseTableFunction.html" title="class in org.apache.samza.table.remote"><span class="typeNameLink">BaseTableFunction</span></a> - Class in <a href="org/apache/samza/table/remote/package-summary.html">org.apache.samza.table.remote</a></dt> +<dd> +<div class="block">Base class for all table read and write functions.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/BaseTableFunction.html#BaseTableFunction--">BaseTableFunction()</a></span> - Constructor for class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/BaseTableFunction.html" title="class in org.apache.samza.table.remote">BaseTableFunction</a></dt> +<dd> </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> @@ -687,7 +691,7 @@ <dd> <div class="block">Deletes the mapping for the specified <code>key</code> from this key-value store (if such mapping exists).</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#delete-K-">delete(K)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#delete-K-java.lang.Object...-">delete(K, Object...)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> <dd> <div class="block">Deletes the mapping for the specified <code>key</code> from this table (if such mapping exists).</div> </dd> @@ -699,7 +703,7 @@ <dd> <div class="block">Deletes the mappings for the specified <code>keys</code> from this key-value store (if such mappings exist).</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#deleteAll-java.util.List-">deleteAll(List<K>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#deleteAll-java.util.List-java.lang.Object...-">deleteAll(List<K>, Object...)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> <dd> <div class="block">Deletes the mappings for the specified <code>keys</code> from this table.</div> </dd> @@ -708,7 +712,7 @@ <div class="block">Delete all <code>records</code> with the specified <code>keys</code> from the remote store The default implementation calls deleteAllAsync and blocks on the completion afterwards.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#deleteAllAsync-java.util.List-java.lang.Object...-">deleteAllAsync(List<K>, Object...)</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> @@ -716,7 +720,12 @@ <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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#deleteAllAsync-java.util.Collection-java.lang.Object...-">deleteAllAsync(Collection<K>, Object...)</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> and additional arguments from + the remote store.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#deleteAsync-K-java.lang.Object...-">deleteAsync(K, Object...)</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> @@ -724,6 +733,10 @@ <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/table/remote/TableWriteFunction.html#deleteAsync-K-java.lang.Object...-">deleteAsync(K, Object...)</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> and additional arguments 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> @@ -1000,7 +1013,7 @@ </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/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#get-K-java.lang.Object...-">get(K, Object...)</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> @@ -1016,7 +1029,7 @@ <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/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#getAll-java.util.List-java.lang.Object...-">getAll(List<K>, Object...)</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> @@ -1024,7 +1037,7 @@ <dd> <div class="block">Fetch the table <code>records</code> for specified <code>keys</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#getAllAsync-java.util.List-java.lang.Object...-">getAllAsync(List<K>, Object...)</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> @@ -1032,6 +1045,10 @@ <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/table/remote/TableReadFunction.html#getAllAsync-java.util.Collection-java.lang.Object...-">getAllAsync(Collection<K>, Object...)</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> and additional arguments.</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> @@ -1052,7 +1069,7 @@ <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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#getAsync-K-java.lang.Object...-">getAsync(K, Object...)</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> @@ -1060,6 +1077,10 @@ <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/table/remote/TableReadFunction.html#getAsync-K-java.lang.Object...-">getAsync(K, Object...)</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> with additional arguments.</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> @@ -1132,10 +1153,14 @@ <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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html#getCredits-K-V-java.lang.Object...-">getCredits(K, V, Object...)</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/table/remote/TableRateLimiter.CreditFunction.html#getCredits-int-java.lang.Object...-">getCredits(int, Object...)</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>opId</code> and associated <code>args</code>.</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> @@ -1855,6 +1880,12 @@ <dd> <div class="block">Initializes the table during container initialization.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/BaseTableFunction.html#init-org.apache.samza.context.Context-org.apache.samza.table.AsyncReadWriteTable-">init(Context, AsyncReadWriteTable)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/BaseTableFunction.html" title="class in org.apache.samza.table.remote">BaseTableFunction</a></dt> +<dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableFunction.html#init-org.apache.samza.context.Context-org.apache.samza.table.AsyncReadWriteTable-">init(Context, AsyncReadWriteTable)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote">TableFunction</a></dt> +<dd> +<div class="block">Initializes the function before any operation.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/TableProvider.html#init-org.apache.samza.context.Context-">init(Context)</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">Initialize TableProvider with container and task context</div> @@ -1958,11 +1989,7 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/sql/schema/SqlFieldSchema.html#isPrimitiveField--">isPrimitiveField()</a></span> - Method in class org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlFieldSchema.html" title="class in org.apache.samza.sql.schema">SqlFieldSchema</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#isRetriable-java.lang.Throwable-">isRetriable(Throwable)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote">TableReadFunction</a></dt> -<dd> -<div class="block">Determine whether the current operation can be retried with the last thrown exception.</div> -</dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#isRetriable-java.lang.Throwable-">isRetriable(Throwable)</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> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableFunction.html#isRetriable-java.lang.Throwable-">isRetriable(Throwable)</a></span> - Method in interface org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote">TableFunction</a></dt> <dd> <div class="block">Determine whether the current operation can be retried with the last thrown exception.</div> </dd> @@ -2553,7 +2580,7 @@ <dd> <div class="block">Updates the mapping of the specified key-value pair; Associates the specified <code>key</code> with the specified <code>value</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#put-K-V-">put(K, V)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#put-K-V-java.lang.Object...-">put(K, V, Object...)</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">Updates the mapping of the specified key-value pair; Associates the specified <code>key</code> with the specified <code>value</code>.</div> @@ -2573,7 +2600,7 @@ <dd> <div class="block">Updates the mappings of the specified key-value <code>entries</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#putAll-java.util.List-">putAll(List<Entry<K, V>>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/ReadWriteTable.html" title="interface in org.apache.samza.table">ReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#putAll-java.util.List-java.lang.Object...-">putAll(List<Entry<K, V>>, Object...)</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">Updates the mappings of the specified key-value <code>entries</code>.</div> </dd> @@ -2586,7 +2613,7 @@ <div class="block">Place a collection of <a href="org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><code>IncomingMessageEnvelope</code></a> on the queue for the specified <a href="org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#putAllAsync-java.util.List-">putAllAsync(List<Entry<K, V>>)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#putAllAsync-java.util.List-java.lang.Object...-">putAllAsync(List<Entry<K, V>>, Object...)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Asynchronously updates the mappings of the specified key-value <code>entries</code>.</div> </dd> @@ -2594,7 +2621,11 @@ <dd> <div class="block">Asynchronously store the table <code>records</code> with specified <code>keys</code>.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#putAsync-K-V-">putAsync(K, V)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#putAllAsync-java.util.Collection-java.lang.Object...-">putAllAsync(Collection<Entry<K, V>>, Object...)</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 store the table <code>records</code> with specified <code>keys</code> and additional arguments.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#putAsync-K-V-java.lang.Object...-">putAsync(K, V, Object...)</a></span> - Method in interface org.apache.samza.table.<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a></dt> <dd> <div class="block">Asynchronously updates the mapping of the specified key-value pair; Associates the specified <code>key</code> with the specified <code>value</code>.</div> @@ -2603,6 +2634,10 @@ <dd> <div class="block">Asynchronously store single table <code>record</code> with specified <code>key</code>.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#putAsync-K-V-java.lang.Object...-">putAsync(K, V, Object...)</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 store single table <code>record</code> with specified <code>key</code> and additional arguments.</div> +</dd> </dl> <a name="I:R"> <!-- --> @@ -2620,6 +2655,10 @@ <div class="block">A rate limiter interface used by Samza components to limit throughput of operations against a resource.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#read-int-java.lang.Object...-">read(int, Object...)</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">Executes a read operation.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#READ_CREDIT_FN">READ_CREDIT_FN</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/table/descriptors/RemoteTableDescriptor.html#READ_FN">READ_FN</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> @@ -2635,6 +2674,14 @@ </dd> <dt><a href="org/apache/samza/metrics/ReadableMetricsRegistryListener.html" title="interface in org.apache.samza.metrics"><span class="typeNameLink">ReadableMetricsRegistryListener</span></a> - Interface in <a href="org/apache/samza/metrics/package-summary.html">org.apache.samza.metrics</a></dt> <dd> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/AsyncReadWriteTable.html#readAsync-int-java.lang.Object...-">readAsync(int, Object...)</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 executes a read operation.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableReadFunction.html#readAsync-int-java.lang.Object...-">readAsync(int, Object...)</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 read data from table for specified <code>opId</code> and additional arguments.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManager.html#readLastCheckpoint-org.apache.samza.container.TaskName-">readLastCheckpoint(TaskName)</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">Returns the last recorded checkpoint for a specified taskName.</div> @@ -2664,10 +2711,6 @@ <dd> <div class="block">Register a SystemStreamPartition to this SystemConsumer.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemConsumer.html#register-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.Startpoint-">register(SystemStreamPartition, Startpoint)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a></dt> -<dd> -<div class="block">Registers the <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> to the SystemConsumer.</div> -</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemProducer.html#register-java.lang.String-">register(String)</a></span> - Method in interface org.apache.samza.system.<a href="org/apache/samza/system/SystemProducer.html" title="interface in org.apache.samza.system">SystemProducer</a></dt> <dd> <div class="block">Registers this producer to send messages from a specified Samza source, such as a StreamTask.</div> @@ -2676,10 +2719,6 @@ <dd> <div class="block">Register a SystemStreamPartition to this SystemConsumer.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/util/BlockingEnvelopeMap.html#register-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.Startpoint-">register(SystemStreamPartition, Startpoint)</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> -<div class="block">Registers the <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> to the SystemConsumer.</div> -</dd> <dt><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html" title="class in org.apache.samza.table.descriptors"><span class="typeNameLink">RemoteTableDescriptor</span></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>> - 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 remote store backed tables</div> @@ -2706,6 +2745,10 @@ <dd> <div class="block">A reservoir interface to store, update and display values</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/system/SystemAdmin.html#resolveStartpointToOffset-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.Startpoint-">resolveStartpointToOffset(SystemStreamPartition, Startpoint)</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">Resolves the startpoint to a system specific offset.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/storage/StorageEngine.html#restore-java.util.Iterator-">restore(Iterator<IncomingMessageEnvelope>)</a></span> - Method in interface org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage">StorageEngine</a></dt> <dd> <div class="block">Restore the content of this StorageEngine from the changelog.</div> @@ -2825,11 +2868,13 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.operators.OutputStream-">sendTo(OutputStream<M>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt> <dd> -<div class="block">Allows sending messages in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to an <a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>.</div> +<div class="block">Allows sending messages in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to an <a href="org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a> and then propagates this + <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to the next chained operator</div> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/operators/MessageStream.html#sendTo-org.apache.samza.table.Table-">sendTo(Table<KV<K, V>>)</a></span> - Method in interface org.apache.samza.operators.<a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a></dt> <dd> -<div class="block">Sends messages in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to a <a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a>.</div> +<div class="block">Allows sending messages in this <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to a <a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a> and then propagates this + <a href="org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a> to the next chained operator.</div> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/config/Config.html#SENSITIVE_MASK">SENSITIVE_MASK</a></span> - Static variable 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> @@ -3060,10 +3105,6 @@ <dd> <div class="block">Startpoint represents a position in a stream partition.</div> </dd> -<dt><a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointCustom</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt> -<dd> -<div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents a custom startpoint.</div> -</dd> <dt><a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointOldest</span></a> - Class in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt> <dd> <div class="block">A <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents the earliest offset in a stream partition.</div> @@ -3096,9 +3137,9 @@ <dd> <div class="block">Constructs a <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a> that represents the latest offset in a stream partition.</div> </dd> -<dt><a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><span class="typeNameLink">StartpointVisitor</span></a> - Interface in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt> +<dt><a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><span class="typeNameLink">StartpointVisitor</span></a><<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="type parameter in StartpointVisitor">IN</a>,<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="type parameter in StartpointVisitor">OUT</a>> - Interface in <a href="org/apache/samza/startpoint/package-summary.html">org.apache.samza.startpoint</a></dt> <dd> -<div class="block">Visitor interface for system consumers to implement to support <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a>s.</div> +<div class="block">A <a href="org/apache/samza/system/SystemAdmin.html" title="interface in org.apache.samza.system"><code>SystemAdmin</code></a> implementation should implement this abstraction to support <a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><code>Startpoint</code></a>.</div> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/runtime/ApplicationRunner.html#status--">status()</a></span> - Method in interface org.apache.samza.runtime.<a href="org/apache/samza/runtime/ApplicationRunner.html" title="interface in org.apache.samza.runtime">ApplicationRunner</a></dt> <dd> @@ -3369,6 +3410,8 @@ </a> <h2 class="title">T</h2> <dl> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/BaseTableFunction.html#table">table</a></span> - Variable in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/BaseTableFunction.html" title="class in org.apache.samza.table.remote">BaseTableFunction</a></dt> +<dd> </dd> <dt><a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><span class="typeNameLink">Table</span></a><<a href="org/apache/samza/table/Table.html" title="type parameter in Table">R</a>> - Interface in <a href="org/apache/samza/table/package-summary.html">org.apache.samza.table</a></dt> <dd> <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> @@ -3383,6 +3426,10 @@ <dd> <div class="block">A <a href="org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors"><code>TableDescriptor</code></a> can be used for specifying Samza and implementation-specific properties of a <a href="org/apache/samza/table/Table.html" title="interface in org.apache.samza.table"><code>Table</code></a>.</div> </dd> +<dt><a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableFunction</span></a> - Interface in <a href="org/apache/samza/table/remote/package-summary.html">org.apache.samza.table.remote</a></dt> +<dd> +<div class="block">The root interface for table read and write function.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/BaseTableDescriptor.html#tableId">tableId</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/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TablePart</span></a> - Interface in <a href="org/apache/samza/table/remote/package-summary.html">org.apache.samza.table.remote</a></dt> @@ -3486,19 +3533,23 @@ </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/container/TaskName.html#TaskName-java.lang.String-">TaskName(String)</a></span> - Constructor for class org.apache.samza.container.<a href="org/apache/samza/container/TaskName.html" title="class in org.apache.samza.container">TaskName</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-K-">throttle(K)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-K-java.lang.Object...-">throttle(K, Object...)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> <dd> <div class="block">Throttle a request with a key argument if necessary.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-K-V-">throttle(K, V)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-K-V-java.lang.Object...-">throttle(K, V, Object...)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> <dd> <div class="block">Throttle a request with both the key and value arguments if necessary.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-java.util.Collection-">throttle(Collection<K>)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-int-java.lang.Object...-">throttle(int, Object...)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> +<dd> +<div class="block">Throttle a request with opId and associated arguments</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttle-java.util.Collection-java.lang.Object...-">throttle(Collection<K>, Object...)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> <dd> <div class="block">Throttle a request with a collection of keys as the argument if necessary.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttleRecords-java.util.Collection-">throttleRecords(Collection<Entry<K, V>>)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableRateLimiter.html#throttleRecords-java.util.Collection-java.lang.Object...-">throttleRecords(Collection<Entry<K, V>>, Object...)</a></span> - Method in class org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.html" title="class in org.apache.samza.table.remote">TableRateLimiter</a></dt> <dd> <div class="block">Throttle a request with a collection of table records as the argument if necessary.</div> </dd> @@ -3608,6 +3659,14 @@ <dd> <div class="block">Generate configuration for this building block.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/retry/TableRetryPolicy.html#toConfig-org.apache.samza.config.Config-org.apache.samza.config.Config-">toConfig(Config, Config)</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">Generate configuration for this building block.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/utils/SerdeUtils.html#toJson-java.lang.String-java.lang.Object-">toJson(String, Object)</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 serialize Java objects as json strings</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/Checkpoint.html#toString--">toString()</a></span> - Method in class org.apache.samza.checkpoint.<a href="org/apache/samza/checkpoint/Checkpoint.html" title="class in org.apache.samza.checkpoint">Checkpoint</a></dt> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/config/MapConfig.html#toString--">toString()</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> @@ -3865,25 +3924,21 @@ the order they are declared.</div> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/metrics/Timer.html#visit-org.apache.samza.metrics.MetricsVisitor-">visit(MetricsVisitor)</a></span> - Method in class org.apache.samza.metrics.<a href="org/apache/samza/metrics/Timer.html" title="class in org.apache.samza.metrics">Timer</a></dt> <dd> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointSpecific-">visit(SystemStreamPartition, StartpointSpecific)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> -<dd> -<div class="block">Seek to specific offset represented by <a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint"><code>StartpointSpecific</code></a></div> -</dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointTimestamp-">visit(SystemStreamPartition, StartpointTimestamp)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-IN-org.apache.samza.startpoint.StartpointSpecific-">visit(IN, StartpointSpecific)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> <dd> -<div class="block">Seek to timestamp offset represented by <a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint"><code>StartpointTimestamp</code></a></div> +<div class="block">Performs a sequence of operations using the <code>IN</code> and <a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint"><code>StartpointSpecific</code></a> and returns the result of the execution.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointOldest-">visit(SystemStreamPartition, StartpointOldest)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-IN-org.apache.samza.startpoint.StartpointTimestamp-">visit(IN, StartpointTimestamp)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> <dd> -<div class="block">Seek to earliest offset represented by <a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint"><code>StartpointOldest</code></a></div> +<div class="block">Performs a sequence of operations using the <code>IN</code> and <a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint"><code>StartpointTimestamp</code></a> and returns the result of the execution.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointUpcoming-">visit(SystemStreamPartition, StartpointUpcoming)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-IN-org.apache.samza.startpoint.StartpointOldest-">visit(IN, StartpointOldest)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> <dd> -<div class="block">Seek to latest offset represented by <a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint"><code>StartpointUpcoming</code></a></div> +<div class="block">Performs a sequence of operations using the <code>IN</code> and <a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint"><code>StartpointOldest</code></a> and returns the result of the execution.</div> </dd> -<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-org.apache.samza.system.SystemStreamPartition-org.apache.samza.startpoint.StartpointCustom-">visit(SystemStreamPartition, StartpointCustom)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> +<dt><span class="memberNameLink"><a href="org/apache/samza/startpoint/StartpointVisitor.html#visit-IN-org.apache.samza.startpoint.StartpointUpcoming-">visit(IN, StartpointUpcoming)</a></span> - Method in interface org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint">StartpointVisitor</a></dt> <dd> -<div class="block">Bootstrap signal represented by <a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint"><code>StartpointCustom</code></a></div> +<div class="block">Performs a sequence of operations using the <code>IN</code> and <a href="org/apache/samza/startpoint/StartpointUpcoming.html" title="class in org.apache.samza.startpoint"><code>StartpointUpcoming</code></a> and returns the result of the execution.</div> </dd> </dl> <a name="I:W"> @@ -4063,6 +4118,10 @@ the order they are declared.</div> <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.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withRateLimiterDisabled--">withRateLimiterDisabled()</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">Disable both read and write rate limiter.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadFunction-org.apache.samza.table.remote.TableReadFunction-">withReadFunction(TableReadFunction<K, V>)</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">Use specified TableReadFunction with remote table and a retry policy.</div> @@ -4071,6 +4130,10 @@ the order they are declared.</div> <dd> <div class="block">Specify the rate limit for table read operations.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRateLimiterDisabled--">withReadRateLimiterDisabled()</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">Disable the read rate limiter.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withReadRetryPolicy-org.apache.samza.table.retry.TableRetryPolicy-">withReadRetryPolicy(TableRetryPolicy)</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">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> @@ -4125,6 +4188,10 @@ the order they are declared.</div> <dd> <div class="block">Specify the rate limit for table write operations.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRateLimiterDisabled--">withWriteRateLimiterDisabled()</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">Disable the write rate limiter.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/RemoteTableDescriptor.html#withWriteRetryPolicy-org.apache.samza.table.retry.TableRetryPolicy-">withWriteRetryPolicy(TableRetryPolicy)</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">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> @@ -4133,6 +4200,10 @@ the order they are declared.</div> <dd> <div class="block">Specify the TTL for each write access, ie.</div> </dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/ReadWriteTable.html#write-int-java.lang.Object...-">write(int, Object...)</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">Executes a write operation.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#WRITE_AROUND">WRITE_AROUND</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/RemoteTableDescriptor.html#WRITE_CREDIT_FN">WRITE_CREDIT_FN</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> @@ -4143,6 +4214,14 @@ the order they are declared.</div> <dd> </dd> <dt><span class="memberNameLink"><a href="org/apache/samza/table/descriptors/CachingTableDescriptor.html#WRITE_TTL_MS">WRITE_TTL_MS</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/AsyncReadWriteTable.html#writeAsync-int-java.lang.Object...-">writeAsync(int, Object...)</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 executes a write operation.</div> +</dd> +<dt><span class="memberNameLink"><a href="org/apache/samza/table/remote/TableWriteFunction.html#writeAsync-int-java.lang.Object...-">writeAsync(int, Object...)</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 write data to table for specified <code>opId</code> and additional arguments.</div> +</dd> <dt><span class="memberNameLink"><a href="org/apache/samza/checkpoint/CheckpointManager.html#writeCheckpoint-org.apache.samza.container.TaskName-org.apache.samza.checkpoint.Checkpoint-">writeCheckpoint(TaskName, Checkpoint)</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">Writes a checkpoint based on the current state of a Samza stream partition.</div>
Modified: samza/site/learn/documentation/latest/api/javadocs/index.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/index.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/index.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/index.html Fri Jun 7 20:22:19 2019 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:36 PDT 2019 --> -<title>samza-api 1.1.1-SNAPSHOT API</title> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:03 PDT 2019 --> +<title>samza-api 1.2.0 API</title> <script type="text/javascript"> tmpTargetPage = "" + window.location.search; if (tmpTargetPage != "" && tmpTargetPage != "undefined") Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/Partition.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>Partition (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>Partition (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="Partition (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="Partition (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/SamzaException.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>SamzaException (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>SamzaException (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="SamzaException (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="SamzaException (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Evolving.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>InterfaceStability.Evolving (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>InterfaceStability.Evolving (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="InterfaceStability.Evolving (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability.Evolving (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Stable.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>InterfaceStability.Stable (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>InterfaceStability.Stable (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="InterfaceStability.Stable (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability.Stable (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.Unstable.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>InterfaceStability.Unstable (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>InterfaceStability.Unstable (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="InterfaceStability.Unstable (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability.Unstable (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/InterfaceStability.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>InterfaceStability (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>InterfaceStability (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="InterfaceStability (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="InterfaceStability (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-frame.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:36 PDT 2019 --> -<title>org.apache.samza.annotation (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:03 PDT 2019 --> +<title>org.apache.samza.annotation (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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/annotation/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-summary.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:36 PDT 2019 --> -<title>org.apache.samza.annotation (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:03 PDT 2019 --> +<title>org.apache.samza.annotation (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="org.apache.samza.annotation (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.annotation (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/annotation/package-tree.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:36 PDT 2019 --> -<title>org.apache.samza.annotation Class Hierarchy (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:03 PDT 2019 --> +<title>org.apache.samza.annotation Class Hierarchy (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="org.apache.samza.annotation Class Hierarchy (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.annotation Class Hierarchy (samza-api 1.2.0 API)"; } } catch(err) { @@ -86,9 +86,9 @@ </ul> <h2 title="Annotation Type Hierarchy">Annotation Type Hierarchy</h2> <ul> -<li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Evolving</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Unstable</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Stable.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Stable</span></a> (implements java.lang.annotation.Annotation)</li> +<li type="circle">org.apache.samza.annotation.<a href="../../../../org/apache/samza/annotation/InterfaceStability.Evolving.html" title="annotation in org.apache.samza.annotation"><span class="typeNameLink">InterfaceStability.Evolving</span></a> (implements java.lang.annotation.Annotation)</li> </ul> </div> <!-- ======= START OF BOTTOM NAVBAR ====== --> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/SamzaApplication.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/SamzaApplication.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/SamzaApplication.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/SamzaApplication.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>SamzaApplication (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>SamzaApplication (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="SamzaApplication (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="SamzaApplication (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/StreamApplication.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>StreamApplication (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>StreamApplication (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="StreamApplication (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="StreamApplication (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/TaskApplication.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/TaskApplication.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/TaskApplication.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/TaskApplication.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>TaskApplication (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>TaskApplication (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="TaskApplication (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="TaskApplication (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/ApplicationDescriptor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/ApplicationDescriptor.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/ApplicationDescriptor.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/ApplicationDescriptor.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>ApplicationDescriptor (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>ApplicationDescriptor (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="ApplicationDescriptor (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="ApplicationDescriptor (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/StreamApplicationDescriptor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/StreamApplicationDescriptor.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/StreamApplicationDescriptor.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/application/descriptors/StreamApplicationDescriptor.html Fri Jun 7 20:22:19 2019 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_202) on Mon Apr 15 15:43:35 PDT 2019 --> -<title>StreamApplicationDescriptor (samza-api 1.1.1-SNAPSHOT API)</title> -<meta name="date" content="2019-04-15"> +<!-- Generated by javadoc (1.8.0_121) on Thu Jun 06 15:02:02 PDT 2019 --> +<title>StreamApplicationDescriptor (samza-api 1.2.0 API)</title> +<meta name="date" content="2019-06-06"> <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="StreamApplicationDescriptor (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="StreamApplicationDescriptor (samza-api 1.2.0 API)"; } } catch(err) {
