[11/51] [partial] incubator-gearpump-site git commit: [GEARPUMP-242] Update website for 0.8.2-incubating release

[ka...@apache.org]

http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/6091d5f1/content/releases/latest/api/scala/index.html
----------------------------------------------------------------------
diff --git a/content/releases/latest/api/scala/index.html b/content/releases/latest/api/scala/index.html
index 8b28bef..19fac06 100644
--- a/content/releases/latest/api/scala/index.html
+++ b/content/releases/latest/api/scala/index.html
@@ -49,7 +49,7 @@
             <ol class="templates"><li title="org.apache.gearpump.Message"><a class="tplshow" href="org/apache/gearpump/Message$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/Message.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Message</span></a></li></ol>
             <ol class="packages"> <li class="pack" title="org.apache.gearpump.cluster">
             <a class="tplshow" href="org/apache/gearpump/cluster/package.html" target="template">org.apache.gearpump.cluster</a>
-            <ol class="templates"><li title="org.apache.gearpump.cluster.AppDescription"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppDescription.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppDescription</span></a></li><li title="org.apache.gearpump.cluster.AppJar"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppJar.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppJar</span></a></li><li title="org.apache.gearpump.cluster.Application"><a class="tplshow" href="org/apache/gearpump/cluster/Application$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/Application.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Application</span></a></li><li title="org.apache.gearpump.cluster.ApplicationMaster"><div class="placeholder"></
 div><a class="tplshow" href="org/apache/gearpump/cluster/ApplicationMaster.html" target="template"><span class="class">(class)</span><span class="tplLink">ApplicationMaster</span></a></li><li title="org.apache.gearpump.cluster.AppMasterContext"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterContext.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppMasterContext</span></a></li><li title="org.apache.gearpump.cluster.AppMasterRegisterData"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterRegisterData.html" target="template"><span class="trait">(trait)</span><span class="tplLink">AppMasterRegisterData</span></a></li><li title="org.apache.gearpump.cluster.AppMasterToMaster"><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterToMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">A
 ppMasterToMaster</span></a></li><li title="org.apache.gearpump.cluster.AppMasterToWorker"><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterToWorker$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">AppMasterToWorker</span></a></li><li title="org.apache.gearpump.cluster.ClientToMaster"><a class="tplshow" href="org/apache/gearpump/cluster/ClientToMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">ClientToMaster</span></a></li><li title="org.apache.gearpump.cluster.ClusterConfig"><a class="tplshow" href="org/apache/gearpump/cluster/ClusterConfig$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">ClusterConfig</span></a></li><li title="org.apache.gearpump.cluster.ClusterConfigSource"><a class="tplshow" href="org/apache/gearpump/cluster/ClusterConfigSource$.html" target="template">
 <span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/ClusterConfigSource.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ClusterConfigSource</span></a></li><li title="org.apache.gearpump.cluster.ExecutorContext"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/ExecutorContext.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorContext</span></a></li><li title="org.apache.gearpump.cluster.ExecutorJVMConfig"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/ExecutorJVMConfig.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorJVMConfig</span></a></li><li title="org.apache.gearpump.cluster.MasterToAppMaster"><a class="tplshow" href="org/apache/gearpump/cluster/MasterToAppMaster$.html" target="template"><span class="object">(object)</span><div class="placeho
 lder"></div><span class="tplLink">MasterToAppMaster</span></a></li><li title="org.apache.gearpump.cluster.MasterToClient"><a class="tplshow" href="org/apache/gearpump/cluster/MasterToClient$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">MasterToClient</span></a></li><li title="org.apache.gearpump.cluster.UserConfig"><a class="tplshow" href="org/apache/gearpump/cluster/UserConfig$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/UserConfig.html" target="template"><span class="class">(class)</span><span class="tplLink">UserConfig</span></a></li><li title="org.apache.gearpump.cluster.WorkerToAppMaster"><a class="tplshow" href="org/apache/gearpump/cluster/WorkerToAppMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">WorkerToAppMaster</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.cluster.AppDescription"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppDescription.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppDescription</span></a></li><li title="org.apache.gearpump.cluster.AppJar"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppJar.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppJar</span></a></li><li title="org.apache.gearpump.cluster.Application"><a class="tplshow" href="org/apache/gearpump/cluster/Application$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/Application.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Application</span></a></li><li title="org.apache.gearpump.cluster.ApplicationMaster"><div class="placeholder"></
 div><a class="tplshow" href="org/apache/gearpump/cluster/ApplicationMaster.html" target="template"><span class="class">(class)</span><span class="tplLink">ApplicationMaster</span></a></li><li title="org.apache.gearpump.cluster.AppMasterContext"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterContext.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppMasterContext</span></a></li><li title="org.apache.gearpump.cluster.AppMasterRegisterData"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterRegisterData.html" target="template"><span class="trait">(trait)</span><span class="tplLink">AppMasterRegisterData</span></a></li><li title="org.apache.gearpump.cluster.AppMasterToMaster"><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterToMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">A
 ppMasterToMaster</span></a></li><li title="org.apache.gearpump.cluster.AppMasterToWorker"><a class="tplshow" href="org/apache/gearpump/cluster/AppMasterToWorker$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">AppMasterToWorker</span></a></li><li title="org.apache.gearpump.cluster.ClientToMaster"><a class="tplshow" href="org/apache/gearpump/cluster/ClientToMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">ClientToMaster</span></a></li><li title="org.apache.gearpump.cluster.ClusterConfig"><a class="tplshow" href="org/apache/gearpump/cluster/ClusterConfig$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">ClusterConfig</span></a></li><li title="org.apache.gearpump.cluster.ClusterConfigSource"><a class="tplshow" href="org/apache/gearpump/cluster/ClusterConfigSource$.html" target="template">
 <span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/ClusterConfigSource.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ClusterConfigSource</span></a></li><li title="org.apache.gearpump.cluster.ExecutorContext"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/ExecutorContext.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorContext</span></a></li><li title="org.apache.gearpump.cluster.ExecutorJVMConfig"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/ExecutorJVMConfig.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorJVMConfig</span></a></li><li title="org.apache.gearpump.cluster.MasterToAppMaster"><a class="tplshow" href="org/apache/gearpump/cluster/MasterToAppMaster$.html" target="template"><span class="object">(object)</span><div class="placeho
 lder"></div><span class="tplLink">MasterToAppMaster</span></a></li><li title="org.apache.gearpump.cluster.MasterToClient"><a class="tplshow" href="org/apache/gearpump/cluster/MasterToClient$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">MasterToClient</span></a></li><li title="org.apache.gearpump.cluster.MasterToWorker"><a class="tplshow" href="org/apache/gearpump/cluster/MasterToWorker$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">MasterToWorker</span></a></li><li title="org.apache.gearpump.cluster.UserConfig"><a class="tplshow" href="org/apache/gearpump/cluster/UserConfig$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/UserConfig.html" target="template"><span class="class">(class)</span><span class="tplLink">UserConfig</span></a></li><li title="org.apache.gearpump.cluster.WorkerT
 oAppMaster"><a class="tplshow" href="org/apache/gearpump/cluster/WorkerToAppMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">WorkerToAppMaster</span></a></li><li title="org.apache.gearpump.cluster.WorkerToMaster"><a class="tplshow" href="org/apache/gearpump/cluster/WorkerToMaster$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">WorkerToMaster</span></a></li></ol>
             <ol class="packages"> <li class="pack" title="org.apache.gearpump.cluster.appmaster">
             <a class="tplshow" href="org/apache/gearpump/cluster/appmaster/package.html" target="template">org.apache.gearpump.cluster.appmaster</a>
             <ol class="templates"><li title="org.apache.gearpump.cluster.appmaster.ApplicationState"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ApplicationState</span></a></li><li title="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment"><a class="tplshow" href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">AppMasterRuntimeEnvironment</span></a></li><li title="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AppMasterRuntimeInfo</span></a></li><li title="org.apache.gea
 rpump.cluster.appmaster.ExecutorSystem"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/appmaster/ExecutorSystem.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorSystem</span></a></li><li title="org.apache.gearpump.cluster.appmaster.ExecutorSystemScheduler"><a class="tplshow" href="org/apache/gearpump/cluster/appmaster/ExecutorSystemScheduler$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">ExecutorSystemScheduler</span></a></li><li title="org.apache.gearpump.cluster.appmaster.WorkerInfo"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" target="template"><span class="case class">(case class)</span><span class="tplLink">WorkerInfo</span></a></li></ol>
@@ -58,21 +58,25 @@
             <a class="tplshow" href="org/apache/gearpump/cluster/client/package.html" target="template">org.apache.gearpump.cluster.client</a>
             <ol class="templates"><li title="org.apache.gearpump.cluster.client.ClientContext"><a class="tplshow" href="org/apache/gearpump/cluster/client/ClientContext$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/client/ClientContext.html" target="template"><span class="class">(class)</span><span class="tplLink">ClientContext</span></a></li><li title="org.apache.gearpump.cluster.client.MasterClient"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/client/MasterClient.html" target="template"><span class="class">(class)</span><span class="tplLink">MasterClient</span></a></li></ol>
             <ol class="packages"> </ol>
+          </li><li class="pack" title="org.apache.gearpump.cluster.embedded">
+            <a class="tplshow" href="org/apache/gearpump/cluster/embedded/package.html" target="template">org.apache.gearpump.cluster.embedded</a>
+            <ol class="templates"><li title="org.apache.gearpump.cluster.embedded.EmbeddedCluster"><a class="tplshow" href="org/apache/gearpump/cluster/embedded/EmbeddedCluster$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/embedded/EmbeddedCluster.html" target="template"><span class="class">(class)</span><span class="tplLink">EmbeddedCluster</span></a></li></ol>
+            <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.cluster.main">
             <a class="tplshow" href="org/apache/gearpump/cluster/main/package.html" target="template">org.apache.gearpump.cluster.main</a>
-            <ol class="templates"><li title="org.apache.gearpump.cluster.main.ArgumentsParser"><a class="tplshow" href="org/apache/gearpump/cluster/main/ArgumentsParser$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/main/ArgumentsParser.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ArgumentsParser</span></a></li><li title="org.apache.gearpump.cluster.main.CLIOption"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/main/CLIOption.html" target="template"><span class="case class">(case class)</span><span class="tplLink">CLIOption</span></a></li><li title="org.apache.gearpump.cluster.main.ParseResult"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/main/ParseResult.html" target="template"><span class="class">(class)</span><span class="tplLink">ParseResult</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.cluster.main.AppSubmitter"><a class="tplshow" href="org/apache/gearpump/cluster/main/AppSubmitter$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">AppSubmitter</span></a></li><li title="org.apache.gearpump.cluster.main.ArgumentsParser"><a class="tplshow" href="org/apache/gearpump/cluster/main/ArgumentsParser$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/main/ArgumentsParser.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ArgumentsParser</span></a></li><li title="org.apache.gearpump.cluster.main.CLIOption"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/main/CLIOption.html" target="template"><span class="case class">(case class)</span><span class="tplLink">CLIOption</span></a></li><li title="org.apache.gearpump.cluster
 .main.Gear"><a class="tplshow" href="org/apache/gearpump/cluster/main/Gear$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Gear</span></a></li><li title="org.apache.gearpump.cluster.main.Info"><a class="tplshow" href="org/apache/gearpump/cluster/main/Info$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Info</span></a></li><li title="org.apache.gearpump.cluster.main.Kill"><a class="tplshow" href="org/apache/gearpump/cluster/main/Kill$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Kill</span></a></li><li title="org.apache.gearpump.cluster.main.Local"><a class="tplshow" href="org/apache/gearpump/cluster/main/Local$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Local</span></a></li><li title="org.apache.gearpump.cluster.main.
 MainRunner"><a class="tplshow" href="org/apache/gearpump/cluster/main/MainRunner$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">MainRunner</span></a></li><li title="org.apache.gearpump.cluster.main.Master"><a class="tplshow" href="org/apache/gearpump/cluster/main/Master$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Master</span></a></li><li title="org.apache.gearpump.cluster.main.MasterWatcher"><a class="tplshow" href="org/apache/gearpump/cluster/main/MasterWatcher$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/main/MasterWatcher.html" target="template"><span class="class">(class)</span><span class="tplLink">MasterWatcher</span></a></li><li title="org.apache.gearpump.cluster.main.ParseResult"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/main/
 ParseResult.html" target="template"><span class="class">(class)</span><span class="tplLink">ParseResult</span></a></li><li title="org.apache.gearpump.cluster.main.Replay"><a class="tplshow" href="org/apache/gearpump/cluster/main/Replay$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Replay</span></a></li><li title="org.apache.gearpump.cluster.main.Worker"><a class="tplshow" href="org/apache/gearpump/cluster/main/Worker$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Worker</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.cluster.master">
             <a class="tplshow" href="org/apache/gearpump/cluster/master/package.html" target="template">org.apache.gearpump.cluster.master</a>
-            <ol class="templates"><li title="org.apache.gearpump.cluster.master.AppMasterLauncher"><a class="tplshow" href="org/apache/gearpump/cluster/master/AppMasterLauncher$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/master/AppMasterLauncher.html" target="template"><span class="class">(class)</span><span class="tplLink">AppMasterLauncher</span></a></li><li title="org.apache.gearpump.cluster.master.AppMasterLauncherFactory"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/AppMasterLauncherFactory.html" target="template"><span class="trait">(trait)</span><span class="tplLink">AppMasterLauncherFactory</span></a></li><li title="org.apache.gearpump.cluster.master.MasterActivity"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterActivity.html" target="template"><span class="case class">(case class)</span><span class="tplLink
 ">MasterActivity</span></a></li><li title="org.apache.gearpump.cluster.master.MasterNode"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterNode.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MasterNode</span></a></li><li title="org.apache.gearpump.cluster.master.MasterProxy"><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterProxy$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterProxy.html" target="template"><span class="class">(class)</span><span class="tplLink">MasterProxy</span></a></li><li title="org.apache.gearpump.cluster.master.MasterStatus"><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterStatus$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">MasterStatus</span></a></li><li title="org.apache.gearpump.cluster.
 master.MasterSummary"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterSummary.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MasterSummary</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.cluster.master.AppManager"><a class="tplshow" href="org/apache/gearpump/cluster/master/AppManager$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">AppManager</span></a></li><li title="org.apache.gearpump.cluster.master.AppMasterLauncher"><a class="tplshow" href="org/apache/gearpump/cluster/master/AppMasterLauncher$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/master/AppMasterLauncher.html" target="template"><span class="class">(class)</span><span class="tplLink">AppMasterLauncher</span></a></li><li title="org.apache.gearpump.cluster.master.AppMasterLauncherFactory"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/AppMasterLauncherFactory.html" target="template"><span class="trait">(trait)</span><span class="tplLink">AppMasterLauncherFactory</s
 pan></a></li><li title="org.apache.gearpump.cluster.master.InMemoryKVService"><a class="tplshow" href="org/apache/gearpump/cluster/master/InMemoryKVService$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/master/InMemoryKVService.html" target="template"><span class="class">(class)</span><span class="tplLink">InMemoryKVService</span></a></li><li title="org.apache.gearpump.cluster.master.Master"><a class="tplshow" href="org/apache/gearpump/cluster/master/Master$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Master</span></a></li><li title="org.apache.gearpump.cluster.master.MasterActivity"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterActivity.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MasterActivity</span></a></li><li title="org.apache.gearpump.cluster.m
 aster.MasterNode"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterNode.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MasterNode</span></a></li><li title="org.apache.gearpump.cluster.master.MasterProxy"><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterProxy$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterProxy.html" target="template"><span class="class">(class)</span><span class="tplLink">MasterProxy</span></a></li><li title="org.apache.gearpump.cluster.master.MasterStatus"><a class="tplshow" href="org/apache/gearpump/cluster/master/MasterStatus$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">MasterStatus</span></a></li><li title="org.apache.gearpump.cluster.master.MasterSummary"><div class="placeholder"></div><a class="tplshow" 
 href="org/apache/gearpump/cluster/master/MasterSummary.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MasterSummary</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.cluster.scheduler">
             <a class="tplshow" href="org/apache/gearpump/cluster/scheduler/package.html" target="template">org.apache.gearpump.cluster.scheduler</a>
-            <ol class="templates"><li title="org.apache.gearpump.cluster.scheduler.Priority"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Priority$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Priority</span></a></li><li title="org.apache.gearpump.cluster.scheduler.Relaxation"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Relaxation$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Relaxation</span></a></li><li title="org.apache.gearpump.cluster.scheduler.Resource"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Resource$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Resource.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Resource</span></a></li><li title="org.apache.gearpump.cluste
 r.scheduler.ResourceAllocation"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/ResourceAllocation.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ResourceAllocation</span></a></li><li title="org.apache.gearpump.cluster.scheduler.ResourceRequest"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/ResourceRequest.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ResourceRequest</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.cluster.scheduler.Priority"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Priority$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Priority</span></a></li><li title="org.apache.gearpump.cluster.scheduler.PriorityScheduler"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/PriorityScheduler.html" target="template"><span class="class">(class)</span><span class="tplLink">PriorityScheduler</span></a></li><li title="org.apache.gearpump.cluster.scheduler.Relaxation"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Relaxation$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Relaxation</span></a></li><li title="org.apache.gearpump.cluster.scheduler.Resource"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Reso
 urce$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Resource.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Resource</span></a></li><li title="org.apache.gearpump.cluster.scheduler.ResourceAllocation"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/ResourceAllocation.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ResourceAllocation</span></a></li><li title="org.apache.gearpump.cluster.scheduler.ResourceRequest"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/ResourceRequest.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ResourceRequest</span></a></li><li title="org.apache.gearpump.cluster.scheduler.Scheduler"><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Scheduler$.html
 " target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/scheduler/Scheduler.html" target="template"><span class="class">(class)</span><span class="tplLink">Scheduler</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.cluster.worker">
             <a class="tplshow" href="org/apache/gearpump/cluster/worker/package.html" target="template">org.apache.gearpump.cluster.worker</a>
-            <ol class="templates"><li title="org.apache.gearpump.cluster.worker.ExecutorProcessLauncher"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/worker/ExecutorProcessLauncher.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ExecutorProcessLauncher</span></a></li><li title="org.apache.gearpump.cluster.worker.ExecutorSlots"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/worker/ExecutorSlots.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorSlots</span></a></li><li title="org.apache.gearpump.cluster.worker.WorkerId"><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerId$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerId.html" target="template"><span class="case class">(case class)</span><span class="tplLink">WorkerId</span></a></li>
 <li title="org.apache.gearpump.cluster.worker.WorkerSummary"><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerSummary$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerSummary.html" target="template"><span class="case class">(case class)</span><span class="tplLink">WorkerSummary</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.cluster.worker.DefaultExecutorProcessLauncher"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/worker/DefaultExecutorProcessLauncher.html" target="template"><span class="class">(class)</span><span class="tplLink">DefaultExecutorProcessLauncher</span></a></li><li title="org.apache.gearpump.cluster.worker.ExecutorProcessLauncher"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/worker/ExecutorProcessLauncher.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ExecutorProcessLauncher</span></a></li><li title="org.apache.gearpump.cluster.worker.ExecutorSlots"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/cluster/worker/ExecutorSlots.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ExecutorSlots</span></a></li><li title="org.apache.gearpump.cluster.worker.W
 orkerId"><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerId$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerId.html" target="template"><span class="case class">(case class)</span><span class="tplLink">WorkerId</span></a></li><li title="org.apache.gearpump.cluster.worker.WorkerSummary"><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerSummary$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/cluster/worker/WorkerSummary.html" target="template"><span class="case class">(case class)</span><span class="tplLink">WorkerSummary</span></a></li></ol>
             <ol class="packages"> </ol>
           </li></ol>
           </li><li class="pack" title="org.apache.gearpump.external">
@@ -89,16 +93,16 @@
           </li></ol>
           </li><li class="pack" title="org.apache.gearpump.jarstore">
             <a class="tplshow" href="org/apache/gearpump/jarstore/package.html" target="template">org.apache.gearpump.jarstore</a>
-            <ol class="templates"><li title="org.apache.gearpump.jarstore.FilePath"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/jarstore/FilePath.html" target="template"><span class="case class">(case class)</span><span class="tplLink">FilePath</span></a></li><li title="org.apache.gearpump.jarstore.JarStoreService"><a class="tplshow" href="org/apache/gearpump/jarstore/JarStoreService$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/jarstore/JarStoreService.html" target="template"><span class="trait">(trait)</span><span class="tplLink">JarStoreService</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.jarstore.FileDirective"><a class="tplshow" href="org/apache/gearpump/jarstore/FileDirective$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">FileDirective</span></a></li><li title="org.apache.gearpump.jarstore.FilePath"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/jarstore/FilePath.html" target="template"><span class="case class">(case class)</span><span class="tplLink">FilePath</span></a></li><li title="org.apache.gearpump.jarstore.FileServer"><a class="tplshow" href="org/apache/gearpump/jarstore/FileServer$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/jarstore/FileServer.html" target="template"><span class="class">(class)</span><span class="tplLink">FileServer</span></a></li><li title="org.apache.gearpump.jarstore.JarStore"><a class="tplshow" href="org/apache/
 gearpump/jarstore/JarStore$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/jarstore/JarStore.html" target="template"><span class="trait">(trait)</span><span class="tplLink">JarStore</span></a></li><li title="org.apache.gearpump.jarstore.JarStoreClient"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/jarstore/JarStoreClient.html" target="template"><span class="class">(class)</span><span class="tplLink">JarStoreClient</span></a></li><li title="org.apache.gearpump.jarstore.JarStoreServer"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/jarstore/JarStoreServer.html" target="template"><span class="class">(class)</span><span class="tplLink">JarStoreServer</span></a></li></ol>
+            <ol class="packages"> <li class="pack" title="org.apache.gearpump.jarstore.local">
+            <a class="tplshow" href="org/apache/gearpump/jarstore/local/package.html" target="template">org.apache.gearpump.jarstore.local</a>
+            <ol class="templates"><li title="org.apache.gearpump.jarstore.local.LocalJarStore"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/jarstore/local/LocalJarStore.html" target="template"><span class="class">(class)</span><span class="tplLink">LocalJarStore</span></a></li></ol>
             <ol class="packages"> </ol>
+          </li></ol>
           </li><li class="pack" title="org.apache.gearpump.metrics">
             <a class="tplshow" href="org/apache/gearpump/metrics/package.html" target="template">org.apache.gearpump.metrics</a>
             <ol class="templates"><li title="org.apache.gearpump.metrics.AkkaReporter"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/metrics/AkkaReporter.html" target="template"><span class="class">(class)</span><span class="tplLink">AkkaReporter</span></a></li><li title="org.apache.gearpump.metrics.Counter"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/metrics/Counter.html" target="template"><span class="class">(class)</span><span class="tplLink">Counter</span></a></li><li title="org.apache.gearpump.metrics.Histogram"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/metrics/Histogram.html" target="template"><span class="class">(class)</span><span class="tplLink">Histogram</span></a></li><li title="org.apache.gearpump.metrics.JvmMetricsSet"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/metrics/JvmMetricsSet.html" target="template"><span class="class">(class)</span><sp
 an class="tplLink">JvmMetricsSet</span></a></li><li title="org.apache.gearpump.metrics.Meter"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/metrics/Meter.html" target="template"><span class="class">(class)</span><span class="tplLink">Meter</span></a></li><li title="org.apache.gearpump.metrics.Metrics"><a class="tplshow" href="org/apache/gearpump/metrics/Metrics$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/metrics/Metrics.html" target="template"><span class="class">(class)</span><span class="tplLink">Metrics</span></a></li><li title="org.apache.gearpump.metrics.MetricsAggregator"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/metrics/MetricsAggregator.html" target="template"><span class="trait">(trait)</span><span class="tplLink">MetricsAggregator</span></a></li><li title="org.apache.gearpump.metrics.MetricsReporterService"><a class="tplshow" href="org/apache/ge
 arpump/metrics/MetricsReporterService$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/metrics/MetricsReporterService.html" target="template"><span class="class">(class)</span><span class="tplLink">MetricsReporterService</span></a></li></ol>
             <ol class="packages"> </ol>
-          </li><li class="pack" title="org.apache.gearpump.partitioner">
-            <a class="tplshow" href="org/apache/gearpump/partitioner/package.html" target="template">org.apache.gearpump.partitioner</a>
-            <ol class="templates"><li title="org.apache.gearpump.partitioner.BroadcastPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/BroadcastPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">BroadcastPartitioner</span></a></li><li title="org.apache.gearpump.partitioner.CoLocationPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/CoLocationPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">CoLocationPartitioner</span></a></li><li title="org.apache.gearpump.partitioner.HashPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/HashPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">HashPartitioner</span></a></li><li title="org.apache.gearpump.partitioner.MulticastPartitioner"><div class="placeholder"></div><a class=
 "tplshow" href="org/apache/gearpump/partitioner/MulticastPartitioner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">MulticastPartitioner</span></a></li><li title="org.apache.gearpump.partitioner.Partitioner"><a class="tplshow" href="org/apache/gearpump/partitioner/Partitioner$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/partitioner/Partitioner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Partitioner</span></a></li><li title="org.apache.gearpump.partitioner.PartitionerByClassName"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/PartitionerByClassName.html" target="template"><span class="class">(class)</span><span class="tplLink">PartitionerByClassName</span></a></li><li title="org.apache.gearpump.partitioner.PartitionerDescription"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partiti
 oner/PartitionerDescription.html" target="template"><span class="case class">(case class)</span><span class="tplLink">PartitionerDescription</span></a></li><li title="org.apache.gearpump.partitioner.PartitionerFactory"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/PartitionerFactory.html" target="template"><span class="trait">(trait)</span><span class="tplLink">PartitionerFactory</span></a></li><li title="org.apache.gearpump.partitioner.PartitionerObject"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/PartitionerObject.html" target="template"><span class="class">(class)</span><span class="tplLink">PartitionerObject</span></a></li><li title="org.apache.gearpump.partitioner.ShuffleGroupingPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/ShuffleGroupingPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">ShuffleGro
 upingPartitioner</span></a></li><li title="org.apache.gearpump.partitioner.ShufflePartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/ShufflePartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">ShufflePartitioner</span></a></li><li title="org.apache.gearpump.partitioner.UnicastPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/partitioner/UnicastPartitioner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">UnicastPartitioner</span></a></li></ol>
-            <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.security">
             <a class="tplshow" href="org/apache/gearpump/security/package.html" target="template">org.apache.gearpump.security</a>
             <ol class="templates"><li title="org.apache.gearpump.security.Authenticator"><a class="tplshow" href="org/apache/gearpump/security/Authenticator$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/security/Authenticator.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Authenticator</span></a></li><li title="org.apache.gearpump.security.ConfigFileBasedAuthenticator"><a class="tplshow" href="org/apache/gearpump/security/ConfigFileBasedAuthenticator$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/security/ConfigFileBasedAuthenticator.html" target="template"><span class="class">(class)</span><span class="tplLink">ConfigFileBasedAuthenticator</span></a></li><li title="org.apache.gearpump.security.PasswordUtil"><a class="tplshow" href="org/apache/gearpump/security/PasswordUtil$.html" target="template"><span class="object">(objec
 t)</span><div class="placeholder"></div><span class="tplLink">PasswordUtil</span></a></li></ol>
@@ -116,14 +120,10 @@
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.dsl">
             <a class="tplshow" href="org/apache/gearpump/streaming/dsl/package.html" target="template">org.apache.gearpump.streaming.dsl</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.CollectionDataSource"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html" target="template"><span class="class">(class)</span><span class="tplLink">CollectionDataSource</span></a></li><li title="org.apache.gearpump.streaming.dsl.KVStream"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/KVStream.html" target="template"><span class="class">(class)</span><span class="tplLink">KVStream</span></a></li><li title="org.apache.gearpump.streaming.dsl.LoggerSink"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/LoggerSink.html" target="template"><span class="class">(class)</span><span class="tplLink">LoggerSink</span></a></li><li title="org.apache.gearpump.streaming.dsl.Stream"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/Stream$.html" target="template"><sp
 an class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/Stream.html" target="template"><span class="class">(class)</span><span class="tplLink">Stream</span></a></li><li title="org.apache.gearpump.streaming.dsl.StreamApp"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/StreamApp$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/StreamApp.html" target="template"><span class="class">(class)</span><span class="tplLink">StreamApp</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.CollectionDataSource"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html" target="template"><span class="class">(class)</span><span class="tplLink">CollectionDataSource</span></a></li><li title="org.apache.gearpump.streaming.dsl.KVStream"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/KVStream.html" target="template"><span class="class">(class)</span><span class="tplLink">KVStream</span></a></li><li title="org.apache.gearpump.streaming.dsl.LoggerSink"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/LoggerSink.html" target="template"><span class="class">(class)</span><span class="tplLink">LoggerSink</span></a></li><li title="org.apache.gearpump.streaming.dsl.Stream"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/Stream$.html" target="template"><sp
 an class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/Stream.html" target="template"><span class="class">(class)</span><span class="tplLink">Stream</span></a></li><li title="org.apache.gearpump.streaming.dsl.StreamApp"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/StreamApp$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/StreamApp.html" target="template"><span class="class">(class)</span><span class="tplLink">StreamApp</span></a></li><li title="org.apache.gearpump.streaming.dsl.WindowStream"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/WindowStream.html" target="template"><span class="class">(class)</span><span class="tplLink">WindowStream</span></a></li></ol>
             <ol class="packages"> <li class="pack" title="org.apache.gearpump.streaming.dsl.javaapi">
             <a class="tplshow" href="org/apache/gearpump/streaming/dsl/javaapi/package.html" target="template">org.apache.gearpump.streaming.dsl.javaapi</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.javaapi.JavaStream"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" target="template"><span class="class">(class)</span><span class="tplLink">JavaStream</span></a></li><li title="org.apache.gearpump.streaming.dsl.javaapi.JavaStreamApp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.html" target="template"><span class="class">(class)</span><span class="tplLink">JavaStreamApp</span></a></li></ol>
-            <ol class="packages"> </ol>
-          </li><li class="pack" title="org.apache.gearpump.streaming.dsl.op">
-            <a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/package.html" target="template">org.apache.gearpump.streaming.dsl.op</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.op.DataSinkOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/DataSinkOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">DataSinkOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.DataSourceOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/DataSourceOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">DataSourceOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.Direct"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/Direct$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Direct</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.FlatMapOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/s
 treaming/dsl/op/FlatMapOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">FlatMapOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.GroupByOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/GroupByOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">GroupByOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.MasterOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/MasterOp.html" target="template"><span class="trait">(trait)</span><span class="tplLink">MasterOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.MergeOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/MergeOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MergeOp</span></a></li><li title="org.apache.gearpump.streaming.dsl
 .op.Op"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/Op.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Op</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.OpChain"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/OpChain.html" target="template"><span class="case class">(case class)</span><span class="tplLink">OpChain</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.OpEdge"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/OpEdge.html" target="template"><span class="trait">(trait)</span><span class="tplLink">OpEdge</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.ParameterizedOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/ParameterizedOp.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Parameterize
 dOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.ProcessorOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/ProcessorOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ProcessorOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.ReduceOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/ReduceOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ReduceOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.Shuffle"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/Shuffle$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Shuffle</span></a></li><li title="org.apache.gearpump.streaming.dsl.op.SlaveOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/op/SlaveOp
 .html" target="template"><span class="trait">(trait)</span><span class="tplLink">SlaveOp</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.javaapi.JavaStream"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/javaapi/JavaStream.html" target="template"><span class="class">(class)</span><span class="tplLink">JavaStream</span></a></li><li title="org.apache.gearpump.streaming.dsl.javaapi.JavaStreamApp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/javaapi/JavaStreamApp.html" target="template"><span class="class">(class)</span><span class="tplLink">JavaStreamApp</span></a></li><li title="org.apache.gearpump.streaming.dsl.javaapi.JavaWindowStream"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/javaapi/JavaWindowStream.html" target="template"><span class="class">(class)</span><span class="tplLink">JavaWindowStream</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.dsl.partitioner">
             <a class="tplshow" href="org/apache/gearpump/streaming/dsl/partitioner/package.html" target="template">org.apache.gearpump.streaming.dsl.partitioner</a>
@@ -131,9 +131,29 @@
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.dsl.plan">
             <a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/package.html" target="template">org.apache.gearpump.streaming.dsl.plan</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.plan.OpTranslator"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/OpTranslator$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/OpTranslator.html" target="template"><span class="class">(class)</span><span class="tplLink">OpTranslator</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.Planner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/Planner.html" target="template"><span class="class">(class)</span><span class="tplLink">Planner</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.plan.ChainableOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/ChainableOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">ChainableOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.DataSinkOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/DataSinkOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">DataSinkOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.DataSourceOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/DataSourceOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">DataSourceOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.Direct"><a class="tplshow" href="org/apache/gearpump
 /streaming/dsl/plan/Direct$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Direct</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.GroupByOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/GroupByOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">GroupByOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.MergeOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/MergeOp.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MergeOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.Op"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/Op.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Op</span></a></li><li title="org.apache.gearpu
 mp.streaming.dsl.plan.OpChainException"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/OpChainException.html" target="template"><span class="class">(class)</span><span class="tplLink">OpChainException</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.OpEdge"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/OpEdge.html" target="template"><span class="trait">(trait)</span><span class="tplLink">OpEdge</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.Planner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/Planner.html" target="template"><span class="class">(class)</span><span class="tplLink">Planner</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.ProcessorOp"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/ProcessorOp.html" target="template"><span class=
 "case class">(case class)</span><span class="tplLink">ProcessorOp</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.Shuffle"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/Shuffle$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Shuffle</span></a></li></ol>
+            <ol class="packages"> <li class="pack" title="org.apache.gearpump.streaming.dsl.plan.functions">
+            <a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/functions/package.html" target="template">org.apache.gearpump.streaming.dsl.plan.functions</a>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.plan.functions.AndThen"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" target="template"><span class="class">(class)</span><span class="tplLink">AndThen</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.functions.EmitFunction"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/functions/EmitFunction.html" target="template"><span class="class">(class)</span><span class="tplLink">EmitFunction</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapFunction"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapFunction.html" target="template"><span class="class">(class)</span><span class="tplLink">FlatMapFunction</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.functions.ReduceFun
 ction"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/functions/ReduceFunction.html" target="template"><span class="class">(class)</span><span class="tplLink">ReduceFunction</span></a></li><li title="org.apache.gearpump.streaming.dsl.plan.functions.SingleInputFunction"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/plan/functions/SingleInputFunction.html" target="template"><span class="trait">(trait)</span><span class="tplLink">SingleInputFunction</span></a></li></ol>
             <ol class="packages"> </ol>
           </li></ol>
+          </li><li class="pack" title="org.apache.gearpump.streaming.dsl.task">
+            <a class="tplshow" href="org/apache/gearpump/streaming/dsl/task/package.html" target="template">org.apache.gearpump.streaming.dsl.task</a>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.task.CountTriggerTask"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" target="template"><span class="class">(class)</span><span class="tplLink">CountTriggerTask</span></a></li><li title="org.apache.gearpump.streaming.dsl.task.EventTimeTriggerTask"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" target="template"><span class="class">(class)</span><span class="tplLink">EventTimeTriggerTask</span></a></li><li title="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" target="template"><span class="class">(
 class)</span><span class="tplLink">ProcessingTimeTriggerTask</span></a></li><li title="org.apache.gearpump.streaming.dsl.task.TransformTask"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/task/TransformTask.html" target="template"><span class="class">(class)</span><span class="tplLink">TransformTask</span></a></li></ol>
+            <ol class="packages"> </ol>
+          </li><li class="pack" title="org.apache.gearpump.streaming.dsl.window">
+            <a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/package.html" target="template">org.apache.gearpump.streaming.dsl.window</a>
+            <ol class="templates"></ol>
+            <ol class="packages"> <li class="pack" title="org.apache.gearpump.streaming.dsl.window.api">
+            <a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/package.html" target="template">org.apache.gearpump.streaming.dsl.window.api</a>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.window.api.Accumulating"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/Accumulating$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Accumulating</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.AccumulationMode"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html" target="template"><span class="trait">(trait)</span><span class="tplLink">AccumulationMode</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.CountTrigger"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/CountTrigger$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">CountTrigger</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.CountWindow">
 <a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/CountWindow$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">CountWindow</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" target="template"><span class="case class">(case class)</span><span class="tplLink">CountWindowFn</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.Discarding"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/Discarding$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Discarding</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.EventTimeTrigger"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/EventTimeTrigger$.html" target="temp
 late"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">EventTimeTrigger</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.FixedWindow"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/FixedWindow$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">FixedWindow</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.GroupByFn"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/GroupByFn.html" target="template"><span class="trait">(trait)</span><span class="tplLink">GroupByFn</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.ProcessingTimeTrigger"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/ProcessingTimeTrigger$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">Processing
 TimeTrigger</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.SlidingWindow"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindow$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">SlidingWindow</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFn.html" target="template"><span class="case class">(case class)</span><span class="tplLink">SlidingWindowFn</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.Trigger"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Trigger</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.Window"><div class="placehol
 der"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/Window.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Window</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.api.WindowFn"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/api/WindowFn.html" target="template"><span class="trait">(trait)</span><span class="tplLink">WindowFn</span></a></li></ol>
+            <ol class="packages"> </ol>
+          </li><li class="pack" title="org.apache.gearpump.streaming.dsl.window.impl">
+            <a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/package.html" target="template">org.apache.gearpump.streaming.dsl.window.impl</a>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.dsl.window.impl.Bucket"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/Bucket$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/Bucket.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Bucket</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner"><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.html" target="template"><span class="class">(class)</span><span class="tplLink">DefaultWindowRunner</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow"><div class="placeholder"></div><a class="tplshow"
  href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" target="template"><span class="case class">(case class)</span><span class="tplLink">GroupAlsoByWindow</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.impl.ReduceFnRunner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/ReduceFnRunner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ReduceFnRunner</span></a></li><li title="org.apache.gearpump.streaming.dsl.window.impl.WindowRunner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/dsl/window/impl/WindowRunner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">WindowRunner</span></a></li></ol>
+            <ol class="packages"> </ol>
+          </li></ol>
+          </li></ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.executor">
             <a class="tplshow" href="org/apache/gearpump/streaming/executor/package.html" target="template">org.apache.gearpump.streaming.executor</a>
             <ol class="templates"><li title="org.apache.gearpump.streaming.executor.Executor"><a class="tplshow" href="org/apache/gearpump/streaming/executor/Executor$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/executor/Executor.html" target="template"><span class="class">(class)</span><span class="tplLink">Executor</span></a></li><li title="org.apache.gearpump.streaming.executor.ExecutorRestartPolicy"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/executor/ExecutorRestartPolicy.html" target="template"><span class="class">(class)</span><span class="tplLink">ExecutorRestartPolicy</span></a></li><li title="org.apache.gearpump.streaming.executor.ITaskLauncher"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/executor/ITaskLauncher.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ITaskLauncher</span></a></l
 i><li title="org.apache.gearpump.streaming.executor.TaskLauncher"><a class="tplshow" href="org/apache/gearpump/streaming/executor/TaskLauncher$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/executor/TaskLauncher.html" target="template"><span class="class">(class)</span><span class="tplLink">TaskLauncher</span></a></li></ol>
@@ -175,14 +195,14 @@
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.kafka.lib">
             <a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/package.html" target="template">org.apache.gearpump.streaming.kafka.lib</a>
-            <ol class="templates"></ol>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.kafka.lib.KafkaMessageDecoder"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/KafkaMessageDecoder.html" target="template"><span class="trait">(trait)</span><span class="tplLink">KafkaMessageDecoder</span></a></li><li title="org.apache.gearpump.streaming.kafka.lib.MessageAndWatermark"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/MessageAndWatermark.html" target="template"><span class="case class">(case class)</span><span class="tplLink">MessageAndWatermark</span></a></li></ol>
             <ol class="packages"> <li class="pack" title="org.apache.gearpump.streaming.kafka.lib.sink">
             <a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/sink/package.html" target="template">org.apache.gearpump.streaming.kafka.lib.sink</a>
             <ol class="templates"><li title="org.apache.gearpump.streaming.kafka.lib.sink.AbstractKafkaSink"><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html" target="template"><span class="class">(class)</span><span class="tplLink">AbstractKafkaSink</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.kafka.lib.source">
             <a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/package.html" target="template">org.apache.gearpump.streaming.kafka.lib.source</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource"><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" target="template"><span class="class">(class)</span><span class="tplLink">AbstractKafkaSource</span></a></li><li title="org.apache.gearpump.streaming.kafka.lib.source.DefaultMessageDecoder"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/DefaultMessageDecoder.html" target="template"><span class="class">(class)</span><span class="tplLink">DefaultMessageDecoder</span></a></li><li title="org.apache.gearpump.streaming.kafka.lib.source.StringMessageDecoder"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/StringMessageD
 ecoder.html" target="template"><span class="class">(class)</span><span class="tplLink">StringMessageDecoder</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource"><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" target="template"><span class="class">(class)</span><span class="tplLink">AbstractKafkaSource</span></a></li><li title="org.apache.gearpump.streaming.kafka.lib.source.DefaultKafkaMessageDecoder"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/DefaultKafkaMessageDecoder.html" target="template"><span class="class">(class)</span><span class="tplLink">DefaultKafkaMessageDecoder</span></a></li></ol>
             <ol class="packages"> <li class="pack" title="org.apache.gearpump.streaming.kafka.lib.source.consumer">
             <a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/consumer/package.html" target="template">org.apache.gearpump.streaming.kafka.lib.source.consumer</a>
             <ol class="templates"><li title="org.apache.gearpump.streaming.kafka.lib.source.consumer.FetchThread"><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/consumer/FetchThread$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">FetchThread</span></a></li><li title="org.apache.gearpump.streaming.kafka.lib.source.consumer.KafkaConsumer"><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaConsumer.html" target="template"><span class="class">(class)</span><span class="tplLink">KafkaConsumer</span></a></li><li title="org.apache.gearpump.streaming.kafka.lib.source.consumer.KafkaMessage"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessa
 ge.html" target="template"><span class="case class">(case class)</span><span class="tplLink">KafkaMessage</span></a></li></ol>
@@ -214,9 +234,9 @@
             <a class="tplshow" href="org/apache/gearpump/streaming/monoid/package.html" target="template">org.apache.gearpump.streaming.monoid</a>
             <ol class="templates"><li title="org.apache.gearpump.streaming.monoid.AlgebirdGroup"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/monoid/AlgebirdGroup.html" target="template"><span class="class">(class)</span><span class="tplLink">AlgebirdGroup</span></a></li><li title="org.apache.gearpump.streaming.monoid.AlgebirdMonoid"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/monoid/AlgebirdMonoid.html" target="template"><span class="class">(class)</span><span class="tplLink">AlgebirdMonoid</span></a></li></ol>
             <ol class="packages"> </ol>
-          </li><li class="pack" title="org.apache.gearpump.streaming.serializer">
-            <a class="tplshow" href="org/apache/gearpump/streaming/serializer/package.html" target="template">org.apache.gearpump.streaming.serializer</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.serializer.ChillSerializer"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/serializer/ChillSerializer.html" target="template"><span class="class">(class)</span><span class="tplLink">ChillSerializer</span></a></li></ol>
+          </li><li class="pack" title="org.apache.gearpump.streaming.partitioner">
+            <a class="tplshow" href="org/apache/gearpump/streaming/partitioner/package.html" target="template">org.apache.gearpump.streaming.partitioner</a>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.partitioner.BroadcastPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/BroadcastPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">BroadcastPartitioner</span></a></li><li title="org.apache.gearpump.streaming.partitioner.CoLocationPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/CoLocationPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">CoLocationPartitioner</span></a></li><li title="org.apache.gearpump.streaming.partitioner.HashPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/HashPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">HashPartitioner</span></a></li><li title="org.apache.gearpump.streaming.part
 itioner.MulticastPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/MulticastPartitioner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">MulticastPartitioner</span></a></li><li title="org.apache.gearpump.streaming.partitioner.Partitioner"><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/Partitioner$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/Partitioner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">Partitioner</span></a></li><li title="org.apache.gearpump.streaming.partitioner.PartitionerByClassName"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/PartitionerByClassName.html" target="template"><span class="class">(class)</span><span class="tplLink">PartitionerByClassName</span></a></li><li title="org.apach
 e.gearpump.streaming.partitioner.PartitionerDescription"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/PartitionerDescription.html" target="template"><span class="case class">(case class)</span><span class="tplLink">PartitionerDescription</span></a></li><li title="org.apache.gearpump.streaming.partitioner.PartitionerFactory"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/PartitionerFactory.html" target="template"><span class="trait">(trait)</span><span class="tplLink">PartitionerFactory</span></a></li><li title="org.apache.gearpump.streaming.partitioner.PartitionerObject"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/PartitionerObject.html" target="template"><span class="class">(class)</span><span class="tplLink">PartitionerObject</span></a></li><li title="org.apache.gearpump.streaming.partitioner.ShuffleGroupingPartitioner"><div 
 class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/ShuffleGroupingPartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">ShuffleGroupingPartitioner</span></a></li><li title="org.apache.gearpump.streaming.partitioner.ShufflePartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/ShufflePartitioner.html" target="template"><span class="class">(class)</span><span class="tplLink">ShufflePartitioner</span></a></li><li title="org.apache.gearpump.streaming.partitioner.UnicastPartitioner"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/partitioner/UnicastPartitioner.html" target="template"><span class="trait">(trait)</span><span class="tplLink">UnicastPartitioner</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.sink">
             <a class="tplshow" href="org/apache/gearpump/streaming/sink/package.html" target="template">org.apache.gearpump.streaming.sink</a>
@@ -224,7 +244,7 @@
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.source">
             <a class="tplshow" href="org/apache/gearpump/streaming/source/package.html" target="template">org.apache.gearpump.streaming.source</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.source.DataSource"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSource.html" target="template"><span class="trait">(trait)</span><span class="tplLink">DataSource</span></a></li><li title="org.apache.gearpump.streaming.source.DataSourceConfig"><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSourceConfig$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">DataSourceConfig</span></a></li><li title="org.apache.gearpump.streaming.source.DataSourceProcessor"><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSourceProcessor$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">DataSourceProcessor</span></a></li><li title="org.apache.gearpump.streaming.source.DataSourceTask"><a class="tplshow" href="org/apache/ge
 arpump/streaming/source/DataSourceTask$.html" target="template"><span class="object">(object)</span></a><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSourceTask.html" target="template"><span class="class">(class)</span><span class="tplLink">DataSourceTask</span></a></li><li title="org.apache.gearpump.streaming.source.DefaultTimeStampFilter"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/source/DefaultTimeStampFilter.html" target="template"><span class="class">(class)</span><span class="tplLink">DefaultTimeStampFilter</span></a></li></ol>
+            <ol class="templates"><li title="org.apache.gearpump.streaming.source.DataSource"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSource.html" target="template"><span class="trait">(trait)</span><span class="tplLink">DataSource</span></a></li><li title="org.apache.gearpump.streaming.source.DataSourceConfig"><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSourceConfig$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">DataSourceConfig</span></a></li><li title="org.apache.gearpump.streaming.source.DataSourceProcessor"><a class="tplshow" href="org/apache/gearpump/streaming/source/DataSourceProcessor$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">DataSourceProcessor</span></a></li><li title="org.apache.gearpump.streaming.source.DataSourceTask"><div class="placeholder"></div><a clas
 s="tplshow" href="org/apache/gearpump/streaming/source/DataSourceTask.html" target="template"><span class="class">(class)</span><span class="tplLink">DataSourceTask</span></a></li><li title="org.apache.gearpump.streaming.source.Watermark"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/source/Watermark.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Watermark</span></a></li></ol>
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.state">
             <a class="tplshow" href="org/apache/gearpump/streaming/state/package.html" target="template">org.apache.gearpump.streaming.state</a>
@@ -244,14 +264,14 @@
             <ol class="packages"> </ol>
           </li><li class="pack" title="org.apache.gearpump.streaming.task">
             <a class="tplshow" href="org/apache/gearpump/streaming/task/package.html" target="template">org.apache.gearpump.streaming.task</a>
-            <ol class="templates"><li title="org.apache.gearpump.streaming.task.Ack"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/Ack.html" target="template"><span class="case class">(case class)</span><span class="tplLink">Ack</span></a></li><li title="org.apache.gearpump.streaming.task.AckRequest"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/AckRequest.html" target="template"><span class="case class">(case class)</span><span class="tplLink">AckRequest</span></a></li><li title="org.apache.gearpump.streaming.task.CheckpointClock"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/CheckpointClock.html" target="template"><span class="case class">(case class)</span><span class="tplLink">CheckpointClock</span></a></li><li title="org.apache.gearpump.streaming.task.CheckProcessorDeath"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpum
 p/streaming/task/CheckProcessorDeath.html" target="template"><span class="case class">(case class)</span><span class="tplLink">CheckProcessorDeath</span></a></li><li title="org.apache.gearpump.streaming.task.ClockEvent"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/ClockEvent.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ClockEvent</span></a></li><li title="org.apache.gearpump.streaming.task.ExpressTransport"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/ExpressTransport.html" target="template"><span class="trait">(trait)</span><span class="tplLink">ExpressTransport</span></a></li><li title="org.apache.gearpump.streaming.task.GetCheckpointClock"><a class="tplshow" href="org/apache/gearpump/streaming/task/GetCheckpointClock$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">GetCheckpointClock</span><
 /a></li><li title="org.apache.gearpump.streaming.task.GetDAG"><a class="tplshow" href="org/apache/gearpump/streaming/task/GetDAG$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">GetDAG</span></a></li><li title="org.apache.gearpump.streaming.task.GetLatestMinClock"><a class="tplshow" href="org/apache/gearpump/streaming/task/GetLatestMinClock$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">GetLatestMinClock</span></a></li><li title="org.apache.gearpump.streaming.task.GetStartClock"><a class="tplshow" href="org/apache/gearpump/streaming/task/GetStartClock$.html" target="template"><span class="object">(object)</span><div class="placeholder"></div><span class="tplLink">GetStartClock</span></a></li><li title="org.apache.gearpump.streaming.task.GetUpstreamMinClock"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/GetUps
 treamMinClock.html" target="template"><span class="case class">(case class)</span><span class="tplLink">GetUpstreamMinClock</span></a></li><li title="org.apache.gearpump.streaming.task.InitialAckRequest"><div class="placeholder"></div><a class="tplshow" href="org/apache/gearpump/streaming/task/InitialAckRe

<TRUNCATED>