You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ka...@apache.org on 2016/11/29 07:57:10 UTC
[13/51] [partial] incubator-gearpump-site git commit: [GEARPUMP-242]
Update website for 0.8.2-incubating release
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 0134e88..5f9cbd0 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 Thu Aug 11 09:54:18 PDT 2016 -->
+<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:21 PST 2016 -->
<title>Serialized Form</title>
-<meta name="date" content="2016-08-11">
+<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>
@@ -797,6 +797,31 @@
</a>
<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.WorkerConfig$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.WorkerConfig$</a> extends scala.runtime.AbstractFunction1<com.typesafe.config.Config,<a href="org/apache/gearpump/cluster/MasterToClient.WorkerConfig.html" title="class in org.apache.gearpump.cluster">MasterToClient.WorkerConfig</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToWorker.UpdateResourceFailed">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceFailed.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToWorker.UpdateResourceFailed</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToWorker.UpdateResourceFailed:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceFailed$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToWorker.UpdateResourceFailed$</a> extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Throwable,<a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceFailed.html" title="class in org.apache.gearpump.cluster">MasterToWorker.UpdateResourceFailed</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToWorker.UpdateResourceSucceed:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceSucceed$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToWorker.UpdateResourceSucceed$</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToWorker.WorkerRegistered">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToWorker.WorkerRegistered.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToWorker.WorkerRegistered</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToWorker.WorkerRegistered:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/MasterToWorker.WorkerRegistered$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToWorker.WorkerRegistered$</a> extends scala.runtime.AbstractFunction2<<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/master/Master.MasterInfo.html" title="class in org.apache.gearpump.cluster.master">Master.MasterInfo</a>,<a href="org/apache/gearpump/cluster/MasterToWorker.WorkerRegistered.html" title="class in org.apache.gearpump.cluster">MasterToWorker.WorkerRegistered</a>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.cluster.UserConfig">
<!-- -->
</a>
@@ -848,6 +873,31 @@
</a>
<h3>Class <a href="org/apache/gearpump/cluster/WorkerToAppMaster.ShutdownExecutorSucceed$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.WorkerToAppMaster.ShutdownExecutorSucceed$</a> extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,<a href="org/apache/gearpump/cluster/WorkerToAppMaster.ShutdownExecutorSucceed.html" title="class in org.apache.gearpump.cluster">WorkerToAppMaster.ShutdownExecutorSucceed</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.WorkerToMaster.RegisterNewWorker:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/WorkerToMaster.RegisterNewWorker$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.WorkerToMaster.RegisterNewWorker$</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.WorkerToMaster.RegisterWorker">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/WorkerToMaster.RegisterWorker.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.WorkerToMaster.RegisterWorker</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.WorkerToMaster.RegisterWorker:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/WorkerToMaster.RegisterWorker$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.WorkerToMaster.RegisterWorker$</a> extends scala.runtime.AbstractFunction1<<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/WorkerToMaster.RegisterWorker.html" title="class in org.apache.gearpump.cluster">WorkerToMaster.RegisterWorker</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.WorkerToMaster.ResourceUpdate">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/WorkerToMaster.ResourceUpdate.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.WorkerToMaster.ResourceUpdate</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.WorkerToMaster.ResourceUpdate:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/WorkerToMaster.ResourceUpdate$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.WorkerToMaster.ResourceUpdate$</a> extends scala.runtime.AbstractFunction3<akka.actor.ActorRef,<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/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a>,<a href="org/apache/gearpump/cluster/WorkerToMaster.ResourceUpdate.html" title="class in org.apache.gearpump.cluster">WorkerToMaster.ResourceUpdate</a>> implements Serializable</h3>
+</li>
</ul>
</li>
<li class="blockList">
@@ -879,6 +929,16 @@
</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<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>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo">
<!-- -->
</a>
@@ -1036,6 +1096,21 @@
</a>
<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StopExecutorSystem$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler.StopExecutorSystem$</a> extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystem</a>,<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StopExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.StopExecutorSystem</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted$</a> extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.Session.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler.Session</a>,<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.LauncherStarted">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/LauncherStarted.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.LauncherStarted</a> extends java.lang.Object implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.MasterConnectionKeeper.AppMasterRegisterTimeout:D">
<!-- -->
</a>
@@ -1083,6 +1158,16 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.MasterConnectionKeeperSpec.ConnectionKeeperTestEnv">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.ConnectionKeeperTestEnv.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.MasterConnectionKeeperSpec.ConnectionKeeperTestEnv</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.MasterConnectionKeeperSpec.ConnectionKeeperTestEnv:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.ConnectionKeeperTestEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.MasterConnectionKeeperSpec.ConnectionKeeperTestEnv$</a> extends scala.runtime.AbstractFunction3<akka.testkit.TestProbe,akka.actor.ActorRef,akka.testkit.TestProbe,<a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.ConnectionKeeperTestEnv.html" title="class in org.apache.gearpump.cluster.appmaster">MasterConnectionKeeperSpec.ConnectionKeeperTestEnv</a>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.WorkerInfo">
<!-- -->
</a>
@@ -1145,6 +1230,151 @@
<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.cluster.master</h2>
<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.MasterState">
+<!-- -->
+</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 java.lang.Object implements Serializable</h3>
+</li>
+<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<java.lang.Object,scala.collection.immutable.Map<java.lang.Object,scala.Tuple2<akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeInfo</a>>>,scala.collection.immutable.Set<java.lang.Object>,scala.collection.immutable.Set<java.lang.Object>,<a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.RecoverApplication">
+<!-- -->
+</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 java.lang.Object implements Serializable</h3>
+</li>
+<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<<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>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.DeleteKVGroup">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.DeleteKVGroup</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.DeleteKVGroup:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.DeleteKVGroup$</a> extends scala.runtime.AbstractFunction1<java.lang.String,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.DeleteKVGroup</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKV">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GetKV</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKV:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GetKV$</a> extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKV</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKVFailed">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GetKVFailed</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKVFailed:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GetKVFailed$</a> extends scala.runtime.AbstractFunction1<java.lang.Throwable,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVFailed</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKVSuccess">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GetKVSuccess</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GetKVSuccess:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GetKVSuccess$</a> extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GetKVSuccess</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GroupDeleted">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GroupDeleted</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.GroupDeleted:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.GroupDeleted$</a> extends scala.runtime.AbstractFunction1<java.lang.String,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.GroupDeleted</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKV">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKV.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.PutKV</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKV:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKV$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.PutKV$</a> extends scala.runtime.AbstractFunction3<java.lang.String,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKV.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKV</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKVFailed">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.PutKVFailed</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKVFailed:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.PutKVFailed$</a> extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.Throwable,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.PutKVFailed</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.PutKVSuccess:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVSuccess$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.PutKVSuccess$</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.Request">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.Request.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.Request</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.Request:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/InMemoryKVService.Request$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.InMemoryKVService.Request$</a> extends scala.runtime.AbstractFunction2<akka.actor.ActorRef,java.lang.String,<a href="org/apache/gearpump/cluster/master/InMemoryKVService.Request.html" title="class in org.apache.gearpump.cluster.master">InMemoryKVService.Request</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.MasterInfo">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.MasterInfo.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.MasterInfo</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.MasterInfo:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.MasterInfo$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.MasterInfo$</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.MasterListUpdated">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.MasterListUpdated.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.MasterListUpdated</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.MasterListUpdated:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.MasterListUpdated$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.MasterListUpdated$</a> extends scala.runtime.AbstractFunction1<scala.collection.immutable.List<<a href="org/apache/gearpump/cluster/master/MasterNode.html" title="class in org.apache.gearpump.cluster.master">MasterNode</a>>,<a href="org/apache/gearpump/cluster/master/Master.MasterListUpdated.html" title="class in org.apache.gearpump.cluster.master">Master.MasterListUpdated</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.SlotStatus">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.SlotStatus.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.SlotStatus</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.SlotStatus:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.SlotStatus$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.SlotStatus$</a> extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,<a href="org/apache/gearpump/cluster/master/Master.SlotStatus.html" title="class in org.apache.gearpump.cluster.master">Master.SlotStatus</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.WorkerTerminated">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.WorkerTerminated</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.master.Master.WorkerTerminated:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.Master.WorkerTerminated$</a> extends scala.runtime.AbstractFunction1<<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/master/Master.WorkerTerminated.html" title="class in org.apache.gearpump.cluster.master">Master.WorkerTerminated</a>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.cluster.master.MasterActivity">
<!-- -->
</a>
@@ -1354,6 +1584,26 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.scheduler.Scheduler.ApplicationFinished">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished.html" title="class in org.apache.gearpump.cluster.scheduler">org.apache.gearpump.cluster.scheduler.Scheduler.ApplicationFinished</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.scheduler.Scheduler.ApplicationFinished:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished$.html" title="class in org.apache.gearpump.cluster.scheduler">org.apache.gearpump.cluster.scheduler.Scheduler.ApplicationFinished$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler.ApplicationFinished</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.scheduler.Scheduler.PendingRequest">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest.html" title="class in org.apache.gearpump.cluster.scheduler">org.apache.gearpump.cluster.scheduler.Scheduler.PendingRequest</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.scheduler.Scheduler.PendingRequest:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest$.html" title="class in org.apache.gearpump.cluster.scheduler">org.apache.gearpump.cluster.scheduler.Scheduler.PendingRequest$</a> extends scala.runtime.AbstractFunction4<java.lang.Object,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/scheduler/ResourceRequest.html" title="class in org.apache.gearpump.cluster.scheduler">ResourceRequest</a>,java.lang.Object,<a href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest.html" title="class in org.apache.gearpump.cluster.scheduler">Scheduler.PendingRequest</a>> implements Serializable</h3>
+</li>
</ul>
</li>
<li class="blockList">
@@ -1380,6 +1630,26 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.worker.Worker.ExecutorResult">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/worker/Worker.ExecutorResult.html" title="class in org.apache.gearpump.cluster.worker">org.apache.gearpump.cluster.worker.Worker.ExecutorResult</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.worker.Worker.ExecutorResult:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/worker/Worker.ExecutorResult$.html" title="class in org.apache.gearpump.cluster.worker">org.apache.gearpump.cluster.worker.Worker.ExecutorResult$</a> extends scala.runtime.AbstractFunction1<scala.util.Try<java.lang.Object>,<a href="org/apache/gearpump/cluster/worker/Worker.ExecutorResult.html" title="class in org.apache.gearpump.cluster.worker">Worker.ExecutorResult</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.worker.Worker.ProcessInfo">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/worker/Worker.ProcessInfo.html" title="class in org.apache.gearpump.cluster.worker">org.apache.gearpump.cluster.worker.Worker.ProcessInfo</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.cluster.worker.Worker.ProcessInfo:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/cluster/worker/Worker.ProcessInfo$.html" title="class in org.apache.gearpump.cluster.worker">org.apache.gearpump.cluster.worker.Worker.ProcessInfo$</a> extends scala.runtime.AbstractFunction3<<a href="org/apache/gearpump/util/RichProcess.html" title="class in org.apache.gearpump.util">RichProcess</a>,scala.Option<java.lang.String>,java.lang.String,<a href="org/apache/gearpump/cluster/worker/Worker.ProcessInfo.html" title="class in org.apache.gearpump.cluster.worker">Worker.ProcessInfo</a>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.cluster.worker.WorkerId">
<!-- -->
</a>
@@ -1469,6 +1739,16 @@
<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.jarstore</h2>
<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.jarstore.FileDirective.FileInfo">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/jarstore/FileDirective.FileInfo.html" title="class in org.apache.gearpump.jarstore">org.apache.gearpump.jarstore.FileDirective.FileInfo</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.jarstore.FileDirective.FileInfo:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/jarstore/FileDirective.FileInfo$.html" title="class in org.apache.gearpump.jarstore">org.apache.gearpump.jarstore.FileDirective.FileInfo$</a> extends scala.runtime.AbstractFunction3<java.lang.String,java.io.File,java.lang.Object,<a href="org/apache/gearpump/jarstore/FileDirective.FileInfo.html" title="class in org.apache.gearpump.jarstore">FileDirective.FileInfo</a>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.jarstore.FilePath">
<!-- -->
</a>
@@ -1490,6 +1770,16 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.jarstore.FileServer.Port">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/jarstore/FileServer.Port.html" title="class in org.apache.gearpump.jarstore">org.apache.gearpump.jarstore.FileServer.Port</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.jarstore.FileServer.Port:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/jarstore/FileServer.Port$.html" title="class in org.apache.gearpump.jarstore">org.apache.gearpump.jarstore.FileServer.Port$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/jarstore/FileServer.Port.html" title="class in org.apache.gearpump.jarstore">FileServer.Port</a>> implements Serializable</h3>
+</li>
</ul>
</li>
<li class="blockList">
@@ -1563,92 +1853,6 @@
</ul>
</li>
<li class="blockList">
-<h2 title="Package">Package org.apache.gearpump.partitioner</h2>
-<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.partitioner.BroadcastPartitioner">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.BroadcastPartitioner</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.CoLocationPartitioner">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.CoLocationPartitioner</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.HashPartitioner">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/HashPartitioner.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.HashPartitioner</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.Partitioner:D">
-<!-- -->
-</a>
-<h3>Class org.apache.gearpump.partitioner.Partitioner$ 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 java.lang.Object readResolve()</pre>
-</li>
-</ul>
-</li>
-<li class="blockList">
-<h3>Serialized Fields</h3>
-<ul class="blockList">
-<li class="blockListLast">
-<h4>UNKNOWN_PARTITION_ID</h4>
-<pre>int UNKNOWN_PARTITION_ID</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.PartitionerByClassName">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/PartitionerByClassName.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.PartitionerByClassName</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.PartitionerDescription">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/PartitionerDescription.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.PartitionerDescription</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.PartitionerDescription:D">
-<!-- -->
-</a>
-<h3>Class org.apache.gearpump.partitioner.PartitionerDescription$ extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/partitioner/PartitionerFactory.html" title="interface in org.apache.gearpump.partitioner">PartitionerFactory</a>,<a href="org/apache/gearpump/partitioner/PartitionerDescription.html" title="class in org.apache.gearpump.partitioner">PartitionerDescription</a>> implements Serializable</h3>
-<ul class="blockList">
-<li class="blockList">
-<h3>Serialization Methods</h3>
-<ul class="blockList">
-<li class="blockListLast">
-<h4>readResolve</h4>
-<pre>private java.lang.Object readResolve()</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.PartitionerObject">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/PartitionerObject.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.PartitionerObject</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.ShuffleGroupingPartitioner">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/ShuffleGroupingPartitioner.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.ShuffleGroupingPartitioner</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.partitioner.ShufflePartitioner">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/partitioner/ShufflePartitioner.html" title="class in org.apache.gearpump.partitioner">org.apache.gearpump.partitioner.ShufflePartitioner</a> extends java.lang.Object implements Serializable</h3>
-</li>
-</ul>
-</li>
-<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.serializer</h2>
<ul class="blockList">
<li class="blockList"><a name="org.apache.gearpump.serializer.FastKryoSerializer.KryoSerializationException">
@@ -1998,6 +2202,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<akka.actor.ActorRef,<a href="org/apache/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.TaskActorRef</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.AppMasterSpec.TaskStarted:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/appmaster/AppMasterSpec.TaskStarted$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.AppMasterSpec.TaskStarted$</a> extends java.lang.Object implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.ClockService.ChangeToNewDAG">
<!-- -->
</a>
@@ -2233,6 +2442,11 @@
</a>
<h3>Class <a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.UniCast$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.ExecutorManager.UniCast$</a> extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.UniCast.html" title="class in org.apache.gearpump.streaming.appmaster">ExecutorManager.UniCast</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.ExecutorManagerSpec.StartExecutorActorPlease:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.StartExecutorActorPlease$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.ExecutorManagerSpec.StartExecutorActorPlease$</a> extends java.lang.Object implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.JarScheduler.ExecutorFailed">
<!-- -->
</a>
@@ -2426,6 +2640,16 @@
</a>
<h3>Class <a href="org/apache/gearpump/streaming/appmaster/TaskManager.TaskList$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.TaskManager.TaskList$</a> extends scala.runtime.AbstractFunction1<scala.collection.immutable.Map<<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,java.lang.Object>,<a href="org/apache/gearpump/streaming/appmaster/TaskManager.TaskList.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.TaskList</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.TaskManagerSpec.Env">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Env.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.TaskManagerSpec.Env</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.TaskManagerSpec.Env:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Env$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.TaskManagerSpec.Env$</a> extends scala.runtime.AbstractFunction6<akka.testkit.TestProbe,akka.testkit.TestProbe,akka.testkit.TestProbe,akka.testkit.TestProbe,akka.actor.ActorRef,<a href="org/apache/gearpump/streaming/appmaster/JarScheduler.html" title="class in org.apache.gearpump.streaming.appmaster">JarScheduler</a>,<a href="org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Env.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManagerSpec.Env</a>> implements Serializable</h3>
+</li>
<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.TaskRegistry.Accept:D">
<!-- -->
</a>
@@ -2494,19 +2718,39 @@
</ul>
</li>
<li class="blockList">
-<h2 title="Package">Package org.apache.gearpump.streaming.dsl.op</h2>
+<h2 title="Package">Package org.apache.gearpump.streaming.dsl.partitioner</h2>
<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.DataSinkOp">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.DataSinkOp</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.DataSinkOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.DataSinkOp$ extends java.lang.Object implements Serializable</h3>
-<ul class="blockList">
-<li class="blockList">
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People$.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitionerSpec.People$</a> extends scala.runtime.AbstractFunction2<java.lang.String,java.lang.String,<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">GroupByPartitionerSpec.People</a>> implements Serializable</h3>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package org.apache.gearpump.streaming.dsl.plan</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.ChainableOp">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.ChainableOp</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.ChainableOp:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.ChainableOp$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
<h3>Serialization Methods</h3>
<ul class="blockList">
<li class="blockListLast">
@@ -2517,15 +2761,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.DataSourceOp">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.DataSourceOp</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.DataSinkOp</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.DataSourceOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.DataSinkOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.DataSourceOp$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.DataSinkOp$ extends scala.runtime.AbstractFunction4<<a href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a>,java.lang.Object,<a href="org/apache/gearpump/cluster/UserConfig.html" title="class in org.apache.gearpump.cluster">UserConfig</a>,java.lang.String,<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSinkOp</a>> implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2538,15 +2782,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.Direct">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/Direct.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.Direct</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.DataSourceOp</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.Direct:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.DataSourceOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.Direct$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.DataSourceOp$ extends scala.runtime.AbstractFunction4<<a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a>,java.lang.Object,<a href="org/apache/gearpump/cluster/UserConfig.html" title="class in org.apache.gearpump.cluster">UserConfig</a>,java.lang.String,<a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">DataSourceOp</a>> implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2559,15 +2803,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.FlatMapOp">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.Direct">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/FlatMapOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.FlatMapOp</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/Direct.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.Direct</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.FlatMapOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.Direct:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.FlatMapOp$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.Direct$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2580,15 +2824,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.GroupByOp">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.GroupByOp">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/GroupByOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.GroupByOp</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.GroupByOp</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.GroupByOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.GroupByOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.GroupByOp$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.GroupByOp$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2601,15 +2845,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.MergeOp">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.MergeOp">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.MergeOp</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.MergeOp</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.MergeOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.MergeOp:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.MergeOp$ extends scala.runtime.AbstractFunction2<java.lang.String,<a href="org/apache/gearpump/cluster/UserConfig.html" title="class in org.apache.gearpump.cluster">UserConfig</a>,<a href="org/apache/gearpump/streaming/dsl/op/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.op">MergeOp</a>> implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.MergeOp$ extends scala.runtime.AbstractFunction2<java.lang.String,<a href="org/apache/gearpump/cluster/UserConfig.html" title="class in org.apache.gearpump.cluster">UserConfig</a>,<a href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">MergeOp</a>> implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2622,15 +2866,40 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.OpChain">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpChainException">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpChainException.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpChainException</a> extends java.lang.RuntimeException implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpSpec.AnySink">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpSpec.AnySink</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpSpec.AnySource">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpSpec.AnySource.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpSpec.AnySource</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.PlannerSpec.AnySink">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.PlannerSpec.AnySink</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.PlannerSpec.AnySource">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/OpChain.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.OpChain</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySource.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.PlannerSpec.AnySource</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.OpChain:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.OpChain$ extends scala.runtime.AbstractFunction1<scala.collection.immutable.List<<a href="org/apache/gearpump/streaming/dsl/op/Op.html" title="interface in org.apache.gearpump.streaming.dsl.op">Op</a>>,<a href="org/apache/gearpump/streaming/dsl/op/OpChain.html" title="class in org.apache.gearpump.streaming.dsl.op">OpChain</a>> implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.ProcessorOp</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.ProcessorOp:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.ProcessorOp$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2643,15 +2912,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.ProcessorOp">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.Shuffle">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/ProcessorOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.ProcessorOp</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/Shuffle.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.Shuffle</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.ProcessorOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.Shuffle:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.ProcessorOp$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.plan.Shuffle$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2664,15 +2933,55 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.ReduceOp">
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package org.apache.gearpump.streaming.dsl.plan.functions</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/ReduceOp.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.ReduceOp</a> extends java.lang.Object implements Serializable</h3>
+<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.op.ReduceOp:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.EmitFunction">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.ReduceOp$ extends java.lang.Object implements Serializable</h3>
+<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>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapFunction">
+<!-- -->
+</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>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.ReduceFunction">
+<!-- -->
+</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>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package org.apache.gearpump.streaming.dsl.task</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask.Triggering:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.Triggering$.html" title="class in org.apache.gearpump.streaming.dsl.task">org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask.Triggering$</a> extends java.lang.Object implements Serializable</h3>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package org.apache.gearpump.streaming.dsl.window.api</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Accumulating">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Accumulating.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Accumulating</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Accumulating:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.Accumulating$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2685,15 +2994,15 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.Shuffle">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountTrigger">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/op/Shuffle.html" title="class in org.apache.gearpump.streaming.dsl.op">org.apache.gearpump.streaming.dsl.op.Shuffle</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountTrigger</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.op.Shuffle:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountTrigger:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.op.Shuffle$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountTrigger$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2706,20 +3015,57 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn">
+<!-- -->
+</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>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountWindowFn$ extends scala.runtime.AbstractFunction1<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>> implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Discarding">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Discarding.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Discarding</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Discarding:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.Discarding$ extends java.lang.Object implements Serializable</h3>
+<ul class="blockList">
<li class="blockList">
-<h2 title="Package">Package org.apache.gearpump.streaming.dsl.partitioner</h2>
+<h3>Serialization Methods</h3>
<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.dsl.partitioner">org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger:D">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.partitioner.GroupByPartitioner$ extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger$ extends java.lang.Object implements Serializable</h3>
<ul class="blockList">
<li class="blockList">
<h3>Serialization Methods</h3>
@@ -2732,40 +3078,114 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/ProcessingTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger$ 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 java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn">
+<!-- -->
+</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>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn$ extends scala.runtime.AbstractFunction2<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>> implements Serializable</h3>
+<ul class="blockList">
<li class="blockList">
-<h2 title="Package">Package org.apache.gearpump.streaming.dsl.plan</h2>
+<h3>Serialization Methods</h3>
<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpTranslator">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Window">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpTranslator</a> extends java.lang.Object implements Serializable</h3>
+<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>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpTranslator.AndThen">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Window:D">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpTranslator.AndThen</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.api.Window$ extends scala.runtime.AbstractFunction3<<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>> implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpTranslator.DummyInputFunction">
+</ul>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h2 title="Package">Package org.apache.gearpump.streaming.dsl.window.impl</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Bucket">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.DummyInputFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpTranslator.DummyInputFunction</a> extends java.lang.Object implements Serializable</h3>
+<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>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpTranslator.FlatMapFunction">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Bucket:D">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpTranslator.FlatMapFunction</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class org.apache.gearpump.streaming.dsl.window.impl.Bucket$ 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 java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup">
+<!-- -->
+</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>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpTranslator.ReduceFunction">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup:D">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan">org.apache.gearpump.streaming.dsl.plan.OpTranslator.ReduceFunction</a> extends java.lang.Object implements Serializable</h3>
+<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>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.OpTranslator:D">
+<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow">
<!-- -->
</a>
-<h3>Class org.apache.gearpump.streaming.dsl.plan.OpTranslator$ 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.GroupAlsoByWindow:D">
+<!-- -->
+</a>
+<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>
@@ -2920,7 +3340,7 @@
<li class="blockList"><a name="org.apache.gearpump.streaming.javaapi.Graph">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/javaapi/Graph.html" title="class in org.apache.gearpump.streaming.javaapi">org.apache.gearpump.streaming.javaapi.Graph</a> extends <a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a><<a href="org/apache/gearpump/streaming/Processor.html" title="interface in org.apache.gearpump.streaming">Processor</a><? extends <a href="org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task">Task</a>>,<a href="org/apache/gearpump/partitioner/Partitioner.html" title="interface in org.apache.gearpump.partitioner">Partitioner</a>> implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/javaapi/Graph.html" title="class in org.apache.gearpump.streaming.javaapi">org.apache.gearpump.streaming.javaapi.Graph</a> extends <a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a><<a href="org/apache/gearpump/streaming/Processor.html" title="interface in org.apache.gearpump.streaming">Processor</a><? extends <a href="org/apache/gearpump/streaming/task/Task.html" title="class in org.apache.gearpump.streaming.task">Task</a>>,<a href="org/apache/gearpump/streaming/partitioner/Partitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">Partitioner</a>> implements Serializable</h3>
</li>
</ul>
</li>
@@ -2948,6 +3368,16 @@
</ul>
</li>
<li class="blockList">
+<h2 title="Package">Package org.apache.gearpump.streaming.kafka.lib</h2>
+<ul class="blockList">
+<li class="blockList"><a name="org.apache.gearpump.streaming.kafka.lib.MessageAndWatermark">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html" title="class in org.apache.gearpump.streaming.kafka.lib">org.apache.gearpump.streaming.kafka.lib.MessageAndWatermark</a> extends java.lang.Object implements Serializable</h3>
+</li>
+</ul>
+</li>
+<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.streaming.kafka.lib.sink</h2>
<ul class="blockList">
<li class="blockList"><a name="org.apache.gearpump.streaming.kafka.lib.sink.AbstractKafkaSink">
@@ -2965,15 +3395,10 @@
</a>
<h3>Class <a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource</a> extends java.lang.Object implements Serializable</h3>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.kafka.lib.source.DefaultMessageDecoder">
+<li class="blockList"><a name="org.apache.gearpump.streaming.kafka.lib.source.DefaultKafkaMessageDecoder">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">org.apache.gearpump.streaming.kafka.lib.source.DefaultMessageDecoder</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.kafka.lib.source.StringMessageDecoder">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/streaming/kafka/lib/source/StringMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">org.apache.gearpump.streaming.kafka.lib.source.StringMessageDecoder</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">org.apache.gearpump.streaming.kafka.lib.source.DefaultKafkaMessageDecoder</a> extends java.lang.Object implements Serializable</h3>
</li>
</ul>
</li>
@@ -3058,12 +3483,88 @@
</ul>
</li>
<li class="blockList">
-<h2 title="Package">Package org.apache.gearpump.streaming.serializer</h2>
+<h2 title="Package">Package org.apache.gearpump.streaming.partitioner</h2>
<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.serializer.ChillSerializer">
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.BroadcastPartitioner">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.BroadcastPartitioner</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.CoLocationPartitioner">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.CoLocationPartitioner</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.HashPartitioner">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/serializer/ChillSerializer.html" title="class in org.apache.gearpump.streaming.serializer">org.apache.gearpump.streaming.serializer.ChillSerializer</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/HashPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.HashPartitioner</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.Partitioner:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.partitioner.Partitioner$ 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 java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+<li class="blockList">
+<h3>Serialized Fields</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>UNKNOWN_PARTITION_ID</h4>
+<pre>int UNKNOWN_PARTITION_ID</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.PartitionerByClassName">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/PartitionerByClassName.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.PartitionerByClassName</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.PartitionerDescription">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/PartitionerDescription.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.PartitionerDescription</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.PartitionerDescription:D">
+<!-- -->
+</a>
+<h3>Class org.apache.gearpump.streaming.partitioner.PartitionerDescription$ extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/streaming/partitioner/PartitionerFactory.html" title="interface in org.apache.gearpump.streaming.partitioner">PartitionerFactory</a>,<a href="org/apache/gearpump/streaming/partitioner/PartitionerDescription.html" title="class in org.apache.gearpump.streaming.partitioner">PartitionerDescription</a>> implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.PartitionerObject">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/PartitionerObject.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.PartitionerObject</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.ShuffleGroupingPartitioner">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.ShuffleGroupingPartitioner</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.streaming.partitioner.ShufflePartitioner">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/streaming/partitioner/ShufflePartitioner.html" title="class in org.apache.gearpump.streaming.partitioner">org.apache.gearpump.streaming.partitioner.ShufflePartitioner</a> extends java.lang.Object implements Serializable</h3>
</li>
</ul>
</li>
@@ -3073,10 +3574,26 @@
<li class="blockList">
<h2 title="Package">Package org.apache.gearpump.streaming.source</h2>
<ul class="blockList">
-<li class="blockList"><a name="org.apache.gearpump.streaming.source.DefaultTimeStampFilter">
+<li class="blockList"><a name="org.apache.gearpump.streaming.source.Watermark">
<!-- -->
</a>
-<h3>Class <a href="org/apache/gearpump/streaming/source/DefaultTimeStampFilter.html" title="class in org.apache.gearpump.streaming.source">org.apache.gearpump.streaming.source.DefaultTimeStampFilter</a> extends java.lang.Object implements Serializable</h3>
+<h3>Class <a href="org/apache/gearpump/streaming/source/Watermark.html" title="class in org.apache.gearpump.streaming.source">org.apache.gearpump.streaming.source.Watermark</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<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<java.time.Instant,<a href="org/apache/gearpump/streaming/source/Watermark.html" title="class in org.apache.gearpump.streaming.source">Watermark</a>> implements Serializable</h3>
+<ul class="blockList">
+<li class="blockList">
+<h3>Serialization Methods</h3>
+<ul class="blockList">
+<li class="blockListLast">
+<h4>readResolve</h4>
+<pre>private java.lang.Object readResolve()</pre>
+</li>
+</ul>
+</li>
+</ul>
</li>
</ul>
</li>
@@ -3441,27 +3958,6 @@
</li>
</ul>
</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.task.StartTime">
-<!-- -->
-</a>
-<h3>Class <a href="org/apache/gearpump/streaming/task/StartTime.html" title="class in org.apache.gearpump.streaming.task">org.apache.gearpump.streaming.task.StartTime</a> extends java.lang.Object implements Serializable</h3>
-</li>
-<li class="blockList"><a name="org.apache.gearpump.streaming.task.StartTime:D">
-<!-- -->
-</a>
-<h3>Class org.apache.gearpump.streaming.task.StartTime$ extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/streaming/task/StartTime.html" title="class in org.apache.gearpump.streaming.task">StartTime</a>> implements Serializable</h3>
-<ul class="blockList">
-<li class="blockList">
-<h3>Serialization Methods</h3>
-<ul class="blockList">
-<li class="blockListLast">
-<h4>readResolve</h4>
-<pre>private java.lang.Object readResolve()</pre>
-</li>
-</ul>
-</li>
-</ul>
-</li>
<li class="blockList"><a name="org.apache.gearpump.streaming.task.Subscriber">
<!-- -->
</a>
@@ -3642,6 +4138,16 @@
</li>
</ul>
</li>
+<li class="blockList"><a name="org.apache.gearpump.transport.MockTransportSerializer.NettyMessage">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/transport/MockTransportSerializer.NettyMessage.html" title="class in org.apache.gearpump.transport">org.apache.gearpump.transport.MockTransportSerializer.NettyMessage</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.transport.MockTransportSerializer.NettyMessage:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/transport/MockTransportSerializer.NettyMessage$.html" title="class in org.apache.gearpump.transport">org.apache.gearpump.transport.MockTransportSerializer.NettyMessage$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/transport/MockTransportSerializer.NettyMessage.html" title="class in org.apache.gearpump.transport">MockTransportSerializer.NettyMessage</a>> implements Serializable</h3>
+</li>
</ul>
</li>
<li class="blockList">
@@ -3797,6 +4303,31 @@
</a>
<h3>Class <a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed$.html" title="class in org.apache.gearpump.util">org.apache.gearpump.util.ActorSystemBooter.RegisterActorSystemFailed$</a> extends scala.runtime.AbstractFunction1<java.lang.Throwable,<a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed.html" title="class in org.apache.gearpump.util">ActorSystemBooter.RegisterActorSystemFailed</a>> implements Serializable</h3>
</li>
+<li class="blockList"><a name="org.apache.gearpump.util.ActorSystemBooterSpec.Boot">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/util/ActorSystemBooterSpec.Boot.html" title="class in org.apache.gearpump.util">org.apache.gearpump.util.ActorSystemBooterSpec.Boot</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.util.ActorSystemBooterSpec.Boot:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/util/ActorSystemBooterSpec.Boot$.html" title="class in org.apache.gearpump.util">org.apache.gearpump.util.ActorSystemBooterSpec.Boot$</a> extends scala.runtime.AbstractFunction3<akka.actor.ActorSystem,akka.testkit.TestProbe,akka.actor.ActorSystem,<a href="org/apache/gearpump/util/ActorSystemBooterSpec.Boot.html" title="class in org.apache.gearpump.util">ActorSystemBooterSpec.Boot</a>> implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.util.ConfigsSpec.Data">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/util/ConfigsSpec.Data.html" title="class in org.apache.gearpump.util">org.apache.gearpump.util.ConfigsSpec.Data</a> extends java.lang.Object implements Serializable</h3>
+</li>
+<li class="blockList"><a name="org.apache.gearpump.util.ConfigsSpec.Data:D">
+<!-- -->
+</a>
+<h3>Class <a href="org/apache/gearpump/util/ConfigsSpec.Data$.html" title="class in org.apache.gearpump.util">org.apache.gearpump.util.ConfigsSpec.Data$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/util/ConfigsSpec.Data.html" title="class in org.apache.gearpump.util">ConfigsSpec.Dat
<TRUNCATED>