http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/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 0911270..5a0f92d 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 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>Class Hierarchy</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> @@ -76,6 +76,7 @@ <li><a href="org/apache/gearpump/cluster/package-tree.html">org.apache.gearpump.cluster</a>, </li> <li><a href="org/apache/gearpump/cluster/appmaster/package-tree.html">org.apache.gearpump.cluster.appmaster</a>, </li> <li><a href="org/apache/gearpump/cluster/client/package-tree.html">org.apache.gearpump.cluster.client</a>, </li> +<li><a href="org/apache/gearpump/cluster/embedded/package-tree.html">org.apache.gearpump.cluster.embedded</a>, </li> <li><a href="org/apache/gearpump/cluster/main/package-tree.html">org.apache.gearpump.cluster.main</a>, </li> <li><a href="org/apache/gearpump/cluster/master/package-tree.html">org.apache.gearpump.cluster.master</a>, </li> <li><a href="org/apache/gearpump/cluster/scheduler/package-tree.html">org.apache.gearpump.cluster.scheduler</a>, </li> @@ -83,17 +84,20 @@ <li><a href="org/apache/gearpump/external/hbase/package-tree.html">org.apache.gearpump.external.hbase</a>, </li> <li><a href="org/apache/gearpump/external/hbase/dsl/package-tree.html">org.apache.gearpump.external.hbase.dsl</a>, </li> <li><a href="org/apache/gearpump/jarstore/package-tree.html">org.apache.gearpump.jarstore</a>, </li> +<li><a href="org/apache/gearpump/jarstore/local/package-tree.html">org.apache.gearpump.jarstore.local</a>, </li> <li><a href="org/apache/gearpump/metrics/package-tree.html">org.apache.gearpump.metrics</a>, </li> -<li><a href="org/apache/gearpump/partitioner/package-tree.html">org.apache.gearpump.partitioner</a>, </li> <li><a href="org/apache/gearpump/security/package-tree.html">org.apache.gearpump.security</a>, </li> <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/javaapi/package-tree.html">org.apache.gearpump.streaming.dsl.javaapi</a>, </li> -<li><a href="org/apache/gearpump/streaming/dsl/op/package-tree.html">org.apache.gearpump.streaming.dsl.op</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/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> <li><a href="org/apache/gearpump/streaming/executor/package-tree.html">org.apache.gearpump.streaming.executor</a>, </li> <li><a href="org/apache/gearpump/streaming/hadoop/package-tree.html">org.apache.gearpump.streaming.hadoop</a>, </li> <li><a href="org/apache/gearpump/streaming/hadoop/lib/package-tree.html">org.apache.gearpump.streaming.hadoop.lib</a>, </li> @@ -103,6 +107,7 @@ <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> <li><a href="org/apache/gearpump/streaming/kafka/lib/sink/package-tree.html">org.apache.gearpump.streaming.kafka.lib.sink</a>, </li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/package-tree.html">org.apache.gearpump.streaming.kafka.lib.source</a>, </li> <li><a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/package-tree.html">org.apache.gearpump.streaming.kafka.lib.source.consumer</a>, </li> @@ -112,7 +117,7 @@ <li><a href="org/apache/gearpump/streaming/kafka/util/package-tree.html">org.apache.gearpump.streaming.kafka.util</a>, </li> <li><a href="org/apache/gearpump/streaming/metrics/package-tree.html">org.apache.gearpump.streaming.metrics</a>, </li> <li><a href="org/apache/gearpump/streaming/monoid/package-tree.html">org.apache.gearpump.streaming.monoid</a>, </li> -<li><a href="org/apache/gearpump/streaming/serializer/package-tree.html">org.apache.gearpump.streaming.serializer</a>, </li> +<li><a href="org/apache/gearpump/streaming/partitioner/package-tree.html">org.apache.gearpump.streaming.partitioner</a>, </li> <li><a href="org/apache/gearpump/streaming/sink/package-tree.html">org.apache.gearpump.streaming.sink</a>, </li> <li><a href="org/apache/gearpump/streaming/source/package-tree.html">org.apache.gearpump.streaming.source</a>, </li> <li><a href="org/apache/gearpump/streaming/state/api/package-tree.html">org.apache.gearpump.streaming.state.api</a>, </li> @@ -142,6 +147,7 @@ <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.BindLifeCycle$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.BindLifeCycle$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystem$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystem$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystemFailed$</span></a> (implements 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.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.LookupTaskActorRef$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.TaskActorRef$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AppMasterToExecutor.StartAllTasks$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartAllTasks$</span></a> (implements scala.Serializable)</li> @@ -175,6 +181,7 @@ <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.ChangeToNewDAGSuccess$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.ChangeToNewDAGSuccess$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.Report$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.Report$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.StoredStartClock$</span></a> (implements scala.Serializable)</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.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.DAGOperationFailed$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.DAGOperationFailed$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.LatestDAG$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.LatestDAG$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.NewDAGDeployed$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.NewDAGDeployed$</span></a> (implements scala.Serializable)</li> @@ -191,7 +198,14 @@ <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemLauncher.LaunchExecutorSystemTimeout$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemLauncher.LaunchExecutorSystemTimeout$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.ResourceAllocationTimeOut$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.ResourceAllocationTimeOut$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StopExecutorSystem$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.StopExecutorSystem$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileServer.Port$.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileServer.Port$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.DeleteKVGroup$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.DeleteKVGroup$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVFailed$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.GetKVFailed$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GroupDeleted$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.GroupDeleted$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/JarScheduler.ExecutorFailed$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">JarScheduler.ExecutorFailed$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/Master.MasterListUpdated$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">Master.MasterListUpdated$</span></a> (implements 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.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/MasterProxy.WatchMaster$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">MasterProxy.WatchMaster$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterActivated$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.AppMasterActivated$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterDataDetailRequest$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToAppMaster.AppMasterDataDetailRequest$</span></a> (implements scala.Serializable)</li> @@ -211,6 +225,8 @@ <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToClient.SubmitApplicationResultValue$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToClient.SubmitApplicationResultValue$</span></a> (implements scala.Serializable)</li> <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.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> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.MsgBatch$.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Server.MsgBatch$</span></a> (implements scala.Serializable)</li> @@ -218,6 +234,8 @@ <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskManager.FailedToRecover$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskManager.FailedToRecover$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskManager.TaskList$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskManager.TaskList$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskRegistry.TaskLocations$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskRegistry.TaskLocations$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/Worker.ExecutorResult$.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">Worker.ExecutorResult$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/WorkerToMaster.RegisterWorker$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">WorkerToMaster.RegisterWorker$</span></a> (implements scala.Serializable)</li> </ul> </li> <li type="circle">scala.runtime.AbstractFunction18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,R> (implements scala.Function18<T1,T2,T3,T4,T5,T6,T7,T8,T9,T10,T11,T12,T13,T14,T15,T16,T17,T18,R>) @@ -247,12 +265,20 @@ <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.Session$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.Session$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StartExecutorSystems$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.StartExecutorSystems$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.UnRegisterTask$.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster.UnRegisterTask$</span></a> (implements scala.Serializable)</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.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKV$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.GetKV$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.GetKVSuccess$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.GetKVSuccess$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.PutKVFailed$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.PutKVFailed$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/InMemoryKVService.Request$.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">InMemoryKVService.Request$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/JarScheduler.NewDag$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">JarScheduler.NewDag$</span></a> (implements scala.Serializable)</li> <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.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> +<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToWorker.UpdateResourceFailed$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToWorker.UpdateResourceFailed$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToWorker.WorkerRegistered$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">MasterToWorker.WorkerRegistered$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.Counter$.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Metrics.Counter$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.Gauge$.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Metrics.Gauge$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskActor.MessageAndSender$.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">TaskActor.MessageAndSender$</span></a> (implements scala.Serializable)</li> @@ -270,6 +296,7 @@ </li> <li type="circle">scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>) <ul> +<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.SaveAppData$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">AppMasterToMaster.SaveAppData$</span></a> (implements scala.Serializable)</li> @@ -284,13 +311,20 @@ <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> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.ConnectionKeeperTestEnv$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">MasterConnectionKeeperSpec.ConnectionKeeperTestEnv$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/TaskLauncher.TaskArgument$.html" title="class in org.apache.gearpump.streaming.executor"><span class="typeNameLink">TaskLauncher.TaskArgument$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskManager.DAGDiff$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskManager.DAGDiff$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/Worker.ProcessInfo$.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">Worker.ProcessInfo$</span></a> (implements scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/WorkerToMaster.ResourceUpdate$.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">WorkerToMaster.ResourceUpdate$</span></a> (implements scala.Serializable)</li> </ul> </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> @@ -301,6 +335,7 @@ <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.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> </ul> </li> <li type="circle">scala.runtime.AbstractFunction5<T1,T2,T3,T4,T5,R> (implements scala.Function5<T1,T2,T3,T4,T5,R>) @@ -309,6 +344,11 @@ <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.Meter$.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Metrics.Meter$</span></a> (implements scala.Serializable)</li> </ul> </li> +<li type="circle">scala.runtime.AbstractFunction6<T1,T2,T3,T4,T5,T6,R> (implements scala.Function6<T1,T2,T3,T4,T5,T6,R>) +<ul> +<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskManagerSpec.Env$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">TaskManagerSpec.Env$</span></a> (implements scala.Serializable)</li> +</ul> +</li> <li type="circle">scala.runtime.AbstractFunction7<T1,T2,T3,T4,T5,T6,T7,R> (implements scala.Function7<T1,T2,T3,T4,T5,T6,T7,R>) <ul> <li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/Metrics.Histogram$.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">Metrics.Histogram$</span></a> (implements scala.Serializable)</li> @@ -339,6 +379,7 @@ <li type="circle">org.apache.gearpump.streaming.kafka.<a href="org/apache/gearpump/streaming/kafka/KafkaStoreFactory.html" title="class in org.apache.gearpump.streaming.kafka"><span class="typeNameLink">KafkaStoreFactory</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> </ul> </li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/Accumulating.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">Accumulating</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.streaming.task.<a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">Ack</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/AckRequest.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">AckRequest</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AckRequestSerializer.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AckRequestSerializer</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> @@ -350,15 +391,24 @@ <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.BindLifeCycle.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.BindLifeCycle</span></a> (implements scala.Product, 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.Product, 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.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.Daemon.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.Daemon</span></a> (implements akka.actor.Actor)</li> +<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.Daemon.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.Daemon</span></a> (implements akka.actor.Actor) +<ul> +<li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/Worker.InJvmExecutor.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">Worker.InJvmExecutor</span></a></li> +</ul> +</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystem.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystem</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystemFailed</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemTimeOut$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystemTimeOut$</span></a></li> +<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooterSpec.AcceptThreeArguments.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooterSpec.AcceptThreeArguments</span></a> (implements akka.actor.Actor)</li> +<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooterSpec.AcceptZeroArguments.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooterSpec.AcceptZeroArguments</span></a> (implements akka.actor.Actor)</li> +<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.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooterSpec.Dummy.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooterSpec.Dummy</span></a> (implements akka.actor.Actor)</li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorUtil.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorUtil</span></a></li> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaHelper.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">AkkaHelper</span></a></li> <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.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> @@ -383,9 +433,13 @@ <li type="circle">org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ApplicationMaster.html" title="class in org.apache.gearpump.cluster"><span class="typeNameLink">ApplicationMaster</span></a> (implements akka.actor.Actor) <ul> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster</span></a></li> +<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.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> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.AllocateResourceTimeOut$</span></a> (implements scala.Product, 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.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.LookupTaskActorRef</span></a> (implements scala.Product, scala.Serializable)</li> @@ -398,7 +452,9 @@ <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> (implements akka.actor.Actor)</li> <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> <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.Product, scala.Serializable)</li> @@ -438,12 +494,14 @@ <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.Product, 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.Product, 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.Product, scala.Serializable)</li> +<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.partitioner.<a href="org/apache/gearpump/partitioner/BroadcastPartitioner.html" title="class in org.apache.gearpump.partitioner"><span class="typeNameLink">BroadcastPartitioner</span></a> (implements org.apache.gearpump.partitioner.<a href="org/apache/gearpump/partitioner/MulticastPartitioner.html" title="interface in org.apache.gearpump.partitioner">MulticastPartitioner</a>)</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> <li type="circle">org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/CheckProcessorDeath.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">CheckProcessorDeath</span></a> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.serializer.<a href="org/apache/gearpump/streaming/serializer/ChillSerializer.html" title="class in org.apache.gearpump.streaming.serializer"><span class="typeNameLink">ChillSerializer</span></a><T> (implements org.apache.gearpump.streaming.state.api.<a href="org/apache/gearpump/streaming/state/api/Serializer.html" title="interface in org.apache.gearpump.streaming.state.api">Serializer</a><T>)</li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Client.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Client</span></a> (implements akka.actor.Actor)</li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Client.ChannelFutureOps.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Client.ChannelFutureOps</span></a></li> <li type="circle">org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Client.ChannelReady.html" title="class in org.apache.gearpump.transport.netty"><span class="typeNameLink">Client.ChannelReady</span></a> (implements scala.Product, scala.Serializable)</li> @@ -487,16 +545,21 @@ <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.Report.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.Report</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.SnapshotStartClock$.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.SnapshotStartClock$</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockService.StoredStartClock</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ClockServiceSpec.Store.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ClockServiceSpec.Store</span></a> (implements org.apache.gearpump.streaming.storage.<a href="org/apache/gearpump/streaming/storage/AppDataStore.html" title="interface in org.apache.gearpump.streaming.storage">AppDataStore</a>)</li> <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.partitioner.<a href="org/apache/gearpump/partitioner/CoLocationPartitioner.html" title="class in org.apache.gearpump.partitioner"><span class="typeNameLink">CoLocationPartitioner</span></a> (implements org.apache.gearpump.partitioner.<a href="org/apache/gearpump/partitioner/UnicastPartitioner.html" title="interface in org.apache.gearpump.partitioner">UnicastPartitioner</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> <li type="circle">org.apache.gearpump.util.<a href="org/apache/gearpump/util/Constants.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">Constants</span></a></li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/Constants.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">Constants</span></a></li> <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.<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> @@ -509,16 +572,27 @@ <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.ReplaceProcessor.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.ReplaceProcessor</span></a> (implements org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.DAGOperation.html" title="interface in org.apache.gearpump.streaming.appmaster">DagManager.DAGOperation</a>, scala.Product, scala.Serializable)</li> <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.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManager.WatchChange.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManager.WatchChange</span></a> (implements scala.Product, scala.Serializable)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.op"><span class="typeNameLink">DataSinkOp</span></a><T> (implements org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/ParameterizedOp.html" title="interface in org.apache.gearpump.streaming.dsl.op">ParameterizedOp</a><T>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/DagManagerSpec.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">DagManagerSpec</span></a></li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">DataSinkOp</span></a> (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.sink.<a href="org/apache/gearpump/streaming/sink/DataSinkProcessor.html" title="class in org.apache.gearpump.streaming.sink"><span class="typeNameLink">DataSinkProcessor</span></a></li> <li type="circle">org.apache.gearpump.streaming.source.<a href="org/apache/gearpump/streaming/source/DataSourceConfig.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceConfig</span></a></li> -<li type="circle">org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.op"><span class="typeNameLink">DataSourceOp</span></a><T> (implements org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/ParameterizedOp.html" title="interface in org.apache.gearpump.streaming.dsl.op">ParameterizedOp</a><T>, scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.streaming.dsl.plan.<a href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" title="class in org.apache.gearpump.streaming.dsl.plan"><span class="typeNameLink">DataSourceOp</span></a> (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.source.<a href="org/apache/gearpump/streaming/source/DataSourceProcessor.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DataSourceProcessor</span></a></li> -<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">DefaultMessageDecoder</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/MessageDecoder.html" title="interface in org.apache.gearpump.streaming.transaction.api">MessageDecoder</a>)</li> +<li type="circle">org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/DefaultExecutorProcessLauncher.html" title="class in org.apache.gearpump.cluster.worker"><span class="typeNameLink">DefaultExecutorProcessLauncher</span></a> (implements org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/ExecutorProcessLauncher.html" title="interface in org.apache.gearpump.cluster.worker">ExecutorProcessLauncher</a>)</li> +<li type="circle">org.apache.gearpump.streaming.kafka.lib.source.<a href="org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">DefaultKafkaMessageDecoder</span></a> (implements org.apache.gearpump.streaming.kafka.lib.<a href="org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html" title="interface in org.apache.gearpump.streaming.kafka.lib">KafkaMessageDecoder</a>)</li> <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.source.<a href="org/apache/gearpump/streaming/source/DefaultTimeStampFilter.html" title="class in org.apache.gearpump.streaming.source"><span class="typeNameLink">DefaultTimeStampFilter</span></a> (implements org.apache.gearpump.streaming.transaction.api.<a href="org/apache/gearpump/streaming/transaction/api/TimeStampFilter.html" title="interface in org.apache.gearpump.streaming.transaction.api">TimeStampFilter</a>)</li> -<li type="circle">org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/Direct.html" title="class in org.apache.gearpump.streaming.dsl.op"><span class="typeNameLink">Direct</span></a> (implements org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/OpEdge.html" title="interface in org.apache.gearpump.streaming.dsl.op">OpEdge</a>, 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.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> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/DummyAppMasterLauncherFactory.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">DummyAppMasterLauncherFactory</span></a> (implements org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppMasterLauncherFactory.html" title="interface in org.apache.gearpump.cluster.master">AppMasterLauncherFactory</a>)</li> +<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">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> @@ -526,6 +600,7 @@ <li type="circle">org.apache.gearpump.cluster.scheduler.<a href="org/apache/gearpump/cluster/scheduler/Relaxation.html" title="class in org.apache.gearpump.cluster.scheduler"><span class="typeNameLink">Relaxation</span></a></li> </ul> </li> +<li type="circle">org.apache.gearpump.streaming.dsl.window.api.<a href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger.html" title="class in org.apache.gearpump.streaming.dsl.window.api"><span class="typeNameLink">EventTimeTrigger</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.executor.<a href="org/apache/gearpump/streaming/executor/Executor.html" title="class in org.apache.gearpump.streaming.executor"><span class="typeNameLink">Executor</span></a> (implements akka.actor.Actor, 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.streaming.executor.<a href="org/apache/gearpump/streaming/executor/Executor.ExecutorConfig.html" title="class in org.apache.gearpump.streaming.executor"><span class="typeNameLink">Executor.ExecutorConfig</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/Executor.ExecutorSummary.html" title="class in org.apache.gearpump.streaming.executor"><span class="typeNameLink">Executor.ExecutorSummary</span></a> (implements scala.Product, scala.Serializable)</li> @@ -550,6 +625,7 @@ <li type="circle">org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/ExecutorManager.StartExecutors.html" title="class in org.apache.gearpump.streaming.appmaster"><span class="typeNameLink">ExecutorManager.StartExecutors</span></a> (implements scala.Product, scala.Serializable)</li> <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> @@ -568,6 +644,8 @@ <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StartExecutorSystems.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.StartExecutorSystems</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StartExecutorSystemTimeout$.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.StartExecutorSystemTimeout$</span></a> (implements scala.Product, scala.Serializable)</li> <li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.StopExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemScheduler.StopExecutorSystem</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemSchedulerSpec.ExecutorSystemLauncherStarted</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemSchedulerSpec.MockExecutorSystemLauncher.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemSchedulerSpec.MockExecutorSystemLauncher</span></a> (implements akka.actor.Actor)</li> <li type="circle">org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">ExecutorToAppMaster</span></a></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.Product, 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.Product, scala.Serializable)</li> @@ -579,10 +657,209 @@ <li type="circle">org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/FastKryoSerializer.html" title="class in org.apache.gearpump.serializer"><span class="typeNameLink">FastKryoSerializer</span></a> (implements org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/Serializer.html" title="interface in org.apache.gearpump.serializer">Serializer</a>)</li> <li type="circle">org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/FastKryoSerializer.KryoSerializationException$.html" title="class in org.apache.gearpump.serializer"><span class="typeNameLink">FastKryoSerializer.KryoSerializationException$</span></a> (implements scala.Serializable)</li> <li type="circle">org.apache.gearpump.streaming.kafka.lib.source.consumer.<a href="org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread.FetchThreadFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.source.consumer"><span class="typeNameLink">FetchThread.FetchThreadFactory</span></a> (implements java.io.Serializable)</li> +<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileDirective.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileDirective</span></a></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.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileDirective.Form.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileDirective.Form</span></a></li> <li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FilePath.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FilePath</span></a> (implements scala.Product, scala.Serializable)</li> +<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileServer.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileServer</span></a></li> +<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileServer.Client.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileServer.Client</span></a></li> +<li type="circle">org.apache.gearpump.jarstore.<a href="org/apache/gearpump/jarstore/FileServer.Port.html" title="class in org.apache.gearpump.jarstore"><span class="typeNameLink">FileServer.Port</span></a> (implements scala.Product, scala.Serializable)</li> +<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.op.<a href="org/apache/gearpump/streaming/dsl/op/FlatMapOp.html" title="class in org.apache.gearpump.streaming.dsl.op"><span class="typeNameLink">FlatMapOp</span></a><T,R> (implements scala.Product, scala.Serializable, org.apache.gearpump.streaming.dsl.op.<a href="org/apache/gearpump/streaming/dsl/op/SlaveOp.html" title="interface in org.apache.gearpump.streaming.dsl.op">SlaveOp</a><T>)</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.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> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">AppMasterRuntimeEnvironmentSpec</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/ExecutorSystemLauncherSpec.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemLauncherSpec</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/ExecutorSystemSchedulerSpec.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">ExecutorSystemSchedulerSpec</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/InMemoryKVServiceSpec.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">InMemoryKVServiceSpec</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> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/MasterConnectionKeeperSpec.html" title="class in org.apache.gearpump.cluster.appmaster"><span class="typeNameLink">MasterConnectionKeeperSpec</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> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/MainSpec.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">MainSpec</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> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.cluster.main.<a href="org/apache/gearpump/cluster/main/MasterWatcherSpec.html" title="class in org.apache.gearpump.cluster.main"><span class="typeNameLink">MasterWatcherSpec</span></a></li> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/AppMasterLauncherSpec.html" title="class in org.apache.gearpump.cluster.master"><span class="typeNameLink">AppMasterLauncherSpec</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> +</ul> +</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> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/MetricsSpec.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">MetricsSpec</span></a></li> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.security.<a href="org/apache/gearpump/security/ConfigFileBasedAuthenticatorSpec.html" title="class in org.apache.gearpump.security"><span class="typeNameLink">ConfigFileBasedAuthenticatorSpec</span></a></li> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.security.<a href="org/apache/gearpump/security/PasswordUtilSpec.html" title="class in org.apache.gearpump.security"><span class="typeNameLink">PasswordUtilSpec</span></a></li> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.serializer.<a href="org/apache/gearpump/serializer/SerializerSpec.html" title="class in org.apache.gearpump.serializer"><span class="typeNameLink">SerializerSpec</span></a></li> +</ul> +</li> +<li type="circle">org.scalatest.FlatSpec +<ul> +<li type="circle">org.apache.gearpump.transport.<a href="org/apache/gearpump/transport/NettySpec.html" title="class in org.apache.gearpump.transport"><span class="typeNameLink">NettySpec</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/ActorSystemBooterSpec.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooterSpec</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/ActorUtilSpec.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorUtilSpec</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/ConfigsSpec.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ConfigsSpec</span></a></
<TRUNCATED>
