http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html
deleted file mode 100644
index fbe7f26..0000000
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html
+++ /dev/null
@@ -1,232 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" 
"http://www.w3.org/TR/html4/loose.dtd";>
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
-<title>GroupByFunction</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
-    try {
-        if (location.href.indexOf('is-external=true') == -1) {
-            parent.document.title="GroupByFunction";
-        }
-    }
-    catch(err) {
-    }
-//-->
-var methods = {"i0":6};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 target="_top">Frames</a></li>
-<li><a href="GroupByFunction.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_top");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary:&nbsp;</li>
-<li>Nested&nbsp;|&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail:&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!--   -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">org.apache.gearpump.streaming.javaapi.dsl.functions</div>
-<h2 title="Interface GroupByFunction" class="title">Interface 
GroupByFunction&lt;T,Group&gt;</h2>
-</div>
-<div class="contentContainer">
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<dl>
-<dt><span class="paramLabel">Type Parameters:</span></dt>
-<dd><code>T</code> - Input value type</dd>
-<dd><code>Group</code> - Group Type</dd>
-</dl>
-<dl>
-<dt>All Superinterfaces:</dt>
-<dd>java.io.Serializable</dd>
-</dl>
-<hr>
-<br>
-<pre>public interface <span 
class="typeNameLabel">GroupByFunction&lt;T,Group&gt;</span>
-extends java.io.Serializable</pre>
-<div class="block">GroupBy function which assign value of type T to 
groups</div>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!--   -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" 
summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t3" class="tableTab"><span><a 
href="javascript:show(4);">Abstract Methods</a></span><span 
class="tabEnd">&nbsp;</span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="type parameter in GroupByFunction">Group</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html#apply-T-">apply</a></span>(<a
 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="type parameter in GroupByFunction">T</a>&nbsp;t)</code>&nbsp;</td>
-</tr>
-</table>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!--   -->
-</a>
-<h3>Method Detail</h3>
-<a name="apply-java.lang.Object-">
-<!--   -->
-</a><a name="apply-T-">
-<!--   -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>apply</h4>
-<pre><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="type parameter in GroupByFunction">Group</a>&nbsp;apply(<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="type parameter in GroupByFunction">T</a>&nbsp;t)</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 target="_top">Frames</a></li>
-<li><a href="GroupByFunction.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_bottom");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary:&nbsp;</li>
-<li>Nested&nbsp;|&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail:&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!--   -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html
deleted file mode 100644
index 57af86e..0000000
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html
+++ /dev/null
@@ -1,232 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" 
"http://www.w3.org/TR/html4/loose.dtd";>
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
-<title>MapFunction</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
-    try {
-        if (location.href.indexOf('is-external=true') == -1) {
-            parent.document.title="MapFunction";
-        }
-    }
-    catch(err) {
-    }
-//-->
-var methods = {"i0":6};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 target="_top">Frames</a></li>
-<li><a href="MapFunction.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_top");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary:&nbsp;</li>
-<li>Nested&nbsp;|&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail:&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!--   -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">org.apache.gearpump.streaming.javaapi.dsl.functions</div>
-<h2 title="Interface MapFunction" class="title">Interface 
MapFunction&lt;T,R&gt;</h2>
-</div>
-<div class="contentContainer">
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<dl>
-<dt><span class="paramLabel">Type Parameters:</span></dt>
-<dd><code>T</code> - Input value type</dd>
-<dd><code>R</code> - Output value type</dd>
-</dl>
-<dl>
-<dt>All Superinterfaces:</dt>
-<dd>java.io.Serializable</dd>
-</dl>
-<hr>
-<br>
-<pre>public interface <span class="typeNameLabel">MapFunction&lt;T,R&gt;</span>
-extends java.io.Serializable</pre>
-<div class="block">Function that map a value of type T to value of type R</div>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!--   -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" 
summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t3" class="tableTab"><span><a 
href="javascript:show(4);">Abstract Methods</a></span><span 
class="tabEnd">&nbsp;</span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="type parameter in MapFunction">R</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html#apply-T-">apply</a></span>(<a
 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="type parameter in MapFunction">T</a>&nbsp;t)</code>&nbsp;</td>
-</tr>
-</table>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!--   -->
-</a>
-<h3>Method Detail</h3>
-<a name="apply-java.lang.Object-">
-<!--   -->
-</a><a name="apply-T-">
-<!--   -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>apply</h4>
-<pre><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="type parameter in MapFunction">R</a>&nbsp;apply(<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="type parameter in MapFunction">T</a>&nbsp;t)</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 target="_top">Frames</a></li>
-<li><a href="MapFunction.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_bottom");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary:&nbsp;</li>
-<li>Nested&nbsp;|&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail:&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!--   -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html
deleted file mode 100644
index 69b0117..0000000
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html
+++ /dev/null
@@ -1,233 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" 
"http://www.w3.org/TR/html4/loose.dtd";>
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
-<title>ReduceFunction</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
-    try {
-        if (location.href.indexOf('is-external=true') == -1) {
-            parent.document.title="ReduceFunction";
-        }
-    }
-    catch(err) {
-    }
-//-->
-var methods = {"i0":6};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"]};
-var altColor = "altColor";
-var rowColor = "rowColor";
-var tableTab = "tableTab";
-var activeTableTab = "activeTableTab";
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li>Next&nbsp;Class</li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 target="_top">Frames</a></li>
-<li><a href="ReduceFunction.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_top");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary:&nbsp;</li>
-<li>Nested&nbsp;|&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail:&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.top">
-<!--   -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<!-- ======== START OF CLASS DATA ======== -->
-<div class="header">
-<div class="subTitle">org.apache.gearpump.streaming.javaapi.dsl.functions</div>
-<h2 title="Interface ReduceFunction" class="title">Interface 
ReduceFunction&lt;T&gt;</h2>
-</div>
-<div class="contentContainer">
-<div class="description">
-<ul class="blockList">
-<li class="blockList">
-<dl>
-<dt><span class="paramLabel">Type Parameters:</span></dt>
-<dd><code>T</code> - Input value type</dd>
-</dl>
-<dl>
-<dt>All Superinterfaces:</dt>
-<dd>java.io.Serializable</dd>
-</dl>
-<hr>
-<br>
-<pre>public interface <span 
class="typeNameLabel">ReduceFunction&lt;T&gt;</span>
-extends java.io.Serializable</pre>
-<div class="block">Function that applies reduce operation</div>
-</li>
-</ul>
-</div>
-<div class="summary">
-<ul class="blockList">
-<li class="blockList">
-<!-- ========== METHOD SUMMARY =========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.summary">
-<!--   -->
-</a>
-<h3>Method Summary</h3>
-<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" 
summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t3" class="tableTab"><span><a 
href="javascript:show(4);">Abstract Methods</a></span><span 
class="tabEnd">&nbsp;</span></span></caption>
-<tr>
-<th class="colFirst" scope="col">Modifier and Type</th>
-<th class="colLast" scope="col">Method and Description</th>
-</tr>
-<tr id="i0" class="altColor">
-<td class="colFirst"><code><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="type parameter in ReduceFunction">T</a></code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html#apply-T-T-">apply</a></span>(<a
 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="type parameter in ReduceFunction">T</a>&nbsp;t1,
-     <a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="type parameter in ReduceFunction">T</a>&nbsp;t2)</code>&nbsp;</td>
-</tr>
-</table>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-<div class="details">
-<ul class="blockList">
-<li class="blockList">
-<!-- ============ METHOD DETAIL ========== -->
-<ul class="blockList">
-<li class="blockList"><a name="method.detail">
-<!--   -->
-</a>
-<h3>Method Detail</h3>
-<a name="apply-java.lang.Object-java.lang.Object-">
-<!--   -->
-</a><a name="apply-T-T-">
-<!--   -->
-</a>
-<ul class="blockListLast">
-<li class="blockList">
-<h4>apply</h4>
-<pre><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="type parameter in ReduceFunction">T</a>&nbsp;apply(<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="type parameter in ReduceFunction">T</a>&nbsp;t1,
-        <a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="type parameter in ReduceFunction">T</a>&nbsp;t2)</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-</ul>
-</div>
-</div>
-<!-- ========= END OF CLASS DATA ========= -->
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li class="navBarCell1Rev">Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li>Next&nbsp;Class</li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 target="_top">Frames</a></li>
-<li><a href="ReduceFunction.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_bottom");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<div>
-<ul class="subNavList">
-<li>Summary:&nbsp;</li>
-<li>Nested&nbsp;|&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.summary">Method</a></li>
-</ul>
-<ul class="subNavList">
-<li>Detail:&nbsp;</li>
-<li>Field&nbsp;|&nbsp;</li>
-<li>Constr&nbsp;|&nbsp;</li>
-<li><a href="#method.detail">Method</a></li>
-</ul>
-</div>
-<a name="skip.navbar.bottom">
-<!--   -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-frame.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-frame.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-frame.html
deleted file mode 100644
index 7289ee6..0000000
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-frame.html
+++ /dev/null
@@ -1,24 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" 
"http://www.w3.org/TR/html4/loose.dtd";>
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
-<title>org.apache.gearpump.streaming.javaapi.dsl.functions</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../../../script.js"></script>
-</head>
-<body>
-<h1 class="bar"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html"
 
target="classFrame">org.apache.gearpump.streaming.javaapi.dsl.functions</a></h1>
-<div class="indexContainer">
-<h2 title="Interfaces">Interfaces</h2>
-<ul title="Interfaces">
-<li><a href="FilterFunction.html" title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions" target="classFrame"><span 
class="interfaceName">FilterFunction</span></a></li>
-<li><a href="FlatMapFunction.html" title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions" target="classFrame"><span 
class="interfaceName">FlatMapFunction</span></a></li>
-<li><a href="GroupByFunction.html" title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions" target="classFrame"><span 
class="interfaceName">GroupByFunction</span></a></li>
-<li><a href="MapFunction.html" title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions" target="classFrame"><span 
class="interfaceName">MapFunction</span></a></li>
-<li><a href="ReduceFunction.html" title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions" target="classFrame"><span 
class="interfaceName">ReduceFunction</span></a></li>
-</ul>
-</div>
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html
deleted file mode 100644
index 8a6d784..0000000
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html
+++ /dev/null
@@ -1,166 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" 
"http://www.w3.org/TR/html4/loose.dtd";>
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
-<title>org.apache.gearpump.streaming.javaapi.dsl.functions</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
-    try {
-        if (location.href.indexOf('is-external=true') == -1) {
-            
parent.document.title="org.apache.gearpump.streaming.javaapi.dsl.functions";
-        }
-    }
-    catch(err) {
-    }
-//-->
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li class="navBarCell1Rev">Package</li>
-<li>Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/package-summary.html">Prev&nbsp;Package</a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/kafka/package-summary.html">Next&nbsp;Package</a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html"
 target="_top">Frames</a></li>
-<li><a href="package-summary.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_top");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<a name="skip.navbar.top">
-<!--   -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<div class="header">
-<h1 title="Package" 
class="title">Package&nbsp;org.apache.gearpump.streaming.javaapi.dsl.functions</h1>
-</div>
-<div class="contentContainer">
-<ul class="blockList">
-<li class="blockList">
-<table class="typeSummary" border="0" cellpadding="3" cellspacing="0" 
summary="Interface Summary table, listing interfaces, and an explanation">
-<caption><span>Interface Summary</span><span 
class="tabEnd">&nbsp;</span></caption>
-<tr>
-<th class="colFirst" scope="col">Interface</th>
-<th class="colLast" scope="col">Description</th>
-</tr>
-<tbody>
-<tr class="altColor">
-<td class="colFirst"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/FilterFunction.html"
 title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions">FilterFunction</a>&lt;T&gt;</td>
-<td class="colLast">
-<div class="block">Filter function</div>
-</td>
-</tr>
-<tr class="rowColor">
-<td class="colFirst"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html"
 title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions">FlatMapFunction</a>&lt;T,R&gt;</td>
-<td class="colLast">
-<div class="block">Function that converts a value of type T to a iterator of 
values of type R.</div>
-</td>
-</tr>
-<tr class="altColor">
-<td class="colFirst"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions">GroupByFunction</a>&lt;T,Group&gt;</td>
-<td class="colLast">
-<div class="block">GroupBy function which assign value of type T to 
groups</div>
-</td>
-</tr>
-<tr class="rowColor">
-<td class="colFirst"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions">MapFunction</a>&lt;T,R&gt;</td>
-<td class="colLast">
-<div class="block">Function that map a value of type T to value of type R</div>
-</td>
-</tr>
-<tr class="altColor">
-<td class="colFirst"><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="interface in 
org.apache.gearpump.streaming.javaapi.dsl.functions">ReduceFunction</a>&lt;T&gt;</td>
-<td class="colLast">
-<div class="block">Function that applies reduce operation</div>
-</td>
-</tr>
-</tbody>
-</table>
-</li>
-</ul>
-</div>
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li class="navBarCell1Rev">Package</li>
-<li>Class</li>
-<li><a href="package-tree.html">Tree</a></li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/package-summary.html">Prev&nbsp;Package</a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/kafka/package-summary.html">Next&nbsp;Package</a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html"
 target="_top">Frames</a></li>
-<li><a href="package-summary.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_bottom");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<a name="skip.navbar.bottom">
-<!--   -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html
deleted file mode 100644
index 33d5b52..0000000
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html
+++ /dev/null
@@ -1,139 +0,0 @@
-<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" 
"http://www.w3.org/TR/html4/loose.dtd";>
-<!-- NewPage -->
-<html lang="en">
-<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
-<title>org.apache.gearpump.streaming.javaapi.dsl.functions Class 
Hierarchy</title>
-<meta name="date" content="2016-11-28">
-<link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
-<script type="text/javascript" src="../../../../../../../script.js"></script>
-</head>
-<body>
-<script type="text/javascript"><!--
-    try {
-        if (location.href.indexOf('is-external=true') == -1) {
-            
parent.document.title="org.apache.gearpump.streaming.javaapi.dsl.functions 
Class Hierarchy";
-        }
-    }
-    catch(err) {
-    }
-//-->
-</script>
-<noscript>
-<div>JavaScript is disabled on your browser.</div>
-</noscript>
-<!-- ========= START OF TOP NAVBAR ======= -->
-<div class="topNav"><a name="navbar.top">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.top.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li>Class</li>
-<li class="navBarCell1Rev">Tree</li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/package-tree.html">Prev</a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/kafka/package-tree.html">Next</a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html"
 target="_top">Frames</a></li>
-<li><a href="package-tree.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_top">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_top");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<a name="skip.navbar.top">
-<!--   -->
-</a></div>
-<!-- ========= END OF TOP NAVBAR ========= -->
-<div class="header">
-<h1 class="title">Hierarchy For Package 
org.apache.gearpump.streaming.javaapi.dsl.functions</h1>
-<span class="packageHierarchyLabel">Package Hierarchies:</span>
-<ul class="horizontal">
-<li><a href="../../../../../../../overview-tree.html">All Packages</a></li>
-</ul>
-</div>
-<div class="contentContainer">
-<h2 title="Interface Hierarchy">Interface Hierarchy</h2>
-<ul>
-<li type="circle">java.io.Serializable
-<ul>
-<li type="circle">org.apache.gearpump.streaming.javaapi.dsl.functions.<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/FilterFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">FilterFunction</span></a>&lt;T&gt;</li>
-<li type="circle">org.apache.gearpump.streaming.javaapi.dsl.functions.<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">FlatMapFunction</span></a>&lt;T,R&gt;</li>
-<li type="circle">org.apache.gearpump.streaming.javaapi.dsl.functions.<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">GroupByFunction</span></a>&lt;T,Group&gt;</li>
-<li type="circle">org.apache.gearpump.streaming.javaapi.dsl.functions.<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/MapFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">MapFunction</span></a>&lt;T,R&gt;</li>
-<li type="circle">org.apache.gearpump.streaming.javaapi.dsl.functions.<a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html"
 title="interface in org.apache.gearpump.streaming.javaapi.dsl.functions"><span 
class="typeNameLink">ReduceFunction</span></a>&lt;T&gt;</li>
-</ul>
-</li>
-</ul>
-</div>
-<!-- ======= START OF BOTTOM NAVBAR ====== -->
-<div class="bottomNav"><a name="navbar.bottom">
-<!--   -->
-</a>
-<div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation 
links">Skip navigation links</a></div>
-<a name="navbar.bottom.firstrow">
-<!--   -->
-</a>
-<ul class="navList" title="Navigation">
-<li><a href="../../../../../../../overview-summary.html">Overview</a></li>
-<li><a href="package-summary.html">Package</a></li>
-<li>Class</li>
-<li class="navBarCell1Rev">Tree</li>
-<li><a href="../../../../../../../deprecated-list.html">Deprecated</a></li>
-<li><a href="../../../../../../../index-all.html">Index</a></li>
-<li><a href="../../../../../../../help-doc.html">Help</a></li>
-</ul>
-</div>
-<div class="subNav">
-<ul class="navList">
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/javaapi/package-tree.html">Prev</a></li>
-<li><a 
href="../../../../../../../org/apache/gearpump/streaming/kafka/package-tree.html">Next</a></li>
-</ul>
-<ul class="navList">
-<li><a 
href="../../../../../../../index.html?org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html"
 target="_top">Frames</a></li>
-<li><a href="package-tree.html" target="_top">No&nbsp;Frames</a></li>
-</ul>
-<ul class="navList" id="allclasses_navbar_bottom">
-<li><a 
href="../../../../../../../allclasses-noframe.html">All&nbsp;Classes</a></li>
-</ul>
-<div>
-<script type="text/javascript"><!--
-  allClassesLink = document.getElementById("allclasses_navbar_bottom");
-  if(window==top) {
-    allClassesLink.style.display = "block";
-  }
-  else {
-    allClassesLink.style.display = "none";
-  }
-  //-->
-</script>
-</div>
-<a name="skip.navbar.bottom">
-<!--   -->
-</a></div>
-<!-- ======== END OF BOTTOM NAVBAR ======= -->
-</body>
-</html>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html
index 2d11cb5..d8e09ab 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-frame.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.javaapi</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html
index f03415f..73c802b 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-summary.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.javaapi</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>
@@ -43,7 +43,7 @@
 <div class="subNav">
 <ul class="navList">
 <li><a 
href="../../../../../org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html">Prev&nbsp;Package</a></li>
-<li><a 
href="../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html">Next&nbsp;Package</a></li>
+<li><a 
href="../../../../../org/apache/gearpump/streaming/kafka/package-summary.html">Next&nbsp;Package</a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../index.html?org/apache/gearpump/streaming/javaapi/package-summary.html"
 target="_top">Frames</a></li>
@@ -135,7 +135,7 @@
 <div class="subNav">
 <ul class="navList">
 <li><a 
href="../../../../../org/apache/gearpump/streaming/hadoop/lib/rotation/package-summary.html">Prev&nbsp;Package</a></li>
-<li><a 
href="../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/package-summary.html">Next&nbsp;Package</a></li>
+<li><a 
href="../../../../../org/apache/gearpump/streaming/kafka/package-summary.html">Next&nbsp;Package</a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../index.html?org/apache/gearpump/streaming/javaapi/package-summary.html"
 target="_top">Frames</a></li>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html
index db51103..99b1943 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/javaapi/package-tree.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.javaapi Class Hierarchy</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>
@@ -43,7 +43,7 @@
 <div class="subNav">
 <ul class="navList">
 <li><a 
href="../../../../../org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html">Prev</a></li>
-<li><a 
href="../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html">Next</a></li>
+<li><a 
href="../../../../../org/apache/gearpump/streaming/kafka/package-tree.html">Next</a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../index.html?org/apache/gearpump/streaming/javaapi/package-tree.html"
 target="_top">Frames</a></li>
@@ -117,7 +117,7 @@
 <div class="subNav">
 <ul class="navList">
 <li><a 
href="../../../../../org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html">Prev</a></li>
-<li><a 
href="../../../../../org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html">Next</a></li>
+<li><a 
href="../../../../../org/apache/gearpump/streaming/kafka/package-tree.html">Next</a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../index.html?org/apache/gearpump/streaming/javaapi/package-tree.html"
 target="_top">Frames</a></li>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html
index a6c0c0c..3bfddee 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSink.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 -->
 <title>KafkaSink</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html
index d257930..562a0c5 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaSource.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 -->
 <title>KafkaSource</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html
index e42a5d1..3a9b6bd 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 -->
 <title>KafkaStoreFactory</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html
index f6c99d3..4c29267 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:13 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 -->
 <title>KafkaDSL</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>
@@ -128,7 +128,7 @@ extends java.lang.Object</pre>
 <th class="colOne" scope="col">Constructor and Description</th>
 </tr>
 <tr class="altColor">
-<td class="colOne"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#KafkaDSL-org.apache.gearpump.streaming.dsl.Stream-">KafkaDSL</a></span>(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in KafkaDSL">T</a>&gt;&nbsp;stream)</code>&nbsp;</td>
+<td class="colOne"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#KafkaDSL-org.apache.gearpump.streaming.dsl.scalaapi.Stream-">KafkaDSL</a></span>(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in KafkaDSL">T</a>&gt;&nbsp;stream)</code>&nbsp;</td>
 </tr>
 </table>
 </li>
@@ -146,8 +146,8 @@ extends java.lang.Object</pre>
 <th class="colLast" scope="col">Method and Description</th>
 </tr>
 <tr id="i0" class="altColor">
-<td class="colFirst"><code>static &lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl">Stream</a>&lt;T&gt;</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#createAtLeastOnceStream-org.apache.gearpump.streaming.dsl.StreamApp-java.lang.String-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">createAtLeastOnceStream</a></span>(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/StreamApp.html" 
title="class in org.apache.gearpump.streaming.dsl">StreamApp</a>&nbsp;app,
+<td class="colFirst"><code>static &lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;T&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#createAtLeastOnceStream-org.apache.gearpump.streaming.dsl.scalaapi.StreamApp-java.lang.String-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">createAtLeastOnceStream</a></span>(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html"
 title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">StreamApp</a>&nbsp;app,
                        java.lang.String&nbsp;topics,
                        <a 
href="../../../../../../org/apache/gearpump/streaming/transaction/api/CheckpointStoreFactory.html"
 title="interface in 
org.apache.gearpump.streaming.transaction.api">CheckpointStoreFactory</a>&nbsp;checkpointStoreFactory,
                        java.util.Properties&nbsp;properties,
@@ -158,8 +158,8 @@ extends java.lang.Object</pre>
 </td>
 </tr>
 <tr id="i1" class="rowColor">
-<td class="colFirst"><code>static &lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl">Stream</a>&lt;T&gt;</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#createAtMostOnceStream-org.apache.gearpump.streaming.dsl.StreamApp-java.lang.String-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">createAtMostOnceStream</a></span>(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/StreamApp.html" 
title="class in org.apache.gearpump.streaming.dsl">StreamApp</a>&nbsp;app,
+<td class="colFirst"><code>static &lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;T&gt;</code></td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#createAtMostOnceStream-org.apache.gearpump.streaming.dsl.scalaapi.StreamApp-java.lang.String-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">createAtMostOnceStream</a></span>(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html"
 title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">StreamApp</a>&nbsp;app,
                       java.lang.String&nbsp;topics,
                       java.util.Properties&nbsp;properties,
                       int&nbsp;parallelism,
@@ -170,10 +170,10 @@ extends java.lang.Object</pre>
 </tr>
 <tr id="i2" class="altColor">
 <td class="colFirst"><code>static &lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="class in 
org.apache.gearpump.streaming.kafka.dsl">KafkaDSL</a>&lt;T&gt;</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#streamToKafkaDSL-org.apache.gearpump.streaming.dsl.Stream-">streamToKafkaDSL</a></span>(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl">Stream</a>&lt;T&gt;&nbsp;stream)</code>&nbsp;</td>
+<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#streamToKafkaDSL-org.apache.gearpump.streaming.dsl.scalaapi.Stream-">streamToKafkaDSL</a></span>(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;T&gt;&nbsp;stream)</code>&nbsp;</td>
 </tr>
 <tr id="i3" class="rowColor">
-<td class="colFirst"><code><a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in KafkaDSL">T</a>&gt;</code></td>
+<td class="colFirst"><code><a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in KafkaDSL">T</a>&gt;</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html#writeToKafka-java.lang.String-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">writeToKafka</a></span>(java.lang.String&nbsp;topic,
             java.util.Properties&nbsp;properties,
             int&nbsp;parallelism,
@@ -204,13 +204,13 @@ extends java.lang.Object</pre>
 <!--   -->
 </a>
 <h3>Constructor Detail</h3>
-<a name="KafkaDSL-org.apache.gearpump.streaming.dsl.Stream-">
+<a name="KafkaDSL-org.apache.gearpump.streaming.dsl.scalaapi.Stream-">
 <!--   -->
 </a>
 <ul class="blockListLast">
 <li class="blockList">
 <h4>KafkaDSL</h4>
-<pre>public&nbsp;KafkaDSL(<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in KafkaDSL">T</a>&gt;&nbsp;stream)</pre>
+<pre>public&nbsp;KafkaDSL(<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in KafkaDSL">T</a>&gt;&nbsp;stream)</pre>
 </li>
 </ul>
 </li>
@@ -221,13 +221,13 @@ extends java.lang.Object</pre>
 <!--   -->
 </a>
 <h3>Method Detail</h3>
-<a 
name="createAtMostOnceStream-org.apache.gearpump.streaming.dsl.StreamApp-java.lang.String-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">
+<a 
name="createAtMostOnceStream-org.apache.gearpump.streaming.dsl.scalaapi.StreamApp-java.lang.String-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">
 <!--   -->
 </a>
 <ul class="blockList">
 <li class="blockList">
 <h4>createAtMostOnceStream</h4>
-<pre>public static&nbsp;&lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl">Stream</a>&lt;T&gt;&nbsp;createAtMostOnceStream(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/StreamApp.html" 
title="class in org.apache.gearpump.streaming.dsl">StreamApp</a>&nbsp;app,
+<pre>public static&nbsp;&lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;T&gt;&nbsp;createAtMostOnceStream(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html"
 title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">StreamApp</a>&nbsp;app,
                                                    
java.lang.String&nbsp;topics,
                                                    
java.util.Properties&nbsp;properties,
                                                    int&nbsp;parallelism,
@@ -247,13 +247,13 @@ extends java.lang.Object</pre>
 </dl>
 </li>
 </ul>
-<a 
name="createAtLeastOnceStream-org.apache.gearpump.streaming.dsl.StreamApp-java.lang.String-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">
+<a 
name="createAtLeastOnceStream-org.apache.gearpump.streaming.dsl.scalaapi.StreamApp-java.lang.String-org.apache.gearpump.streaming.transaction.api.CheckpointStoreFactory-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">
 <!--   -->
 </a>
 <ul class="blockList">
 <li class="blockList">
 <h4>createAtLeastOnceStream</h4>
-<pre>public static&nbsp;&lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl">Stream</a>&lt;T&gt;&nbsp;createAtLeastOnceStream(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/StreamApp.html" 
title="class in org.apache.gearpump.streaming.dsl">StreamApp</a>&nbsp;app,
+<pre>public static&nbsp;&lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;T&gt;&nbsp;createAtLeastOnceStream(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.html"
 title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">StreamApp</a>&nbsp;app,
                                                     
java.lang.String&nbsp;topics,
                                                     <a 
href="../../../../../../org/apache/gearpump/streaming/transaction/api/CheckpointStoreFactory.html"
 title="interface in 
org.apache.gearpump.streaming.transaction.api">CheckpointStoreFactory</a>&nbsp;checkpointStoreFactory,
                                                     
java.util.Properties&nbsp;properties,
@@ -275,13 +275,13 @@ extends java.lang.Object</pre>
 </dl>
 </li>
 </ul>
-<a name="streamToKafkaDSL-org.apache.gearpump.streaming.dsl.Stream-">
+<a name="streamToKafkaDSL-org.apache.gearpump.streaming.dsl.scalaapi.Stream-">
 <!--   -->
 </a>
 <ul class="blockList">
 <li class="blockList">
 <h4>streamToKafkaDSL</h4>
-<pre>public static&nbsp;&lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="class in 
org.apache.gearpump.streaming.kafka.dsl">KafkaDSL</a>&lt;T&gt;&nbsp;streamToKafkaDSL(<a
 href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl">Stream</a>&lt;T&gt;&nbsp;stream)</pre>
+<pre>public static&nbsp;&lt;T&gt;&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="class in 
org.apache.gearpump.streaming.kafka.dsl">KafkaDSL</a>&lt;T&gt;&nbsp;streamToKafkaDSL(<a
 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in 
org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;T&gt;&nbsp;stream)</pre>
 </li>
 </ul>
 <a 
name="writeToKafka-java.lang.String-java.util.Properties-int-org.apache.gearpump.cluster.UserConfig-java.lang.String-">
@@ -290,7 +290,7 @@ extends java.lang.Object</pre>
 <ul class="blockListLast">
 <li class="blockList">
 <h4>writeToKafka</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in 
KafkaDSL">T</a>&gt;&nbsp;writeToKafka(java.lang.String&nbsp;topic,
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/gearpump/streaming/dsl/scalaapi/Stream.html" 
title="class in org.apache.gearpump.streaming.dsl.scalaapi">Stream</a>&lt;<a 
href="../../../../../../org/apache/gearpump/streaming/kafka/dsl/KafkaDSL.html" 
title="type parameter in 
KafkaDSL">T</a>&gt;&nbsp;writeToKafka(java.lang.String&nbsp;topic,
                               java.util.Properties&nbsp;properties,
                               int&nbsp;parallelism,
                               <a 
href="../../../../../../org/apache/gearpump/cluster/UserConfig.html" 
title="class in org.apache.gearpump.cluster">UserConfig</a>&nbsp;userConfig,

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html
index 37a0d0c..167ba47 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-frame.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.dsl</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html
index b42fdc1..1f2569a 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-summary.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.dsl</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html
index e1c0cca..39cd848 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/dsl/package-tree.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.dsl Class Hierarchy</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html
index fd8be7e..7f11f14 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>KafkaMessageDecoder</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html
index a22ed61..bc690b0 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>MessageAndWatermark</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html
index ba329ed..5cd1c36 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-frame.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.lib</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html
index 75d0d9b..f44a210 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-summary.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.lib</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html
index db88fa4..5d4f334 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/package-tree.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.lib Class Hierarchy</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" 
title="Style">
 <script type="text/javascript" src="../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html
index da7a1d4..2a5d16c 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 -->
 <title>AbstractKafkaSink.KafkaProducerFactory</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
 <script type="text/javascript" src="../../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html
index 0c85abd..95caf40 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:12 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:36 SST 2017 -->
 <title>AbstractKafkaSink</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
 <script type="text/javascript" src="../../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html
index 8b2f84d..6e759de 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-frame.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.lib.sink</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
 <script type="text/javascript" src="../../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html
index 432631a..9ae21ee 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.lib.sink</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
 <script type="text/javascript" src="../../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html
index 2f9d2b0..e71be30 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:20 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>org.apache.gearpump.streaming.kafka.lib.sink Class Hierarchy</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
 <script type="text/javascript" src="../../../../../../../script.js"></script>
 </head>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html
----------------------------------------------------------------------
diff --git 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html
 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html
index 9450506..a575984 100644
--- 
a/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html
+++ 
b/content/releases/latest/api/java/org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:19 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:40 SST 2017 -->
 <title>AbstractKafkaSource</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
 <link rel="stylesheet" type="text/css" 
href="../../../../../../../stylesheet.css" title="Style">
 <script type="text/javascript" src="../../../../../../../script.js"></script>
 </head>
@@ -184,9 +184,8 @@ implements <a 
href="../../../../../../../org/apache/gearpump/streaming/transacti
 <tr id="i2" class="altColor">
 <td class="colFirst"><code>java.time.Instant</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#getWatermark--">getWatermark</a></span>()</code>
-<div class="block">Returns a watermark
- no timestamp earlier than the watermark
- should enter the system</div>
+<div class="block">Returns a watermark such that no timestamp earlier than the 
watermark should enter the system
+ Watermark.MAX mark the end of source data</div>
 </td>
 </tr>
 <tr id="i3" class="rowColor">
@@ -344,9 +343,8 @@ implements <a 
href="../../../../../../../org/apache/gearpump/streaming/transacti
 <h4>getWatermark</h4>
 <pre>public&nbsp;java.time.Instant&nbsp;getWatermark()</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">DataSource</a></code></span></div>
-<div class="block">Returns a watermark
- no timestamp earlier than the watermark
- should enter the system</div>
+<div class="block">Returns a watermark such that no timestamp earlier than the 
watermark should enter the system
+ Watermark.MAX mark the end of source data</div>
 <dl>
 <dt><span class="overrideSpecifyLabel">Specified by:</span></dt>
 <dd><code><a 
href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html#getWatermark--">getWatermark</a></code>&nbsp;in
 interface&nbsp;<code><a 
href="../../../../../../../org/apache/gearpump/streaming/source/DataSource.html"
 title="interface in 
org.apache.gearpump.streaming.source">DataSource</a></code></dd>


Reply via email to