Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-summary.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-summary.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-summary.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators.data (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators.data (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="org.apache.samza.operators.data (samza-api 0.12.0 API)"; + parent.document.title="org.apache.samza.operators.data (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -84,7 +84,7 @@ <tr class="altColor"> <td class="colFirst"><a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a><K,M></td> <td class="colLast"> -<div class="block">An entry in the input/output <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s.</div> +<div class="block">An entry in the input/output <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s</div> </td> </tr> <tr class="rowColor"> @@ -105,7 +105,7 @@ </tr> <tbody> <tr class="altColor"> -<td class="colFirst"><a href="../../../../../org/apache/samza/operators/data/IncomingSystemMessageEnvelope.html" title="class in org.apache.samza.operators.data">IncomingSystemMessageEnvelope</a></td> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data">InputMessageEnvelope</a></td> <td class="colLast"> <div class="block">A <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> that provides additional information about its input <a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a> and its <a href="../../../../../org/apache/samza/operators/data/Offset.html" title="interface in org.apache.samza.operators.data"><code>Offset</code></a> within the <a href="../../../../../org/apache/samza/system/SystemStreamPartition.html" title="class in org.apache.samza.system"><code>SystemStreamPartition</code></a>.</div>
Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-tree.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-tree.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/data/package-tree.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators.data Class Hierarchy (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators.data Class Hierarchy (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="org.apache.samza.operators.data Class Hierarchy (samza-api 0.12.0 API)"; + parent.document.title="org.apache.samza.operators.data Class Hierarchy (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -80,7 +80,7 @@ <ul> <li type="circle">java.lang.Object <ul> -<li type="circle">org.apache.samza.operators.data.<a href="../../../../../org/apache/samza/operators/data/IncomingSystemMessageEnvelope.html" title="class in org.apache.samza.operators.data"><span class="typeNameLink">IncomingSystemMessageEnvelope</span></a> (implements org.apache.samza.operators.data.<a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a><K,M>)</li> +<li type="circle">org.apache.samza.operators.data.<a href="../../../../../org/apache/samza/operators/data/InputMessageEnvelope.html" title="class in org.apache.samza.operators.data"><span class="typeNameLink">InputMessageEnvelope</span></a> (implements org.apache.samza.operators.data.<a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a><K,M>)</li> <li type="circle">org.apache.samza.operators.data.<a href="../../../../../org/apache/samza/operators/data/LongOffset.html" title="class in org.apache.samza.operators.data"><span class="typeNameLink">LongOffset</span></a> (implements org.apache.samza.operators.data.<a href="../../../../../org/apache/samza/operators/data/Offset.html" title="interface in org.apache.samza.operators.data">Offset</a>)</li> </ul> </li> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FilterFunction.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>FilterFunction (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>FilterFunction (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="FilterFunction (samza-api 0.12.0 API)"; + parent.document.title="FilterFunction (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.functions</div> -<h2 title="Interface FilterFunction" class="title">Interface FilterFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Interface FilterFunction" class="title">Interface FilterFunction<M></h2> </div> <div class="contentContainer"> <div class="description"> @@ -100,7 +100,11 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt><span class="paramLabel">Type Parameters:</span></dt> -<dd><code>M</code> - type of the input <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd><code>M</code> - type of the input message</dd> +</dl> +<dl> +<dt>All Superinterfaces:</dt> +<dd><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dd> </dl> <dl> <dt>Functional Interface:</dt> @@ -110,8 +114,9 @@ var activeTableTab = "activeTableTab"; <br> <pre><a href="../../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation">@InterfaceStability.Unstable</a> @FunctionalInterface -public interface <span class="typeNameLabel">FilterFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span></pre> -<div class="block">A function that specifies whether a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> should be retained for further processing or filtered out.</div> +public interface <span class="typeNameLabel">FilterFunction<M></span> +extends <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></pre> +<div class="block">A function that specifies whether a message should be retained for further processing or filtered out.</div> </li> </ul> </div> @@ -133,10 +138,17 @@ public interface <span class="typeNameLa <tr id="i0" class="altColor"> <td class="colFirst"><code>boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html#apply-M-">apply</a></span>(<a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="type parameter in FilterFunction">M</a> message)</code> -<div class="block">Returns a boolean indicating whether this <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> should be retained or filtered out.</div> +<div class="block">Returns a boolean indicating whether this message should be retained or filtered out.</div> </td> </tr> </table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.operators.functions.InitableFunction"> +<!-- --> +</a> +<h3>Methods inherited from interface org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></h3> +<code><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init</a></code></li> +</ul> </li> </ul> </li> @@ -151,7 +163,7 @@ public interface <span class="typeNameLa <!-- --> </a> <h3>Method Detail</h3> -<a name="apply-org.apache.samza.operators.data.MessageEnvelope-"> +<a name="apply-java.lang.Object-"> <!-- --> </a><a name="apply-M-"> <!-- --> @@ -160,12 +172,12 @@ public interface <span class="typeNameLa <li class="blockList"> <h4>apply</h4> <pre>boolean apply(<a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="type parameter in FilterFunction">M</a> message)</pre> -<div class="block">Returns a boolean indicating whether this <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> should be retained or filtered out.</div> +<div class="block">Returns a boolean indicating whether this message should be retained or filtered out.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>message</code> - the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to be checked</dd> +<dd><code>message</code> - the input message to be checked</dd> <dt><span class="returnLabel">Returns:</span></dt> -<dd>true if <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> should be retained</dd> +<dd>true if <code>message</code> should be retained</dd> </dl> </li> </ul> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/FlatMapFunction.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>FlatMapFunction (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>FlatMapFunction (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="FlatMapFunction (samza-api 0.12.0 API)"; + parent.document.title="FlatMapFunction (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab"; <div class="subNav"> <ul class="navList"> <li><a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../index.html?org/apache/samza/operators/functions/FlatMapFunction.html" target="_top">Frames</a></li> @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.functions</div> -<h2 title="Interface FlatMapFunction" class="title">Interface FlatMapFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,OM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Interface FlatMapFunction" class="title">Interface FlatMapFunction<M,OM></h2> </div> <div class="contentContainer"> <div class="description"> @@ -100,8 +100,12 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt><span class="paramLabel">Type Parameters:</span></dt> -<dd><code>M</code> - type of the input <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> -<dd><code>OM</code> - type of the transformed <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s</dd> +<dd><code>M</code> - type of the input message</dd> +<dd><code>OM</code> - type of the transformed messages</dd> +</dl> +<dl> +<dt>All Superinterfaces:</dt> +<dd><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dd> </dl> <dl> <dt>Functional Interface:</dt> @@ -111,8 +115,9 @@ var activeTableTab = "activeTableTab"; <br> <pre><a href="../../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation">@InterfaceStability.Unstable</a> @FunctionalInterface -public interface <span class="typeNameLabel">FlatMapFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,OM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span></pre> -<div class="block">A function that transforms a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into a collection of 0 or more <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s, +public interface <span class="typeNameLabel">FlatMapFunction<M,OM></span> +extends <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></pre> +<div class="block">A function that transforms an input message into a collection of 0 or more messages, possibly of a different type.</div> </li> </ul> @@ -135,10 +140,17 @@ public interface <span class="typeNameLa <tr id="i0" class="altColor"> <td class="colFirst"><code>java.util.Collection<<a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="type parameter in FlatMapFunction">OM</a>></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html#apply-M-">apply</a></span>(<a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="type parameter in FlatMapFunction">M</a> message)</code> -<div class="block">Transforms the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into a collection of 0 or more <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s.</div> +<div class="block">Transforms the provided message into a collection of 0 or more messages.</div> </td> </tr> </table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.operators.functions.InitableFunction"> +<!-- --> +</a> +<h3>Methods inherited from interface org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></h3> +<code><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init</a></code></li> +</ul> </li> </ul> </li> @@ -153,7 +165,7 @@ public interface <span class="typeNameLa <!-- --> </a> <h3>Method Detail</h3> -<a name="apply-org.apache.samza.operators.data.MessageEnvelope-"> +<a name="apply-java.lang.Object-"> <!-- --> </a><a name="apply-M-"> <!-- --> @@ -162,12 +174,12 @@ public interface <span class="typeNameLa <li class="blockList"> <h4>apply</h4> <pre>java.util.Collection<<a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="type parameter in FlatMapFunction">OM</a>> apply(<a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="type parameter in FlatMapFunction">M</a> message)</pre> -<div class="block">Transforms the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into a collection of 0 or more <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s.</div> +<div class="block">Transforms the provided message into a collection of 0 or more messages.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>message</code> - the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to be transformed</dd> +<dd><code>message</code> - the input message to be transformed</dd> <dt><span class="returnLabel">Returns:</span></dt> -<dd>a collection of 0 or more transformed <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s</dd> +<dd>a collection of 0 or more transformed messages</dd> </dl> </li> </ul> @@ -199,7 +211,7 @@ public interface <span class="typeNameLa <div class="subNav"> <ul class="navList"> <li><a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Prev Class</span></a></li> -<li><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Next Class</span></a></li> +<li><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> <li><a href="../../../../../index.html?org/apache/samza/operators/functions/FlatMapFunction.html" target="_top">Frames</a></li> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/InitableFunction.html Tue Feb 28 01:45:28 2017 @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Wed Feb 22 13:00:21 PST 2017 --> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> <title>InitableFunction (samza-api 0.13.0-SNAPSHOT API)</title> -<meta name="date" content="2017-02-22"> +<meta name="date" content="2017-02-27"> <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/versioned/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/JoinFunction.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>JoinFunction (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>JoinFunction (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,13 +12,13 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="JoinFunction (samza-api 0.12.0 API)"; + parent.document.title="JoinFunction (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { } //--> -var methods = {"i0":6}; +var methods = {"i0":6,"i1":6,"i2":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -48,7 +48,7 @@ var activeTableTab = "activeTableTab"; </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.functions</div> -<h2 title="Interface JoinFunction" class="title">Interface JoinFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,JM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,RM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Interface JoinFunction" class="title">Interface JoinFunction<K,M,JM,RM></h2> </div> <div class="contentContainer"> <div class="description"> @@ -100,21 +100,22 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt><span class="paramLabel">Type Parameters:</span></dt> -<dd><code>M</code> - type of the input <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> -<dd><code>JM</code> - type of the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to join with</dd> -<dd><code>RM</code> - type of the joined <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd><code>K</code> - type of the join key</dd> +<dd><code>M</code> - type of the input message</dd> +<dd><code>JM</code> - type of the message to join with</dd> +<dd><code>RM</code> - type of the joined message</dd> </dl> <dl> -<dt>Functional Interface:</dt> -<dd>This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.</dd> +<dt>All Superinterfaces:</dt> +<dd><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dd> </dl> <hr> <br> <pre><a href="../../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation">@InterfaceStability.Unstable</a> - @FunctionalInterface -public interface <span class="typeNameLabel">JoinFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,JM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,RM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span></pre> -<div class="block">A function that joins <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s from two <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and produces - a joined <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>.</div> +public interface <span class="typeNameLabel">JoinFunction<K,M,JM,RM></span> +extends <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></pre> +<div class="block">A function that joins messages from two <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and produces + a joined message.</div> </li> </ul> </div> @@ -137,10 +138,29 @@ public interface <span class="typeNameLa <td class="colFirst"><code><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">RM</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html#apply-M-JM-">apply</a></span>(<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">M</a> message, <a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">JM</a> otherMessage)</code> -<div class="block">Join the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s and produces the joined <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>.</div> +<div class="block">Join the provided input messages and produces the joined messages.</div> +</td> +</tr> +<tr id="i1" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">K</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html#getFirstKey-M-">getFirstKey</a></span>(<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">M</a> message)</code> +<div class="block">Method to get the join key in the messages from the first input stream</div> +</td> +</tr> +<tr id="i2" class="altColor"> +<td class="colFirst"><code><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">K</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html#getSecondKey-JM-">getSecondKey</a></span>(<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">JM</a> message)</code> +<div class="block">Method to get the join key in the messages from the second input stream</div> </td> </tr> </table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.operators.functions.InitableFunction"> +<!-- --> +</a> +<h3>Methods inherited from interface org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></h3> +<code><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init</a></code></li> +</ul> </li> </ul> </li> @@ -155,23 +175,59 @@ public interface <span class="typeNameLa <!-- --> </a> <h3>Method Detail</h3> -<a name="apply-org.apache.samza.operators.data.MessageEnvelope-org.apache.samza.operators.data.MessageEnvelope-"> +<a name="apply-java.lang.Object-java.lang.Object-"> <!-- --> </a><a name="apply-M-JM-"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>apply</h4> <pre><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">RM</a> apply(<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">M</a> message, <a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">JM</a> otherMessage)</pre> -<div class="block">Join the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s and produces the joined <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>.</div> +<div class="block">Join the provided input messages and produces the joined messages.</div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>message</code> - the input message</dd> +<dd><code>otherMessage</code> - the message to join with</dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>the joined message</dd> +</dl> +</li> +</ul> +<a name="getFirstKey-java.lang.Object-"> +<!-- --> +</a><a name="getFirstKey-M-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getFirstKey</h4> +<pre><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">K</a> getFirstKey(<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">M</a> message)</pre> +<div class="block">Method to get the join key in the messages from the first input stream</div> +<dl> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>message</code> - the input message from the first input stream</dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>the join key</dd> +</dl> +</li> +</ul> +<a name="getSecondKey-java.lang.Object-"> +<!-- --> +</a><a name="getSecondKey-JM-"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>getSecondKey</h4> +<pre><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">K</a> getSecondKey(<a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="type parameter in JoinFunction">JM</a> message)</pre> +<div class="block">Method to get the join key in the messages from the second input stream</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>message</code> - the input <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> -<dd><code>otherMessage</code> - the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to join with</dd> +<dd><code>message</code> - the input message from the second input stream</dd> <dt><span class="returnLabel">Returns:</span></dt> -<dd>the joined <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd>the join key</dd> </dl> </li> </ul> @@ -202,7 +258,7 @@ public interface <span class="typeNameLa </div> <div class="subNav"> <ul class="navList"> -<li><a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Prev Class</span></a></li> +<li><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Prev Class</span></a></li> <li><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">Next Class</span></a></li> </ul> <ul class="navList"> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/MapFunction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/MapFunction.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/MapFunction.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/MapFunction.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>MapFunction (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>MapFunction (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="MapFunction (samza-api 0.12.0 API)"; + parent.document.title="MapFunction (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.functions</div> -<h2 title="Interface MapFunction" class="title">Interface MapFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,OM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Interface MapFunction" class="title">Interface MapFunction<M,OM></h2> </div> <div class="contentContainer"> <div class="description"> @@ -100,8 +100,12 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt><span class="paramLabel">Type Parameters:</span></dt> -<dd><code>M</code> - type of the input <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> -<dd><code>OM</code> - type of the transformed <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd><code>M</code> - type of the input message</dd> +<dd><code>OM</code> - type of the transformed message</dd> +</dl> +<dl> +<dt>All Superinterfaces:</dt> +<dd><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dd> </dl> <dl> <dt>Functional Interface:</dt> @@ -111,8 +115,9 @@ var activeTableTab = "activeTableTab"; <br> <pre><a href="../../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation">@InterfaceStability.Unstable</a> @FunctionalInterface -public interface <span class="typeNameLabel">MapFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,OM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span></pre> -<div class="block">A function that transforms a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into another <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>, possibly of a different type.</div> +public interface <span class="typeNameLabel">MapFunction<M,OM></span> +extends <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></pre> +<div class="block">A function that transforms an input message into another message, possibly of a different type.</div> </li> </ul> </div> @@ -134,10 +139,17 @@ public interface <span class="typeNameLa <tr id="i0" class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="type parameter in MapFunction">OM</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html#apply-M-">apply</a></span>(<a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="type parameter in MapFunction">M</a> message)</code> -<div class="block">Transforms the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into another <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></div> +<div class="block">Transforms the provided message into another message</div> </td> </tr> </table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.operators.functions.InitableFunction"> +<!-- --> +</a> +<h3>Methods inherited from interface org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></h3> +<code><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init</a></code></li> +</ul> </li> </ul> </li> @@ -152,7 +164,7 @@ public interface <span class="typeNameLa <!-- --> </a> <h3>Method Detail</h3> -<a name="apply-org.apache.samza.operators.data.MessageEnvelope-"> +<a name="apply-java.lang.Object-"> <!-- --> </a><a name="apply-M-"> <!-- --> @@ -161,12 +173,12 @@ public interface <span class="typeNameLa <li class="blockList"> <h4>apply</h4> <pre><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="type parameter in MapFunction">OM</a> apply(<a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="type parameter in MapFunction">M</a> message)</pre> -<div class="block">Transforms the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into another <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></div> +<div class="block">Transforms the provided message into another message</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>message</code> - the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to be transformed</dd> +<dd><code>message</code> - the input message to be transformed</dd> <dt><span class="returnLabel">Returns:</span></dt> -<dd>the transformed <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd>the transformed message</dd> </dl> </li> </ul> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/SinkFunction.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>SinkFunction (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>SinkFunction (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="SinkFunction (samza-api 0.12.0 API)"; + parent.document.title="SinkFunction (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.functions</div> -<h2 title="Interface SinkFunction" class="title">Interface SinkFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Interface SinkFunction" class="title">Interface SinkFunction<M></h2> </div> <div class="contentContainer"> <div class="description"> @@ -100,7 +100,11 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <dl> <dt><span class="paramLabel">Type Parameters:</span></dt> -<dd><code>M</code> - type of the input <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd><code>M</code> - type of the input message</dd> +</dl> +<dl> +<dt>All Superinterfaces:</dt> +<dd><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></dd> </dl> <dl> <dt>Functional Interface:</dt> @@ -110,8 +114,9 @@ var activeTableTab = "activeTableTab"; <br> <pre><a href="../../../../../org/apache/samza/annotation/InterfaceStability.Unstable.html" title="annotation in org.apache.samza.annotation">@InterfaceStability.Unstable</a> @FunctionalInterface -public interface <span class="typeNameLabel">SinkFunction<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span></pre> -<div class="block">A function that allows sending a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to an output system.</div> +public interface <span class="typeNameLabel">SinkFunction<M></span> +extends <a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></pre> +<div class="block">A function that allows sending a message to an output system.</div> </li> </ul> </div> @@ -135,11 +140,18 @@ public interface <span class="typeNameLa <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/samza/operators/functions/SinkFunction.html#apply-M-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-">apply</a></span>(<a href="../../../../../org/apache/samza/operators/functions/SinkFunction.html" title="type parameter in SinkFunction">M</a> message, <a href="../../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task">MessageCollector</a> messageCollector, <a href="../../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task">TaskCoordinator</a> taskCoordinator)</code> -<div class="block">Allows sending the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to an output <a href="../../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> using +<div class="block">Allows sending the provided message to an output <a href="../../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> using the provided <a href="../../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a>.</div> </td> </tr> </table> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.samza.operators.functions.InitableFunction"> +<!-- --> +</a> +<h3>Methods inherited from interface org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></h3> +<code><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html#init-org.apache.samza.config.Config-org.apache.samza.task.TaskContext-">init</a></code></li> +</ul> </li> </ul> </li> @@ -154,7 +166,7 @@ public interface <span class="typeNameLa <!-- --> </a> <h3>Method Detail</h3> -<a name="apply-org.apache.samza.operators.data.MessageEnvelope-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-"> +<a name="apply-java.lang.Object-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-"> <!-- --> </a><a name="apply-M-org.apache.samza.task.MessageCollector-org.apache.samza.task.TaskCoordinator-"> <!-- --> @@ -165,13 +177,13 @@ public interface <span class="typeNameLa <pre>void apply(<a href="../../../../../org/apache/samza/operators/functions/SinkFunction.html" title="type parameter in SinkFunction">M</a> message, <a href="../../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task">MessageCollector</a> messageCollector, <a href="../../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task">TaskCoordinator</a> taskCoordinator)</pre> -<div class="block">Allows sending the provided <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to an output <a href="../../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> using +<div class="block">Allows sending the provided message to an output <a href="../../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a> using the provided <a href="../../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a>. Also provides access to the <a href="../../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task"><code>TaskCoordinator</code></a> to request commits or shut the container down.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> -<dd><code>message</code> - the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to be sent to an output <a href="../../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a></dd> -<dd><code>messageCollector</code> - the <a href="../../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a> to use to send the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> +<dd><code>message</code> - the input message to be sent to an output <a href="../../../../../org/apache/samza/system/SystemStream.html" title="class in org.apache.samza.system"><code>SystemStream</code></a></dd> +<dd><code>messageCollector</code> - the <a href="../../../../../org/apache/samza/task/MessageCollector.html" title="interface in org.apache.samza.task"><code>MessageCollector</code></a> to send the <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a></dd> <dd><code>taskCoordinator</code> - the <a href="../../../../../org/apache/samza/task/TaskCoordinator.html" title="interface in org.apache.samza.task"><code>TaskCoordinator</code></a> to request commits or shutdown</dd> </dl> </li> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-frame.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-frame.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-frame.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators.functions (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators.functions (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -15,6 +15,7 @@ <ul title="Interfaces"> <li><a href="FilterFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">FilterFunction</span></a></li> <li><a href="FlatMapFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">FlatMapFunction</span></a></li> +<li><a href="InitableFunction.html" title="interface in org.apache.samza.operators.functions" target="classFrame"><span class="interfaceName">InitableFunction</span></a></li> <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> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-summary.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-summary.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-summary.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators.functions (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators.functions (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -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.12.0 API)"; + parent.document.title="org.apache.samza.operators.functions (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -82,35 +82,41 @@ </tr> <tbody> <tr class="altColor"> -<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions">FilterFunction</a><M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></td> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions">FilterFunction</a><M></td> <td class="colLast"> -<div class="block">A function that specifies whether a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> should be retained for further processing or filtered out.</div> +<div class="block">A function that specifies whether a message should be retained for further processing or filtered out.</div> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions">FlatMapFunction</a><M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,OM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></td> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions">FlatMapFunction</a><M,OM></td> <td class="colLast"> -<div class="block">A function that transforms a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into a collection of 0 or more <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s, +<div class="block">A function that transforms an input message into a collection of 0 or more messages, possibly of a different type.</div> </td> </tr> <tr class="altColor"> -<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a><M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,JM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,RM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></td> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/InitableFunction.html" title="interface in org.apache.samza.operators.functions">InitableFunction</a></td> <td class="colLast"> -<div class="block">A function that joins <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s from two <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and produces - a joined <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>.</div> +<div class="block">interface defined to initalize the context of message transformation functions</div> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions">MapFunction</a><M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>,OM extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></td> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/JoinFunction.html" title="interface in org.apache.samza.operators.functions">JoinFunction</a><K,M,JM,RM></td> <td class="colLast"> -<div class="block">A function that transforms a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> into another <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>, possibly of a different type.</div> +<div class="block">A function that joins messages from two <a href="../../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s and produces + a joined message.</div> </td> </tr> <tr class="altColor"> -<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions">SinkFunction</a><M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></td> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/MapFunction.html" title="interface in org.apache.samza.operators.functions">MapFunction</a><M,OM></td> <td class="colLast"> -<div class="block">A function that allows sending a <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a> to an output system.</div> +<div class="block">A function that transforms an input message into another message, possibly of a different type.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><a href="../../../../../org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions">SinkFunction</a><M></td> +<td class="colLast"> +<div class="block">A function that allows sending a message to an output system.</div> </td> </tr> </tbody> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-tree.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-tree.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/functions/package-tree.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators.functions Class Hierarchy (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators.functions Class Hierarchy (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -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.12.0 API)"; + parent.document.title="org.apache.samza.operators.functions Class Hierarchy (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -78,12 +78,16 @@ <div class="contentContainer"> <h2 title="Interface Hierarchy">Interface Hierarchy</h2> <ul> +<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> +<ul> <li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/FilterFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FilterFunction</span></a><M></li> <li type="circle">org.apache.samza.operators.functions.<a href="../../../../../org/apache/samza/operators/functions/FlatMapFunction.html" title="interface in org.apache.samza.operators.functions"><span class="typeNameLink">FlatMapFunction</span></a><M,OM></li> -<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><M,JM,RM></li> +<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></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></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></li> </ul> +</li> +</ul> </div> <!-- ======= START OF BOTTOM NAVBAR ====== --> <div class="bottomNav"><a name="navbar.bottom"> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-frame.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-frame.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-frame.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-frame.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> @@ -13,8 +13,11 @@ <div class="indexContainer"> <h2 title="Interfaces">Interfaces</h2> <ul title="Interfaces"> +<li><a href="ContextManager.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">ContextManager</span></a></li> <li><a href="MessageStream.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">MessageStream</span></a></li> -<li><a href="StreamOperatorTask.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">StreamOperatorTask</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="StreamGraphBuilder.html" title="interface in org.apache.samza.operators" target="classFrame"><span class="interfaceName">StreamGraphBuilder</span></a></li> </ul> </div> </body> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-summary.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-summary.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-summary.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-summary.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> @@ -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.12.0 API)"; + parent.document.title="org.apache.samza.operators (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -82,15 +82,33 @@ </tr> <tbody> <tr class="altColor"> -<td class="colFirst"><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><M extends <a href="../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></td> +<td class="colFirst"><a href="../../../../org/apache/samza/operators/ContextManager.html" title="interface in org.apache.samza.operators">ContextManager</a></td> <td class="colLast"> -<div class="block">Represents a stream of <a href="../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data"><code>MessageEnvelope</code></a>s.</div> +<div class="block">Interface class defining methods to initialize and finalize the context used by the transformation functions.</div> </td> </tr> <tr class="rowColor"> -<td class="colFirst"><a href="../../../../org/apache/samza/operators/StreamOperatorTask.html" title="interface in org.apache.samza.operators">StreamOperatorTask</a></td> +<td class="colFirst"><a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators">MessageStream</a><M></td> <td class="colLast"> -<div class="block">A <a href="../../../../org/apache/samza/operators/StreamOperatorTask.html" title="interface in org.apache.samza.operators"><code>StreamOperatorTask</code></a> is the basic interface to implement for processing <a href="../../../../org/apache/samza/operators/MessageStream.html" title="interface in org.apache.samza.operators"><code>MessageStream</code></a>s.</div> +<div class="block">Represents a stream of messages.</div> +</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><M></td> +<td class="colLast"> +<div class="block">The interface class defining the specific <a href="../../../../org/apache/samza/operators/functions/SinkFunction.html" title="interface in org.apache.samza.operators.functions"><code>SinkFunction</code></a> for a system <a href="../../../../org/apache/samza/operators/OutputStream.html" title="interface in org.apache.samza.operators"><code>OutputStream</code></a>.</div> +</td> +</tr> +<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">Job-level programming interface to create an operator DAG and run in various different runtime environments.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><a href="../../../../org/apache/samza/operators/StreamGraphBuilder.html" title="interface in org.apache.samza.operators">StreamGraphBuilder</a></td> +<td class="colLast"> +<div class="block">This interface defines a factory class that user will implement to create user-defined operator DAG in a <a href="../../../../org/apache/samza/operators/StreamGraph.html" title="interface in org.apache.samza.operators"><code>StreamGraph</code></a> object.</div> </td> </tr> </tbody> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-tree.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-tree.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-tree.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/package-tree.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>org.apache.samza.operators Class Hierarchy (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>org.apache.samza.operators Class Hierarchy (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../script.js"></script> @@ -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.12.0 API)"; + parent.document.title="org.apache.samza.operators Class Hierarchy (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -78,8 +78,11 @@ <div class="contentContainer"> <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/StreamOperatorTask.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">StreamOperatorTask</span></a></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/StreamGraphBuilder.html" title="interface in org.apache.samza.operators"><span class="typeNameLink">StreamGraphBuilder</span></a></li> </ul> </div> <!-- ======= START OF BOTTOM NAVBAR ====== --> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/AnyTrigger.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>AnyTrigger (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>AnyTrigger (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="AnyTrigger (samza-api 0.12.0 API)"; + parent.document.title="AnyTrigger (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.triggers</div> -<h2 title="Class AnyTrigger" class="title">Class AnyTrigger<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Class AnyTrigger" class="title">Class AnyTrigger<M></h2> </div> <div class="contentContainer"> <ul class="inheritance"> @@ -112,7 +112,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>public class <span class="typeNameLabel">AnyTrigger<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span> +<pre>public class <span class="typeNameLabel">AnyTrigger<M></span> extends java.lang.Object implements <a href="../../../../../org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a></pre> <div class="block">A <a href="../../../../../org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers"><code>Trigger</code></a> fires as soon as any of its individual triggers has fired.</div> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/CountTrigger.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>CountTrigger (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>CountTrigger (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="CountTrigger (samza-api 0.12.0 API)"; + parent.document.title="CountTrigger (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) { @@ -92,7 +92,7 @@ var activeTableTab = "activeTableTab"; <!-- ======== START OF CLASS DATA ======== --> <div class="header"> <div class="subTitle">org.apache.samza.operators.triggers</div> -<h2 title="Class CountTrigger" class="title">Class CountTrigger<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></h2> +<h2 title="Class CountTrigger" class="title">Class CountTrigger<M></h2> </div> <div class="contentContainer"> <ul class="inheritance"> @@ -112,7 +112,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>public class <span class="typeNameLabel">CountTrigger<M extends <a href="../../../../../org/apache/samza/operators/data/MessageEnvelope.html" title="interface in org.apache.samza.operators.data">MessageEnvelope</a>></span> +<pre>public class <span class="typeNameLabel">CountTrigger<M></span> extends java.lang.Object implements <a href="../../../../../org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers">Trigger</a></pre> <div class="block">A <a href="../../../../../org/apache/samza/operators/triggers/Trigger.html" title="interface in org.apache.samza.operators.triggers"><code>Trigger</code></a> that fires when the number of messages in the <a href="../../../../../org/apache/samza/operators/windows/WindowPane.html" title="class in org.apache.samza.operators.windows"><code>WindowPane</code></a> Modified: samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html URL: http://svn.apache.org/viewvc/samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html?rev=1784679&r1=1784678&r2=1784679&view=diff ============================================================================== --- samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html (original) +++ samza/site/learn/documentation/versioned/api/javadocs/org/apache/samza/operators/triggers/DurationCharacteristic.html Tue Feb 28 01:45:28 2017 @@ -2,8 +2,8 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:42:11 PST 2017 --> -<title>DurationCharacteristic (samza-api 0.12.0 API)</title> +<!-- Generated by javadoc (1.8.0_74) on Mon Feb 27 17:44:11 PST 2017 --> +<title>DurationCharacteristic (samza-api 0.13.0-SNAPSHOT API)</title> <meta name="date" content="2017-02-27"> <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> <script type="text/javascript" src="../../../../../script.js"></script> @@ -12,7 +12,7 @@ <script type="text/javascript"><!-- try { if (location.href.indexOf('is-external=true') == -1) { - parent.document.title="DurationCharacteristic (samza-api 0.12.0 API)"; + parent.document.title="DurationCharacteristic (samza-api 0.13.0-SNAPSHOT API)"; } } catch(err) {
