You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2017/02/28 01:45:31 UTC
svn commit: r1784679 [5/11] - in /samza/site: ./ archive/ community/
contribute/ learn/documentation/versioned/ learn/documentation/versioned/api/
learn/documentation/versioned/api/javadocs/
learn/documentation/versioned/api/javadocs/org/apache/samza/ ...
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) {