You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2017/04/26 03:08:04 UTC

[02/51] [partial] incubator-gearpump-site git commit: [GEARPUMP-299] Update gearpump.apache.org page for 0.8.3 release

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/package-list
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/package-list b/content/releases/latest/api/java/package-list
index 08d18dc..110c4a4 100644
--- a/content/releases/latest/api/java/package-list
+++ b/content/releases/latest/api/java/package-list
@@ -16,11 +16,14 @@ org.apache.gearpump.security
 org.apache.gearpump.serializer
 org.apache.gearpump.streaming
 org.apache.gearpump.streaming.appmaster
-org.apache.gearpump.streaming.dsl
+org.apache.gearpump.streaming.dsl.api.functions
 org.apache.gearpump.streaming.dsl.javaapi
+org.apache.gearpump.streaming.dsl.javaapi.functions
 org.apache.gearpump.streaming.dsl.partitioner
 org.apache.gearpump.streaming.dsl.plan
 org.apache.gearpump.streaming.dsl.plan.functions
+org.apache.gearpump.streaming.dsl.scalaapi
+org.apache.gearpump.streaming.dsl.scalaapi.functions
 org.apache.gearpump.streaming.dsl.task
 org.apache.gearpump.streaming.dsl.window.api
 org.apache.gearpump.streaming.dsl.window.impl
@@ -30,7 +33,6 @@ org.apache.gearpump.streaming.hadoop.lib
 org.apache.gearpump.streaming.hadoop.lib.format
 org.apache.gearpump.streaming.hadoop.lib.rotation
 org.apache.gearpump.streaming.javaapi
-org.apache.gearpump.streaming.javaapi.dsl.functions
 org.apache.gearpump.streaming.kafka
 org.apache.gearpump.streaming.kafka.dsl
 org.apache.gearpump.streaming.kafka.lib

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/serialized-form.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/serialized-form.html b/content/releases/latest/api/java/serialized-form.html
index 5f9cbd0..60fed1f 100644
--- a/content/releases/latest/api/java/serialized-form.html
+++ b/content/releases/latest/api/java/serialized-form.html
@@ -2,9 +2,9 @@
 <!-- NewPage -->
 <html lang="en">
 <head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:21 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 -->
 <title>Serialized Form</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>
@@ -95,15 +95,6 @@
 </li>
 </ul>
 </li>
-<li class="blockList">
-<h3>Serialized Fields</h3>
-<ul class="blockList">
-<li class="blockListLast">
-<h4>noTimeStamp</h4>
-<pre>long noTimeStamp</pre>
-</li>
-</ul>
-</li>
 </ul>
 </li>
 </ul>
@@ -153,6 +144,62 @@
 </li>
 </ul>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.ACTIVE:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.ACTIVE$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.ACTIVE$</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.FAILED:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.FAILED$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.FAILED$</a> extends <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">ApplicationTerminalStatus</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.NONEXIST:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.NONEXIST$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.NONEXIST$</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.PENDING:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.PENDING$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.PENDING$</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.SUCCEEDED:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.SUCCEEDED$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.SUCCEEDED$</a> extends <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">ApplicationTerminalStatus</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.TERMINATED:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.TERMINATED$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.TERMINATED$</a> extends <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">ApplicationTerminalStatus</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus:D">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.cluster.ApplicationStatus$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationTerminalStatus">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationTerminalStatus</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterContext">
 <!--   -->
 </a>
@@ -161,7 +208,7 @@
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterContext:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.cluster.AppMasterContext$ extends scala.runtime.AbstractFunction7&lt;java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a>,<a href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" title="class in org.apache.gearpump.cluster.appmaster">WorkerInfo</a>,scala.Option&lt;<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>&gt;,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/AppMasterRegisterData.html" title="interface in org.apache.gearpump.cluster">AppMasterRegisterData</a>,<a href="org/apache/gearpump/cluster/AppMasterContext.html" title="class in org.apache.gearpump.cluster">AppMasterContext</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.cluster.AppMasterContext$ extends scala.runtime.AbstractFunction6&lt;java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a>,<a href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" title="class in org.apache.gearpump.cluster.appmaster">WorkerInfo</a>,scala.Option&lt;<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>&gt;,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/AppMasterContext.html" title="class in org.apache.gearpump.cluster">AppMasterContext</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -174,20 +221,20 @@
 </li>
 </ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster">
+<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.AppDataSaved$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved$</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster:D">
+<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster$</a> extends scala.runtime.AbstractFunction1&lt;java.lang.Object,<a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.ActivateAppMaster</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved:D">
+<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.AppDataSaved$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved$</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged$</a> extends scala.runtime.AbstractFunction4&lt;java.lang.Object,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.Throwable,<a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.ApplicationStatusChanged</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary">
 <!--   -->
@@ -197,7 +244,7 @@
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary$</a> extends scala.runtime.AbstractFunction8&lt;java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GeneralAppMasterSummary</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary$</a> extends scala.runtime.AbstractFunction8&lt;java.lang.Object,java.lang.String,java.lang.String,java.lang.String,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GeneralAppMasterSummary</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.GetAllWorkers:D">
 <!--   -->
@@ -267,7 +314,7 @@
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.RegisterAppMaster:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.RegisterAppMaster$</a> extends scala.runtime.AbstractFunction2&lt;akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/AppMasterRegisterData.html" title="interface in org.apache.gearpump.cluster">AppMasterRegisterData</a>,<a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.RegisterAppMaster</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.RegisterAppMaster$</a> extends scala.runtime.AbstractFunction3&lt;java.lang.Object,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" title="class in org.apache.gearpump.cluster.appmaster">WorkerInfo</a>,<a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.RegisterAppMaster</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.RequestResource">
 <!--   -->
@@ -429,6 +476,16 @@
 </a>
 <h3>Class <a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.QueryWorkerConfig$</a> extends scala.runtime.AbstractFunction1&lt;<a href="org/apache/gearpump/cluster/worker/WorkerId.html" title="class in org.apache.gearpump.cluster.worker">WorkerId</a>,<a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig.html" title="class in org.apache.gearpump.cluster">ClientToMaster.QueryWorkerConfig</a>&gt; implements Serializable</h3>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener$</a> extends scala.runtime.AbstractFunction1&lt;java.lang.Object,<a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html" title="class in org.apache.gearpump.cluster">ClientToMaster.RegisterAppResultListener</a>&gt; implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.ClientToMaster.RemoveMaster">
 <!--   -->
 </a>
@@ -585,7 +642,7 @@
 <li class="blockList"><a name="org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData$</a> extends scala.runtime.AbstractFunction9&lt;java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster.AppMasterData</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData$</a> extends scala.runtime.AbstractFunction9&lt;<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster.AppMasterData</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.MasterToAppMaster.AppMasterDataDetailRequest">
 <!--   -->
@@ -677,6 +734,26 @@
 </a>
 <h3>Class <a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToAppMaster.WorkerList$</a> extends scala.runtime.AbstractFunction1&lt;scala.collection.immutable.List&lt;<a href="org/apache/gearpump/cluster/worker/WorkerId.html" title="class in org.apache.gearpump.cluster.worker">WorkerId</a>&gt;,<a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster.WorkerList</a>&gt; implements Serializable</h3>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationFailed">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationFailed</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationFailed:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationFailed$</a> extends scala.runtime.AbstractFunction2&lt;java.lang.Object,java.lang.Throwable,<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed.html" title="class in org.apache.gearpump.cluster">MasterToClient.ApplicationFailed</a>&gt; implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded$</a> extends scala.runtime.AbstractFunction1&lt;java.lang.Object,<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded.html" title="class in org.apache.gearpump.cluster">MasterToClient.ApplicationSucceeded</a>&gt; implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.AppMasterConfig">
 <!--   -->
 </a>
@@ -903,15 +980,15 @@
 <li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.gearpump.cluster.appmaster</h2>
 <ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationState">
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationMetaData">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ApplicationState</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ApplicationMetaData</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationState:D">
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationMetaData:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.cluster.appmaster.ApplicationState$ extends scala.runtime.AbstractFunction7&lt;java.lang.Object,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster">AppDescription</a>,scala.Option&lt;<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>&gt;,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationState</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.cluster.appmaster.ApplicationMetaData$ extends scala.runtime.AbstractFunction5&lt;java.lang.Object,java.lang.Object,<a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster">AppDescription</a>,scala.Option&lt;<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>&gt;,java.lang.String,<a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationMetaData</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -924,30 +1001,15 @@
 </li>
 </ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster:D">
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.StartAppMaster$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster$</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv">
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv:D">
-<!--   -->
-</a>
-<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</a> extends scala.runtime.AbstractFunction4&lt;akka.testkit.TestProbe,akka.testkit.TestProbe,akka.testkit.TestProbe,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a>&gt; implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo">
-<!--   -->
-</a>
-<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo:D">
-<!--   -->
-</a>
-<h3>Class org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo$ extends scala.runtime.AbstractFunction8&lt;java.lang.Object,java.lang.String,akka.actor.ActorRef,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,com.typesafe.config.Config,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeInfo</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo$ extends scala.runtime.AbstractFunction10&lt;java.lang.Object,java.lang.String,akka.actor.ActorRef,akka.actor.ActorRef,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,com.typesafe.config.Config,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,<a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationRuntimeInfo</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -960,6 +1022,21 @@
 </li>
 </ul>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.StartAppMaster$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster$</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</a> extends scala.runtime.AbstractFunction4&lt;akka.testkit.TestProbe,akka.testkit.TestProbe,akka.testkit.TestProbe,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a>&gt; implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ExecutorSystem">
 <!--   -->
 </a>
@@ -1192,6 +1269,31 @@
 </ul>
 </li>
 <li class="blockList">
+<h2 title="Package">Package&nbsp;org.apache.gearpump.cluster.client</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest$.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest$</a> extends scala.runtime.AbstractFunction1&lt;java.lang.String,<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest.html" title="class in org.apache.gearpump.cluster.client">RunningApplicationSpec.MockAskAppMasterRequest</a>&gt; implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse:D">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse$.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse$</a> extends scala.runtime.AbstractFunction1&lt;java.lang.String,<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse.html" title="class in org.apache.gearpump.cluster.client">RunningApplicationSpec.MockAskAppMasterResponse</a>&gt; implements Serializable</h3>
+</li>
+</ul>
+</li>
+<li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.gearpump.cluster.main</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.gearpump.cluster.main.ArgumentsParser.Syntax">
@@ -1225,6 +1327,11 @@
 </li>
 </ul>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.main.MasterWatcher:D:Danonfun:D3:D:Danonfun:Dapply:D1">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.cluster.main.MasterWatcher$$anonfun$3$$anonfun$apply$1 extends java.lang.Object implements Serializable</h3>
+</li>
 </ul>
 </li>
 <li class="blockList">
@@ -1238,7 +1345,7 @@
 <li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.MasterState:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.MasterState$</a> extends scala.runtime.AbstractFunction4&lt;java.lang.Object,scala.collection.immutable.Map&lt;java.lang.Object,scala.Tuple2&lt;akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeInfo</a>&gt;&gt;,scala.collection.immutable.Set&lt;java.lang.Object&gt;,scala.collection.immutable.Set&lt;java.lang.Object&gt;,<a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.MasterState$</a> extends scala.runtime.AbstractFunction2&lt;java.lang.Object,scala.collection.immutable.Map&lt;java.lang.Object,<a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationRuntimeInfo</a>&gt;,<a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.RecoverApplication">
 <!--   -->
@@ -1248,7 +1355,7 @@
 <li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.RecoverApplication:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.RecoverApplication$</a> extends scala.runtime.AbstractFunction1&lt;<a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationState</a>,<a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication.html" title="class in org.apache.gearpump.cluster.master">AppManager.RecoverApplication</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.RecoverApplication$</a> extends scala.runtime.AbstractFunction1&lt;<a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationMetaData</a>,<a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication.html" title="class in org.apache.gearpump.cluster.master">AppManager.RecoverApplication</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.DeleteKVGroup">
 <!--   -->
@@ -2064,7 +2171,7 @@
 <li class="blockList"><a name="org.apache.gearpump.streaming.ExecutorToAppMaster.MessageLoss:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming">org.apache.gearpump.streaming.ExecutorToAppMaster.MessageLoss$</a> extends scala.runtime.AbstractFunction3&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,java.lang.String,<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a>&gt; implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming">org.apache.gearpump.streaming.ExecutorToAppMaster.MessageLoss$</a> extends scala.runtime.AbstractFunction4&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,java.lang.String,scala.Option&lt;java.lang.Throwable&gt;,<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a>&gt; implements Serializable</h3>
 </li>
 <li class="blockList"><a name="org.apache.gearpump.streaming.ExecutorToAppMaster.RegisterExecutor">
 <!--   -->
@@ -2202,6 +2309,11 @@
 </a>
 <h3>Class <a href="org/apache/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.AppMaster.TaskActorRef$</a> extends scala.runtime.AbstractFunction1&lt;akka.actor.ActorRef,<a href="org/apache/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.TaskActorRef</a>&gt; implements Serializable</h3>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.AppMaster:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dappmaster:DAppMaster:D:DexecutorBrief:D1:D:Danonfun:Dapply:D9">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$org$apache$gearpump$streaming$appmaster$AppMaster$$executorBrief$1$$anonfun$apply$9 extends java.lang.Object implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.AppMasterSpec.TaskStarted:D">
 <!--   -->
 </a>
@@ -2267,6 +2379,11 @@
 </a>
 <h3>Class <a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.ClockService.StoredStartClock$</a> extends scala.runtime.AbstractFunction1&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in org.apache.gearpump.streaming.appmaster">ClockService.StoredStartClock</a>&gt; implements Serializable</h3>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.ClockService:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dappmaster:DClockService:D:DupdateCheckpointClocks:D2:D:Danonfun:Dapply:D1">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.appmaster.ClockService$$anonfun$org$apache$gearpump$streaming$appmaster$ClockService$$updateCheckpointClocks$2$$anonfun$apply$1 extends java.lang.Object implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.DagManager.DagInitiated:D">
 <!--   -->
 </a>
@@ -2526,7 +2643,7 @@
 <li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary$ extends scala.runtime.AbstractFunction16&lt;java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,java.lang.String,java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a>&lt;java.lang.Object,java.lang.String&gt;,scala.collection.immutable.List&lt;<a href="org/apache/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.ExecutorBrief</a>&gt;,scala.collection.immutable.Map&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a>&gt;,scala.collection.immutable.Map&lt;java.lang.Object,java.lang.Object&gt;,<a href="org/apache/gearpump/util/HistoryMetricsService.HistoryMetricsCon
 fig.html" title="class in org.apache.gearpump.util">HistoryMetricsService.HistoryMetricsConfig</a>,<a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary$ extends scala.runtime.AbstractFunction16&lt;java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a>&lt;java.lang.Object,java.lang.String&gt;,scala.collection.immutable.List&lt;<a href="org/apache/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.ExecutorBrief</a>&gt;,scala.collection.immutable.Map&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a>&gt;,scala.collection.immutable.Map&lt;
 java.lang.Object,java.lang.Object&gt;,<a href="org/apache/gearpump/util/HistoryMetricsService.HistoryMetricsConfig.html" title="class in org.apache.gearpump.util">HistoryMetricsService.HistoryMetricsConfig</a>,<a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -2693,27 +2810,90 @@
 </ul>
 </li>
 <li class="blockList">
-<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl</h2>
+<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl.api.functions</h2>
 <ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.CollectionDataSource">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.FilterFunction">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/FilterFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.FilterFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.FilterFunction:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.CollectionDataSource</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.api.functions.FilterFunction$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.LoggerSink">
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.FoldFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.LoggerSink</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.FoldFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.Stream.Sink">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.MapFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/Stream.Sink.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.Stream.Sink</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/MapFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.MapFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.StreamApp.Source">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.MapFunction:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/StreamApp.Source.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.StreamApp.Source</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.api.functions.MapFunction$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">FoldFunction</a>&lt;<a href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html" title="type parameter in ReduceFunction">T</a>,scala.Option&lt;<a href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html" title="type parameter in ReduceFunction">T</a>&gt;&gt; implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction:D">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl.javaapi.functions</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/javaapi/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.javaapi.functions">org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.javaapi.functions.GroupByFunction">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="class in org.apache.gearpump.streaming.dsl.javaapi.functions">org.apache.gearpump.streaming.dsl.javaapi.functions.GroupByFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/api/functions/MapFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">MapFunction</a>&lt;<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="type parameter in GroupByFunction">T</a>,<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="type parameter in GroupByFunction">GROUP</a>&gt; implements Serializable</h3>
 </li>
 </ul>
 </li>
@@ -2943,20 +3123,108 @@
 </a>
 <h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.AndThen</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.EmitFunction">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen:D">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.AndThen$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.Emit">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.Emit</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner:D">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl.scalaapi</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.CollectionDataSource">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.CollectionDataSource</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.LoggerSink">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.LoggerSink</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.Stream.Sink">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.Sink.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.Stream.Sink</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.StreamApp.Source">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.Source.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.StreamApp.Source</a> extends java.lang.Object implements Serializable</h3>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl.scalaapi.functions</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/EmitFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.EmitFunction</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapFunction">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FlatMapFunction</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.ReduceFunction">
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.ReduceFunction</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction</a> extends java.lang.Object implements Serializable</h3>
 </li>
 </ul>
 </li>
@@ -3015,15 +3283,15 @@
 </li>
 </ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountWindowFn</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a>&lt;<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="type parameter in CountWindowFunction">T</a>&gt; implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountWindowFn$ extends scala.runtime.AbstractFunction1&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">CountWindowFn</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -3099,15 +3367,15 @@
 </li>
 </ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn$ extends scala.runtime.AbstractFunction2&lt;java.time.Duration,java.time.Duration,<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">SlidingWindowFn</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -3120,15 +3388,15 @@
 </li>
 </ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Window">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Window</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a>&lt;<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="type parameter in SlidingWindowFunction">T</a>&gt; implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Window:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.api.Window$ extends scala.runtime.AbstractFunction3&lt;<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFn.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFn</a>,<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">Trigger</a>,<a href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">AccumulationMode</a>,<a href="org/apache/gearpump/streaming/dsl/window/api/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.api">Window</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -3141,20 +3409,15 @@
 </li>
 </ul>
 </li>
-</ul>
-</li>
-<li class="blockList">
-<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl.window.impl</h2>
-<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Bucket">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Windows">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/Bucket.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.Bucket</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Windows</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Bucket:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Windows:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.impl.Bucket$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.Windows$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -3167,25 +3430,41 @@
 </li>
 </ul>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup">
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.dsl.window.impl</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow:D">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup$.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup$</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow">
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Window">
 <!--   -->
 </a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.Window</a> extends java.lang.Object implements Serializable</h3>
 </li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Window:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.impl.Window$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -3345,9 +3624,6 @@
 </ul>
 </li>
 <li class="blockList">
-<h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.javaapi.dsl.functions</h2>
-</li>
-<li class="blockList">
 <h2 title="Package">Package&nbsp;org.apache.gearpump.streaming.kafka</h2>
 <ul class="blockList">
 <li class="blockList"><a name="org.apache.gearpump.streaming.kafka.KafkaSink">
@@ -3582,7 +3858,7 @@
 <li class="blockList"><a name="org.apache.gearpump.streaming.source.Watermark:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.source.Watermark$ extends scala.runtime.AbstractFunction1&lt;java.time.Instant,<a href="org/apache/gearpump/streaming/source/Watermark.html" title="class in org.apache.gearpump.streaming.source">Watermark</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.source.Watermark$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -3593,6 +3869,19 @@
 </li>
 </ul>
 </li>
+<li class="blockList">
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockList">
+<h4>MAX</h4>
+<pre>java.time.Instant MAX</pre>
+</li>
+<li class="blockListLast">
+<h4>MIN</h4>
+<pre>java.time.Instant MIN</pre>
+</li>
+</ul>
+</li>
 </ul>
 </li>
 </ul>
@@ -3748,6 +4037,27 @@
 </li>
 </ul>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.task.EndingClock">
+<!--   -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/task/EndingClock.html" title="class in org.apache.gearpump.streaming.task">org.apache.gearpump.streaming.task.EndingClock</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.task.EndingClock:D">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.task.EndingClock$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private&nbsp;java.lang.Object&nbsp;readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.streaming.task.GetCheckpointClock">
 <!--   -->
 </a>
@@ -3903,7 +4213,7 @@
 <li class="blockList"><a name="org.apache.gearpump.streaming.task.SendMessageLoss:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.task.SendMessageLoss$ extends scala.runtime.AbstractFunction0&lt;<a href="org/apache/gearpump/streaming/task/SendMessageLoss.html" title="class in org.apache.gearpump.streaming.task">SendMessageLoss</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.task.SendMessageLoss$ extends java.lang.Object implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -4004,6 +4314,11 @@
 </a>
 <h3>Class <a href="org/apache/gearpump/streaming/task/TaskActor.SendAck$.html" title="class in org.apache.gearpump.streaming.task">org.apache.gearpump.streaming.task.TaskActor.SendAck$</a> extends scala.runtime.AbstractFunction2&lt;<a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task">Ack</a>,<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,<a href="org/apache/gearpump/streaming/task/TaskActor.SendAck.html" title="class in org.apache.gearpump.streaming.task">TaskActor.SendAck</a>&gt; implements Serializable</h3>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.task.TaskActor:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dtask:DTaskActor:D:DonStartClock:D4:D:Danonfun:Dapply:D1">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.streaming.task.TaskActor$$anonfun$org$apache$gearpump$streaming$task$TaskActor$$onStartClock$4$$anonfun$apply$1 extends java.lang.Object implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.streaming.task.TaskContextData">
 <!--   -->
 </a>
@@ -4096,7 +4411,7 @@
 <li class="blockList"><a name="org.apache.gearpump.streaming.task.UpstreamMinClock:D">
 <!--   -->
 </a>
-<h3>Class org.apache.gearpump.streaming.task.UpstreamMinClock$ extends scala.runtime.AbstractFunction1&lt;java.lang.Object,<a href="org/apache/gearpump/streaming/task/UpstreamMinClock.html" title="class in org.apache.gearpump.streaming.task">UpstreamMinClock</a>&gt; implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.task.UpstreamMinClock$ extends scala.runtime.AbstractFunction1&lt;scala.Option&lt;java.lang.Object&gt;,<a href="org/apache/gearpump/streaming/task/UpstreamMinClock.html" title="class in org.apache.gearpump.streaming.task">UpstreamMinClock</a>&gt; implements Serializable</h3>
 <ul class="blockList">
 <li class="blockList">
 <h3>Serialization Methods</h3>
@@ -4349,6 +4664,11 @@
 </li>
 </ul>
 </li>
+<li class="blockList"><a name="org.apache.gearpump.util.Graph:D:Danonfun:DgetAcyclicCopy:D2:D:Danonfun:Dapply:D4:D:Danonfun:Dapply:D5:D:Danonfun:Dapply:D6">
+<!--   -->
+</a>
+<h3>Class org.apache.gearpump.util.Graph$$anonfun$getAcyclicCopy$2$$anonfun$apply$4$$anonfun$apply$5$$anonfun$apply$6 extends java.lang.Object implements Serializable</h3>
+</li>
 <li class="blockList"><a name="org.apache.gearpump.util.GraphSpec.Edge">
 <!--   -->
 </a>

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/stylesheet.css
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/stylesheet.css b/content/releases/latest/api/java/stylesheet.css
index cebb4fd..98055b2 100644
--- a/content/releases/latest/api/java/stylesheet.css
+++ b/content/releases/latest/api/java/stylesheet.css
@@ -463,7 +463,6 @@ Table styles
 .useSummary td, .constantsSummary td, .deprecatedSummary td {
     text-align:left;
     padding:0px 0px 12px 10px;
-    width:100%;
 }
 th.colOne, th.colFirst, th.colLast, .useSummary th, .constantsSummary th,
 td.colOne, td.colFirst, td.colLast, .useSummary td, .constantsSummary td{
@@ -488,6 +487,7 @@ td.colOne, th.colOne {
     font-size:13px;
 }
 .overviewSummary td.colFirst, .overviewSummary th.colFirst,
+.useSummary td.colFirst, .useSummary th.colFirst,
 .overviewSummary td.colOne, .overviewSummary th.colOne,
 .memberSummary td.colFirst, .memberSummary th.colFirst,
 .memberSummary td.colOne, .memberSummary th.colOne,