Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/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.util (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.util (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.util (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.util (samza-api 1.2.0 API)"; } } catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/util/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.util 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.util 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.util Class Hierarchy (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="org.apache.samza.util Class Hierarchy (samza-api 1.2.0 API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/overview-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-frame.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/overview-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/overview-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>Overview List (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>Overview List (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/overview-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-summary.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/overview-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/overview-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>Overview (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>Overview (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="Overview (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="Overview (samza-api 1.2.0 API)"; } } catch(err) { @@ -69,7 +69,7 @@ </a></div> <!-- ========= END OF TOP NAVBAR ========= --> <div class="header"> -<h1 class="title">samza-api 1.1.1-SNAPSHOT API</h1> +<h1 class="title">samza-api 1.2.0 API</h1> </div> <div class="contentContainer"> <table class="overviewSummary" border="0" cellpadding="3" cellspacing="0" summary="Packages table, listing packages, and an explanation"> Modified: samza/site/learn/documentation/latest/api/javadocs/overview-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/overview-tree.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/overview-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/overview-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>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>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="Class Hierarchy (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="Class Hierarchy (samza-api 1.2.0 API)"; } } catch(err) { @@ -132,6 +132,7 @@ <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> </ul> </li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/BaseTableFunction.html" title="class in org.apache.samza.table.remote"><span class="typeNameLink">BaseTableFunction</span></a> (implements org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote">TableFunction</a>)</li> <li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap</span></a> (implements org.apache.samza.system.<a href="org/apache/samza/system/SystemConsumer.html" title="interface in org.apache.samza.system">SystemConsumer</a>)</li> <li type="circle">org.apache.samza.util.<a href="org/apache/samza/util/BlockingEnvelopeMap.BlockingEnvelopeMapMetrics.html" title="class in org.apache.samza.util"><span class="typeNameLink">BlockingEnvelopeMap.BlockingEnvelopeMapMetrics</span></a></li> <li type="circle">org.apache.samza.serializers.<a href="org/apache/samza/serializers/ByteBufferSerde.html" title="class in org.apache.samza.serializers"><span class="typeNameLink">ByteBufferSerde</span></a> (implements org.apache.samza.serializers.<a href="org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><T>)</li> @@ -201,7 +202,6 @@ <li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SqlSchemaBuilder.html" title="class in org.apache.samza.sql.schema"><span class="typeNameLink">SqlSchemaBuilder</span></a></li> <li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/Startpoint.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">Startpoint</span></a> <ul> -<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointCustom.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointCustom</span></a></li> <li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointOldest.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointOldest</span></a></li> <li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointSpecific.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointSpecific</span></a></li> <li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointTimestamp.html" title="class in org.apache.samza.startpoint"><span class="typeNameLink">StartpointTimestamp</span></a></li> @@ -308,8 +308,14 @@ <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SinkFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SupplierFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SupplierFunction</span></a><T> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableFunction</span></a> (also extends java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>) +<ul> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V></li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V></li> +</ul> +</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V></li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V></li> </ul> </li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/ClosableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">ClosableTask</span></a></li> @@ -337,8 +343,6 @@ <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SinkFunction</span></a><M> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SupplierFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SupplierFunction</span></a><T> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> </ul> </li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/InitableTask.html" title="interface in org.apache.samza.task"><span class="typeNameLink">InitableTask</span></a></li> @@ -412,10 +416,14 @@ <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/StreamExpander.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">StreamExpander</span></a><OM></li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">StreamTableJoinFunction</span></a><K,M,R,JM> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li> <li type="circle">org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/SupplierFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">SupplierFunction</span></a><T> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableFunction</span></a> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>) +<ul> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V></li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V></li> +</ul> +</li> <li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableRateLimiter.CreditFunction</span></a><K,V> (also extends org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> <li type="circle">org.apache.samza.table.retry.<a href="org/apache/samza/table/retry/TableRetryPolicy.RetryPredicate.html" title="interface in org.apache.samza.table.retry"><span class="typeNameLink">TableRetryPolicy.RetryPredicate</span></a> (also extends java.util.function.Predicate<T>)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote">TablePart</a>)</li> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskFactory.html" title="interface in org.apache.samza.task"><span class="typeNameLink">TaskFactory</span></a><T> <ul> <li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/AsyncStreamTaskFactory.html" title="interface in org.apache.samza.task"><span class="typeNameLink">AsyncStreamTaskFactory</span></a></li> @@ -436,7 +444,7 @@ </ul> </li> <li type="circle">org.apache.samza.system.descriptors.<a href="org/apache/samza/system/descriptors/SimpleInputDescriptorProvider.html" title="interface in org.apache.samza.system.descriptors"><span class="typeNameLink">SimpleInputDescriptorProvider</span></a></li> -<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><span class="typeNameLink">StartpointVisitor</span></a></li> +<li type="circle">org.apache.samza.startpoint.<a href="org/apache/samza/startpoint/StartpointVisitor.html" title="interface in org.apache.samza.startpoint"><span class="typeNameLink">StartpointVisitor</span></a><IN,OUT></li> <li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngine.html" title="interface in org.apache.samza.storage"><span class="typeNameLink">StorageEngine</span></a></li> <li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.html" title="interface in org.apache.samza.storage"><span class="typeNameLink">StorageEngineFactory</span></a><K,V></li> <li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/StreamJob.html" title="interface in org.apache.samza.job"><span class="typeNameLink">StreamJob</span></a></li> @@ -464,9 +472,15 @@ <li type="circle">org.apache.samza.table.descriptors.<a href="org/apache/samza/table/descriptors/TableDescriptor.html" title="interface in org.apache.samza.table.descriptors"><span class="typeNameLink">TableDescriptor</span></a><K,V,D></li> <li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TablePart.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TablePart</span></a> <ul> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableFunction</span></a> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, java.io.Serializable) +<ul> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V></li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V></li> +</ul> +</li> <li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableRateLimiter.CreditFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableRateLimiter.CreditFunction</span></a><K,V> (also extends java.io.Serializable)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> -<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V> (also extends org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/ClosableFunction.html" title="interface in org.apache.samza.operators.functions">ClosableFunction</a>, org.apache.samza.operators.functions.<a href="org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a>, java.io.Serializable)</li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableReadFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableReadFunction</span></a><K,V></li> +<li type="circle">org.apache.samza.table.remote.<a href="org/apache/samza/table/remote/TableWriteFunction.html" title="interface in org.apache.samza.table.remote"><span class="typeNameLink">TableWriteFunction</span></a><K,V></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> @@ -483,8 +497,8 @@ <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> <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.sql.udfs.<a href="org/apache/samza/sql/udfs/SamzaSqlUdf.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdf</span></a> (implements java.lang.annotation.Annotation)</li> <li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/SamzaSqlUdfMethod.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdfMethod</span></a> (implements java.lang.annotation.Annotation)</li> +<li type="circle">org.apache.samza.sql.udfs.<a href="org/apache/samza/sql/udfs/SamzaSqlUdf.html" title="annotation in org.apache.samza.sql.udfs"><span class="typeNameLink">SamzaSqlUdf</span></a> (implements java.lang.annotation.Annotation)</li> </ul> <h2 title="Enum Hierarchy">Enum Hierarchy</h2> <ul> @@ -492,17 +506,17 @@ <ul> <li type="circle">java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable) <ul> +<li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.StatusCode.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus.StatusCode</span></a></li> +<li type="circle">org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskMode.html" title="enum in org.apache.samza.job.model"><span class="typeNameLink">TaskMode</span></a></li> +<li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.StoreMode.html" title="enum in org.apache.samza.storage"><span class="typeNameLink">StorageEngineFactory.StoreMode</span></a></li> +<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.OffsetType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.OffsetType</span></a></li> +<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/MessageType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">MessageType</span></a></li> <li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/DurationCharacteristic.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">DurationCharacteristic</span></a></li> <li type="circle">org.apache.samza.operators.triggers.<a href="org/apache/samza/operators/triggers/FiringType.html" title="enum in org.apache.samza.operators.triggers"><span class="typeNameLink">FiringType</span></a></li> <li type="circle">org.apache.samza.operators.windows.<a href="org/apache/samza/operators/windows/AccumulationMode.html" title="enum in org.apache.samza.operators.windows"><span class="typeNameLink">AccumulationMode</span></a></li> <li type="circle">org.apache.samza.operators.windows.internal.<a href="org/apache/samza/operators/windows/internal/WindowType.html" title="enum in org.apache.samza.operators.windows.internal"><span class="typeNameLink">WindowType</span></a></li> -<li type="circle">org.apache.samza.storage.<a href="org/apache/samza/storage/StorageEngineFactory.StoreMode.html" title="enum in org.apache.samza.storage"><span class="typeNameLink">StorageEngineFactory.StoreMode</span></a></li> -<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/SystemStreamMetadata.OffsetType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">SystemStreamMetadata.OffsetType</span></a></li> -<li type="circle">org.apache.samza.system.<a href="org/apache/samza/system/MessageType.html" title="enum in org.apache.samza.system"><span class="typeNameLink">MessageType</span></a></li> -<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.RequestScope.html" title="enum in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator.RequestScope</span></a></li> -<li type="circle">org.apache.samza.job.<a href="org/apache/samza/job/ApplicationStatus.StatusCode.html" title="enum in org.apache.samza.job"><span class="typeNameLink">ApplicationStatus.StatusCode</span></a></li> -<li type="circle">org.apache.samza.job.model.<a href="org/apache/samza/job/model/TaskMode.html" title="enum in org.apache.samza.job.model"><span class="typeNameLink">TaskMode</span></a></li> <li type="circle">org.apache.samza.sql.schema.<a href="org/apache/samza/sql/schema/SamzaSqlFieldType.html" title="enum in org.apache.samza.sql.schema"><span class="typeNameLink">SamzaSqlFieldType</span></a></li> +<li type="circle">org.apache.samza.task.<a href="org/apache/samza/task/TaskCoordinator.RequestScope.html" title="enum in org.apache.samza.task"><span class="typeNameLink">TaskCoordinator.RequestScope</span></a></li> </ul> </li> </ul> Modified: samza/site/learn/documentation/latest/api/javadocs/serialized-form.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/serialized-form.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/serialized-form.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/serialized-form.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>Serialized Form (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>Serialized Form (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="Serialized Form (samza-api 1.1.1-SNAPSHOT API)"; + parent.document.title="Serialized Form (samza-api 1.2.0 API)"; } } catch(err) { @@ -532,6 +532,24 @@ </li> <li class="blockList"> <h2 title="Package">Package org.apache.samza.table.remote</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.samza.table.remote.BaseTableFunction"> +<!-- --> +</a> +<h3>Class <a href="org/apache/samza/table/remote/BaseTableFunction.html" title="class in org.apache.samza.table.remote">org.apache.samza.table.remote.BaseTableFunction</a> extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>table</h4> +<pre><a href="org/apache/samza/table/AsyncReadWriteTable.html" title="interface in org.apache.samza.table">AsyncReadWriteTable</a><<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="type parameter in AsyncReadWriteTable">K</a>,<a href="org/apache/samza/table/AsyncReadWriteTable.html" title="type parameter in AsyncReadWriteTable">V</a>> table</pre> +</li> +</ul> +</li> +</ul> +</li> +</ul> </li> <li class="blockList"> <h2 title="Package">Package org.apache.samza.table.retry</h2> Modified: samza/site/learn/documentation/latest/api/low-level-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/low-level-api.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/low-level-api.html (original) +++ samza/site/learn/documentation/latest/api/low-level-api.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/api/low-level-api">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/api/low-level-api">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/api/low-level-api">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/api/low-level-api">0.10</a></li> Modified: samza/site/learn/documentation/latest/api/programming-model.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/programming-model.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/programming-model.html (original) +++ samza/site/learn/documentation/latest/api/programming-model.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/api/programming-model">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/api/programming-model">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/api/programming-model">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/api/programming-model">0.10</a></li> Modified: samza/site/learn/documentation/latest/api/samza-sql.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/samza-sql.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/samza-sql.html (original) +++ samza/site/learn/documentation/latest/api/samza-sql.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/api/samza-sql">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/api/samza-sql">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/api/samza-sql">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/api/samza-sql">0.10</a></li> Modified: samza/site/learn/documentation/latest/api/table-api.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/table-api.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/table-api.html (original) +++ samza/site/learn/documentation/latest/api/table-api.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/api/table-api">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/api/table-api">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/api/table-api">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/api/table-api">0.10</a></li> @@ -667,24 +667,25 @@ describes a table stored in RocksDB.</li <p>Samza Table supports both synchronous and asynchronous API. Below is an example for the <strong><code>get</code></strong> operation.</p> -<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="cm">/**</span> +<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="cm">/**</span> <span class="cm"> * Gets the value associated with the specified {@code key}.</span> <span class="cm"> *</span> <span class="cm"> * @param key the key with which the associated value is to be fetched.</span> -<span class="cm"> * @return if found, the value associated with the specified {@code key}; </span> -<span class="cm"> * otherwise, {@code null}.</span> +<span class="cm"> * @param args additional arguments</span> +<span class="cm"> * @return if found, the value associated with the specified {@code key}; otherwise, {@code null}.</span> <span class="cm"> * @throws NullPointerException if the specified {@code key} is {@code null}.</span> <span class="cm"> */</span> - <span class="n">V</span> <span class="nf">get</span><span class="o">(</span><span class="n">K</span> <span class="n">key</span><span class="o">);</span> + <span class="n">V</span> <span class="nf">get</span><span class="o">(</span><span class="n">K</span> <span class="n">key</span><span class="o">,</span> <span class="n">Object</span> <span class="o">...</span> <span class="n">args</span><span class="o">);</span> - <span class="cm">/**</span> + <span class="cm">/**</span> <span class="cm"> * Asynchronously gets the value associated with the specified {@code key}.</span> <span class="cm"> *</span> <span class="cm"> * @param key the key with which the associated value is to be fetched.</span> +<span class="cm"> * @param args additional arguments</span> <span class="cm"> * @return completableFuture for the requested value</span> <span class="cm"> * @throws NullPointerException if the specified {@code key} is {@code null}.</span> <span class="cm"> */</span> - <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">V</span><span class="o">></span> <span class="nf">getAsync</span><span class="o">(</span><span class="n">K</span> <span class="n">key</span><span class="o">);</span></code></pre></figure> + <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">V</span><span class="o">></span> <span class="nf">getAsync</span><span class="o">(</span><span class="n">K</span> <span class="n">key</span><span class="o">,</span> <span class="n">Object</span> <span class="o">...</span> <span class="n">args</span><span class="o">);</span></code></pre></figure> <h1 id="using-table-with-samza-high-level-api">Using Table with Samza High Level API</h1> @@ -842,6 +843,16 @@ method.</p> <td>Count of missed get/getAll() operations</td> </tr> <tr> +<td><code>read-ns</code></td> +<td><code>ReadableTable</code></td> +<td>Average latency of <code>readAsync()</code> operations</td> +</tr> +<tr> +<td><code>num-reads</code></td> +<td><code>ReadableTable</code></td> +<td>Count of <code>readAsync()</code> operations</td> +</tr> +<tr> <td><code>put-ns</code></td> <td><code>ReadWriteTable</code></td> <td>Average latency of <code>put/putAsync()</code> operations</td> @@ -882,6 +893,16 @@ method.</p> <td>Count of <code>deleteAll/deleteAllAsync()</code> operations</td> </tr> <tr> +<td><code>num-writes</code></td> +<td><code>ReadWriteTable</code></td> +<td>Count of <code>writeAsync()</code> operations</td> +</tr> +<tr> +<td><code>write-ns</code></td> +<td><code>ReadWriteTable</code></td> +<td>Average latency of <code>writeAsync()</code> operations</td> +</tr> +<tr> <td><code>flush-ns</code></td> <td><code>ReadWriteTable</code></td> <td>Average latency of flush operations</td> @@ -952,6 +973,10 @@ throughput. </p> All configuration options of a Remote Table can be found in the <a href="https://github.com/apache/samza/blob/master/samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableDescriptor.java";><code>RemoteTableDescriptor</code></a> class. </p> +<p>Couchbase is supported as remote table. See +<a href="https://github.com/apache/samza/blob/master/samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableReadFunction.java";><code>CouchbaseTableReadFunction</code></a> and +<a href="https://github.com/apache/samza/blob/master/samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java";><code>CouchbaseTableWriteFunction</code></a>.</p> + <h3 id="rate-limiting">Rate Limiting</h3> <p>Remote Table has built-in client-side rate limiting support in both of its sync @@ -1003,6 +1028,67 @@ per-request basis such that each individ They can be found in <a href="https://github.com/apache/samza/blob/master/samza-core/src/main/java/org/apache/samza/table/retry/RetryMetrics.java";><code>RetryMetrics</code></a>.</p> +<h3 id="supporting-additional-operations">Supporting Additional Operations</h3> + +<p>Remote Table allows invoking additional operations on remote store that are not directly +supported through the Get/Put/Delete methods. Two categories of operations are supported</p> + +<ul> +<li>Get/Put/Delete operations with additional arguments</li> +<li>Arbitrary operations through readAsync() and writeAsync()<br></li> +</ul> + +<p>We only mandate implementers of table functions to provide implementation for Get/Put/Delete +without additional arguments. End users can subclass a table function, and invoke operations +on remote store directly, if they are not supported by a table function.</p> + +<figure class="highlight"><pre><code class="language-java" data-lang="java"><span></span> <span class="mi">1</span> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyCouchbaseTableWriteFunction</span><span class="o"><</span><span class="n">V</span><span class="o">></span> <span class="kd">extends</span> <span class="n">CouchbaseTableWriteFunction</span><span class="o"><</span><span class="n">V</span><span class="o">></span> <span class="o">{</span> + <span class="mi">2</span> + <span class="mi">3</span> <span class="kd">public</span> <span class="kd">static</span> <span class="kd">final</span> <span class="kt">int</span> <span class="n">OP_COUNTER</span> <span class="o">=</span> <span class="mi">1</span><span class="o">;</span> + <span class="mi">4</span> + <span class="mi">5</span> <span class="nd">@Override</span> + <span class="mi">6</span> <span class="kd">public</span> <span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">T</span><span class="o">></span> <span class="nf">writeAsync</span><span class="o">(</span><span class="kt">int</span> <span class="n">opId</span><span class="o">,</span> <span class="n">Object</span><span class="o">...</span> <span class="n">args</span><span class="o">)</span> <span class="o">{</span> + <span class="mi">7</span> <span class="k">if</span> <span class="o">(</span><span class="n">OP_COUNTER</span> <span class="o">==</span> <span class="n">opId</span><span class="o">)</span> <span class="o">{</span> + <span class="mi">8</span> <span class="n">String</span> <span class="n">id</span> <span class="o">=</span> <span class="o">(</span><span class="n">String</span><span class="o">)</span> <span class="n">args</span><span class="o">[</span><span class="mi">0</span><span class="o">];</span> + <span class="mi">9</span> <span class="n">Long</span> <span class="n">delta</span> <span class="o">=</span> <span class="n">Long</span><span class="o">.</span><span class="na">valueOf</span><span class="o">(</span><span class="n">args</span><span class="o">[</span><span class="mi">1</span><span class="o">].</span><span class="na">toString</span><span class="o">());</span> +<span class="mi">10</span> <span class="k">return</span> <span class="n">convertToFuture</span><span class="o">(</span><span class="n">bucket</span><span class="o">.</span><span class="na">async</span><span class="o">().</span><span class="na">counter</span><span class="o">(</span><span class="n">id</span><span class="o">,</span> <span class="n">delta</span><span class="o">));</span> +<span class="mi">11</span> <span class="o">}</span> +<span class="mi">12</span> <span class="k">throw</span> <span class="k">new</span> <span class="n">SamzaException</span><span class="o">(</span><span class="s">"Unknown opId"</span> <span class="o">+</span> <span class="n">opId</span><span class="o">);</span> +<span class="mi">13</span> <span class="o">}</span> +<span class="mi">14</span> +<span class="mi">15</span> <span class="kd">public</span> <span class="n">CompletableFuture</span><span class="o"><</span><span class="n">Long</span><span class="o">></span> <span class="nf">counterAsync</span><span class="o">(</span><span class="n">String</span> <span class="n">id</span><span class="o">,</span> <span class="kt">long</span> <span class="n">delta</span><span class="o">)</span> <span class="o">{</span> +<span class="mi">16</span> <span class="k">return</span> <span class="n">table</span><span class="o">.</span><span class="na">writeAsync</span><span class="o">(</span><span class="n">OP_COUNTER</span><span class="o">,</span> <span class="n">id</span><span class="o">,</span> <span class="n">delta</span><span class="o">);</span> +<span class="mi">17</span> <span class="o">}</span> +<span class="mi">18</span> <span class="o">}</span> +<span class="mi">19</span> +<span class="mi">20</span> <span class="kd">public</span> <span class="kd">class</span> <span class="nc">MyMapFunc</span> <span class="kd">implements</span> <span class="n">MapFunction</span> <span class="o">{</span> +<span class="mi">21</span> +<span class="mi">22</span> <span class="n">AsyncReadWriteTable</span> <span class="n">table</span><span class="o">;</span> +<span class="mi">23</span> <span class="n">MyCouchbaseTableWriteFunction</span> <span class="n">writeFunc</span><span class="o">;</span> +<span class="mi">24</span> +<span class="mi">25</span> <span class="nd">@Override</span> +<span class="mi">26</span> <span class="kd">public</span> <span class="kt">void</span> <span class="nf">init</span><span class="o">(</span><span class="n">Context</span> <span class="n">context</span><span class="o">)</span> <span class="o">{</span> +<span class="mi">27</span> <span class="n">table</span> <span class="o">=</span> <span class="n">context</span><span class="o">.</span><span class="na">getTaskContext</span><span class="o">().</span><span class="na">getTable</span><span class="o">(...);</span> +<span class="mi">28</span> <span class="n">writeFunc</span> <span class="o">=</span> <span class="o">(</span><span class="n">MyCouchbaseTableWriteFunction</span><span class="o">)</span> <span class="o">((</span><span class="n">RemoteTable</span><span class="o">)</span> <span class="n">table</span><span class="o">).</span><span class="na">getWriteFunction</span><span class="o">();</span> +<span class="mi">29</span> <span class="o">}</span> +<span class="mi">30</span> +<span class="mi">31</span> <span class="nd">@Override</span> +<span class="mi">32</span> <span class="kd">public</span> <span class="n">Object</span> <span class="nf">apply</span><span class="o">(</span><span class="n">Object</span> <span class="n">message</span><span class="o">)</span> <span class="o">{</span> +<span class="mi">33</span> <span class="k">return</span> <span class="n">writeFunc</span><span class="o">.</span><span class="na">counterAsync</span><span class="o">(</span><span class="err">â</span><span class="n">id</span><span class="err">â</span><span class="o">,</span> <span class="mi">100</span><span class="o">);</span> +<span class="mi">34</span> <span class="o">}</span> +<span class="mi">35</span> <span class="o">}</span></code></pre></figure> + +<p>The code above illustrates an example of invoking counter() operation on Couchbase. </p> + +<ol> +<li>Line 5-13: method writeAsync() is implemented to invoke counter(). </li> +<li>Line 15-16: it is then wrapped by a convenience method. Notice here we invoke writeAsync() + on the table, so that other value-added features such as rate limiting, + retry and batching can participate in this call.</li> +<li>Line 27-28: references to the table and read function are obtained</li> +<li>Line 33: the actual invocation.<br></li> +</ol> + <h2 id="local-table">Local Table</h2> <p>A table is considered local when its data physically co-exists on the same host Modified: samza/site/learn/documentation/latest/api/test-framework.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/test-framework.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/test-framework.html (original) +++ samza/site/learn/documentation/latest/api/test-framework.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/api/test-framework">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/api/test-framework">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/api/test-framework">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/api/test-framework">0.10</a></li> Modified: samza/site/learn/documentation/latest/architecture/architecture-overview.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/architecture/architecture-overview.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/architecture/architecture-overview.html (original) +++ samza/site/learn/documentation/latest/architecture/architecture-overview.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/architecture/architecture-overview">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/architecture/architecture-overview">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/architecture/architecture-overview">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/architecture/architecture-overview">0.10</a></li> Modified: samza/site/learn/documentation/latest/architecture/kinesis.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/architecture/kinesis.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/architecture/kinesis.html (original) +++ samza/site/learn/documentation/latest/architecture/kinesis.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/architecture/kinesis">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/architecture/kinesis">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/architecture/kinesis">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/architecture/kinesis">0.10</a></li> Modified: samza/site/learn/documentation/latest/comparisons/introduction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/introduction.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/introduction.html (original) +++ samza/site/learn/documentation/latest/comparisons/introduction.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/comparisons/introduction">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/comparisons/introduction">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/comparisons/introduction">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/comparisons/introduction">0.10</a></li> Modified: samza/site/learn/documentation/latest/comparisons/mupd8.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/mupd8.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/mupd8.html (original) +++ samza/site/learn/documentation/latest/comparisons/mupd8.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/comparisons/mupd8">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/comparisons/mupd8">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/comparisons/mupd8">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/comparisons/mupd8">0.10</a></li> Modified: samza/site/learn/documentation/latest/comparisons/spark-streaming.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/spark-streaming.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/spark-streaming.html (original) +++ samza/site/learn/documentation/latest/comparisons/spark-streaming.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/comparisons/spark-streaming">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/comparisons/spark-streaming">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/comparisons/spark-streaming">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/comparisons/spark-streaming">0.10</a></li> Modified: samza/site/learn/documentation/latest/comparisons/storm.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/comparisons/storm.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/comparisons/storm.html (original) +++ samza/site/learn/documentation/latest/comparisons/storm.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/comparisons/storm">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/comparisons/storm">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/comparisons/storm">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/comparisons/storm">0.10</a></li> Modified: samza/site/learn/documentation/latest/connectors/eventhubs.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/eventhubs.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/eventhubs.html (original) +++ samza/site/learn/documentation/latest/connectors/eventhubs.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/connectors/eventhubs">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/connectors/eventhubs">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/connectors/eventhubs">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/connectors/eventhubs">0.10</a></li> Modified: samza/site/learn/documentation/latest/connectors/hdfs.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/hdfs.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/hdfs.html (original) +++ samza/site/learn/documentation/latest/connectors/hdfs.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/connectors/hdfs">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/connectors/hdfs">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/connectors/hdfs">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/connectors/hdfs">0.10</a></li> Modified: samza/site/learn/documentation/latest/connectors/kafka.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/kafka.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/kafka.html (original) +++ samza/site/learn/documentation/latest/connectors/kafka.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/connectors/kafka">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/connectors/kafka">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/connectors/kafka">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/connectors/kafka">0.10</a></li> Modified: samza/site/learn/documentation/latest/connectors/kinesis.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/kinesis.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/kinesis.html (original) +++ samza/site/learn/documentation/latest/connectors/kinesis.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/connectors/kinesis">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/connectors/kinesis">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/connectors/kinesis">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/connectors/kinesis">0.10</a></li> Modified: samza/site/learn/documentation/latest/connectors/overview.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/connectors/overview.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/connectors/overview.html (original) +++ samza/site/learn/documentation/latest/connectors/overview.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/connectors/overview">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/connectors/overview">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/connectors/overview">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/connectors/overview">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/checkpointing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/checkpointing.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/checkpointing.html (original) +++ samza/site/learn/documentation/latest/container/checkpointing.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/checkpointing">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/checkpointing">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/checkpointing">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/checkpointing">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/coordinator-stream.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/coordinator-stream.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/coordinator-stream.html (original) +++ samza/site/learn/documentation/latest/container/coordinator-stream.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/coordinator-stream">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/coordinator-stream">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/coordinator-stream">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/coordinator-stream">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/event-loop.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/event-loop.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/event-loop.html (original) +++ samza/site/learn/documentation/latest/container/event-loop.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/event-loop">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/event-loop">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/event-loop">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/event-loop">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/jmx.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/jmx.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/jmx.html (original) +++ samza/site/learn/documentation/latest/container/jmx.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/jmx">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/jmx">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/jmx">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/jmx">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/metrics.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/metrics.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/metrics.html (original) +++ samza/site/learn/documentation/latest/container/metrics.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/metrics">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/metrics">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/metrics">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/metrics">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/samza-container.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/samza-container.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/samza-container.html (original) +++ samza/site/learn/documentation/latest/container/samza-container.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/samza-container">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/samza-container">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/samza-container">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/samza-container">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/serialization.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/serialization.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/serialization.html (original) +++ samza/site/learn/documentation/latest/container/serialization.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/serialization">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/serialization">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/serialization">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/serialization">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/state-management.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/state-management.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/state-management.html (original) +++ samza/site/learn/documentation/latest/container/state-management.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/state-management">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/state-management">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/state-management">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/state-management">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/streams.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/streams.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/streams.html (original) +++ samza/site/learn/documentation/latest/container/streams.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/streams">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/streams">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/streams">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/streams">0.10</a></li> Modified: samza/site/learn/documentation/latest/container/windowing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/container/windowing.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/container/windowing.html (original) +++ samza/site/learn/documentation/latest/container/windowing.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/container/windowing">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/container/windowing">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/container/windowing">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/container/windowing">0.10</a></li> Modified: samza/site/learn/documentation/latest/core-concepts/core-concepts.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/core-concepts/core-concepts.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/core-concepts/core-concepts.html (original) +++ samza/site/learn/documentation/latest/core-concepts/core-concepts.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/core-concepts/core-concepts">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/core-concepts/core-concepts">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/core-concepts/core-concepts">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/core-concepts/core-concepts">0.10</a></li> Modified: samza/site/learn/documentation/latest/deployment/deployment-model.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/deployment-model.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/deployment/deployment-model.html (original) +++ samza/site/learn/documentation/latest/deployment/deployment-model.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/deployment/deployment-model">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/deployment/deployment-model">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/deployment/deployment-model">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/deployment/deployment-model">0.10</a></li> Modified: samza/site/learn/documentation/latest/deployment/standalone.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/standalone.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/deployment/standalone.html (original) +++ samza/site/learn/documentation/latest/deployment/standalone.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/deployment/standalone">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/deployment/standalone">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/deployment/standalone">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/deployment/standalone">0.10</a></li> Modified: samza/site/learn/documentation/latest/deployment/yarn.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/deployment/yarn.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/deployment/yarn.html (original) +++ samza/site/learn/documentation/latest/deployment/yarn.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/deployment/yarn">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/deployment/yarn">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/deployment/yarn">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/deployment/yarn">0.10</a></li> Modified: samza/site/learn/documentation/latest/hadoop/consumer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/consumer.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/hadoop/consumer.html (original) +++ samza/site/learn/documentation/latest/hadoop/consumer.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/hadoop/consumer">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/hadoop/consumer">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/hadoop/consumer">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/hadoop/consumer">0.10</a></li> Modified: samza/site/learn/documentation/latest/hadoop/overview.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/overview.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/hadoop/overview.html (original) +++ samza/site/learn/documentation/latest/hadoop/overview.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/hadoop/overview">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/hadoop/overview">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/hadoop/overview">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/hadoop/overview">0.10</a></li> Modified: samza/site/learn/documentation/latest/hadoop/producer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/hadoop/producer.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/hadoop/producer.html (original) +++ samza/site/learn/documentation/latest/hadoop/producer.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/hadoop/producer">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/hadoop/producer">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/hadoop/producer">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/hadoop/producer">0.10</a></li> Modified: samza/site/learn/documentation/latest/index.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/index.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/index.html (original) +++ samza/site/learn/documentation/latest/index.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/">0.10</a></li> Modified: samza/site/learn/documentation/latest/introduction/architecture.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/architecture.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/introduction/architecture.html (original) +++ samza/site/learn/documentation/latest/introduction/architecture.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/introduction/architecture">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/introduction/architecture">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/introduction/architecture">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/introduction/architecture">0.10</a></li> Modified: samza/site/learn/documentation/latest/introduction/background.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/background.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/introduction/background.html (original) +++ samza/site/learn/documentation/latest/introduction/background.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/introduction/background">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/introduction/background">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/introduction/background">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/introduction/background">0.10</a></li> Modified: samza/site/learn/documentation/latest/introduction/concepts.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/introduction/concepts.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/introduction/concepts.html (original) +++ samza/site/learn/documentation/latest/introduction/concepts.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/introduction/concepts">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/introduction/concepts">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/introduction/concepts">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/introduction/concepts">0.10</a></li> Modified: samza/site/learn/documentation/latest/jobs/configuration-table.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration-table.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/configuration-table.html (original) +++ samza/site/learn/documentation/latest/jobs/configuration-table.html Fri Jun 7 20:22:19 2019 @@ -410,14 +410,6 @@ </tr> <tr> - <td class="property" id="job-container-single-thread-mode">job.container.single.thread.mode</td> - <td class="default">false</td> - <td class="description"> - If set to true, samza will fallback to legacy single-threaded event loop. Default is false, which enables the <a href="../container/event-loop.html">multithreading execution</a>. - </td> - </tr> - - <tr> <td class="property" id="job-container-thread-pool-size">job.container.thread.pool.size</td> <td class="default"></td> <td class="description"> Modified: samza/site/learn/documentation/latest/jobs/configuration.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/configuration.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/configuration.html (original) +++ samza/site/learn/documentation/latest/jobs/configuration.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/jobs/configuration">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/jobs/configuration">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/jobs/configuration">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/jobs/configuration">0.10</a></li> Modified: samza/site/learn/documentation/latest/jobs/job-runner.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/job-runner.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/job-runner.html (original) +++ samza/site/learn/documentation/latest/jobs/job-runner.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/jobs/job-runner">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/jobs/job-runner">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/jobs/job-runner">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/jobs/job-runner">0.10</a></li> Modified: samza/site/learn/documentation/latest/jobs/logging.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/logging.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/logging.html (original) +++ samza/site/learn/documentation/latest/jobs/logging.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/jobs/logging">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/jobs/logging">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/jobs/logging">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/jobs/logging">0.10</a></li> Modified: samza/site/learn/documentation/latest/jobs/packaging.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/packaging.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/packaging.html (original) +++ samza/site/learn/documentation/latest/jobs/packaging.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/jobs/packaging">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/jobs/packaging">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/jobs/packaging">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/jobs/packaging">0.10</a></li> Modified: samza/site/learn/documentation/latest/jobs/reprocessing.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/jobs/reprocessing.html?rev=1860788&r1=1860787&r2=1860788&view=diff ============================================================================== --- samza/site/learn/documentation/latest/jobs/reprocessing.html (original) +++ samza/site/learn/documentation/latest/jobs/reprocessing.html Fri Jun 7 20:22:19 2019 @@ -537,11 +537,11 @@ - <li class="hide"><a href="/learn/documentation/0.10/jobs/reprocessing">0.10</a></li> + <li class="hide"><a href="/learn/documentation/1.0/jobs/reprocessing">1.0</a></li> - <li class="hide"><a href="/learn/documentation/1.0/jobs/reprocessing">1.0</a></li> + <li class="hide"><a href="/learn/documentation/0.10/jobs/reprocessing">0.10</a></li>
