Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/BoundedSSPIterator.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/BoundedSSPIterator.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/BoundedSSPIterator.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/BoundedSSPIterator.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:13 PST 2021 --> -<title>BoundedSSPIterator (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>BoundedSSPIterator (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="BoundedSSPIterator (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="BoundedSSPIterator (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.Mode.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.Mode.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.Mode.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.Mode.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:13 PST 2021 --> -<title>ChangelogSSPIterator.Mode (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>ChangelogSSPIterator.Mode (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="ChangelogSSPIterator.Mode (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="ChangelogSSPIterator.Mode (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ChangelogSSPIterator.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:13 PST 2021 --> -<title>ChangelogSSPIterator (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>ChangelogSSPIterator (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="ChangelogSSPIterator (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="ChangelogSSPIterator (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ControlMessage.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ControlMessage.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ControlMessage.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/ControlMessage.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:13 PST 2021 --> -<title>ControlMessage (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>ControlMessage (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="ControlMessage (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="ControlMessage (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { @@ -49,7 +48,7 @@ var activeTableTab = "activeTableTab"; <div class="subNav"> <ul class="navList"> <li><a href="../../../../org/apache/samza/system/ChangelogSSPIterator.Mode.html" title="enum in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../org/apache/samza/system/DrainMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../index.html?org/apache/samza/system/ControlMessage.html" target="_top">Frames</a></li> @@ -108,7 +107,7 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt>Direct Known Subclasses:</dt> -<dd><a href="../../../../org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system">EndOfStreamMessage</a>, <a href="../../../../org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system">WatermarkMessage</a></dd> +<dd><a href="../../../../org/apache/samza/system/DrainMessage.html" title="class in org.apache.samza.system">DrainMessage</a>, <a href="../../../../org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system">EndOfStreamMessage</a>, <a href="../../../../org/apache/samza/system/WatermarkMessage.html" title="class in org.apache.samza.system">WatermarkMessage</a></dd> </dl> <hr> <br> @@ -292,7 +291,7 @@ extends java.lang.Object</pre> <div class="subNav"> <ul class="navList"> <li><a href="../../../../org/apache/samza/system/ChangelogSSPIterator.Mode.html" title="enum in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../org/apache/samza/system/DrainMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../index.html?org/apache/samza/system/ControlMessage.html" target="_top">Frames</a></li> Added: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/DrainMessage.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/DrainMessage.html?rev=1906774&view=auto ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/DrainMessage.html (added) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/DrainMessage.html Wed Jan 18 19:33:25 2023 @@ -0,0 +1,330 @@ +<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd";> +<!-- NewPage --> +<html lang="en"> +<head> +<!-- Generated by javadoc --> +<title>DrainMessage (samza-api 1.9.0-SNAPSHOT API)</title> +<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> +<script type="text/javascript" src="../../../../script.js"></script> +</head> +<body> +<script type="text/javascript"><!-- + try { + if (location.href.indexOf('is-external=true') == -1) { + parent.document.title="DrainMessage (samza-api 1.9.0-SNAPSHOT API)"; + } + } + catch(err) { + } +//--> +var methods = {"i0":10,"i1":10,"i2":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; +</script> +<noscript> +<div>JavaScript is disabled on your browser.</div> +</noscript> +<!-- ========= START OF TOP NAVBAR ======= --> +<div class="topNav"><a name="navbar.top"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> +<a name="navbar.top.firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="../../../../overview-summary.html">Overview</a></li> +<li><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../index-all.html">Index</a></li> +<li><a href="../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../index.html?org/apache/samza/system/DrainMessage.html" target="_top">Frames</a></li> +<li><a href="DrainMessage.html" target="_top">No Frames</a></li> +</ul> +<ul class="navList" id="allclasses_navbar_top"> +<li><a href="../../../../allclasses-noframe.html">All Classes</a></li> +</ul> +<div> +<script type="text/javascript"><!-- + allClassesLink = document.getElementById("allclasses_navbar_top"); + if(window==top) { + allClassesLink.style.display = "block"; + } + else { + allClassesLink.style.display = "none"; + } + //--> +</script> +</div> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li>Nested | </li> +<li>Field | </li> +<li><a href="#constructor.summary">Constr</a> | </li> +<li><a href="#method.summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li>Field | </li> +<li><a href="#constructor.detail">Constr</a> | </li> +<li><a href="#method.detail">Method</a></li> +</ul> +</div> +<a name="skip.navbar.top"> +<!-- --> +</a></div> +<!-- ========= END OF TOP NAVBAR ========= --> +<!-- ======== START OF CLASS DATA ======== --> +<div class="header"> +<div class="subTitle">org.apache.samza.system</div> +<h2 title="Class DrainMessage" class="title">Class DrainMessage</h2> +</div> +<div class="contentContainer"> +<ul class="inheritance"> +<li>java.lang.Object</li> +<li> +<ul class="inheritance"> +<li><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">org.apache.samza.system.ControlMessage</a></li> +<li> +<ul class="inheritance"> +<li>org.apache.samza.system.DrainMessage</li> +</ul> +</li> +</ul> +</li> +</ul> +<div class="description"> +<ul class="blockList"> +<li class="blockList"> +<hr> +<br> +<pre>public class <span class="typeNameLabel">DrainMessage</span> +extends <a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></pre> +<div class="block">The DrainMessage is a control message that is sent out to next stage + once the task has consumed to the end of a bounded stream.</div> +</li> +</ul> +</div> +<div class="summary"> +<ul class="blockList"> +<li class="blockList"> +<!-- ======== CONSTRUCTOR SUMMARY ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor.summary"> +<!-- --> +</a> +<h3>Constructor Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> +<caption><span>Constructors</span><span class="tabEnd"> </span></caption> +<tr> +<th class="colOne" scope="col">Constructor and Description</th> +</tr> +<tr class="altColor"> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/DrainMessage.html#DrainMessage-java.lang.String-">DrainMessage</a></span>(java.lang.String runId)</code> </td> +</tr> +<tr class="rowColor"> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/DrainMessage.html#DrainMessage-java.lang.String-java.lang.String-">DrainMessage</a></span>(java.lang.String taskName, + java.lang.String runId)</code> </td> +</tr> +</table> +</li> +</ul> +<!-- ========== METHOD SUMMARY =========== --> +<ul class="blockList"> +<li class="blockList"><a name="method.summary"> +<!-- --> +</a> +<h3>Method Summary</h3> +<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> +<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> +<tr> +<th class="colFirst" scope="col">Modifier and Type</th> +<th class="colLast" scope="col">Method and Description</th> +</tr> +<tr id="i0" class="altColor"> +<td class="colFirst"><code>boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/DrainMessage.html#equals-java.lang.Object-">equals</a></span>(java.lang.Object obj)</code> </td> +</tr> +<tr id="i1" class="rowColor"> +<td class="colFirst"><code>java.lang.String</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/DrainMessage.html#getRunId--">getRunId</a></span>()</code> </td> +</tr> +<tr id="i2" class="altColor"> +<td class="colFirst"><code>int</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/DrainMessage.html#hashCode--">hashCode</a></span>()</code> </td> +</tr> +</table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.system.ControlMessage"> +<!-- --> +</a> +<h3>Methods inherited from class org.apache.samza.system.<a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></h3> +<code><a href="../../../../org/apache/samza/system/ControlMessage.html#getTaskName--">getTaskName</a>, <a href="../../../../org/apache/samza/system/ControlMessage.html#getVersion--">getVersion</a>, <a href="../../../../org/apache/samza/system/ControlMessage.html#setVersion-int-">setVersion</a></code></li> +</ul> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> +<!-- --> +</a> +<h3>Methods inherited from class java.lang.Object</h3> +<code>clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait</code></li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +<div class="details"> +<ul class="blockList"> +<li class="blockList"> +<!-- ========= CONSTRUCTOR DETAIL ======== --> +<ul class="blockList"> +<li class="blockList"><a name="constructor.detail"> +<!-- --> +</a> +<h3>Constructor Detail</h3> +<a name="DrainMessage-java.lang.String-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>DrainMessage</h4> +<pre>public DrainMessage(java.lang.String runId)</pre> +</li> +</ul> +<a name="DrainMessage-java.lang.String-java.lang.String-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>DrainMessage</h4> +<pre>public DrainMessage(java.lang.String taskName, + java.lang.String runId)</pre> +</li> +</ul> +</li> +</ul> +<!-- ============ METHOD DETAIL ========== --> +<ul class="blockList"> +<li class="blockList"><a name="method.detail"> +<!-- --> +</a> +<h3>Method Detail</h3> +<a name="getRunId--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getRunId</h4> +<pre>public java.lang.String getRunId()</pre> +</li> +</ul> +<a name="hashCode--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>hashCode</h4> +<pre>public int hashCode()</pre> +<dl> +<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> +<dd><code><a href="../../../../org/apache/samza/system/ControlMessage.html#hashCode--">hashCode</a></code> in class <code><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></code></dd> +</dl> +</li> +</ul> +<a name="equals-java.lang.Object-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>equals</h4> +<pre>public boolean equals(java.lang.Object obj)</pre> +<dl> +<dt><span class="overrideSpecifyLabel">Overrides:</span></dt> +<dd><code><a href="../../../../org/apache/samza/system/ControlMessage.html#equals-java.lang.Object-">equals</a></code> in class <code><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system">ControlMessage</a></code></dd> +</dl> +</li> +</ul> +</li> +</ul> +</li> +</ul> +</div> +</div> +<!-- ========= END OF CLASS DATA ========= --> +<!-- ======= START OF BOTTOM NAVBAR ====== --> +<div class="bottomNav"><a name="navbar.bottom"> +<!-- --> +</a> +<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> +<a name="navbar.bottom.firstrow"> +<!-- --> +</a> +<ul class="navList" title="Navigation"> +<li><a href="../../../../overview-summary.html">Overview</a></li> +<li><a href="package-summary.html">Package</a></li> +<li class="navBarCell1Rev">Class</li> +<li><a href="package-tree.html">Tree</a></li> +<li><a href="../../../../deprecated-list.html">Deprecated</a></li> +<li><a href="../../../../index-all.html">Index</a></li> +<li><a href="../../../../help-doc.html">Help</a></li> +</ul> +</div> +<div class="subNav"> +<ul class="navList"> +<li><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../org/apache/samza/system/EndOfStreamMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> +</ul> +<ul class="navList"> +<li><a href="../../../../index.html?org/apache/samza/system/DrainMessage.html" target="_top">Frames</a></li> +<li><a href="DrainMessage.html" target="_top">No Frames</a></li> +</ul> +<ul class="navList" id="allclasses_navbar_bottom"> +<li><a href="../../../../allclasses-noframe.html">All Classes</a></li> +</ul> +<div> +<script type="text/javascript"><!-- + allClassesLink = document.getElementById("allclasses_navbar_bottom"); + if(window==top) { + allClassesLink.style.display = "block"; + } + else { + allClassesLink.style.display = "none"; + } + //--> +</script> +</div> +<div> +<ul class="subNavList"> +<li>Summary: </li> +<li>Nested | </li> +<li>Field | </li> +<li><a href="#constructor.summary">Constr</a> | </li> +<li><a href="#method.summary">Method</a></li> +</ul> +<ul class="subNavList"> +<li>Detail: </li> +<li>Field | </li> +<li><a href="#constructor.detail">Constr</a> | </li> +<li><a href="#method.detail">Method</a></li> +</ul> +</div> +<a name="skip.navbar.bottom"> +<!-- --> +</a></div> +<!-- ======== END OF BOTTOM NAVBAR ======= --> +</body> +</html> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/EndOfStreamMessage.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/EndOfStreamMessage.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/EndOfStreamMessage.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/EndOfStreamMessage.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:13 PST 2021 --> -<title>EndOfStreamMessage (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>EndOfStreamMessage (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="EndOfStreamMessage (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="EndOfStreamMessage (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { @@ -42,7 +41,7 @@ </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../org/apache/samza/system/DrainMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> @@ -216,7 +215,7 @@ extends <a href="../../../../org/apache/ </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../org/apache/samza/system/ControlMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../org/apache/samza/system/DrainMessage.html" title="class in org.apache.samza.system"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/IncomingMessageEnvelope.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/IncomingMessageEnvelope.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/IncomingMessageEnvelope.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/IncomingMessageEnvelope.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>IncomingMessageEnvelope (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>IncomingMessageEnvelope (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,13 +11,13 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="IncomingMessageEnvelope (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="IncomingMessageEnvelope (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { } //--> -var methods = {"i0":9,"i1":9,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10}; +var methods = {"i0":9,"i1":9,"i2":9,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -193,62 +192,81 @@ extends java.lang.Object</pre> </tr> <tr id="i0" class="altColor"> <td class="colFirst"><code>static <a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#buildDrainMessage-org.apache.samza.system.SystemStreamPartition-java.lang.String-">buildDrainMessage</a></span>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> ssp, + java.lang.String runId)</code> </td> +</tr> +<tr id="i1" class="rowColor"> +<td class="colFirst"><code>static <a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#buildEndOfStreamEnvelope-org.apache.samza.system.SystemStreamPartition-">buildEndOfStreamEnvelope</a></span>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> ssp)</code> <div class="block">This method is deprecated in favor of WatermarkManager.buildEndOfStreamEnvelope(SystemStreamPartition ssp).</div> </td> </tr> -<tr id="i1" class="rowColor"> +<tr id="i2" class="altColor"> <td class="colFirst"><code>static <a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#buildWatermarkEnvelope-org.apache.samza.system.SystemStreamPartition-long-">buildWatermarkEnvelope</a></span>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> ssp, long watermark)</code> </td> </tr> -<tr id="i2" class="altColor"> +<tr id="i3" class="rowColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#equals-java.lang.Object-">equals</a></span>(java.lang.Object obj)</code> </td> </tr> -<tr id="i3" class="rowColor"> +<tr id="i4" class="altColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getArrivalTime--">getArrivalTime</a></span>()</code> <div class="block">Getter for arrival time</div> </td> </tr> -<tr id="i4" class="altColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getEventTime--">getEventTime</a></span>()</code> <div class="block">Getter for event time</div> </td> </tr> -<tr id="i5" class="rowColor"> +<tr id="i6" class="altColor"> <td class="colFirst"><code>java.lang.Object</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getKey--">getKey</a></span>()</code> </td> </tr> -<tr id="i6" class="altColor"> +<tr id="i7" class="rowColor"> <td class="colFirst"><code>java.lang.Object</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getMessage--">getMessage</a></span>()</code> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i8" class="altColor"> <td class="colFirst"><code>java.lang.String</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getOffset--">getOffset</a></span>()</code> <div class="block">Offset associated with this message, provided by the system consumer that consumed the message.</div> </td> </tr> -<tr id="i8" class="altColor"> +<tr id="i9" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getSize--">getSize</a></span>()</code> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code><a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getSystemStreamPartition--">getSystemStreamPartition</a></span>()</code> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i11" class="rowColor"> +<td class="colFirst"><code><a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#getSystemStreamPartition-int-">getSystemStreamPartition</a></span>(int elasticityFactor)</code> +<div class="block">fetches the SSP (with keybucket) for the envelope based on elasticity factor.</div> +</td> +</tr> +<tr id="i12" class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#hashCode--">hashCode</a></span>()</code> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i13" class="rowColor"> +<td class="colFirst"><code>boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#isDrain--">isDrain</a></span>()</code> </td> +</tr> +<tr id="i14" class="altColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#isEndOfStream--">isEndOfStream</a></span>()</code> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i15" class="rowColor"> +<td class="colFirst"><code>boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#isWatermark--">isWatermark</a></span>()</code> </td> +</tr> +<tr id="i16" class="altColor"> <td class="colFirst"><code>java.lang.String</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html#toString--">toString</a></span>()</code> </td> </tr> @@ -407,6 +425,29 @@ extends java.lang.Object</pre> <pre>public <a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> getSystemStreamPartition()</pre> </li> </ul> +<a name="getSystemStreamPartition-int-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getSystemStreamPartition</h4> +<pre>public <a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> getSystemStreamPartition(int elasticityFactor)</pre> +<div class="block">fetches the SSP (with keybucket) for the envelope based on elasticity factor. + keyBucket is determined by the key if non-null else by the offset + + Special case messages like Watermark msgs which should belong to all keybuckets of an ssp + however, they might have both key and offset as null, hence keybucket cant be determined + but choosing keybucket = 0 as ssp with keybucket is expected with elasticity enabled + the correct handling of special case messages is the responsibility of the caller</div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>elasticityFactor</code> - </dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>SSP without keybucket if elasticity is not enabled + SSP with keybucket otherwise</dd> +</dl> +</li> +</ul> <a name="getOffset--"> <!-- --> </a> @@ -453,6 +494,24 @@ extends java.lang.Object</pre> <pre>public boolean isEndOfStream()</pre> </li> </ul> +<a name="isDrain--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>isDrain</h4> +<pre>public boolean isDrain()</pre> +</li> +</ul> +<a name="isWatermark--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>isWatermark</h4> +<pre>public boolean isWatermark()</pre> +</li> +</ul> <a name="buildEndOfStreamEnvelope-org.apache.samza.system.SystemStreamPartition-"> <!-- --> </a> @@ -469,6 +528,16 @@ extends java.lang.Object</pre> </dl> </li> </ul> +<a name="buildDrainMessage-org.apache.samza.system.SystemStreamPartition-java.lang.String-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>buildDrainMessage</h4> +<pre>public static <a href="../../../../org/apache/samza/system/IncomingMessageEnvelope.html" title="class in org.apache.samza.system">IncomingMessageEnvelope</a> buildDrainMessage(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> ssp, + java.lang.String runId)</pre> +</li> +</ul> <a name="buildWatermarkEnvelope-org.apache.samza.system.SystemStreamPartition-long-"> <!-- --> </a> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/MessageType.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/MessageType.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/MessageType.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/MessageType.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>MessageType (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>MessageType (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MessageType (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="MessageType (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { @@ -139,12 +138,15 @@ extends java.lang.Enum<<a href="../.. <th class="colOne" scope="col">Enum Constant and Description</th> </tr> <tr class="altColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/MessageType.html#END_OF_STREAM">END_OF_STREAM</a></span></code> </td> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/MessageType.html#DRAIN">DRAIN</a></span></code> </td> </tr> <tr class="rowColor"> -<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/MessageType.html#USER_MESSAGE">USER_MESSAGE</a></span></code> </td> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/MessageType.html#END_OF_STREAM">END_OF_STREAM</a></span></code> </td> </tr> <tr class="altColor"> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/MessageType.html#USER_MESSAGE">USER_MESSAGE</a></span></code> </td> +</tr> +<tr class="rowColor"> <td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/MessageType.html#WATERMARK">WATERMARK</a></span></code> </td> </tr> </table> @@ -231,12 +233,21 @@ the order they are declared.</div> <a name="END_OF_STREAM"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>END_OF_STREAM</h4> <pre>public static final <a href="../../../../org/apache/samza/system/MessageType.html" title="enum in org.apache.samza.system">MessageType</a> END_OF_STREAM</pre> </li> </ul> +<a name="DRAIN"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>DRAIN</h4> +<pre>public static final <a href="../../../../org/apache/samza/system/MessageType.html" title="enum in org.apache.samza.system">MessageType</a> DRAIN</pre> +</li> +</ul> </li> </ul> <!-- ============ METHOD DETAIL ========== --> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/OutgoingMessageEnvelope.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/OutgoingMessageEnvelope.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/OutgoingMessageEnvelope.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/OutgoingMessageEnvelope.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>OutgoingMessageEnvelope (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>OutgoingMessageEnvelope (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="OutgoingMessageEnvelope (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="OutgoingMessageEnvelope (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamSpec.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>StreamSpec (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>StreamSpec (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="StreamSpec (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="StreamSpec (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamValidationException.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamValidationException.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamValidationException.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/StreamValidationException.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>StreamValidationException (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>StreamValidationException (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="StreamValidationException (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="StreamValidationException (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemAdmin.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemAdmin.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemAdmin.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemAdmin.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemAdmin (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemAdmin (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemAdmin (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemAdmin (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemConsumer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemConsumer.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemConsumer.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemConsumer.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemConsumer (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemConsumer (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemConsumer (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemConsumer (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemFactory.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemFactory.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemFactory.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemFactory (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemFactory (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemFactory (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemFactory (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { @@ -290,7 +289,7 @@ var activeTableTab = "activeTableTab"; <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>systemName</code> - The name of the system to create admin for.</dd> <dd><code>config</code> - The config to create admin with.</dd> -<dd><code>adminLabel</code> - a string to provide info the admin instance.</dd> +<dd><code>adminLabel</code> - a string to provide info for the admin instance.</dd> <dt><span class="returnLabel">Returns:</span></dt> <dd>A SystemAdmin</dd> </dl> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducer.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducer.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducer.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemProducer (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemProducer (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemProducer (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemProducer (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducerException.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducerException.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducerException.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemProducerException.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemProducerException (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemProducerException (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemProducerException (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemProducerException (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStream.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStream.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStream.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStream.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStream (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStream (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStream (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStream (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.OffsetType.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStreamMetadata.OffsetType (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStreamMetadata.OffsetType (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStreamMetadata.OffsetType (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStreamMetadata.OffsetType (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.SystemStreamPartitionMetadata.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStreamMetadata.SystemStreamPartitionMetadata (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStreamMetadata.SystemStreamPartitionMetadata (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStreamMetadata.SystemStreamPartitionMetadata (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStreamMetadata.SystemStreamPartitionMetadata (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamMetadata.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStreamMetadata (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStreamMetadata (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStreamMetadata (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStreamMetadata (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartition.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartition.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartition.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartition.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStreamPartition (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStreamPartition (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,13 +11,13 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStreamPartition (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStreamPartition (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -144,6 +143,10 @@ implements java.lang.Comparable<<a hr <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#hash">hash</a></span></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>protected int</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#keyBucket">keyBucket</a></span></code> </td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#partition">partition</a></span></code> </td> </tr> @@ -176,16 +179,26 @@ implements java.lang.Comparable<<a hr </td> </tr> <tr class="rowColor"> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition-java.lang.String-java.lang.String-org.apache.samza.Partition-int-">SystemStreamPartition</a></span>(java.lang.String system, + java.lang.String stream, + <a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a> partition, + int keyBucket)</code> </td> +</tr> +<tr class="altColor"> <td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition-org.apache.samza.system.SystemStreamPartition-">SystemStreamPartition</a></span>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> other)</code> <div class="block">Constructs a Samza stream partition object based upon an existing Samza stream partition.</div> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition-org.apache.samza.system.SystemStream-org.apache.samza.Partition-">SystemStreamPartition</a></span>(<a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a> other, <a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a> partition)</code> <div class="block">Constructs a Samza stream partition object based upon another Samza stream and a specified partition.</div> </td> </tr> +<tr class="altColor"> +<td class="colOne"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#SystemStreamPartition-org.apache.samza.system.SystemStreamPartition-int-">SystemStreamPartition</a></span>(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> other, + int keyBucket)</code> </td> +</tr> </table> </li> </ul> @@ -210,18 +223,22 @@ implements java.lang.Comparable<<a hr <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#equals-java.lang.Object-">equals</a></span>(java.lang.Object obj)</code> </td> </tr> <tr id="i2" class="altColor"> +<td class="colFirst"><code>int</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#getKeyBucket--">getKeyBucket</a></span>()</code> </td> +</tr> +<tr id="i3" class="rowColor"> <td class="colFirst"><code><a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#getPartition--">getPartition</a></span>()</code> </td> </tr> -<tr id="i3" class="rowColor"> +<tr id="i4" class="altColor"> <td class="colFirst"><code><a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#getSystemStream--">getSystemStream</a></span>()</code> </td> </tr> -<tr id="i4" class="altColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#hashCode--">hashCode</a></span>()</code> </td> </tr> -<tr id="i5" class="rowColor"> +<tr id="i6" class="altColor"> <td class="colFirst"><code>java.lang.String</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../org/apache/samza/system/SystemStreamPartition.html#toString--">toString</a></span>()</code> </td> </tr> @@ -266,12 +283,21 @@ implements java.lang.Comparable<<a hr <a name="hash"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>hash</h4> <pre>protected final int hash</pre> </li> </ul> +<a name="keyBucket"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>keyBucket</h4> +<pre>protected final int keyBucket</pre> +</li> +</ul> </li> </ul> <!-- ========= CONSTRUCTOR DETAIL ======== --> @@ -315,7 +341,7 @@ implements java.lang.Comparable<<a hr <a name="SystemStreamPartition-org.apache.samza.system.SystemStream-org.apache.samza.Partition-"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>SystemStreamPartition</h4> <pre>public SystemStreamPartition(<a href="../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system">SystemStream</a> other, @@ -328,6 +354,28 @@ implements java.lang.Comparable<<a hr </dl> </li> </ul> +<a name="SystemStreamPartition-java.lang.String-java.lang.String-org.apache.samza.Partition-int-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>SystemStreamPartition</h4> +<pre>public SystemStreamPartition(java.lang.String system, + java.lang.String stream, + <a href="../../../../org/apache/samza/Partition.html" title="class in org.apache.samza">Partition</a> partition, + int keyBucket)</pre> +</li> +</ul> +<a name="SystemStreamPartition-org.apache.samza.system.SystemStreamPartition-int-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>SystemStreamPartition</h4> +<pre>public SystemStreamPartition(<a href="../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system">SystemStreamPartition</a> other, + int keyBucket)</pre> +</li> +</ul> </li> </ul> <!-- ============ METHOD DETAIL ========== --> @@ -336,6 +384,15 @@ implements java.lang.Comparable<<a hr <!-- --> </a> <h3>Method Detail</h3> +<a name="getKeyBucket--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getKeyBucket</h4> +<pre>public int getKeyBucket()</pre> +</li> +</ul> <a name="getPartition--"> <!-- --> </a> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionIterator.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStreamPartitionIterator (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStreamPartitionIterator (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStreamPartitionIterator (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStreamPartitionIterator (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionMatcher.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionMatcher.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionMatcher.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/SystemStreamPartitionMatcher.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>SystemStreamPartitionMatcher (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>SystemStreamPartitionMatcher (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SystemStreamPartitionMatcher (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="SystemStreamPartitionMatcher (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/WatermarkMessage.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/WatermarkMessage.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/WatermarkMessage.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/WatermarkMessage.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>WatermarkMessage (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>WatermarkMessage (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="WatermarkMessage (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="WatermarkMessage (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/BaseMessageChooser.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 --> -<title>BaseMessageChooser (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>BaseMessageChooser (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="BaseMessageChooser (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="BaseMessageChooser (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooser.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 --> -<title>MessageChooser (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>MessageChooser (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MessageChooser (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="MessageChooser (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/MessageChooserFactory.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 --> -<title>MessageChooserFactory (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>MessageChooserFactory (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MessageChooserFactory (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="MessageChooserFactory (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-frame.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-frame.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-frame.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 --> -<title>org.apache.samza.system.chooser (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>org.apache.samza.system.chooser (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-summary.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-summary.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-summary.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 --> -<title>org.apache.samza.system.chooser (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>org.apache.samza.system.chooser (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="org.apache.samza.system.chooser (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="org.apache.samza.system.chooser (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-tree.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-tree.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/chooser/package-tree.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:15 PST 2021 --> -<title>org.apache.samza.system.chooser Class Hierarchy (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>org.apache.samza.system.chooser Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="org.apache.samza.system.chooser Class Hierarchy (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="org.apache.samza.system.chooser Class Hierarchy (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>ExpandingInputDescriptorProvider (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>ExpandingInputDescriptorProvider (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="ExpandingInputDescriptorProvider (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="ExpandingInputDescriptorProvider (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericInputDescriptor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericInputDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericInputDescriptor.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericInputDescriptor.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>GenericInputDescriptor (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>GenericInputDescriptor (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="GenericInputDescriptor (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="GenericInputDescriptor (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericOutputDescriptor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericOutputDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericOutputDescriptor.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericOutputDescriptor.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>GenericOutputDescriptor (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>GenericOutputDescriptor (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="GenericOutputDescriptor (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="GenericOutputDescriptor (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/GenericSystemDescriptor.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>GenericSystemDescriptor (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>GenericSystemDescriptor (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="GenericSystemDescriptor (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="GenericSystemDescriptor (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputDescriptor.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputDescriptor.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputDescriptor.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputDescriptor.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>InputDescriptor (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>InputDescriptor (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="InputDescriptor (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="InputDescriptor (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) { Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputTransformer.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputTransformer.html?rev=1906774&r1=1906773&r2=1906774&view=diff ============================================================================== --- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputTransformer.html (original) +++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/system/descriptors/InputTransformer.html Wed Jan 18 19:33:25 2023 @@ -2,9 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_212) on Thu Feb 04 10:07:14 PST 2021 --> -<title>InputTransformer (samza-api 1.7.0-SNAPSHOT API)</title> -<meta name="date" content="2021-02-04"> +<!-- Generated by javadoc --> +<title>InputTransformer (samza-api 1.9.0-SNAPSHOT API)</title> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> </head> @@ -12,7 +11,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="InputTransformer (samza-api 1.7.0-SNAPSHOT API)"; + parent.document.title="InputTransformer (samza-api 1.9.0-SNAPSHOT API)"; } } catch(err) {
