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 2016/08/15 01:26:26 UTC
[47/51] [partial] incubator-gearpump-site git commit: update content
folder for 0.8.1
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/c330442c/content/releases/latest/api/java/index-all.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/java/index-all.html b/content/releases/latest/api/java/index-all.html
index 0fcab56..1d770a3 100644
--- a/content/releases/latest/api/java/index-all.html
+++ b/content/releases/latest/api/java/index-all.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (1.8.0_40) on Mon Apr 04 23:10:28 CST 2016 -->
+<!-- Generated by javadoc (1.8.0_25) on Thu Aug 11 09:54:18 PDT 2016 -->
<title>Index</title>
-<meta name="date" content="2016-04-04">
+<meta name="date" content="2016-08-11">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
<script type="text/javascript" src="script.js"></script>
</head>
@@ -73,4231 +73,8252 @@
</a>
<h2 class="title">A</h2>
<dl>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/TaskRegistry.Accept$.html#Accept:D--">Accept$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/TaskRegistry.Accept$.html" title="class in io.gearpump.streaming.appmaster">TaskRegistry.Accept$</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/TaskFilterAggregator.Options$.html#acceptAll--">acceptAll()</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/TaskFilterAggregator.Options$.html" title="class in io.gearpump.streaming.metrics">TaskFilterAggregator.Options$</a></dt>
-<dd> </dd>
-<dt><a href="io/gearpump/streaming/task/Ack.html" title="class in io.gearpump.streaming.task"><span class="typeNameLink">Ack</span></a> - Class in <a href="io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/Ack.html#Ack-io.gearpump.streaming.task.TaskId-short-short-int-">Ack(TaskId, short, short, int)</a></span> - Constructor for class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/Ack.html" title="class in io.gearpump.streaming.task">Ack</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskActor.SendAck.html#ack--">ack()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskActor.SendAck.html" title="class in io.gearpump.streaming.task">TaskActor.SendAck</a></dt>
+<dt><a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html" title="class in org.apache.gearpump.streaming.kafka.lib.sink"><span class="typeNameLink">AbstractKafkaSink</span></a> - Class in <a href="org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html">org.apache.gearpump.streaming.kafka.lib.sink</a></dt>
+<dd>
+<div class="block">kafka sink connectors that invokes {{org.apache.kafka.clients.producer.KafkaProducer}} to send
+ messages to kafka queue</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html#AbstractKafkaSink-java.lang.String-java.util.Properties-org.apache.gearpump.streaming.kafka.util.KafkaConfig.KafkaConfigFactory-org.apache.gearpump.streaming.kafka.lib.sink.AbstractKafkaSink.KafkaProducerFactory-">AbstractKafkaSink(String, Properties, KafkaConfig.KafkaConfigFactory, AbstractKafkaSink.KafkaProducerFactory)</a></span> - Constructor for class org.apache.gearpump.streaming.kafka.lib.sink.<a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html" title="class in org.apache.gearpump.streaming.kafka.lib.sink">AbstractKafkaSink</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/task/Ack$.html" title="class in io.gearpump.streaming.task"><span class="typeNameLink">Ack$</span></a> - Class in <a href="io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html#AbstractKafkaSink-java.lang.String-java.util.Properties-">AbstractKafkaSink(String, Properties)</a></span> - Constructor for class org.apache.gearpump.streaming.kafka.lib.sink.<a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html" title="class in org.apache.gearpump.streaming.kafka.lib.sink">AbstractKafkaSink</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/Ack$.html#Ack:D--">Ack$()</a></span> - Constructor for class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/Ack$.html" title="class in io.gearpump.streaming.task">Ack$</a></dt>
+<dt><a href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.KafkaProducerFactory.html" title="interface in org.apache.gearpump.streaming.kafka.lib.sink"><span class="typeNameLink">AbstractKafkaSink.KafkaProducerFactory</span></a> - Interface in <a href="org/apache/gearpump/streaming/kafka/lib/sink/package-summary.html">org.apache.gearpump.streaming.kafka.lib.sink</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/task/AckRequest.html" title="class in io.gearpump.streaming.task"><span class="typeNameLink">AckRequest</span></a> - Class in <a href="io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt>
+<dt><a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source"><span class="typeNameLink">AbstractKafkaSource</span></a> - Class in <a href="org/apache/gearpump/streaming/kafka/lib/source/package-summary.html">org.apache.gearpump.streaming.kafka.lib.source</a></dt>
+<dd>
+<div class="block">Contains implementation for Kafka source connectors, users should use
+ <a href="org/apache/gearpump/streaming/kafka/KafkaSource.html" title="class in org.apache.gearpump.streaming.kafka"><code>KafkaSource</code></a>.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#AbstractKafkaSource-java.lang.String-java.util.Properties-org.apache.gearpump.streaming.kafka.util.KafkaConfig.KafkaConfigFactory-org.apache.gearpump.streaming.kafka.lib.util.KafkaClient.KafkaClientFactory-org.apache.gearpump.streaming.kafka.lib.source.consumer.FetchThread.FetchThreadFactory-">AbstractKafkaSource(String, Properties, KafkaConfig.KafkaConfigFactory, KafkaClient.KafkaClientFactory, FetchThread.FetchThreadFactory)</a></span> - Constructor for class org.apache.gearpump.streaming.kafka.lib.source.<a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">AbstractKafkaSource</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/AckRequest.html#AckRequest-io.gearpump.streaming.task.TaskId-short-int-">AckRequest(TaskId, short, int)</a></span> - Constructor for class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/AckRequest.html" title="class in io.gearpump.streaming.task">AckRequest</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#AbstractKafkaSource-java.lang.String-java.util.Properties-">AbstractKafkaSource(String, Properties)</a></span> - Constructor for class org.apache.gearpump.streaming.kafka.lib.source.<a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">AbstractKafkaSource</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/task/AckRequest$.html" title="class in io.gearpump.streaming.task"><span class="typeNameLink">AckRequest$</span></a> - Class in <a href="io/gearpump/streaming/task/package-summary.html">io.gearpump.streaming.task</a></dt>
+<dt><a href="org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.store"><span class="typeNameLink">AbstractKafkaStoreFactory</span></a> - Class in <a href="org/apache/gearpump/streaming/kafka/lib/store/package-summary.html">org.apache.gearpump.streaming.kafka.lib.store</a></dt>
+<dd>
+<div class="block">Factory class that constructs a KafkaStore</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html#AbstractKafkaStoreFactory-java.util.Properties-org.apache.gearpump.streaming.kafka.util.KafkaConfig.KafkaConfigFactory-">AbstractKafkaStoreFactory(Properties, KafkaConfig.KafkaConfigFactory)</a></span> - Constructor for class org.apache.gearpump.streaming.kafka.lib.store.<a href="org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.store">AbstractKafkaStoreFactory</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/AckRequest$.html#AckRequest:D--">AckRequest$()</a></span> - Constructor for class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/AckRequest$.html" title="class in io.gearpump.streaming.task">AckRequest$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html#AbstractKafkaStoreFactory-java.util.Properties-">AbstractKafkaStoreFactory(Properties)</a></span> - Constructor for class org.apache.gearpump.streaming.kafka.lib.store.<a href="org/apache/gearpump/streaming/kafka/lib/store/AbstractKafkaStoreFactory.html" title="class in org.apache.gearpump.streaming.kafka.lib.store">AbstractKafkaStoreFactory</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AckRequestSerializer.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AckRequestSerializer</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/TaskRegistry.Accept$.html#Accept:D--">Accept$()</a></span> - Constructor for class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskRegistry.Accept$.html" title="class in org.apache.gearpump.streaming.appmaster">TaskRegistry.Accept$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/AckRequestSerializer.html#AckRequestSerializer--">AckRequestSerializer()</a></span> - Constructor for class io.gearpump.streaming.<a href="io/gearpump/streaming/AckRequestSerializer.html" title="class in io.gearpump.streaming">AckRequestSerializer</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.Options$.html#acceptAll--">acceptAll()</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.Options$.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregator.Options$</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AckSerializer.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AckSerializer</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">Ack</span></a> - Class in <a href="org/apache/gearpump/streaming/task/package-summary.html">org.apache.gearpump.streaming.task</a></dt>
+<dd>
+<div class="block">Ack back to sender task actor.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/Ack.html#Ack-org.apache.gearpump.streaming.task.TaskId-short-short-int-">Ack(TaskId, short, short, int)</a></span> - Constructor for class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task">Ack</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/AckSerializer.html#AckSerializer--">AckSerializer()</a></span> - Constructor for class io.gearpump.streaming.<a href="io/gearpump/streaming/AckSerializer.html" title="class in io.gearpump.streaming">AckSerializer</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/TaskActor.SendAck.html#ack--">ack()</a></span> - Method in class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskActor.SendAck.html" title="class in org.apache.gearpump.streaming.task">TaskActor.SendAck</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/Executor.State$.html#ACTIVE--">ACTIVE()</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/Executor.State$.html" title="class in io.gearpump.streaming.executor">Executor.State$</a></dt>
+<dt><a href="org/apache/gearpump/streaming/task/AckRequest.html" title="class in org.apache.gearpump.streaming.task"><span class="typeNameLink">AckRequest</span></a> - Class in <a href="org/apache/gearpump/streaming/task/package-summary.html">org.apache.gearpump.streaming.task</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/util/AkkaHelper.html#actorFor-akka.actor.ActorSystem-java.lang.String-">actorFor(ActorSystem, String)</a></span> - Static method in class io.gearpump.util.<a href="io/gearpump/util/AkkaHelper.html" title="class in io.gearpump.util">AkkaHelper</a></dt>
-<dd>
-<div class="block">Helper util to access the private[akka] system.actorFor method
-
- This is used for performance optimization, we encode the session Id
- in the ActorRef path.</div>
-</dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskContext.html#actorOf-akka.actor.Props-">actorOf(Props)</a></span> - Method in interface io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/AckRequest.html#AckRequest-org.apache.gearpump.streaming.task.TaskId-short-int-">AckRequest(TaskId, short, int)</a></span> - Constructor for class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/AckRequest.html" title="class in org.apache.gearpump.streaming.task">AckRequest</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskContext.html#actorOf-akka.actor.Props-java.lang.String-">actorOf(Props, String)</a></span> - Method in interface io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt>
+<dt><a href="org/apache/gearpump/streaming/AckRequestSerializer.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AckRequestSerializer</span></a> - Class in <a href="org/apache/gearpump/streaming/package-summary.html">org.apache.gearpump.streaming</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskWrapper.html#actorOf-akka.actor.Props-">actorOf(Props)</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/AckRequestSerializer.html#AckRequestSerializer--">AckRequestSerializer()</a></span> - Constructor for class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AckRequestSerializer.html" title="class in org.apache.gearpump.streaming">AckRequestSerializer</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskWrapper.html#actorOf-akka.actor.Props-java.lang.String-">actorOf(Props, String)</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt>
+<dt><a href="org/apache/gearpump/streaming/AckSerializer.html" title="class in org.apache.gearpump.streaming"><span class="typeNameLink">AckSerializer</span></a> - Class in <a href="org/apache/gearpump/streaming/package-summary.html">org.apache.gearpump.streaming</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#actorPath--">actorPath()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/AckSerializer.html#AckSerializer--">AckSerializer()</a></span> - Constructor for class org.apache.gearpump.streaming.<a href="org/apache/gearpump/streaming/AckSerializer.html" title="class in org.apache.gearpump.streaming">AckSerializer</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/Executor.ExecutorSummary.html#actorPath--">actorPath()</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/Executor.ExecutorSummary.html" title="class in io.gearpump.streaming.executor">Executor.ExecutorSummary</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html#ActivateAppMaster-int-">ActivateAppMaster(int)</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.ActivateAppMaster</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/util/ActorPathUtil.html" title="class in io.gearpump.streaming.util"><span class="typeNameLink">ActorPathUtil</span></a> - Class in <a href="io/gearpump/streaming/util/package-summary.html">io.gearpump.streaming.util</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster$.html#ActivateAppMaster:D--">ActivateAppMaster$()</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster$.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.ActivateAppMaster$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/util/ActorPathUtil.html#ActorPathUtil--">ActorPathUtil()</a></span> - Constructor for class io.gearpump.streaming.util.<a href="io/gearpump/streaming/util/ActorPathUtil.html" title="class in io.gearpump.streaming.util">ActorPathUtil</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/MasterProxy.html#active-akka.actor.ActorRef-">active(ActorRef)</a></span> - Method in class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/MasterProxy.html" title="class in org.apache.gearpump.cluster.master">MasterProxy</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/util/ActorPathUtil$.html" title="class in io.gearpump.streaming.util"><span class="typeNameLink">ActorPathUtil$</span></a> - Class in <a href="io/gearpump/streaming/util/package-summary.html">io.gearpump.streaming.util</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/executor/Executor.State$.html#ACTIVE--">ACTIVE()</a></span> - Method in class org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/Executor.State$.html" title="class in org.apache.gearpump.streaming.executor">Executor.State$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/util/ActorPathUtil$.html#ActorPathUtil:D--">ActorPathUtil$()</a></span> - Constructor for class io.gearpump.streaming.util.<a href="io/gearpump/streaming/util/ActorPathUtil$.html" title="class in io.gearpump.streaming.util">ActorPathUtil$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/MasterSummary.html#activities--">activities()</a></span> - Method in class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/MasterSummary.html" title="class in org.apache.gearpump.cluster.master">MasterSummary</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/AppMaster.html#actorSystem--">actorSystem()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster">AppMaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated.html#actor--">actor()</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated.html" title="class in org.apache.gearpump.util">ActorSystemBooter.ActorCreated</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/Ack.html#actualReceivedNum--">actualReceivedNum()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/Ack.html" title="class in io.gearpump.streaming.task">Ack</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.BindLifeCycle.html#actor--">actor()</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.BindLifeCycle.html" title="class in org.apache.gearpump.util">ActorSystemBooter.BindLifeCycle</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/Executor.TaskArgumentStore.html#add-io.gearpump.streaming.task.TaskId-io.gearpump.streaming.executor.TaskLauncher.TaskArgument-">add(TaskId, TaskLauncher.TaskArgument)</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/Executor.TaskArgumentStore.html" title="class in io.gearpump.streaming.executor">Executor.TaskArgumentStore</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated.html#ActorCreated-akka.actor.ActorRef-java.lang.String-">ActorCreated(ActorRef, String)</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated.html" title="class in org.apache.gearpump.util">ActorSystemBooter.ActorCreated</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/ExecutorRestartPolicy.html#addTaskToExecutor-int-io.gearpump.streaming.task.TaskId-">addTaskToExecutor(int, TaskId)</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in io.gearpump.streaming.executor">ExecutorRestartPolicy</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated$.html#ActorCreated:D--">ActorCreated$()</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated$.html" title="class in org.apache.gearpump.util">ActorSystemBooter.ActorCreated$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/ProcessorAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/ProcessorAggregator.html" title="class in io.gearpump.streaming.metrics">ProcessorAggregator</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/AkkaHelper.html#actorFor-akka.actor.ActorSystem-java.lang.String-">actorFor(ActorSystem, String)</a></span> - Static method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaHelper.html" title="class in org.apache.gearpump.util">AkkaHelper</a></dt>
<dd>
-<div class="block">Accept options:
- key: "readOption", value: one of "readLatest", "readRecent", "readHistory"</div>
+<div class="block">Helper util to access the private[akka] system.actorFor method
+
+ This is used for performance optimization, we encode the session Id
+ in the ActorRef path.</div>
</dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/ProcessorAggregator.html#aggregate-java.lang.String-scala.collection.Iterator-long-">aggregate(String, Iterator<MasterToClient.HistoryMetricsItem>, long)</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/ProcessorAggregator.html" title="class in io.gearpump.streaming.metrics">ProcessorAggregator</a></dt>
+<dt><a href="org/apache/gearpump/transport/ActorLookupById.html" title="interface in org.apache.gearpump.transport"><span class="typeNameLink">ActorLookupById</span></a> - Interface in <a href="org/apache/gearpump/transport/package-summary.html">org.apache.gearpump.transport</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/ProcessorAggregator.Aggregator.html#aggregate-io.gearpump.cluster.MasterToClient.HistoryMetricsItem-">aggregate(MasterToClient.HistoryMetricsItem)</a></span> - Method in interface io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/ProcessorAggregator.Aggregator.html" title="interface in io.gearpump.streaming.metrics">ProcessorAggregator.Aggregator</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorUtil.html#actorNameForExecutor-int-int-">actorNameForExecutor(int, int)</a></span> - Static method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorUtil.html" title="class in org.apache.gearpump.util">ActorUtil</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/ProcessorAggregator.HistogramAggregator.html#aggregate-io.gearpump.cluster.MasterToClient.HistoryMetricsItem-">aggregate(MasterToClient.HistoryMetricsItem)</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/ProcessorAggregator.HistogramAggregator.html" title="class in io.gearpump.streaming.metrics">ProcessorAggregator.HistogramAggregator</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/TaskContext.html#actorOf-akka.actor.Props-">actorOf(Props)</a></span> - Method in interface org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/ProcessorAggregator.MeterAggregator.html#aggregate-io.gearpump.cluster.MasterToClient.HistoryMetricsItem-">aggregate(MasterToClient.HistoryMetricsItem)</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/ProcessorAggregator.MeterAggregator.html" title="class in io.gearpump.streaming.metrics">ProcessorAggregator.MeterAggregator</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/TaskContext.html#actorOf-akka.actor.Props-java.lang.String-">actorOf(Props, String)</a></span> - Method in interface org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskContext.html" title="interface in org.apache.gearpump.streaming.task">TaskContext</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/TaskFilterAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/TaskFilterAggregator.html" title="class in io.gearpump.streaming.metrics">TaskFilterAggregator</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/TaskWrapper.html#actorOf-akka.actor.Props-">actorOf(Props)</a></span> - Method in class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskWrapper.html" title="class in org.apache.gearpump.streaming.task">TaskWrapper</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/TaskFilterAggregator.html#aggregate-io.gearpump.streaming.metrics.TaskFilterAggregator.Options-scala.collection.Iterator-">aggregate(TaskFilterAggregator.Options, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/TaskFilterAggregator.html" title="class in io.gearpump.streaming.metrics">TaskFilterAggregator</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/TaskWrapper.html#actorOf-akka.actor.Props-java.lang.String-">actorOf(Props, String)</a></span> - Method in class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/TaskWrapper.html" title="class in org.apache.gearpump.streaming.task">TaskWrapper</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/metrics/ProcessorAggregator.AggregatorFactory.html#AggregatorFactory--">AggregatorFactory()</a></span> - Constructor for class io.gearpump.streaming.metrics.<a href="io/gearpump/streaming/metrics/ProcessorAggregator.AggregatorFactory.html" title="class in io.gearpump.streaming.metrics">ProcessorAggregator.AggregatorFactory</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/AppMasterToMaster.AppMasterSummary.html#actorPath--">actorPath()</a></span> - Method in interface org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.AppMasterSummary.html" title="interface in org.apache.gearpump.cluster">AppMasterToMaster.AppMasterSummary</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/util/AkkaHelper.html" title="class in io.gearpump.util"><span class="typeNameLink">AkkaHelper</span></a> - Class in <a href="io/gearpump/util/package-summary.html">io.gearpump.util</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html#actorPath--">actorPath()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GeneralAppMasterSummary</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/util/AkkaHelper.html#AkkaHelper--">AkkaHelper()</a></span> - Constructor for class io.gearpump.util.<a href="io/gearpump/util/AkkaHelper.html" title="class in io.gearpump.util">AkkaHelper</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/worker/WorkerSummary.html#actorPath--">actorPath()</a></span> - Method in class org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/WorkerSummary.html" title="class in org.apache.gearpump.cluster.worker">WorkerSummary</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html#AllocateResourceTimeOut:D--">AllocateResourceTimeOut$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in io.gearpump.streaming.appmaster">AppMaster.AllocateResourceTimeOut$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html#actorPath--">actorPath()</a></span> - Method in class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html#allocation--">allocation()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html" title="class in io.gearpump.streaming.appmaster">TaskScheduler.TaskStatus</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/executor/Executor.ExecutorSummary.html#actorPath--">actorPath()</a></span> - Method in class org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/Executor.ExecutorSummary.html" title="class in org.apache.gearpump.streaming.executor">Executor.ExecutorSummary</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/ExecutorRestartPolicy.html#allowRestartExecutor-int-">allowRestartExecutor(int)</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in io.gearpump.streaming.executor">ExecutorRestartPolicy</a></dt>
+<dt><a href="org/apache/gearpump/streaming/util/ActorPathUtil.html" title="class in org.apache.gearpump.streaming.util"><span class="typeNameLink">ActorPathUtil</span></a> - Class in <a href="org/apache/gearpump/streaming/util/package-summary.html">org.apache.gearpump.streaming.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/Subscription.html#allowSendingMoreMessages--">allowSendingMoreMessages()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/Subscription.html" title="class in io.gearpump.streaming.task">Subscription</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/util/ActorPathUtil.html#ActorPathUtil--">ActorPathUtil()</a></span> - Constructor for class org.apache.gearpump.streaming.util.<a href="org/apache/gearpump/streaming/util/ActorPathUtil.html" title="class in org.apache.gearpump.streaming.util">ActorPathUtil</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/plan/OpTranslator.AndThen.html#AndThen-io.gearpump.streaming.dsl.plan.OpTranslator.SingleInputFunction-io.gearpump.streaming.dsl.plan.OpTranslator.SingleInputFunction-">AndThen(OpTranslator.SingleInputFunction<IN, MIDDLE>, OpTranslator.SingleInputFunction<MIDDLE, OUT>)</a></span> - Constructor for class io.gearpump.streaming.dsl.plan.<a href="io/gearpump/streaming/dsl/plan/OpTranslator.AndThen.html" title="class in io.gearpump.streaming.dsl.plan">OpTranslator.AndThen</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.html#actorSystem--">actorSystem()</a></span> - Method in class org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystemScheduler</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/plan/OpTranslator.DummyInputFunction.html#andThen-io.gearpump.streaming.dsl.plan.OpTranslator.SingleInputFunction-">andThen(OpTranslator.SingleInputFunction<T, OUTER>)</a></span> - Method in class io.gearpump.streaming.dsl.plan.<a href="io/gearpump/streaming/dsl/plan/OpTranslator.DummyInputFunction.html" title="class in io.gearpump.streaming.dsl.plan">OpTranslator.DummyInputFunction</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
+<dd>
+<div class="block">ActorSystemBooter start a new JVM process to boot an actor system.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.html#ActorSystemBooter-com.typesafe.config.Config-">ActorSystemBooter(Config)</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.html" title="class in org.apache.gearpump.util">ActorSystemBooter</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/plan/OpTranslator.SingleInputFunction.html#andThen-io.gearpump.streaming.dsl.plan.OpTranslator.SingleInputFunction-">andThen(OpTranslator.SingleInputFunction<OUT, OUTER>)</a></span> - Method in interface io.gearpump.streaming.dsl.plan.<a href="io/gearpump/streaming/dsl/plan/OpTranslator.SingleInputFunction.html" title="interface in io.gearpump.streaming.dsl.plan">OpTranslator.SingleInputFunction</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.ActorCreated</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html#appClock--">appClock()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/ClockService.HealthChecker.ClockValue.html" title="class in io.gearpump.streaming.appmaster">ClockService.HealthChecker.ClockValue</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.ActorCreated$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.ActorCreated$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/storage/AppDataStore.html" title="interface in io.gearpump.streaming.storage"><span class="typeNameLink">AppDataStore</span></a> - Interface in <a href="io/gearpump/streaming/storage/package-summary.html">io.gearpump.streaming.storage</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.ActorSystemRegistered.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.ActorSystemRegistered</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd>
-<div class="block">Generic storage to store KV Data.</div>
+<div class="block">This actor system will watch for parent,
+ If parent dies, this will also die</div>
</dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/transaction/api/OffsetStorage.html#append-long-byte:A-">append(long, byte[])</a></span> - Method in interface io.gearpump.streaming.transaction.api.<a href="io/gearpump/streaming/transaction/api/OffsetStorage.html" title="interface in io.gearpump.streaming.transaction.api">OffsetStorage</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.ActorSystemRegistered$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.ActorSystemRegistered$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/util/RecreateRollingFileAppender.html#append-org.apache.log4j.spi.LoggingEvent-">append(LoggingEvent)</a></span> - Method in class io.gearpump.util.<a href="io/gearpump/util/RecreateRollingFileAppender.html" title="class in io.gearpump.util">RecreateRollingFileAppender</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.BindLifeCycle.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.BindLifeCycle</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/StreamAppMasterSummary.html#appId--">appId()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in io.gearpump.streaming.appmaster">StreamAppMasterSummary</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.BindLifeCycle$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.BindLifeCycle$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskContext.html#appId--">appId()</a></span> - Method in interface io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.CreateActor.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.CreateActor</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskContextData.html#appId--">appId()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskContextData.html" title="class in io.gearpump.streaming.task">TaskContextData</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.CreateActor$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.CreateActor$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskWrapper.html#appId--">appId()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.CreateActorFailed.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.CreateActorFailed</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/JarScheduler.ScheduleTask.html#appJar--">appJar()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/JarScheduler.ScheduleTask.html" title="class in io.gearpump.streaming.appmaster">JarScheduler.ScheduleTask</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.CreateActorFailed$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.CreateActorFailed$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/Executor.html#applicationReady-int-">applicationReady(int)</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/Executor.html" title="class in io.gearpump.streaming.executor">Executor</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.Daemon.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.Daemon</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/DAG$.html#apply-io.gearpump.util.Graph-int-">apply(Graph<ProcessorDescription, PartitionerDescription>, int)</a></span> - Method in class io.gearpump.streaming.<a href="io/gearpump/streaming/DAG$.html" title="class in io.gearpump.streaming">DAG$</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystem.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystem</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/DAG.html#apply-io.gearpump.util.Graph-int-">apply(Graph<ProcessorDescription, PartitionerDescription>, int)</a></span> - Static method in class io.gearpump.streaming.<a href="io/gearpump/streaming/DAG.html" title="class in io.gearpump.streaming">DAG</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystem$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystem$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/Stream$.html#apply-io.gearpump.util.Graph-io.gearpump.streaming.dsl.op.Op-scala.Option-">apply(Graph<Op, OpEdge>, Op, Option<OpEdge>)</a></span> - Method in class io.gearpump.streaming.dsl.<a href="io/gearpump/streaming/dsl/Stream$.html" title="class in io.gearpump.streaming.dsl">Stream$</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystemFailed</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/Stream.html#apply-io.gearpump.util.Graph-io.gearpump.streaming.dsl.op.Op-scala.Option-">apply(Graph<Op, OpEdge>, Op, Option<OpEdge>)</a></span> - Static method in class io.gearpump.streaming.dsl.<a href="io/gearpump/streaming/dsl/Stream.html" title="class in io.gearpump.streaming.dsl">Stream</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemFailed$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystemFailed$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/StreamApp$.html#apply-java.lang.String-io.gearpump.cluster.client.ClientContext-io.gearpump.cluster.UserConfig-">apply(String, ClientContext, UserConfig)</a></span> - Method in class io.gearpump.streaming.dsl.<a href="io/gearpump/streaming/dsl/StreamApp$.html" title="class in io.gearpump.streaming.dsl">StreamApp$</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorSystemBooter.RegisterActorSystemTimeOut$.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorSystemBooter.RegisterActorSystemTimeOut$</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/dsl/StreamApp.html#apply-java.lang.String-io.gearpump.cluster.client.ClientContext-io.gearpump.cluster.UserConfig-">apply(String, ClientContext, UserConfig)</a></span> - Static method in class io.gearpump.streaming.dsl.<a href="io/gearpump/streaming/dsl/StreamApp.html" title="class in io.gearpump.streaming.dsl">StreamApp</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.ActorSystemRegistered.html#ActorSystemRegistered-akka.actor.ActorRef-">ActorSystemRegistered(ActorRef)</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.ActorSystemRegistered.html" title="class in org.apache.gearpump.util">ActorSystemBooter.ActorSystemRegistered</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/TaskLauncher$.html#apply-io.gearpump.cluster.ExecutorContext-io.gearpump.cluster.UserConfig-">apply(ExecutorContext, UserConfig)</a></span> - Method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/TaskLauncher$.html" title="class in io.gearpump.streaming.executor">TaskLauncher$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorSystemBooter.ActorSystemRegistered$.html#ActorSystemRegistered:D--">ActorSystemRegistered$()</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorSystemBooter.ActorSystemRegistered$.html" title="class in org.apache.gearpump.util">ActorSystemBooter.ActorSystemRegistered$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/executor/TaskLauncher.html#apply-io.gearpump.cluster.ExecutorContext-io.gearpump.cluster.UserConfig-">apply(ExecutorContext, UserConfig)</a></span> - Static method in class io.gearpump.streaming.executor.<a href="io/gearpump/streaming/executor/TaskLauncher.html" title="class in io.gearpump.streaming.executor">TaskLauncher</a></dt>
+<dt><a href="org/apache/gearpump/util/ActorUtil.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">ActorUtil</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/javaapi/dsl/functions/FilterFunction.html#apply-T-">apply(T)</a></span> - Method in interface io.gearpump.streaming.javaapi.dsl.functions.<a href="io/gearpump/streaming/javaapi/dsl/functions/FilterFunction.html" title="interface in io.gearpump.streaming.javaapi.dsl.functions">FilterFunction</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/ActorUtil.html#ActorUtil--">ActorUtil()</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/ActorUtil.html" title="class in org.apache.gearpump.util">ActorUtil</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html#apply-T-">apply(T)</a></span> - Method in interface io.gearpump.streaming.javaapi.dsl.functions.<a href="io/gearpump/streaming/javaapi/dsl/functions/FlatMapFunction.html" title="interface in io.gearpump.streaming.javaapi.dsl.functions">FlatMapFunction</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/task/Ack.html#actualReceivedNum--">actualReceivedNum()</a></span> - Method in class org.apache.gearpump.streaming.task.<a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task">Ack</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html#apply-T-">apply(T)</a></span> - Method in interface io.gearpump.streaming.javaapi.dsl.functions.<a href="io/gearpump/streaming/javaapi/dsl/functions/GroupByFunction.html" title="interface in io.gearpump.streaming.javaapi.dsl.functions">GroupByFunction</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/executor/Executor.TaskArgumentStore.html#add-org.apache.gearpump.streaming.task.TaskId-org.apache.gearpump.streaming.executor.TaskLauncher.TaskArgument-">add(TaskId, TaskLauncher.TaskArgument)</a></span> - Method in class org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/Executor.TaskArgumentStore.html" title="class in org.apache.gearpump.streaming.executor">Executor.TaskArgumentStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/javaapi/dsl/functions/MapFunction.html#apply-T-">apply(T)</a></span> - Method in interface io.gearpump.streaming.javaapi.dsl.functions.<a href="io/gearpump/streaming/javaapi/dsl/functions/MapFunction.html" title="interface in io.gearpump.streaming.javaapi.dsl.functions">MapFunction</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.CounterMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.CounterMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.CounterMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html#apply-T-T-">apply(T, T)</a></span> - Method in interface io.gearpump.streaming.javaapi.dsl.functions.<a href="io/gearpump/streaming/javaapi/dsl/functions/ReduceFunction.html" title="interface in io.gearpump.streaming.javaapi.dsl.functions">ReduceFunction</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.DummyHistoryMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.DummyHistoryMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.DummyHistoryMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/Processor$.html#apply-int-java.lang.String-io.gearpump.cluster.UserConfig-scala.reflect.ClassTag-">apply(int, String, UserConfig, ClassTag<T>)</a></span> - Method in class io.gearpump.streaming.<a href="io/gearpump/streaming/Processor$.html" title="class in io.gearpump.streaming">Processor$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.GaugeMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.GaugeMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.GaugeMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/Processor$.html#apply-java.lang.Class-int-java.lang.String-io.gearpump.cluster.UserConfig-">apply(Class<T>, int, String, UserConfig)</a></span> - Method in class io.gearpump.streaming.<a href="io/gearpump/streaming/Processor$.html" title="class in io.gearpump.streaming">Processor$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.HistogramMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.HistogramMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.HistogramMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/sink/DataSinkProcessor$.html#apply-io.gearpump.streaming.sink.DataSink-int-java.lang.String-io.gearpump.cluster.UserConfig-akka.actor.ActorSystem-">apply(DataSink, int, String, UserConfig, ActorSystem)</a></span> - Method in class io.gearpump.streaming.sink.<a href="io/gearpump/streaming/sink/DataSinkProcessor$.html" title="class in io.gearpump.streaming.sink">DataSinkProcessor$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.HistoryMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in interface org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.HistoryMetricsStore.html" title="interface in org.apache.gearpump.util">HistoryMetricsService.HistoryMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/sink/DataSinkProcessor.html#apply-io.gearpump.streaming.sink.DataSink-int-java.lang.String-io.gearpump.cluster.UserConfig-akka.actor.ActorSystem-">apply(DataSink, int, String, UserConfig, ActorSystem)</a></span> - Static method in class io.gearpump.streaming.sink.<a href="io/gearpump/streaming/sink/DataSinkProcessor.html" title="class in io.gearpump.streaming.sink">DataSinkProcessor</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.MeterMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.MeterMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.MeterMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/source/DataSourceProcessor$.html#apply-io.gearpump.streaming.source.DataSource-int-java.lang.String-io.gearpump.cluster.UserConfig-akka.actor.ActorSystem-">apply(DataSource, int, String, UserConfig, ActorSystem)</a></span> - Method in class io.gearpump.streaming.source.<a href="io/gearpump/streaming/source/DataSourceProcessor$.html" title="class in io.gearpump.streaming.source">DataSourceProcessor$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.MetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in interface org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.MetricsStore.html" title="interface in org.apache.gearpump.util">HistoryMetricsService.MetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/source/DataSourceProcessor.html#apply-io.gearpump.streaming.source.DataSource-int-java.lang.String-io.gearpump.cluster.UserConfig-akka.actor.ActorSystem-">apply(DataSource, int, String, UserConfig, ActorSystem)</a></span> - Static method in class io.gearpump.streaming.source.<a href="io/gearpump/streaming/source/DataSourceProcessor.html" title="class in io.gearpump.streaming.source">DataSourceProcessor</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.SingleValueMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-">add(Metrics.MetricType)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.SingleValueMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.SingleValueMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/StreamApplication$.html#apply-java.lang.String-io.gearpump.util.Graph-io.gearpump.cluster.UserConfig-">apply(String, Graph<T, P>, UserConfig)</a></span> - Method in class io.gearpump.streaming.<a href="io/gearpump/streaming/StreamApplication$.html" title="class in io.gearpump.streaming">StreamApplication$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.SingleValueMetricsStore.html#add-org.apache.gearpump.metrics.Metrics.MetricType-long-">add(Metrics.MetricType, long)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.SingleValueMetricsStore.html" title="class in org.apache.gearpump.util">HistoryMetricsService.SingleValueMetricsStore</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/StreamApplication.html#apply-java.lang.String-io.gearpump.util.Graph-io.gearpump.cluster.UserConfig-">apply(String, Graph<T, P>, UserConfig)</a></span> - Static method in class io.gearpump.streaming.<a href="io/gearpump/streaming/StreamApplication.html" title="class in io.gearpump.streaming">StreamApplication</a></dt>
-<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
-<dd>
-<div class="block">AppMaster is the head of a streaming application.</div>
-</dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/AppMaster.html#AppMaster-io.gearpump.cluster.AppMasterContext-io.gearpump.cluster.AppDescription-">AppMaster(AppMasterContext, AppDescription)</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster">AppMaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/transport/netty/Server.AddChannel.html#AddChannel-org.jboss.netty.channel.Channel-">AddChannel(Channel)</a></span> - Constructor for class org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.AddChannel.html" title="class in org.apache.gearpump.transport.netty">Server.AddChannel</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/javaapi/StreamApplication.html#appMaster--">appMaster()</a></span> - Method in class io.gearpump.streaming.javaapi.<a href="io/gearpump/streaming/javaapi/StreamApplication.html" title="class in io.gearpump.streaming.javaapi">StreamApplication</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/transport/netty/Server.AddChannel$.html#AddChannel:D--">AddChannel$()</a></span> - Constructor for class org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.AddChannel$.html" title="class in org.apache.gearpump.transport.netty">Server.AddChannel$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/StreamApplication.html#appMaster--">appMaster()</a></span> - Method in class io.gearpump.streaming.<a href="io/gearpump/streaming/StreamApplication.html" title="class in io.gearpump.streaming">StreamApplication</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html#addCheckpointStore-kafka.common.TopicAndPartition-org.apache.gearpump.streaming.transaction.api.CheckpointStore-">addCheckpointStore(TopicAndPartition, CheckpointStore)</a></span> - Method in class org.apache.gearpump.streaming.kafka.lib.source.<a href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" title="class in org.apache.gearpump.streaming.kafka.lib.source">AbstractKafkaSource</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskContext.html#appMaster--">appMaster()</a></span> - Method in interface io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskContext.html" title="interface in io.gearpump.streaming.task">TaskContext</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Graph.html#addEdge-scala.Tuple3-">addEdge(Tuple3<N, E, N>)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a></dt>
<dd>
-<div class="block">The actorRef of AppMaster</div>
+<div class="block">Add a edge
+ Current Graph is changed.</div>
</dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskContextData.html#appMaster--">appMaster()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskContextData.html" title="class in io.gearpump.streaming.task">TaskContextData</a></dt>
-<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/task/TaskWrapper.html#appMaster--">appMaster()</a></span> - Method in class io.gearpump.streaming.task.<a href="io/gearpump/streaming/task/TaskWrapper.html" title="class in io.gearpump.streaming.task">TaskWrapper</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Graph.html#addEdge-N-E-N-">addEdge(N, E, N)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a></dt>
+<dd>
+<div class="block">add edge
+ Current Graph is changed.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/TaskManager.DAGDiff.html#addedProcessors--">addedProcessors()</a></span> - Method in class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskManager.DAGDiff.html" title="class in org.apache.gearpump.streaming.appmaster">TaskManager.DAGDiff</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster$.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster$</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Graph.html#addGraph-org.apache.gearpump.util.Graph-">addGraph(Graph<N, E>)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a></dt>
+<dd>
+<div class="block">Add another graph
+ Current graph is changed.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.AddMaster$.html#AddMaster:D--">AddMaster$()</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.AddMaster$.html" title="class in org.apache.gearpump.cluster">ClientToMaster.AddMaster$</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/AppMaster$.html#AppMaster:D--">AppMaster$()</a></span> - Constructor for class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/AppMaster$.html" title="class in io.gearpump.streaming.appmaster">AppMaster$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/kafka/KafkaSource.html#addPartitionAndStore-kafka.common.TopicAndPartition-org.apache.gearpump.streaming.transaction.api.CheckpointStore-">addPartitionAndStore(TopicAndPartition, CheckpointStore)</a></span> - Method in class org.apache.gearpump.streaming.kafka.<a href="org/apache/gearpump/streaming/kafka/KafkaSource.html" title="class in org.apache.gearpump.streaming.kafka">KafkaSource</a></dt>
+<dd>
+<div class="block">for tests only</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html#address--">address()</a></span> - Method in class org.apache.gearpump.cluster.appmaster.<a href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html" title="class in org.apache.gearpump.cluster.appmaster">ExecutorSystem</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.AllocateResourceTimeOut$</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/executor/ExecutorRestartPolicy.html#addTaskToExecutor-int-org.apache.gearpump.streaming.task.TaskId-">addTaskToExecutor(int, TaskId)</a></span> - Method in class org.apache.gearpump.streaming.executor.<a href="org/apache/gearpump/streaming/executor/ExecutorRestartPolicy.html" title="class in org.apache.gearpump.streaming.executor">ExecutorRestartPolicy</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.ExecutorBrief</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Graph.html#addVertex-N-">addVertex(N)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a></dt>
+<dd>
+<div class="block">Add a vertex
+ Current Graph is changed.</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker.html#AddWorker-int-">AddWorker(int)</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker.html" title="class in org.apache.gearpump.cluster">ClientToMaster.AddWorker</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.ExecutorBrief$.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.ExecutorBrief$</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker$.html#AddWorker:D--">AddWorker$()</a></span> - Constructor for class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.AddWorker$.html" title="class in org.apache.gearpump.cluster">ClientToMaster.AddWorker$</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.LookupTaskActorRef</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/metrics/MetricsAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in interface org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/MetricsAggregator.html" title="interface in org.apache.gearpump.metrics">MetricsAggregator</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.LookupTaskActorRef$.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.LookupTaskActorRef$</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator</a></dt>
+<dd>
+<div class="block">Accepts options:
+ key: "readOption", value: one of "readLatest", "readRecent", "readHistory"</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.html#aggregate-java.lang.String-scala.collection.Iterator-long-">aggregate(String, Iterator<MasterToClient.HistoryMetricsItem>, long)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.ServiceNotAvailableException.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.ServiceNotAvailableException</span></a> - Exception in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.Aggregator.html#aggregate-org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem-">aggregate(MasterToClient.HistoryMetricsItem)</a></span> - Method in interface org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.Aggregator.html" title="interface in org.apache.gearpump.streaming.metrics">ProcessorAggregator.Aggregator</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.TaskActorRef</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.HistogramAggregator.html#aggregate-org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem-">aggregate(MasterToClient.HistoryMetricsItem)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.HistogramAggregator.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.HistogramAggregator</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html" title="class in io.gearpump.streaming.appmaster"><span class="typeNameLink">AppMaster.TaskActorRef$</span></a> - Class in <a href="io/gearpump/streaming/appmaster/package-summary.html">io.gearpump.streaming.appmaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.MeterAggregator.html#aggregate-org.apache.gearpump.cluster.MasterToClient.HistoryMetricsItem-">aggregate(MasterToClient.HistoryMetricsItem)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.MeterAggregator.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.MeterAggregator</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/appmaster/AppMaster.html#appMasterService--">appMasterService()</a></span> - Method in class io.gearpump.streaming.appmaster.<a href="io/gearpump/streaming/appmaster/AppMaster.html" title="class in io.gearpump.streaming.appmaster">AppMaster</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregator</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.html#aggregate-org.apache.gearpump.streaming.metrics.TaskFilterAggregator.Options-scala.collection.Iterator-">aggregate(TaskFilterAggregator.Options, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/TaskFilterAggregator.html" title="class in org.apache.gearpump.streaming.metrics">TaskFilterAggregator</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/AppMasterToExecutor.html#AppMasterToExecutor--">AppMasterToExecutor()</a></span> - Constructor for class io.gearpump.streaming.<a href="io/gearpump/streaming/AppMasterToExecutor.html" title="class in io.gearpump.streaming">AppMasterToExecutor</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.DummyMetricsAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.DummyMetricsAggregator.html" title="class in org.apache.gearpump.util">HistoryMetricsService.DummyMetricsAggregator</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/HistoryMetricsService.SkipAllAggregator.html#aggregate-scala.collection.immutable.Map-scala.collection.Iterator-">aggregate(Map<String, String>, Iterator<MasterToClient.HistoryMetricsItem>)</a></span> - Method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/HistoryMetricsService.SkipAllAggregator.html" title="class in org.apache.gearpump.util">HistoryMetricsService.SkipAllAggregator</a></dt>
<dd> </dd>
-<dt><span class="memberNameLink"><a href="io/gearpump/streaming/AppMasterToExecutor$.html#AppMasterToExecutor:D--">AppMasterToExecutor$()</a></span> - Constructor for class io.gearpump.streaming.<a href="io/gearpump/streaming/AppMasterToExecutor$.html" title="class in io.gearpump.streaming">AppMasterToExecutor$</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/ClientToMaster.QueryHistoryMetrics.html#aggregatorClazz--">aggregatorClazz()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/ClientToMaster.QueryHistoryMetrics.html" title="class in org.apache.gearpump.cluster">ClientToMaster.QueryHistoryMetrics</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.ChangeTask.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTask</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.AggregatorFactory.html#AggregatorFactory--">AggregatorFactory()</a></span> - Constructor for class org.apache.gearpump.streaming.metrics.<a href="org/apache/gearpump/streaming/metrics/ProcessorAggregator.AggregatorFactory.html" title="class in org.apache.gearpump.streaming.metrics">ProcessorAggregator.AggregatorFactory</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.ChangeTask$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTask$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/Constants.html#AKKA_SCHEDULER_TICK_DURATION--">AKKA_SCHEDULER_TICK_DURATION()</a></span> - Static method in class org.apache.gearpump.util.<a href="org/apache/gearpump/util/Constants.html" title="class in org.apache.gearpump.util">Constants</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.ChangeTasks.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTasks</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util"><span class="typeNameLink">AkkaApp</span></a> - Interface in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd>
-<div class="block">dagVersion, life, and subscribers will be changed on target task list.</div>
+<div class="block">A Main class helper to load Akka configuration automatically.</div>
</dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.ChangeTasks$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.ChangeTasks$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/AkkaApp.html#akkaConfig--">akkaConfig()</a></span> - Method in interface org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaApp.html" title="interface in org.apache.gearpump.util">AkkaApp</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.LaunchTasks.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.LaunchTasks</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><a href="org/apache/gearpump/util/AkkaHelper.html" title="class in org.apache.gearpump.util"><span class="typeNameLink">AkkaHelper</span></a> - Class in <a href="org/apache/gearpump/util/package-summary.html">org.apache.gearpump.util</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.LaunchTasks$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.LaunchTasks$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/util/AkkaHelper.html#AkkaHelper--">AkkaHelper()</a></span> - Constructor for class org.apache.gearpump.util.<a href="org/apache/gearpump/util/AkkaHelper.html" title="class in org.apache.gearpump.util">AkkaHelper</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.MsgLostException.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.MsgLostException</span></a> - Exception in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><a href="org/apache/gearpump/metrics/AkkaReporter.html" title="class in org.apache.gearpump.metrics"><span class="typeNameLink">AkkaReporter</span></a> - Class in <a href="org/apache/gearpump/metrics/package-summary.html">org.apache.gearpump.metrics</a></dt>
+<dd>
+<div class="block">A reporter class for logging metrics values to a remote actor periodically</div>
+</dd>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/metrics/AkkaReporter.html#AkkaReporter-akka.actor.ActorSystem-org.apache.gearpump.codahale.metrics.MetricRegistry-">AkkaReporter(ActorSystem, MetricRegistry)</a></span> - Constructor for class org.apache.gearpump.metrics.<a href="org/apache/gearpump/metrics/AkkaReporter.html" title="class in org.apache.gearpump.metrics">AkkaReporter</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.RestartClockService$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.RestartClockService$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" title="class in org.apache.gearpump.streaming.monoid"><span class="typeNameLink">AlgebirdGroup</span></a><<a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" title="type parameter in AlgebirdGroup">T</a>> - Class in <a href="org/apache/gearpump/streaming/monoid/package-summary.html">org.apache.gearpump.streaming.monoid</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StartAllTasks.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartAllTasks</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html#AlgebirdGroup-com.twitter.algebird.Group-">AlgebirdGroup(Group<T>)</a></span> - Constructor for class org.apache.gearpump.streaming.monoid.<a href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" title="class in org.apache.gearpump.streaming.monoid">AlgebirdGroup</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StartAllTasks$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartAllTasks$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" title="class in org.apache.gearpump.streaming.monoid"><span class="typeNameLink">AlgebirdMonoid</span></a><<a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" title="type parameter in AlgebirdMonoid">T</a>> - Class in <a href="org/apache/gearpump/streaming/monoid/package-summary.html">org.apache.gearpump.streaming.monoid</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StartDynamicDag.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartDynamicDag</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html#AlgebirdMonoid-com.twitter.algebird.Monoid-">AlgebirdMonoid(Monoid<T>)</a></span> - Constructor for class org.apache.gearpump.streaming.monoid.<a href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" title="class in org.apache.gearpump.streaming.monoid">AlgebirdMonoid</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StartDynamicDag$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartDynamicDag$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/master/MasterSummary.html#aliveFor--">aliveFor()</a></span> - Method in class org.apache.gearpump.cluster.master.<a href="org/apache/gearpump/cluster/master/MasterSummary.html" title="class in org.apache.gearpump.cluster.master">MasterSummary</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StartTask.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartTask</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/worker/WorkerSummary.html#aliveFor--">aliveFor()</a></span> - Method in class org.apache.gearpump.cluster.worker.<a href="org/apache/gearpump/cluster/worker/WorkerSummary.html" title="class in org.apache.gearpump.cluster.worker">WorkerSummary</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StartTask$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StartTask$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/transport/netty/Server.html#allChannels--">allChannels()</a></span> - Method in class org.apache.gearpump.transport.netty.<a href="org/apache/gearpump/transport/netty/Server.html" title="class in org.apache.gearpump.transport.netty">Server</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StopTask.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StopTask</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html#AllocateResourceTimeOut:D--">AllocateResourceTimeOut$()</a></span> - Constructor for class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/AppMaster.AllocateResourceTimeOut$.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.AllocateResourceTimeOut$</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.StopTask$.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.StopTask$</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html#allocation--">allocation()</a></span> - Method in class org.apache.gearpump.streaming.appmaster.<a href="org/apache/gearpump/streaming/appmaster/TaskScheduler.TaskStatus.html" title="class in org.apache.gearpump.streaming.appmaster">TaskScheduler.TaskStatus</a></dt>
<dd> </dd>
-<dt><a href="io/gearpump/streaming/AppMasterToExecutor.TaskChanged.html" title="class in io.gearpump.streaming"><span class="typeNameLink">AppMasterToExecutor.TaskChanged</span></a> - Class in <a href="io/gearpump/streaming/package-summary.html">io.gearpump.streaming</a></dt>
+<dt><span class="memberNameLink"><a href="org/apache/gearpump/cluster/MasterToAppMaster.ResourceAllocated.html#allocations--">allocations()</a></span> - Method in class org.apache.gearpump.cluster.<a href="org/apache/gearpump/cluster/MasterToAppMaster.ResourceAllocated.html" title="class in org.apache.gearpump.cluster">Maste
<TRUNCATED>