You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2018/01/04 00:31:43 UTC
svn commit: r1820026 [7/24] - in /samza/site: ./
img/latest/learn/documentation/hadoop/ img/latest/learn/documentation/rest/
learn/documentation/latest/ learn/documentation/latest/api/
learn/documentation/latest/api/javadocs/ learn/documentation/latest...
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-frame.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-frame.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-frame.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators.functions (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators.functions (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../../script.js"></script>
</head>
@@ -21,6 +21,8 @@
<li><a href="JoinFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">JoinFunction</span></a></li>
<li><a href="MapFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">MapFunction</span></a></li>
<li><a href="SinkFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">SinkFunction</span></a></li>
+<li><a href="StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">StreamTableJoinFunction</span></a></li>
+<li><a href="WatermarkFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">WatermarkFunction</span></a></li>
</ul>
</div>
</body>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-summary.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-summary.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-summary.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators.functions (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators.functions (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.operators.functions (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.operators.functions (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -129,6 +129,18 @@
<div class="block">Allows sending a message to an output system.</div>
</td>
</tr>
+<tr class="altColor">
+<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/StreamTableJoinFunction.html" title="interface in org.apache.samza.operators.functions">StreamTableJoinFunction</a><K,M,R,JM></td>
+<td class="colLast">
+<div class="block">Joins incoming messages with records from a table by the join key.</div>
+</td>
+</tr>
+<tr class="rowColor">
+<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/WatermarkFunction.html" title="interface in org.apache.samza.operators.functions">WatermarkFunction</a><T></td>
+<td class="colLast">
+<div class="block">Allows handling of watermarks.</div>
+</td>
+</tr>
</tbody>
</table>
</li>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-tree.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-tree.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/functions/package-tree.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators.functions Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators.functions Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.operators.functions Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.operators.functions Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -86,6 +86,7 @@
<li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">JoinFunction</span></a><K,M,JM,RM> (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>)</li>
<li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">MapFunction</span></a><M,OM> (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>)</li>
<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>)</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>)</li>
</ul>
</li>
<li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">InitableFunction</span></a>
@@ -96,8 +97,10 @@
<li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">JoinFunction</span></a><K,M,JM,RM> (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>)</li>
<li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">MapFunction</span></a><M,OM> (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>)</li>
<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>)</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>)</li>
</ul>
</li>
+<li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/WatermarkFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">WatermarkFunction</span></a><T></li>
</ul>
</div>
<!-- ======= START OF BOTTOM NAVBAR ====== -->
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-frame.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-frame.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-frame.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style">
<script type="text/javascript" src="../../../../script.js"></script>
</head>
@@ -17,6 +17,11 @@
<li><a href="MessageStream.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">MessageStream</span></a></li>
<li><a href="OutputStream.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">OutputStream</span></a></li>
<li><a href="StreamGraph.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">StreamGraph</span></a></li>
+<li><a href="TableDescriptor.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">TableDescriptor</span></a></li>
+</ul>
+<h2 title="Classes">Classes</h2>
+<ul title="Classes">
+<li><a href="KV.html" title="class in org.apache.samza.operators" target="classFrame">KV</a></li>
</ul>
</div>
</body>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-summary.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-summary.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-summary.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.operators (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.operators (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -94,7 +94,7 @@
</td>
</tr>
<tr class="altColor">
-<td class="colFirst"><a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a><K,V,M></td>
+<td class="colFirst"><a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators">OutputStream</a><M></td>
<td class="colLast">
<div class="block">An output stream to send messages to.</div>
</td>
@@ -102,7 +102,31 @@
<tr class="rowColor">
<td class="colFirst"><a href="../../../../org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators">StreamGraph</a></td>
<td class="colLast">
-<div class="block">Provides access to <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and <a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>s used to describe the processing logic.</div>
+<div class="block">Provides access to <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and <a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>s used to describe application logic.</div>
+</td>
+</tr>
+<tr class="altColor">
+<td class="colFirst"><a href="../../../../org/apache/samza/operators/TableDescriptor.html" title="interface in org.apache.samza.operators">TableDescriptor</a><K,V,D extends <a href="../../../../org/apache/samza/operators/TableDescriptor.html" title="interface in org.apache.samza.operators">TableDescriptor</a><K,V,D>></td>
+<td class="colLast">
+<div class="block">User facing class to collect metadata that fully describes a
+ Samza table.</div>
+</td>
+</tr>
+</tbody>
+</table>
+</li>
+<li class="blockList">
+<table class="typeSummary" border="0" cellpadding="3" cellspacing="0" summary="Class Summary table, listing classes, and an explanation">
+<caption><span>Class Summary</span><span class="tabEnd"> </span></caption>
+<tr>
+<th class="colFirst" scope="col">Class</th>
+<th class="colLast" scope="col">Description</th>
+</tr>
+<tbody>
+<tr class="altColor">
+<td class="colFirst"><a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators">KV</a><K,V></td>
+<td class="colLast">
+<div class="block">A key and value pair.</div>
</td>
</tr>
</tbody>
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-tree.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-tree.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/package-tree.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.operators Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.operators Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -76,12 +76,21 @@
</ul>
</div>
<div class="contentContainer">
+<h2 title="Class Hierarchy">Class Hierarchy</h2>
+<ul>
+<li type="circle">java.lang.Object
+<ul>
+<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/KV.html" title="class in org.apache.samza.operators"><span class="typeNameLink">KV</span></a><K,V></li>
+</ul>
+</li>
+</ul>
<h2 title="Interface Hierarchy">Interface Hierarchy</h2>
<ul>
<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">ContextManager</span></a></li>
<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">MessageStream</span></a><M></li>
-<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">OutputStream</span></a><K,V,M></li>
+<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">OutputStream</span></a><M></li>
<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">StreamGraph</span></a></li>
+<li type="circle">org.apache.samza.operators.<a href="../../../../org/apache/samza/operators/TableDescriptor.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">TableDescriptor</span></a><K,V,D></li>
</ul>
</div>
<!-- ======= START OF BOTTOM NAVBAR ====== -->
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>AnyTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>AnyTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="AnyTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="AnyTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>CountTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>CountTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="CountTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="CountTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>DurationCharacteristic (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>DurationCharacteristic (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="DurationCharacteristic (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="DurationCharacteristic (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/FiringType.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/FiringType.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/FiringType.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/FiringType.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>FiringType (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>FiringType (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="FiringType (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="FiringType (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/RepeatingTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/RepeatingTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/RepeatingTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/RepeatingTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>RepeatingTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>RepeatingTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="RepeatingTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="RepeatingTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeBasedTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeBasedTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeBasedTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeBasedTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:21 PDT 2017 -->
-<title>TimeBasedTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>TimeBasedTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="TimeBasedTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="TimeBasedTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>TimeSinceFirstMessageTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>TimeSinceFirstMessageTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="TimeSinceFirstMessageTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="TimeSinceFirstMessageTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>TimeSinceLastMessageTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>TimeSinceLastMessageTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="TimeSinceLastMessageTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="TimeSinceLastMessageTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeTrigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeTrigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeTrigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/TimeTrigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>TimeTrigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>TimeTrigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="TimeTrigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="TimeTrigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Trigger.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Trigger.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Trigger.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Trigger.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>Trigger (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Trigger (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="Trigger (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Trigger (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Triggers.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Triggers.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Triggers.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/Triggers.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>Triggers (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Triggers (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="Triggers (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Triggers (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-frame.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-frame.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-frame.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-frame.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators.triggers (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators.triggers (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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/operators/triggers/package-summary.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-summary.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-summary.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-summary.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators.triggers (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators.triggers (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.operators.triggers (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.operators.triggers (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-tree.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-tree.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-tree.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/triggers/package-tree.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>org.apache.samza.operators.triggers Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>org.apache.samza.operators.triggers Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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.operators.triggers Class Hierarchy (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="org.apache.samza.operators.triggers Class Hierarchy (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/AccumulationMode.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>AccumulationMode (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>AccumulationMode (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="AccumulationMode (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="AccumulationMode (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Window.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Window.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Window.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Window.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>Window (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Window (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="Window (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Window (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowKey.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowKey.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowKey.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowKey.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>WindowKey (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>WindowKey (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="WindowKey (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="WindowKey (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowPane.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowPane.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowPane.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/WindowPane.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>WindowPane (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>WindowPane (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="WindowPane (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="WindowPane (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
Modified: samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html
URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html?rev=1820026&r1=1820025&r2=1820026&view=diff
==============================================================================
--- samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html (original)
+++ samza/site/learn/documentation/latest/api/javadocs/org/apache/samza/operators/windows/Windows.html Thu Jan 4 00:31:39 2018
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_60) on Mon Jun 12 14:24:22 PDT 2017 -->
-<title>Windows (samza-api 0.13.1-SNAPSHOT API)</title>
-<meta name="date" content="2017-06-12">
+<!-- Generated by javadoc (1.8.0_121) on Wed Jan 03 16:26:16 PST 2018 -->
+<title>Windows (samza-api 0.14.1-SNAPSHOT API)</title>
+<meta name="date" content="2018-01-03">
<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="Windows (samza-api 0.13.1-SNAPSHOT API)";
+ parent.document.title="Windows (samza-api 0.14.1-SNAPSHOT API)";
}
}
catch(err) {
@@ -188,52 +188,62 @@ extends java.lang.Object</pre>
</tr>
<tr id="i0" class="altColor">
<td class="colFirst"><code>static <M,K> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,java.util.Collection<M>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-">keyedSessionWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
- java.time.Duration sessionGap)</code>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedSessionWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
+ java.time.Duration sessionGap,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><M> msgSerde)</code>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided
<code>sessionGap</code>.</div>
</td>
</tr>
<tr id="i1" class="rowColor">
<td class="colFirst"><code>static <M,K,WV> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,WV></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">keyedSessionWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedSessionWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedSessionWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
java.time.Duration sessionGap,
java.util.function.Supplier<? extends WV> initialValue,
- <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator)</code>
+ <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><WV> windowValueSerde)</code>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided
<code>sessionGap</code> and applies the provided fold function to them.</div>
</td>
</tr>
<tr id="i2" class="altColor">
-<td class="colFirst"><code>static <M,K> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,java.util.Collection<M>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-">keyedTumblingWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
- java.time.Duration interval)</code>
-<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping
- processing time based windows using the provided keyFn.</div>
-</td>
-</tr>
-<tr id="i3" class="rowColor">
<td class="colFirst"><code>static <M,K,WV> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,WV></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">keyedTumblingWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedTumblingWindow</a></span>(java.util.function.Function<? super M,? extends K> keyFn,
java.time.Duration interval,
java.util.function.Supplier<? extends WV> initialValue,
- <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator)</code>
+ <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><WV> windowValueSerde)</code>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping processing
time based windows based on the provided keyFn and applies the provided fold function to them.</div>
</td>
</tr>
+<tr id="i3" class="rowColor">
+<td class="colFirst"><code>static <M,K> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,java.util.Collection<M>></code></td>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#keyedTumblingWindow-java.util.function.Function-java.time.Duration-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">keyedTumblingWindow</a></span>(java.util.function.Function<M,K> keyFn,
+ java.time.Duration interval,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><M> msgSerde)</code>
+<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping
+ processing time based windows using the provided keyFn.</div>
+</td>
+</tr>
<tr id="i4" class="altColor">
<td class="colFirst"><code>static <M> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,java.lang.Void,java.util.Collection<M>></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#tumblingWindow-java.time.Duration-">tumblingWindow</a></span>(java.time.Duration duration)</code>
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#tumblingWindow-java.time.Duration-org.apache.samza.serializers.Serde-">tumblingWindow</a></span>(java.time.Duration duration,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><M> msgSerde)</code>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping
processing time based windows.</div>
</td>
</tr>
<tr id="i5" class="rowColor">
<td class="colFirst"><code>static <M,WV> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,java.lang.Void,WV></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#tumblingWindow-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">tumblingWindow</a></span>(java.time.Duration interval,
+<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/windows/Windows.html#tumblingWindow-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-">tumblingWindow</a></span>(java.time.Duration interval,
java.util.function.Supplier<? extends WV> initialValue,
- <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator)</code>
+ <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><WV> windowValueSerde)</code>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that windows values into fixed-size processing time based windows and aggregates
them applying the provided function.</div>
</td>
@@ -260,7 +270,7 @@ extends java.lang.Object</pre>
<!-- -->
</a>
<h3>Method Detail</h3>
-<a name="keyedTumblingWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">
+<a name="keyedTumblingWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">
<!-- -->
</a>
<ul class="blockList">
@@ -269,7 +279,9 @@ extends java.lang.Object</pre>
<pre>public static <M,K,WV> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,WV> keyedTumblingWindow(java.util.function.Function<? super M,? extends K> keyFn,
java.time.Duration interval,
java.util.function.Supplier<? extends WV> initialValue,
- <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator)</pre>
+ <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><WV> windowValueSerde)</pre>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping processing
time based windows based on the provided keyFn and applies the provided fold function to them.
@@ -295,19 +307,23 @@ extends java.lang.Object</pre>
<dd><code>initialValue</code> - the initial value supplier for the aggregator. Invoked when a new window is created.</dd>
<dd><code>aggregator</code> - the function to incrementally update the window value. Invoked when a new message
arrives for the window.</dd>
+<dd><code>keySerde</code> - the serde for the window key</dd>
+<dd><code>windowValueSerde</code> - the serde for the window value</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the created <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> function.</dd>
</dl>
</li>
</ul>
-<a name="keyedTumblingWindow-java.util.function.Function-java.time.Duration-">
+<a name="keyedTumblingWindow-java.util.function.Function-java.time.Duration-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>keyedTumblingWindow</h4>
-<pre>public static <M,K> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,java.util.Collection<M>> keyedTumblingWindow(java.util.function.Function<? super M,? extends K> keyFn,
- java.time.Duration interval)</pre>
+<pre>public static <M,K> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,java.util.Collection<M>> keyedTumblingWindow(java.util.function.Function<M,K> keyFn,
+ java.time.Duration interval,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><M> msgSerde)</pre>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping
processing time based windows using the provided keyFn.
@@ -327,12 +343,14 @@ extends java.lang.Object</pre>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>keyFn</code> - function to extract key from the message</dd>
<dd><code>interval</code> - the duration in processing time</dd>
+<dd><code>keySerde</code> - the serde for the window key</dd>
+<dd><code>msgSerde</code> - the serde for the input message</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the created <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> function</dd>
</dl>
</li>
</ul>
-<a name="tumblingWindow-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">
+<a name="tumblingWindow-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-">
<!-- -->
</a>
<ul class="blockList">
@@ -340,7 +358,8 @@ extends java.lang.Object</pre>
<h4>tumblingWindow</h4>
<pre>public static <M,WV> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,java.lang.Void,WV> tumblingWindow(java.time.Duration interval,
java.util.function.Supplier<? extends WV> initialValue,
- <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator)</pre>
+ <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><WV> windowValueSerde)</pre>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that windows values into fixed-size processing time based windows and aggregates
them applying the provided function.
@@ -363,18 +382,20 @@ extends java.lang.Object</pre>
<dd><code>initialValue</code> - the initial value supplier for the aggregator. Invoked when a new window is created.</dd>
<dd><code>aggregator</code> - the function to incrementally update the window value. Invoked when a new message
arrives for the window.</dd>
+<dd><code>windowValueSerde</code> - the serde for the window value</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the created <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> function</dd>
</dl>
</li>
</ul>
-<a name="tumblingWindow-java.time.Duration-">
+<a name="tumblingWindow-java.time.Duration-org.apache.samza.serializers.Serde-">
<!-- -->
</a>
<ul class="blockList">
<li class="blockList">
<h4>tumblingWindow</h4>
-<pre>public static <M> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,java.lang.Void,java.util.Collection<M>> tumblingWindow(java.time.Duration duration)</pre>
+<pre>public static <M> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,java.lang.Void,java.util.Collection<M>> tumblingWindow(java.time.Duration duration,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><M> msgSerde)</pre>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into fixed-size, non-overlapping
processing time based windows.
@@ -395,12 +416,13 @@ extends java.lang.Object</pre>
<dd><code>M</code> - the type of the input message</dd>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>duration</code> - the duration in processing time</dd>
+<dd><code>msgSerde</code> - the serde for the input message</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the created <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> function</dd>
</dl>
</li>
</ul>
-<a name="keyedSessionWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-">
+<a name="keyedSessionWindow-java.util.function.Function-java.time.Duration-java.util.function.Supplier-org.apache.samza.operators.functions.FoldLeftFunction-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">
<!-- -->
</a>
<ul class="blockList">
@@ -409,7 +431,9 @@ extends java.lang.Object</pre>
<pre>public static <M,K,WV> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,WV> keyedSessionWindow(java.util.function.Function<? super M,? extends K> keyFn,
java.time.Duration sessionGap,
java.util.function.Supplier<? extends WV> initialValue,
- <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator)</pre>
+ <a href="../../../../../org/apache/samza/operators/functions/FoldLeftFunction.html" title="interface in org.apache.samza.operators.functions">FoldLeftFunction</a><? super M,WV> aggregator,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><WV> windowValueSerde)</pre>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided
<code>sessionGap</code> and applies the provided fold function to them.
@@ -439,19 +463,23 @@ extends java.lang.Object</pre>
<dd><code>initialValue</code> - the initial value supplier for the aggregator. Invoked when a new window is created.</dd>
<dd><code>aggregator</code> - the function to incrementally update the window value. Invoked when a new message
arrives for the window.</dd>
+<dd><code>keySerde</code> - the serde for the window key</dd>
+<dd><code>windowValueSerde</code> - the serde for the window value</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the created <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> function</dd>
</dl>
</li>
</ul>
-<a name="keyedSessionWindow-java.util.function.Function-java.time.Duration-">
+<a name="keyedSessionWindow-java.util.function.Function-java.time.Duration-org.apache.samza.serializers.Serde-org.apache.samza.serializers.Serde-">
<!-- -->
</a>
<ul class="blockListLast">
<li class="blockList">
<h4>keyedSessionWindow</h4>
<pre>public static <M,K> <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows">Window</a><M,K,java.util.Collection<M>> keyedSessionWindow(java.util.function.Function<? super M,? extends K> keyFn,
- java.time.Duration sessionGap)</pre>
+ java.time.Duration sessionGap,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><K> keySerde,
+ <a href="../../../../../org/apache/samza/serializers/Serde.html" title="interface in org.apache.samza.serializers">Serde</a><M> msgSerde)</pre>
<div class="block">Creates a <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> that groups incoming messages into sessions per-key based on the provided
<code>sessionGap</code>.
@@ -477,6 +505,8 @@ extends java.lang.Object</pre>
<dt><span class="paramLabel">Parameters:</span></dt>
<dd><code>keyFn</code> - the function to extract the window key from a message}</dd>
<dd><code>sessionGap</code> - the timeout gap for defining the session</dd>
+<dd><code>keySerde</code> - the serde for the window key</dd>
+<dd><code>msgSerde</code> - the serde for the input message</dd>
<dt><span class="returnLabel">Returns:</span></dt>
<dd>the created <a href="../../../../../org/apache/samza/operators/windows/Window.html" title="interface in org.apache.samza.operators.windows"><code>Window</code></a> function</dd>
</dl>