You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gearpump.apache.org by ma...@apache.org on 2017/04/26 03:08:05 UTC
[03/51] [partial] incubator-gearpump-site git commit: [GEARPUMP-299]
Update gearpump.apache.org page for 0.8.3 release
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/overview-tree.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/overview-tree.html b/content/releases/latest/api/java/overview-tree.html
index 5a0f92d..5c26d7f 100644
--- a/content/releases/latest/api/java/overview-tree.html
+++ b/content/releases/latest/api/java/overview-tree.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:21 PST 2016 -->
+<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 -->
<title>Class Hierarchy</title>
-<meta name="date" content="2016-11-28">
+<meta name="date" content="2017-04-25">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -90,11 +90,14 @@
<li><a href="org/apache/gearpump/serializer/package-tree.html">org.apache.gearpump.serializer</a>, </li>
<li><a href="org/apache/gearpump/streaming/package-tree.html">org.apache.gearpump.streaming</a>, </li>
<li><a href="org/apache/gearpump/streaming/appmaster/package-tree.html">org.apache.gearpump.streaming.appmaster</a>, </li>
-<li><a href="org/apache/gearpump/streaming/dsl/package-tree.html">org.apache.gearpump.streaming.dsl</a>, </li>
+<li><a href="org/apache/gearpump/streaming/dsl/api/functions/package-tree.html">org.apache.gearpump.streaming.dsl.api.functions</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/javaapi/package-tree.html">org.apache.gearpump.streaming.dsl.javaapi</a>, </li>
+<li><a href="org/apache/gearpump/streaming/dsl/javaapi/functions/package-tree.html">org.apache.gearpump.streaming.dsl.javaapi.functions</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/partitioner/package-tree.html">org.apache.gearpump.streaming.dsl.partitioner</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/package-tree.html">org.apache.gearpump.streaming.dsl.plan</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/plan/functions/package-tree.html">org.apache.gearpump.streaming.dsl.plan.functions</a>, </li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/package-tree.html">org.apache.gearpump.streaming.dsl.scalaapi</a>, </li>
+<li><a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/package-tree.html">org.apache.gearpump.streaming.dsl.scalaapi.functions</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/task/package-tree.html">org.apache.gearpump.streaming.dsl.task</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/window/api/package-tree.html">org.apache.gearpump.streaming.dsl.window.api</a>, </li>
<li><a href="org/apache/gearpump/streaming/dsl/window/impl/package-tree.html">org.apache.gearpump.streaming.dsl.window.impl</a>, </li>
@@ -104,7 +107,6 @@
<li><a href="org/apache/gearpump/streaming/hadoop/lib/format/package-tree.html">org.apache.gearpump.streaming.hadoop.lib.format</a>, </li>
<li><a href="org/apache/gearpump/streaming/hadoop/lib/rotation/package-tree.html">org.apache.gearpump.streaming.hadoop.lib.rotation</a>, </li>
<li><a href="org/apache/gearpump/streaming/javaapi/package-tree.html">org.apache.gearpump.streaming.javaapi</a>, </li>
-<li><a href="org/apache/gearpump/streaming/javaapi/dsl/functions/package-tree.html">org.apache.gearpump.streaming.javaapi.dsl.functions</a>, </li>
<li><a href="org/apache/gearpump/streaming/kafka/package-tree.html">org.apache.gearpump.streaming.kafka</a>, </li>
<li><a href="org/apache/gearpump/streaming/kafka/dsl/package-tree.html">org.apache.gearpump.streaming.kafka.dsl</a>, </li>
<li><a href="org/apache/gearpump/streaming/kafka/lib/package-tree.html">org.apache.gearpump.streaming.kafka.lib</a>, </li>
@@ -156,7 +158,6 @@
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.StopTask$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StopTask$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TaskRejected$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskRejected$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TasksChanged$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TasksChanged$</span></a> (implements scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.ActivateAppMaster$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GetWorkerData$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.GetWorkerData$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.MasterData$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.MasterData$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToMaster.StallingTasks$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToMaster.StallingTasks$</span></a> (implements scala.Serializable)</li>
@@ -171,6 +172,7 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.JarStoreServerAddress$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.JarStoreServerAddress$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryAppMasterConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryAppMasterConfig$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryWorkerConfig$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.RegisterAppResultListener$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RemoveMaster$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.RemoveMaster$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RemoveWorker$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.RemoveWorker$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.ResolveAppId$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.ResolveAppId$</span></a> (implements scala.Serializable)</li>
@@ -215,6 +217,7 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.ReplayFromTimestampWindowTrailingEdge$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.ReplayFromTimestampWindowTrailingEdge$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.ResourceAllocated$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.ResourceAllocated$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.WorkerList$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.ApplicationSucceeded$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.AppMasterConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.AppMasterConfig$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.MasterConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.MasterConfig$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ReplayApplicationResult$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.ReplayApplicationResult$</span></a> (implements scala.Serializable)</li>
@@ -226,6 +229,8 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.WorkerConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.WorkerConfig$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.DemandMoreMetrics$.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Metrics.DemandMoreMetrics$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.transport.<a href="org/apache/gearpump/transport/MockTransportSerializer.NettyMessage$.html" title="class in org.apache.gearpump.transport"><span class="typeNameLink">MockTransportSerializer.NettyMessage$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.client.<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest$.html" title="class in org.apache.gearpump.cluster.client"><span class="typeNameLink">RunningApplicationSpec.MockAskAppMasterRequest$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.client.<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse$.html" title="class in org.apache.gearpump.cluster.client"><span class="typeNameLink">RunningApplicationSpec.MockAskAppMasterResponse$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/Scheduler.ApplicationFinished$.html" title="class in org.apache.gearpump.cluster.scheduler"><span class="typeNameLink">Scheduler.ApplicationFinished$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.AddChannel$.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Server.AddChannel$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.CloseChannel$.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Server.CloseChannel$</span></a> (implements scala.Serializable)</li>
@@ -248,12 +253,12 @@
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.ActorCreated$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.CreateActor$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.CreateActor$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.CreateActorFailed$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.CreateActorFailed$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">AppManager.MasterState$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TaskChanged$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskChanged$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TaskLocationsReady$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskLocationsReady$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TaskLocationsReceived$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskLocationsReceived$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GetAppData$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.GetAppData$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GetAppDataResult$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.GetAppDataResult$</span></a> (implements scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.RegisterAppMaster$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.RequestResource$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.RequestResource$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.CommandResult$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.CommandResult$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.HealthChecker.ClockValue$</span></a> (implements scala.Serializable)</li>
@@ -274,6 +279,7 @@
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/JarScheduler.ResourceRequestDetail$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">JarScheduler.ResourceRequestDetail$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/Master.SlotStatus$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">Master.SlotStatus$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterDataRequest$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.AppMasterDataRequest$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.ApplicationFailed$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.HistoryMetrics$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.HistoryMetrics$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.HistoryMetricsItem$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.HistoryMetricsItem$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.LastFailure$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.LastFailure$</span></a> (implements scala.Serializable)</li>
@@ -299,6 +305,7 @@
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooterSpec.Boot$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooterSpec.Boot$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TaskRegistered$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskRegistered$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.InvalidAppMaster$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.InvalidAppMaster$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.RegisterAppMaster$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.SaveAppData$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.SaveAppData$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToWorker.ChangeExecutorResource$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToWorker.ChangeExecutorResource$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToWorker.ShutdownExecutor$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToWorker.ShutdownExecutor$</span></a> (implements scala.Serializable)</li>
@@ -309,7 +316,6 @@
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.TaskLaunchData$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.TaskLaunchData$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystem$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemLauncher.LaunchExecutorSystem$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystemRejected$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemLauncher.LaunchExecutorSystemRejected$</span></a> (implements scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster.MessageLoss$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.RegisterTask$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster.RegisterTask$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileDirective.FileInfo$.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileDirective.FileInfo$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKV$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.PutKV$</span></a> (implements scala.Serializable)</li>
@@ -322,17 +328,18 @@
</li>
<li type="circle">scala.runtime.AbstractFunction4<T1,T2,T3,T4,R> (implements scala.Function4<T1,T2,T3,T4,R>)
<ul>
-<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">AppManager.MasterState$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.ExecutorBrief$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.ExecutorBrief$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTask$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.ChangeTasks$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTasks$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.LaunchTasks$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.LaunchTasks$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TaskLocationsRejected$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskLocationsRejected$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.ApplicationStatusChanged$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToWorker.LaunchExecutor$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToWorker.LaunchExecutor$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryHistoryMetrics$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryHistoryMetrics$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.ExecutorInfo$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManager.ExecutorInfo$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.ExecutorStarted$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManager.ExecutorStarted$</span></a> (implements scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster.MessageLoss$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.RegisterExecutor$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster.RegisterExecutor$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/JarScheduler.ScheduleTask$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">JarScheduler.ScheduleTask$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/Scheduler.PendingRequest$.html" title="class in org.apache.gearpump.cluster.scheduler"><span class="typeNameLink">Scheduler.PendingRequest$</span></a> (implements scala.Serializable)</li>
@@ -408,7 +415,7 @@
<li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/AkkaReporter.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">AkkaReporter</span></a> (implements org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/MetricsReporterService.ReportTo.html" title="interface in org.apache.gearpump.metrics">MetricsReporterService.ReportTo</a>)</li>
<li type="circle">org.apache.gearpump.streaming.monoid.<a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" title="class in org.apache.gearpump.streaming.monoid"><span class="typeNameLink">AlgebirdGroup</span></a><T> (implements org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/Group.html" title="interface in org.apache.gearpump.streaming.state.api">Group</a><T>)</li>
<li type="circle">org.apache.gearpump.streaming.monoid.<a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" title="class in org.apache.gearpump.streaming.monoid"><span class="typeNameLink">AlgebirdMonoid</span></a><T> (implements org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/Monoid.html" title="interface in org.apache.gearpump.streaming.state.api">Monoid</a><T>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">AndThen</span></a><IN,MIDDLE,OUT> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunction.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">SingleInputFunction</a><IN,OUT>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">AndThen</span></a><IN,MIDDLE,OUT> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppDescription</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.log4j.AppenderSkeleton (implements org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler)
<ul>
@@ -436,7 +443,22 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/TestUtil.DummyAppMaster.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">TestUtil.DummyAppMaster</span></a></li>
</ul>
</li>
-<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ApplicationState</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ApplicationMetaData</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ApplicationRuntimeInfo</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus</span></a> (implements java.io.Serializable)
+<ul>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.ACTIVE$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus.ACTIVE$</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.NONEXIST$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus.NONEXIST$</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.PENDING$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus.PENDING$</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationTerminalStatus</span></a>
+<ul>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.FAILED$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus.FAILED$</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.SUCCEEDED$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus.SUCCEEDED$</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatus.TERMINATED$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatus.TERMINATED$</span></a> (implements scala.Product, scala.Serializable)</li>
+</ul>
+</li>
+</ul>
+</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppManager.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">AppManager</span></a> (implements akka.actor.Actor, akka.actor.Stash, org.apache.gearpump.util.<a href="org/apache/gearpump/util/TimeOutScheduler.html" title="interface in org.apache.gearpump.util">TimeOutScheduler</a>)</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">AppManager.MasterState</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">AppManager.RecoverApplication</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -453,7 +475,6 @@
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.MasterWithExecutorSystemProvider$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppMasterRuntimeEnvironment.MasterWithExecutorSystemProvider$</span></a></li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.StartAppMaster$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppMasterRuntimeEnvironment.StartAppMaster$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</span></a> (implements scala.Product, scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppMasterRuntimeInfo</span></a> (implements org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterRegisterData.html" title="interface in org.apache.gearpump.cluster">AppMasterRegisterData</a>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMasterSpec.TaskStarted$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMasterSpec.TaskStarted$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor</span></a></li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.ChangeTask.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTask</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -474,8 +495,8 @@
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.TasksLaunched$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TasksLaunched$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster</span></a></li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToMaster.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToMaster</span></a></li>
-<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.ActivateAppMaster</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.AppDataSaved$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.AppDataSaved$</span></a> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.ApplicationStatusChanged</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.GeneralAppMasterSummary</span></a> (implements org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.AppMasterSummary.html" title="interface in org.apache.gearpump.cluster">AppMasterToMaster.AppMasterSummary</a>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GetAllWorkers$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.GetAllWorkers$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GetAppData.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.GetAppData</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -497,7 +518,6 @@
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/AppSubmitter.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">AppSubmitter</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.Syntax.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">ArgumentsParser.Syntax</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">BroadcastPartitioner</span></a> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/MulticastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">MulticastPartitioner</a>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/Bucket.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">Bucket</span></a> (implements java.lang.Comparable<T>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">ChainableOp</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/CheckpointClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">CheckpointClock</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.state.impl.<a href="org/apache/gearpump/streaming/state/impl/CheckpointManager.html" title="class in org.apache.gearpump.streaming.state.impl"><span class="typeNameLink">CheckpointManager</span></a></li>
@@ -524,6 +544,7 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryMasterConfig$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryMasterConfig$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.QueryWorkerConfig</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.ReadOption$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.ReadOption$</span></a></li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.RegisterAppResultListener</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RemoveMaster.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.RemoveMaster</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.RemoveWorker.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.RemoveWorker</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.ResolveAppId.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClientToMaster.ResolveAppId</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -549,7 +570,7 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClusterConfig.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClusterConfig</span></a></li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClusterConfig.Configs.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClusterConfig.Configs</span></a></li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClusterConfigSource.ClusterConfigSourceImpl.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ClusterConfigSource.ClusterConfigSourceImpl</span></a> (implements org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClusterConfigSource.html" title="interface in org.apache.gearpump.cluster">ClusterConfigSource</a>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.<a href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">CollectionDataSource</span></a><T> (implements org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">CollectionDataSource</span></a><T> (implements org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a>)</li>
<li type="circle">org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.streaming.partitioner"><span class="typeNameLink">CoLocationPartitioner</span></a> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">UnicastPartitioner</a>)</li>
<li type="circle">org.apache.gearpump.security.<a href="org/apache/gearpump/security/ConfigFileBasedAuthenticator.html" title="class in org.apache.gearpump.security"><span class="typeNameLink">ConfigFileBasedAuthenticator</span></a> (implements org.apache.gearpump.security.<a href="org/apache/gearpump/security/Authenticator.html" title="interface in org.apache.gearpump.security">Authenticator</a>)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ConfigsSpec.Data.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ConfigsSpec.Data</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -558,8 +579,7 @@
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Context.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Context</span></a> (implements org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/IContext.html" title="interface in org.apache.gearpump.transport.netty">IContext</a>)</li>
<li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Counter.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Counter</span></a></li>
<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountTrigger</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">Trigger</a>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountWindow</span></a></li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountWindowFn</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFn.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFn</a>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountWindows</span></a></li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/DAG.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">DAG</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager</span></a> (implements akka.actor.Actor, akka.actor.Stash)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.DagInitiated$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.DagInitiated$</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -583,8 +603,6 @@
<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.grouper.<a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/DefaultPartitionGrouper.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.grouper"><span class="typeNameLink">DefaultPartitionGrouper</span></a> (implements org.apache.gearpump.streaming.kafka.lib.source.grouper.<a href="org/apache/gearpump/streaming/kafka/lib/source/grouper/PartitionGrouper.html" title="interface in org.apache.gearpump.streaming.kafka.lib.source.grouper">PartitionGrouper</a>)</li>
<li type="circle">org.apache.gearpump.streaming.hadoop.lib.format.<a href="org/apache/gearpump/streaming/hadoop/lib/format/DefaultSequenceFormatter.html" title="class in org.apache.gearpump.streaming.hadoop.lib.format"><span class="typeNameLink">DefaultSequenceFormatter</span></a> (implements org.apache.gearpump.streaming.hadoop.lib.format.<a href="org/apache/gearpump/streaming/hadoop/lib/format/OutputFormatter.html" title="interface in org.apache.gearpump.streaming.hadoop.lib.format">OutputFormatter</a>)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">DefaultWindowRunner</span></a><IN,GROUP,OUT> (implements org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" title="interface in org.apache.gearpump.streaming.dsl.window.impl">WindowRunner</a>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">DefaultWindowRunner.WindowGroup</span></a><GROUP> (implements java.lang.Comparable<T>, scala.Product, scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup$.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">DefaultWindowRunner.WindowGroup$</span></a> (implements scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Direct.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">Direct</span></a> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/OpEdge.html" title="interface in org.apache.gearpump.streaming.dsl.plan">OpEdge</a>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Discarding.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">Discarding</span></a> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">AccumulationMode</a>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncher.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">DummyAppMasterLauncher</span></a> (implements akka.actor.Actor)</li>
@@ -592,7 +610,8 @@
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/Echo.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">Echo</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/EchoActor.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">EchoActor</span></a> (implements akka.actor.Actor)</li>
<li type="circle">org.apache.gearpump.cluster.embedded.<a href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html" title="class in org.apache.gearpump.cluster.embedded"><span class="typeNameLink">EmbeddedCluster</span></a></li>
-<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/EmitFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">EmitFunction</span></a><T> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunction.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">SingleInputFunction</a><IN,OUT>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">Emit</span></a><T> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>)</li>
+<li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/EndingClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">EndingClock</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">scala.Enumeration (implements scala.Serializable)
<ul>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/LogUtil.ProcessType$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">LogUtil.ProcessType$</span></a></li>
@@ -626,7 +645,6 @@
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.StartExecutorsTimeOut$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManager.StartExecutorsTimeOut$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.UniCast.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManager.UniCast</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ExecutorManagerSpec.StartExecutorActorPlease$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManagerSpec.StartExecutorActorPlease$</span></a> (implements scala.Product, scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in org.apache.gearpump.streaming.executor"><span class="typeNameLink">ExecutorRestartPolicy</span></a></li>
<li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/ExecutorSlots.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">ExecutorSlots</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystem</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemLauncher</span></a> (implements akka.actor.Actor)</li>
@@ -667,8 +685,13 @@
<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileServerSpec.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileServerSpec</span></a></li>
<li type="circle">org.apache.gearpump.streaming.hadoop.lib.rotation.<a href="org/apache/gearpump/streaming/hadoop/lib/rotation/FileSizeRotation.html" title="class in org.apache.gearpump.streaming.hadoop.lib.rotation"><span class="typeNameLink">FileSizeRotation</span></a> (implements scala.Product, org.apache.gearpump.streaming.hadoop.lib.rotation.<a href="org/apache/gearpump/streaming/hadoop/lib/rotation/Rotation.html" title="interface in org.apache.gearpump.streaming.hadoop.lib.rotation">Rotation</a>, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/FileUtils.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">FileUtils</span></a></li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/FixedWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">FixedWindow</span></a></li>
-<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">FlatMapFunction</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunction.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">SingleInputFunction</a><IN,OUT>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/FixedWindows.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">FixedWindows</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">FlatMapper</span></a><IN,OUT> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>)</li>
+<li type="circle">org.scalatest.FlatSpec
+<ul>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationStatusSpec.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationStatusSpec</span></a></li>
+</ul>
+</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppManagerSpec.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppManagerSpec</span></a> (implements org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterHarness.html" title="interface in org.apache.gearpump.cluster">MasterHarness</a>)</li>
@@ -701,6 +724,11 @@
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
+<li type="circle">org.apache.gearpump.cluster.client.<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.html" title="class in org.apache.gearpump.cluster.client"><span class="typeNameLink">RunningApplicationSpec</span></a></li>
+</ul>
+</li>
+<li type="circle">org.scalatest.FlatSpec
+<ul>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentParserSpec.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">ArgumentParserSpec</span></a></li>
</ul>
</li>
@@ -721,7 +749,7 @@
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/ApplicationStateSpec.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">ApplicationStateSpec</span></a></li>
+<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/ApplicationMetaDataSpec.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">ApplicationMetaDataSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
@@ -771,6 +799,11 @@
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
+<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/RestartPolicySpec.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">RestartPolicySpec</span></a></li>
+</ul>
+</li>
+<li type="circle">org.scalatest.FlatSpec
+<ul>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/UtilSpec.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">UtilSpec</span></a></li>
</ul>
</li>
@@ -801,22 +834,22 @@
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.dsl.<a href="org/apache/gearpump/streaming/dsl/StreamAppSpec.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">StreamAppSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitionerSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.dsl.<a href="org/apache/gearpump/streaming/dsl/StreamSpec.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">StreamSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitionerSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamAppSpec.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">StreamAppSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
<ul>
-<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamSpec.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">StreamSpec</span></a></li>
</ul>
</li>
<li type="circle">org.scalatest.FlatSpec
@@ -859,6 +892,7 @@
<li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/SubscriptionSpec.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">SubscriptionSpec</span></a></li>
</ul>
</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">FoldRunner</span></a><T,A> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/FunctionRunner.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">FunctionRunner</a><IN,OUT>)</li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/Gear.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">Gear</span></a></li>
<li type="circle">org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/GearpumpSerialization.html" title="class in org.apache.gearpump.serializer"><span class="typeNameLink">GearpumpSerialization</span></a></li>
<li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/GetCheckpointClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">GetCheckpointClock</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/ClockEvent.html" title="interface in org.apache.gearpump.streaming.task">ClockEvent</a>, scala.Product, scala.Serializable)</li>
@@ -880,9 +914,9 @@
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.Path$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">Graph.Path$</span></a></li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/GraphSpec.Edge.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">GraphSpec.Edge</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/GraphSpec.Vertex.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">GraphSpec.Vertex</span></a> (implements scala.Product, scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">GroupAlsoByWindow</span></a><T,GROUP> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/GroupByFn.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">GroupByFn</a><T,GROUP>, scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.window.impl.<a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl"><span class="typeNameLink">GroupAlsoByWindow</span></a><T,GROUP> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">GroupByOp</span></a><IN,GROUP> (implements org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Op.html" title="interface in org.apache.gearpump.streaming.dsl.plan">Op</a>, scala.Product, scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitioner</span></a><T,Group> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">UnicastPartitioner</a>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitioner.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitioner</span></a><T,GROUP> (implements org.apache.gearpump.streaming.partitioner.<a href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.streaming.partitioner">UnicastPartitioner</a>)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.partitioner.<a href="org/apache/gearpump/streaming/dsl/partitioner/GroupByPartitionerSpec.People.html" title="class in org.apache.gearpump.streaming.dsl.partitioner"><span class="typeNameLink">GroupByPartitionerSpec.People</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.hadoop.<a href="org/apache/gearpump/streaming/hadoop/HadoopCheckpointStore.html" title="class in org.apache.gearpump.streaming.hadoop"><span class="typeNameLink">HadoopCheckpointStore</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in org.apache.gearpump.streaming.transaction.api">CheckpointStore</a>)</li>
<li type="circle">org.apache.gearpump.streaming.hadoop.<a href="org/apache/gearpump/streaming/hadoop/HadoopCheckpointStoreFactory.html" title="class in org.apache.gearpump.streaming.hadoop"><span class="typeNameLink">HadoopCheckpointStoreFactory</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/CheckpointStoreFactory.html" title="interface in org.apache.gearpump.streaming.transaction.api">CheckpointStoreFactory</a>)</li>
@@ -950,7 +984,7 @@
<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.consumer.<a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer"><span class="typeNameLink">KafkaMessage</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.kafka.lib.store.<a href="org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html" title="class in org.apache.gearpump.streaming.kafka.lib.store"><span class="typeNameLink">KafkaStore</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/CheckpointStore.html" title="interface in org.apache.gearpump.streaming.transaction.api">CheckpointStore</a>)</li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/Kill.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">Kill</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.<a href="org/apache/gearpump/streaming/dsl/KVStream.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">KVStream</span></a><K,V></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/KVStream.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">KVStream</span></a><K,V></li>
<li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/LatencyProbe.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">LatencyProbe</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/LatencyProbeSerializer.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">LatencyProbeSerializer</span></a> (implements org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskMessageSerializer.html" title="interface in org.apache.gearpump.streaming.task">TaskMessageSerializer</a><T>)</li>
<li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/LatestMinClock.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">LatestMinClock</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -958,7 +992,7 @@
<li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/LifeTime.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">LifeTime</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/Local.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">Local</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li>
<li type="circle">org.apache.gearpump.jarstore.local.<a href="org/apache/gearpump/jarstore/local/LocalJarStore.html" title="class in org.apache.gearpump.jarstore.local"><span class="typeNameLink">LocalJarStore</span></a> (implements org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/JarStore.html" title="interface in org.apache.gearpump.jarstore">JarStore</a>)</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.<a href="org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl"><span class="typeNameLink">LoggerSink</span></a><T> (implements org.apache.gearpump.streaming.sink.<a href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a>)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.scalaapi.<a href="org/apache/gearpump/streaming/dsl/scalaapi/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi"><span class="typeNameLink">LoggerSink</span></a><T> (implements org.apache.gearpump.streaming.sink.<a href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a>)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/LogUtil.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">LogUtil</span></a></li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/MainRunner.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">MainRunner</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/Master.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">Master</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li>
@@ -969,7 +1003,6 @@
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/Master.SlotStatus.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">Master.SlotStatus</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/Master.WorkerTerminated.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">Master.WorkerTerminated</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/MasterActivity.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">MasterActivity</span></a> (implements scala.Product, scala.Serializable)</li>
-<li type="circle">org.apache.gearpump.cluster.client.<a href="org/apache/gearpump/cluster/client/MasterClient.html" title="class in org.apache.gearpump.cluster.client"><span class="typeNameLink">MasterClient</span></a></li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">MasterConnectionKeeper</span></a> (implements akka.actor.Actor)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.AppMasterRegisterTimeout$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">MasterConnectionKeeper.AppMasterRegisterTimeout$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeper.MasterConnectionStatus$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">MasterConnectionKeeper.MasterConnectionStatus$</span></a></li>
@@ -1000,6 +1033,8 @@
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.ShutdownAppMaster$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.ShutdownAppMaster$</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.WorkerList</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient</span></a></li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.ApplicationFailed</span></a> (implements org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationResult.html" title="interface in org.apache.gearpump.cluster">MasterToClient.ApplicationResult</a>, scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.ApplicationSucceeded</span></a> (implements org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationResult.html" title="interface in org.apache.gearpump.cluster">MasterToClient.ApplicationResult</a>, scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.AppMasterConfig.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.AppMasterConfig</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.HistoryMetrics.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.HistoryMetrics</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.HistoryMetricsItem.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.HistoryMetricsItem</span></a> (implements scala.Product, scala.Serializable)</li>
@@ -1051,6 +1086,12 @@
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyConfig.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">NettyConfig</span></a></li>
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyRenameThreadFactory.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">NettyRenameThreadFactory</span></a> (implements java.util.concurrent.ThreadFactory)</li>
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/NettyUtil.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">NettyUtil</span></a></li>
+<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">NonMergingWindowFunction</span></a><T> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFunction.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFunction</a><T>)
+<ul>
+<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">CountWindowFunction</span></a><T> (implements scala.Product, scala.Serializable)</li>
+<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">SlidingWindowFunction</span></a><T> (implements scala.Product, scala.Serializable)</li>
+</ul>
+</li>
<li type="circle">org.jboss.netty.handler.codec.oneone.OneToOneEncoder (implements org.jboss.netty.channel.ChannelDownstreamHandler)
<ul>
<li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/MessageEncoder.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">MessageEncoder</span></a></li>
@@ -1065,7 +1106,6 @@
<li type="circle">org.apache.gearpump.security.<a href="org/apache/gearpump/security/PasswordUtil.html" title="class in org.apache.gearpump.security"><span class="typeNameLink">PasswordUtil</span></a></li>
<li type="circle">org.apache.gearpump.streaming.state.impl.<a href="org/apache/gearpump/streaming/state/impl/PersistentStateConfig.html" title="class in org.apache.gearpump.streaming.state.impl"><span class="typeNameLink">PersistentStateConfig</span></a></li>
<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/Planner.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">Planner</span></a></li>
-<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnyGroupByFn.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec.AnyGroupByFn</span></a> (implements org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/GroupByFn.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">GroupByFn</a><T,GROUP>)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySink.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec.AnySink</span></a> (implements org.apache.gearpump.streaming.sink.<a href="org/apache/gearpump/streaming/sink/DataSink.html" title="interface in org.apache.gearpump.streaming.sink">DataSink</a>)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/PlannerSpec.AnySource.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">PlannerSpec.AnySource</span></a> (implements org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSource.html" title="interface in org.apache.gearpump.streaming.source">DataSource</a>)</li>
<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/ProcessingTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">ProcessingTimeTrigger</span></a> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">Trigger</a>)</li>
@@ -1109,6 +1149,11 @@
</li>
<li type="circle">org.scalatest.PropSpec
<ul>
+<li type="circle">org.apache.gearpump.streaming.dsl.task.<a href="org/apache/gearpump/streaming/dsl/task/TransformTaskSpec.html" title="class in org.apache.gearpump.streaming.dsl.task"><span class="typeNameLink">TransformTaskSpec</span></a></li>
+</ul>
+</li>
+<li type="circle">org.scalatest.PropSpec
+<ul>
<li type="circle">org.apache.gearpump.streaming.sink.<a href="org/apache/gearpump/streaming/sink/DataSinkTaskSpec.html" title="class in org.apache.gearpump.streaming.sink"><span class="typeNameLink">DataSinkTaskSpec</span></a></li>
</ul>
</li>
@@ -1142,13 +1187,15 @@
<li type="circle">org.apache.gearpump.streaming.state.impl.<a href="org/apache/gearpump/streaming/state/impl/WindowStateSpec.html" title="class in org.apache.gearpump.streaming.state.impl"><span class="typeNameLink">WindowStateSpec</span></a></li>
</ul>
</li>
-<li type="circle">org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions"><span class="typeNameLink">ReduceFunction</span></a><T> (implements org.apache.gearpump.streaming.dsl.plan.functions.<a href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunction.html" title="interface in org.apache.gearpump.streaming.dsl.plan.functions">SingleInputFunction</a><IN,OUT>)</li>
<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/Replay.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">Replay</span></a> (implements org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a>, org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/ArgumentsParser.html" title="interface in org.apache.gearpump.cluster.main">ArgumentsParser</a>)</li>
<li type="circle">org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler"><span class="typeNameLink">Resource</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/ResourceAllocation.html" title="class in org.apache.gearpump.cluster.scheduler"><span class="typeNameLink">ResourceAllocation</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/ResourceRequest.html" title="class in org.apache.gearpump.cluster.scheduler"><span class="typeNameLink">ResourceRequest</span></a> (implements scala.Product, scala.Serializable)</li>
<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/RestartPolicy.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">RestartPolicy</span></a></li>
<li type="circle">
<TRUNCATED>