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>
